airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shame...@apache.org
Subject airavata git commit: remove handover waiting period
Date Mon, 14 Sep 2015 19:17:35 GMT
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 <shameerainfo@gmail.com>
Authored: Mon Sep 14 15:17:28 2015 -0400
Committer: Shameera Rathanyaka <shameerainfo@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


Mime
View raw message