airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject [1/3] git commit: removing retry in job submission
Date Fri, 03 Oct 2014 03:15:36 GMT
Repository: airavata
Updated Branches:
  refs/heads/master 881d169c6 -> 36158985c


removing retry in job submission


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

Branch: refs/heads/master
Commit: 3c5fd4bb7024b9abf29e31ac3cba65707eb411fb
Parents: a256f35
Author: lahiru <lahiru@apache.org>
Authored: Thu Oct 2 23:12:43 2014 -0400
Committer: lahiru <lahiru@apache.org>
Committed: Thu Oct 2 23:12:43 2014 -0400

----------------------------------------------------------------------
 .../gsi/ssh/impl/GSISSHAbstractCluster.java     | 23 +++++---------------
 1 file changed, 5 insertions(+), 18 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/airavata/blob/3c5fd4bb/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/impl/GSISSHAbstractCluster.java
----------------------------------------------------------------------
diff --git a/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/impl/GSISSHAbstractCluster.java
b/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/impl/GSISSHAbstractCluster.java
index 4f13cf5..09d9b60 100644
--- a/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/impl/GSISSHAbstractCluster.java
+++ b/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/impl/GSISSHAbstractCluster.java
@@ -297,25 +297,12 @@ public class GSISSHAbstractCluster implements Cluster {
             FileUtils.writeStringToFile(tempPBSFile, scriptContent);
 
             //reusing submitBatchJobWithScript method to submit a job
-            int retry = 3;
             String jobID = null;
-            while (retry > 0) {
-                try {
-                     jobID = this.submitBatchJobWithScript(tempPBSFile.getAbsolutePath(),
-                            jobDescriptor.getWorkingDirectory());
-                     retry = 0;
-                } catch (SSHApiException e) {
-                    retry--;
-                    try {
-                        Thread.sleep(5000);
-                    } catch (InterruptedException e1) {
-                        e1.printStackTrace();
-                    }
-                    reconnect(serverInfo, authenticationInfo);
-                    if(retry==0) {
-                        throw e;
-                    }
-                }
+            try {
+                jobID = this.submitBatchJobWithScript(tempPBSFile.getAbsolutePath(),
+                        jobDescriptor.getWorkingDirectory());
+            } catch (SSHApiException e) {
+                throw e;
             }
             log.debug("Job has successfully submitted, JobID : " + jobID);
             if (jobID != null) {


Mime
View raw message