Changeset 9278

Timestamp:

Oct 4, 2006, 4:32:35 PM (20 years ago)

Author:

eugene

Message:

flushing stderr, stdout when done with job assessment

File:

• trunk/Ohana/src/opihi/pantasks/CheckJobs.c (modified) (3 diffs)

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

@@ -8 +8 @@
   int i, status;
   char varname[64];
+  Queue *queue;
 
   /** test all jobs: ready to test?  finished? **/
@@ -99 +100 @@
         }
 
+        /* flush the stderr and stdout queues */
+        queue = FindQueue ("stdout");
+        if (queue) InitQueue (queue);
+        queue = FindQueue ("stderr");
+        if (queue) InitQueue (queue);
+
         DeleteJob (job);
         continue;
@@ -115 +122 @@
       if (GetTaskTimer(job[0].start) < job[0].task[0].timeout_period) continue;
       if (VerboseMode()) gprint (GP_LOG, "timeout on %s\n", job[0].task[0].name);
+
+      // XXX harvest STDERR and STDOUT from timeout job (should be available...)
+      // XXX add this to controller as well
 
       /* update the timeout counter */