airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject git commit: modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/MonitorID.java
Date Sat, 12 Jul 2014 17:51:07 GMT
Repository: airavata
Updated Branches:
  refs/heads/master 82f34a4ff -> feb1d323a


modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/MonitorID.java


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

Branch: refs/heads/master
Commit: feb1d323af7a9ddd25c2388c5c98ee75f505d67f
Parents: 82f34a4
Author: lahiru <lahiru@apache.org>
Authored: Sat Jul 12 13:50:06 2014 -0400
Committer: lahiru <lahiru@apache.org>
Committed: Sat Jul 12 13:50:06 2014 -0400

----------------------------------------------------------------------
 .../org/apache/airavata/gfac/core/monitor/MonitorID.java | 11 +++++++++++
 1 file changed, 11 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/airavata/blob/feb1d323/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/MonitorID.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/MonitorID.java
b/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/MonitorID.java
index 8599a02..a68c142 100644
--- a/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/MonitorID.java
+++ b/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/MonitorID.java
@@ -187,6 +187,17 @@ public class MonitorID {
                         logger.info("Failed count is high and old status is QUEUED so we
mark this as COMPLETE");
                         this.state = JobState.COMPLETE;
                         break;
+                    default:
+                        int loginfo = getFailedCount()+1;
+                        logger.info("Increasing the failed count to:"+loginfo);
+                        setFailedCount(getFailedCount() + 1);
+                        try {
+                            // when state becomes unknown we sleep for a while
+                            Thread.sleep(10000);
+                        } catch (InterruptedException e) {
+                            e.printStackTrace();  //To change body of catch statement use
File | Settings | File Templates.
+                        }
+                        break;
                 }
             } else {
                 try {


Mime
View raw message