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

Timestamp:

Feb 19, 2007, 3:18:27 PM (19 years ago)

Author:

eugene

Message:

removed usleep from job and task threads; increased controller timeout; added verbosity; fixed quit controller; added check points to pcontrol thread

File:

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

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

@@ -11 +11 @@
   Queue *queue;
 
+  // int Ncheck;
+  // Ncheck = 0;
+
   /** test all jobs: ready to test?  finished? **/
   while ((job = NextJob ()) != NULL) {
+    // Ncheck ++;
 
     task = job[0].task;
 
     /* check poll period (ready to ask for status?) */
-    if (GetTaskTimer(job[0].last) < task[0].poll_period) continue;
+    if (GetTaskTimer(job[0].last, FALSE) < task[0].poll_period) continue;
 
     /* check current status */
@@ -135 +139 @@
      */
     if (job[0].mode == JOB_LOCAL) {
-      if (GetTaskTimer(job[0].start) < task[0].timeout_period) continue;
+      if (GetTaskTimer(job[0].start, FALSE) < task[0].timeout_period) continue;
       if (VerboseMode()) gprint (GP_LOG, "timeout on %s\n", task[0].name);
 
@@ -176 +180 @@
     /* reset polling clock */
     SetTaskTimer (&job[0].last);
-    if (TestElapsedCheck()) return (TRUE);
+    if (TestElapsedCheck()) {
+      // fprintf (stderr, "check %d jobs\n", Ncheck);
+      return (TRUE);
+    }
   }
+  // fprintf (stderr, "check %d jobs\n", Ncheck);
   return (TRUE);
 }