Changeset 13540 for trunk/Ohana/src/opihi/pantasks/JobOps.c

Timestamp:

May 30, 2007, 12:13:00 PM (19 years ago)

Author:

eugene

Message:

added flush jobs command

File:

• trunk/Ohana/src/opihi/pantasks/JobOps.c (modified) (1 diff)

trunk/Ohana/src/opihi/pantasks/JobOps.c

@@ -215 +215 @@
     ActiveJob --;
   }
+
+  job[0].task[0].Npending --;
+  return (TRUE);
+}
+
+int FlushJobs () {
+
+  int i;
+
+  // kill outstanding jobs
+  for (i = 0; i < Njobs; i++) {
+    if (jobs[i][0].mode == JOB_LOCAL) {
+      if (!KillLocalJob (jobs[i])) {
+        jobs[i][0].state = JOB_HUNG;
+        if (VerboseMode()) gprint (GP_LOG, "child process %d is hung, cannot kill\n", jobs[i][0].pid);
+      }
+    } else {
+      if (!KillControllerJob (jobs[i])) {
+        jobs[i][0].state = JOB_HUNG;
+        if (VerboseMode()) gprint (GP_LOG, "child process %d is hung, cannot kill\n", jobs[i][0].pid);
+      }
+    }    
+    jobs[i][0].task[0].Npending = 0;
+    FreeJob (jobs[i]);
+  }
+    
+  Njobs = 0;
+  NJOBS = 20;
+  REALLOCATE (jobs, Job *, NJOBS);
+  ActiveJob = -1;
   return (TRUE);
 }