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/workflow-support Commit: feb1d323af7a9ddd25c2388c5c98ee75f505d67f Parents: 82f34a4 Author: lahiru <[email protected]> Authored: Sat Jul 12 13:50:06 2014 -0400 Committer: lahiru <[email protected]> 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 {
