Changeset 7917 for trunk/Ohana/src/opihi/pantasks/LocalJob.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/LocalJob.c (modified) (6 diffs)

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

@@ -24 +24 @@
     switch (Nread) {
       case -2:  /* error in read (programming error?  system level error?) */
-        fprintf (stderr, "serious IO error\n");
+        gprint (GP_ERR, "serious IO error\n");
         exit (2);
       case -1:  /* no data in pipe */
@@ -36 +36 @@
     switch (Nread) {
       case -2:  /* error in read (programming error?  system level error?) */
-        fprintf (stderr, "serious IO error\n");
+        gprint (GP_ERR, "serious IO error\n");
         exit (2);
       case -1:  /* no data in pipe */
@@ -57 +57 @@
       switch (errno) {
         case ECHILD:
-          fprintf (stderr, "unknown PID, not a child proc\n");
-          fprintf (stderr, "did process already exit?  programming error?\n");
+          gprint (GP_ERR, "unknown PID, not a child proc\n");
+          gprint (GP_ERR, "did process already exit?  programming error?\n");
           job[0].state = JOB_NONE;
           job[0].exit_status = 0;
           return (FALSE);
         case EINVAL:
-          fprintf (stderr, "error EINVAL (waitpid): programming error\n");
+          gprint (GP_ERR, "error EINVAL (waitpid): programming error\n");
           exit (1);
         case EINTR:
-          fprintf (stderr, "error EINTR (waitpid): programming error\n");
+          gprint (GP_ERR, "error EINTR (waitpid): programming error\n");
           exit (1);
         default:
-          fprintf (stderr, "unknown error for waitpid (%d): programming error\n", errno);
+          gprint (GP_ERR, "unknown error for waitpid (%d): programming error\n", errno);
           exit (1);
       }
@@ -81 +81 @@
     default:
       if (result != job[0].pid) {
-        fprintf (stderr, "waitpid error: mis-matched PID (%d vs %d).  programming error\n", result, job[0].pid);
+        gprint (GP_ERR, "waitpid error: mis-matched PID (%d vs %d).  programming error\n", result, job[0].pid);
         exit (1);
       }
@@ -93 +93 @@
       }
       if (WIFSTOPPED(waitstatus)) {
-        fprintf (stderr, "waitpid returns 'stopped': programming error\n");
+        gprint (GP_ERR, "waitpid returns 'stopped': programming error\n");
         exit (1);
       }
@@ -114 +114 @@
   pid = fork ();
   if (!pid) { /* must be child process */
-    if (VerboseMode()) fprintf (stderr, "starting local job\n");
+    if (VerboseMode()) gprint (GP_ERR, "starting local job\n");
 
     /* close the other ends of the pipes */