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/09/18 21:55:19 UTC
git commit: fixing monitrong issue with large number of jobs
Repository: airavata
Updated Branches:
refs/heads/master 003832ce3 -> e88723225
fixing monitrong issue with large number of jobs
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/e8872322
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/e8872322
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/e8872322
Branch: refs/heads/master
Commit: e88723225d0f1dbeb0a9e5206298d624ee5b4d29
Parents: 003832c
Author: lahiru <la...@apache.org>
Authored: Thu Sep 18 15:55:14 2014 -0400
Committer: lahiru <la...@apache.org>
Committed: Thu Sep 18 15:55:14 2014 -0400
----------------------------------------------------------------------
.../java/org/apache/airavata/gsi/ssh/api/job/PBSOutputParser.java | 2 +-
.../org/apache/airavata/gsi/ssh/api/job/SlurmOutputParser.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/e8872322/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/PBSOutputParser.java
----------------------------------------------------------------------
diff --git a/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/PBSOutputParser.java b/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/PBSOutputParser.java
index 73f508b..e8e8cbe 100644
--- a/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/PBSOutputParser.java
+++ b/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/PBSOutputParser.java
@@ -162,7 +162,7 @@ public class PBSOutputParser implements OutputParser {
int lastStop = 0;
for (String jobID : statusMap.keySet()) {
String jobName = jobID.split(",")[1];
- for (int i = lastStop; i < info.length; i++) {
+ for (int i = 0; i < info.length; i++) {
if (info[i].contains(jobName.substring(0,8))) {
// now starts processing this line
log.info(info[i]);
http://git-wip-us.apache.org/repos/asf/airavata/blob/e8872322/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/SlurmOutputParser.java
----------------------------------------------------------------------
diff --git a/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/SlurmOutputParser.java b/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/SlurmOutputParser.java
index e99863b..8660f35 100644
--- a/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/SlurmOutputParser.java
+++ b/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/SlurmOutputParser.java
@@ -160,7 +160,7 @@ public class SlurmOutputParser implements OutputParser {
for (String jobID : statusMap.keySet()) {
String jobId = jobID.split(",")[0];
String jobName = jobID.split(",")[1];
- for (int i = lastStop; i < info.length; i++) {
+ for (int i = 0; i < info.length; i++) {
if (info[i].contains(jobName.substring(0,8))) {
// now starts processing this line
log.info(info[i]);