Changeset 23514

Timestamp:

Mar 25, 2009, 11:13:41 AM (17 years ago)

Author:

eugene

Message:

move Npending increment to CreateJob; check for submit status

File:

• branches/eam_branches/eam_branch_20090322/Ohana/src/opihi/pantasks/JobOps.c (modified) (2 diffs)

branches/eam_branches/eam_branch_20090322/Ohana/src/opihi/pantasks/JobOps.c

@@ -149 +149 @@
     REALLOCATE (jobs, Job *, NJOBS);
   }
+
+  /* increment job counters */
+  task[0].Npending ++;
+
   return (jobs[Njobs-1]);
 }
@@ -245 +249 @@
 int SubmitJob (Job *job) {
 
+  int status;
+
   if (job[0].mode == JOB_LOCAL) {
     if (DEBUG) fprintf (stderr, "submit job: (%zx) %d of %d\n", (size_t) job[0].stdout_buff.buffer, job[0].stdout_buff.Nbuffer, job[0].stdout_buff.Nalloc); 
-    SubmitLocalJob (job);
+    status = SubmitLocalJob (job);
   } else {
-    SubmitControllerJob (job);
+    status = SubmitControllerJob (job);
+  }
+  if (!status) {
+    return FALSE;
   }