You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2014/07/12 19:51:07 UTC
git commit:
modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/MonitorID.java
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 <la...@apache.org>
Authored: Sat Jul 12 13:50:06 2014 -0400
Committer: lahiru <la...@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 {