You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sh...@apache.org on 2015/09/14 21:17:35 UTC
airavata git commit: remove handover waiting period
Repository: airavata
Updated Branches:
refs/heads/master 5256d9734 -> 5568da30e
remove handover waiting period
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/5568da30
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/5568da30
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/5568da30
Branch: refs/heads/master
Commit: 5568da30e4b8b63f35878ebaad1128acc526d4bf
Parents: 5256d97
Author: Shameera Rathanyaka <sh...@gmail.com>
Authored: Mon Sep 14 15:17:28 2015 -0400
Committer: Shameera Rathanyaka <sh...@gmail.com>
Committed: Mon Sep 14 15:17:28 2015 -0400
----------------------------------------------------------------------
.../org/apache/airavata/gfac/server/GfacServerHandler.java | 7 +------
1 file changed, 1 insertion(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/5568da30/modules/gfac/gfac-service/src/main/java/org/apache/airavata/gfac/server/GfacServerHandler.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-service/src/main/java/org/apache/airavata/gfac/server/GfacServerHandler.java b/modules/gfac/gfac-service/src/main/java/org/apache/airavata/gfac/server/GfacServerHandler.java
index 22c1e78..59b7a54 100644
--- a/modules/gfac/gfac-service/src/main/java/org/apache/airavata/gfac/server/GfacServerHandler.java
+++ b/modules/gfac/gfac-service/src/main/java/org/apache/airavata/gfac/server/GfacServerHandler.java
@@ -236,16 +236,11 @@ public class GfacServerHandler implements GfacService.Iface {
rabbitMQProcessLaunchConsumer.sendAck(message.getDeliveryTag());
}
} else {
- // give time to complete handover logic in previous instance.
- try {
- Thread.sleep(6000);
- } catch (InterruptedException e) {
- // ignore
- }
// read process status from registry
ProcessStatus processStatus = ((ProcessStatus) Factory.getDefaultExpCatalog().get
(ExperimentCatalogModelType.PROCESS_STATUS, event.getProcessId()));
status.setState(processStatus.getState());
+ // write server name to zookeeper , this is happen inside createProcessZKNode(...) method
}
}
// update process status