Changeset 15797

Timestamp:

Dec 12, 2007, 12:18:48 PM (18 years ago)

Author:

eugene

Message:

various debug lines to test comm collisions

Location:

trunk/Ohana/src/opihi

Files:

• include/pantasks.h (modified) (1 diff)
• pantasks/CheckJobs.c (modified) (1 diff)
• pantasks/CheckTasks.c (modified) (1 diff)
• pantasks/JobOps.c (modified) (1 diff)

trunk/Ohana/src/opihi/include/pantasks.h

@@ -6 +6 @@
 # include <time.h>
 # include <zlib.h>
+
+# define DEBUG 0
 
 typedef enum {

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

@@ -51 +51 @@
         /* push output buffer data to the stdout and stderr queues */
         /* XXX this will break on 0 values in output streams */
+        if (DEBUG) fprintf (stderr, "job: (%x) %d of %d\n", job[0].stdout_buff.buffer, job[0].stdout_buff.Nbuffer, job[0].stdout_buff.Nalloc); 
         PushNamedQueue ("stdout", job[0].stdout_buff.buffer);
         PushNamedQueue ("stderr", job[0].stderr_buff.buffer);

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

@@ -73 +73 @@
     /* construct job from task */
     job = CreateJob (task);
+    if (DEBUG) fprintf (stderr, "create job: (%x) %d of %d\n", job[0].stdout_buff.buffer, job[0].stdout_buff.Nbuffer, job[0].stdout_buff.Nalloc); 
 
     // gettimeofday (&now, (void *) NULL);

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

@@ -251 +251 @@
 
   if (job[0].mode == JOB_LOCAL) {
+    if (DEBUG) fprintf (stderr, "submit job: (%x) %d of %d\n", job[0].stdout_buff.buffer, job[0].stdout_buff.Nbuffer, job[0].stdout_buff.Nalloc); 
     SubmitLocalJob (job);
   } else {