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

Timestamp:

Jul 16, 2006, 10:58:49 PM (20 years ago)

Author:

eugene

Message:

major updates to use gprint for buffered / threaded printing

File:

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

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

@@ -18 +18 @@
     switch (status) {
       case JOB_PENDING:
-        /* if (VerboseMode()) fprintf (stderr, "job %s (%d) pending\n", job[0].task[0].name, job[0].JobID); */
+        /* if (VerboseMode()) gprint (GP_LOG, "job %s (%d) pending\n", job[0].task[0].name, job[0].JobID); */
         break;
 
       case JOB_BUSY:
-        /* if (VerboseMode()) fprintf (stderr, "job %s (%d) busy\n", job[0].task[0].name, job[0].JobID); */
+        /* if (VerboseMode()) gprint (GP_LOG, "job %s (%d) busy\n", job[0].task[0].name, job[0].JobID); */
         break;
 
@@ -28 +28 @@
         /* run task[0].crash macro, if it exists */
         /* 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);
+        if (VerboseMode()) gprint (GP_LOG, "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);
@@ -48 +48 @@
 
       case JOB_EXIT:
-        if (VerboseMode()) fprintf (stderr, "job %s (%d) exit\n", job[0].task[0].name, job[0].JobID);
+        if (VerboseMode()) gprint (GP_LOG, "job %s (%d) exit\n", job[0].task[0].name, job[0].JobID);
         PushNamedQueue ("stdout", job[0].stdout.buffer);
         PushNamedQueue ("stderr", job[0].stderr.buffer);
@@ -79 +79 @@
 
       default:
-        if (VerboseMode()) fprintf (stderr, "unknown exit status: %d\n", status);
+        if (VerboseMode()) gprint (GP_LOG, "unknown exit status: %d\n", status);
         /** do something more useful here ?? **/
         break;
@@ -89 +89 @@
     if (job[0].mode == JOB_LOCAL) {
       if (GetTaskTimer(job[0].start) < job[0].task[0].timeout_period) continue;
-      if (VerboseMode()) fprintf (stderr, "timeout on %s\n", job[0].task[0].name);
+      if (VerboseMode()) gprint (GP_LOG, "timeout on %s\n", job[0].task[0].name);
 
       /* update the timeout counter */
@@ -96 +96 @@
       if (!KillLocalJob (job)) {
         job[0].state = JOB_HUNG;
-        if (VerboseMode()) fprintf (stderr, "child process %d is hung, cannot kill\n", job[0].pid);
+        if (VerboseMode()) gprint (GP_LOG, "child process %d is hung, cannot kill\n", job[0].pid);
         continue;
       }