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

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

@@ -6 +6 @@
   Task *task;
   int status;
+  struct timeval now;
 
   /** test all tasks: ready to test? ready to run? **/
@@ -13 +14 @@
 
     /* ready to test? : check exec period */
-    if (GetTaskTimer(task[0].last) < task[0].exec_period) continue;
+    if (GetTaskTimer(task[0].last, FALSE) < task[0].exec_period) continue;
 
     /* need to check if the current time is within valid/invalid periods */
@@ -25 +26 @@
     }
     if (task[0].NpendingMax && (task[0].Npending >= task[0].NpendingMax)) {
-        fprintf (stderr, "npending: %d, max npending: %d\n", task[0].Npending, task[0].NpendingMax);
+        // fprintf (stderr, "npending: %d, max npending: %d\n", task[0].Npending, task[0].NpendingMax);
         gettimeofday (&task[0].last, (void *) NULL);
         continue;
     }
+
+    // gettimeofday (&now, (void *) NULL);
+    // fprintf (stderr, "t0: %d %6d  - \n", now.tv_sec, now.tv_usec);
 
     /* ready to run? : run task.exec macro */
@@ -39 +43 @@
     }
 
+    // gettimeofday (&now, (void *) NULL);
+    // fprintf (stderr, "t1: %d %6d  - \n", now.tv_sec, now.tv_usec);
+
     /* check if there are errors with this task */
     if (!ValidateTask (task, TRUE)) { 
@@ -44 +51 @@
         continue;
     }
+    
+    // gettimeofday (&now, (void *) NULL);
+    // fprintf (stderr, "t2: %d %6d  - \n", now.tv_sec, now.tv_usec);
 
     /* construct job from task */
     job = CreateJob (task);
 
+    // gettimeofday (&now, (void *) NULL);
+    // fprintf (stderr, "t3: %d %6d  - \n", now.tv_sec, now.tv_usec);
+
     /* execute job - XXX add status test */
     SubmitJob (job);
+
+    // fprintf (stderr, "nl: %d %6d  - ",
+    // task[0].last.tv_sec, task[0].last.tv_usec);
 
     /* reset timer on task (don't do this if Create/Submit fails) (why not??) */
@@ -55 +71 @@
     task[0].Njobs ++;
     task[0].Npending ++;
+
+    // fprintf (stderr, "%d %6d\n", 
+    // task[0].last.tv_sec, task[0].last.tv_usec);
 
     /* increment Nrun for inclusive ranges with Nmax */