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

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

@@ -54 +54 @@
   int i, valid;
 
-  fprintf (stderr, "\n");
+  gprint (GP_LOG, "\n");
   if (Ntasks == 0) {
-    fprintf (stderr, " no defined tasks\n");
+    gprint (GP_LOG, " no defined tasks\n");
     return;
   }
 
-  fprintf (stderr, " Task Status\n");
-  fprintf (stderr, "  * Name            Njobs  Command\n");
+  gprint (GP_LOG, " Task Status\n");
+  gprint (GP_LOG, "  * Name            Njobs  Command\n");
   for (i = 0; i < Ntasks; i++) {
     valid = CheckTimeRanges (tasks[i][0].ranges, tasks[i][0].Nranges);
-    if (verbose) fprintf (stderr, "\n");
+    if (verbose) gprint (GP_LOG, "\n");
     if (valid) {
-      fprintf (stderr, "  + ");
+      gprint (GP_LOG, "  + ");
     } else {
-      fprintf (stderr, "  - ");
+      gprint (GP_LOG, "  - ");
     }
     if (tasks[i][0].argv == NULL) {
-      fprintf (stderr, "%-15s %5d  %-20s\n", tasks[i][0].name, tasks[i][0].Njobs, "(dynamic)");
+      gprint (GP_LOG, "%-15s %5d  %-20s\n", tasks[i][0].name, tasks[i][0].Njobs, "(dynamic)");
     } else {
-      fprintf (stderr, "%-15s %5d  %-20s\n", tasks[i][0].name, tasks[i][0].Njobs, tasks[i][0].argv[0]);
+      gprint (GP_LOG, "%-15s %5d  %-20s\n", tasks[i][0].name, tasks[i][0].Njobs, tasks[i][0].argv[0]);
     }
     if (verbose) {
-      fprintf (stderr, "    spawn period: %f, polling period: %f, timeout period: %f\n", 
+      gprint (GP_LOG, "    spawn period: %f, polling period: %f, timeout period: %f\n", 
                tasks[i][0].exec_period, tasks[i][0].poll_period, tasks[i][0].timeout_period);
       if (tasks[i][0].host == NULL) {
-        fprintf (stderr, "    task runs locally\n");
+        gprint (GP_LOG, "    task runs locally\n");
         continue;
       }
       if (!strcasecmp(tasks[i][0].host, "ANYHOST")) {
-        fprintf (stderr, "    task host selected by controller\n");
+        gprint (GP_LOG, "    task host selected by controller\n");
         continue;
       }
       if (tasks[i][0].host_required) {
-        fprintf (stderr, "    host %s (required)\n", tasks[i][0].host);
+        gprint (GP_LOG, "    host %s (required)\n", tasks[i][0].host);
       } else {
-        fprintf (stderr, "    host %s (desired)\n", tasks[i][0].host);
+        gprint (GP_LOG, "    host %s (desired)\n", tasks[i][0].host);
       }
     }
@@ -104 +104 @@
   task = FindTask (name);
   if (task == NULL) {
-    fprintf (stderr, "task %s not found\n", name);
+    gprint (GP_LOG, "task %s not found\n", name);
     return (FALSE);
   }
 
-  fprintf (stderr, "\n macro %s\n", task[0].name);
-
-  fprintf (stderr, "\n command: ");
+  gprint (GP_LOG, "\n macro %s\n", task[0].name);
+
+  gprint (GP_LOG, "\n command: ");
   for (i = 0; i < task[0].argc; i++) {
-    fprintf (stderr, "%s ", task[0].argv[i]);
-  }
-  fprintf (stderr, "\n\n");
+    gprint (GP_LOG, "%s ", task[0].argv[i]);
+  }
+  gprint (GP_LOG, "\n\n");
 
   if (task[0].host == NULL) {
-    fprintf (stderr, " task runs locally\n");
+    gprint (GP_LOG, " task runs locally\n");
     goto periods;
   }
   if (!strcasecmp(task[0].host, "ANYHOST")) {
-    fprintf (stderr, " task host selected by controller\n");
+    gprint (GP_LOG, " task host selected by controller\n");
     goto periods;
   }
   if (task[0].host_required) {
-    fprintf (stderr, " host %s (required)\n", task[0].host);
+    gprint (GP_LOG, " host %s (required)\n", task[0].host);
   } else {
-    fprintf (stderr, " host %s (desired)\n", task[0].host);
+    gprint (GP_LOG, " host %s (desired)\n", task[0].host);
   }
 
 periods:
-  fprintf (stderr, " time periods: exec: %f  poll: %f  timeout: %f\n", 
+  gprint (GP_LOG, " time periods: exec: %f  poll: %f  timeout: %f\n", 
            task[0].exec_period, task[0].poll_period, task[0].timeout_period);
 
-  fprintf (stderr, "\n pre-execute macro\n");
+  gprint (GP_LOG, "\n pre-execute macro\n");
   ListMacro (task[0].exec);
 
-  fprintf (stderr, "\n timeout macro\n");
+  gprint (GP_LOG, "\n timeout macro\n");
   ListMacro (task[0].timeout);
 
-  fprintf (stderr, "\n crash macro\n");
+  gprint (GP_LOG, "\n crash macro\n");
   ListMacro (task[0].crash);
 
-  fprintf (stderr, "\n default exit macro\n");
+  gprint (GP_LOG, "\n default exit macro\n");
   ListMacro (task[0].defexit);
 
   for (i = 0; i < task[0].Nexit; i++) {
-    fprintf (stderr, "\n exit macro (status == %d)\n", atoi(task[0].exit[i][0].name));
+    gprint (GP_LOG, "\n exit macro (status == %d)\n", atoi(task[0].exit[i][0].name));
     ListMacro (task[0].exit[i]);
   }
@@ -252 +252 @@
   }
   if (Nt == -1) {
-    fprintf (stderr, "programming error: task not found\n");
+    gprint (GP_ERR, "programming error: task not found\n");
     return (FALSE);
   }
@@ -269 +269 @@
   if (task[0].argc != 0) {
     if (task[0].argv == NULL) {
-      fprintf (stderr, "task command arguments not defined (programming error)\n");
+      gprint (GP_ERR, "task command arguments not defined (programming error)\n");
       return (FALSE);
     }
@@ -275 +275 @@
   }
   if (RequireStatic) {
-    fprintf (stderr, "task command not defined\n");
+    gprint (GP_ERR, "task command not defined\n");
     return (FALSE);
   }
@@ -286 +286 @@
     }
   }
-  fprintf (stderr, "task command not defined\n");
+  gprint (GP_ERR, "task command not defined\n");
   return (FALSE);
 }