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

Timestamp:

Aug 3, 2005, 5:50:08 PM (21 years ago)

Author:

eugene

Message:

psched / pscontrol / pclient dev work

File:

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

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

@@ -26 +26 @@
       case JOB_CRASH:
         /* run task[0].crash macro, if it exists */
-        /* set the stdout and stderr variables with job.stdout, job.stderr */
-        /* XXX this will break on 0 values in output streams */
+        /* push output buffer data to the stdout and stderr queues */
         if (VerboseMode()) fprintf (stderr, "job %s (%d) crash\n", job[0].task[0].name, job[0].JobID);
         PushNamedQueue ("stdout", job[0].stdout.buffer);
         PushNamedQueue ("stderr", job[0].stderr.buffer);
+        /* XXX this will break on 0 values in output streams */
+        /* perhaps define PushNamedQueueBuffer */
         if (job[0].task[0].crash != NULL) {
           exec_loop (job[0].task[0].crash);
@@ -43 +44 @@
         PushNamedQueue ("stderr", job[0].stderr.buffer);
         /* run corresponding task[0].exit macro, if it exists */
-        macro = job[0].task[0].def;
+        macro = job[0].task[0].defexit;
         for (i = 0; i < job[0].task[0].Nexit; i++) {
           if (job[0].exit_status == atoi(job[0].task[0].exit[i][0].name)) {