Changeset 15875

Timestamp:

Dec 16, 2007, 12:28:16 PM (18 years ago)

Author:

eugene

Message:

fixed types in fprintf, flush stdout, stderr before forking

File:

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

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

@@ -15 +15 @@
 
   if ((job[0].state == JOB_EXIT) || (job[0].state == JOB_CRASH)) {
-    if (DEBUG) fprintf (stderr, "empty buffer 0: (%x) %d of %d\n", job[0].stdout_buff.buffer, job[0].stdout_buff.Nbuffer, job[0].stdout_buff.Nalloc); 
+    if (DEBUG) fprintf (stderr, "empty buffer 0: (%zx) %d of %d\n", (size_t) job[0].stdout_buff.buffer, job[0].stdout_buff.Nbuffer, job[0].stdout_buff.Nalloc); 
     EmptyIOBuffer (&job[0].stdout_buff, 10, job[0].stdout_fd);
     EmptyIOBuffer (&job[0].stderr_buff, 10, job[0].stderr_fd);
-    if (DEBUG) fprintf (stderr, "empty buffer 1: (%x) %d of %d\n", job[0].stdout_buff.buffer, job[0].stdout_buff.Nbuffer, job[0].stdout_buff.Nalloc); 
+    if (DEBUG) fprintf (stderr, "empty buffer 1: (%zx) %d of %d\n", (size_t) job[0].stdout_buff.buffer, job[0].stdout_buff.Nbuffer, job[0].stdout_buff.Nalloc); 
     close (job[0].stdout_fd);
     close (job[0].stderr_fd);
   } else {
     /* read stdout buffer */
-    if (DEBUG) fprintf (stderr, "read buffer 0: (%x) %d of %d\n", job[0].stdout_buff.buffer, job[0].stdout_buff.Nbuffer, job[0].stdout_buff.Nalloc); 
+    if (DEBUG) fprintf (stderr, "read buffer 0: (%zx) %d of %d\n", (size_t) job[0].stdout_buff.buffer, job[0].stdout_buff.Nbuffer, job[0].stdout_buff.Nalloc); 
     while ((Nread = ReadtoIOBuffer (&job[0].stdout_buff, job[0].stdout_fd)) > 0);
     switch (Nread) {
@@ -35 +35 @@
         break;
     }
-    if (DEBUG) fprintf (stderr, "read buffer 1: (%x) %d of %d\n", job[0].stdout_buff.buffer, job[0].stdout_buff.Nbuffer, job[0].stdout_buff.Nalloc); 
+    if (DEBUG) fprintf (stderr, "read buffer 1: (%zx) %d of %d\n", (size_t) job[0].stdout_buff.buffer, job[0].stdout_buff.Nbuffer, job[0].stdout_buff.Nalloc); 
   
     /* read stderr buffer */
@@ -120 +120 @@
 
   // XXX nothing to be read at this point
+  // other threads are already halted here.
+  fflush (stdout);
+  fflush (stderr);
 
   pid = fork ();