airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject git commit: closing the thrift transport connection during gfac invocation
Date Sat, 11 Oct 2014 18:55:50 GMT
Repository: airavata
Updated Branches:
  refs/heads/master 7496f507f -> e7be1f4e8


closing the thrift transport connection during gfac invocation


Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/e7be1f4e
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/e7be1f4e
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/e7be1f4e

Branch: refs/heads/master
Commit: e7be1f4e896cbe5f11924377771cdc85411354f8
Parents: 7496f50
Author: lahiru <lahiru@apache.org>
Authored: Sat Oct 11 14:55:44 2014 -0400
Committer: lahiru <lahiru@apache.org>
Committed: Sat Oct 11 14:55:44 2014 -0400

----------------------------------------------------------------------
 .../airavata/api/server/handler/AiravataServerHandler.java       | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/airavata/blob/e7be1f4e/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
b/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
index e75f099..9e257f7 100644
--- a/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
+++ b/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
@@ -1211,7 +1211,7 @@ public class AiravataServerHandler implements Airavata.Iface, Watcher
{
                     registry.update(RegistryModelType.EXPERIMENT_STATUS, status, experimentId);
                     registry.update(RegistryModelType.TASK_DETAIL, taskData, taskData.getTaskID());
                     //launching the experiment
-                    orchestratorClient.launchTask(taskData.getTaskID(),airavataCredStoreToken);
+                    orchestratorClient.launchTask(taskData.getTaskID(), airavataCredStoreToken);
                 }
             }
 
@@ -1232,6 +1232,8 @@ public class AiravataServerHandler implements Airavata.Iface, Watcher
{
             }
             logger.errorId(experimentId, "Error while updating task status, hence updated
experiment status to " + status.toString(), e);
             throw new TException(e);
+        }finally {
+            orchestratorClient.getInputProtocol().getTransport().close();
         }
         return true;
     }


Mime
View raw message