Changeset 4697 for trunk/Ohana/src/opihi/pantasks/CheckJobs.c

Timestamp:

Aug 2, 2005, 9:40:50 AM (21 years ago)

Author:

eugene

Message:

psched bugfixes, moved IOBuffers and queues

File:

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

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

@@ -29 +29 @@
         /* XXX this will break on 0 values in output streams */
         if (VerboseMode()) fprintf (stderr, "job %s (%d) crash\n", job[0].task[0].name, job[0].JobID);
-        set_str_variable ("stdout", job[0].stdout.buffer);
-        set_str_variable ("stderr", job[0].stderr.buffer);
+        PushNamedQueue ("stdout", job[0].stdout.buffer);
+        PushNamedQueue ("stderr", job[0].stderr.buffer);
         if (job[0].task[0].crash != NULL) {
           exec_loop (job[0].task[0].crash);
@@ -40 +40 @@
       case JOB_EXIT:
         if (VerboseMode()) fprintf (stderr, "job %s (%d) exit\n", job[0].task[0].name, job[0].JobID);
-        set_str_variable ("stdout", job[0].stdout.buffer);
-        set_str_variable ("stderr", job[0].stderr.buffer);
+        PushNamedQueue ("stdout", job[0].stdout.buffer);
+        PushNamedQueue ("stderr", job[0].stderr.buffer);
         /* run corresponding task[0].exit macro, if it exists */
         macro = job[0].task[0].def;