Changeset 12404 for trunk/Ohana/src/opihi/pantasks/job_threads.c

Timestamp:

Mar 11, 2007, 10:56:27 AM (19 years ago)

Author:

eugene

Message:

adding intelligent timeouts to task and job threads; removing deprecated files

File:

• trunk/Ohana/src/opihi/pantasks/job_threads.c (modified) (2 diffs)

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

@@ -14 +14 @@
 void *CheckJobsThread (void *data) {
 
+  float next_timeout;
+
   gprintInit ();  // each thread needs to init the printing system
   while (1) {
@@ -25 +27 @@
     // one run of the task checker
     SerialThreadLock ();
-    CheckJobs ();
+    next_timeout = CheckJobs ();
     SerialThreadUnlock ();
     if (VerboseMode() == 2) fprintf (stderr, "J");
-    // fprintf (stderr, "J");
-    // usleep (10000); // allow other threads a chance to run
+
+    next_timeout = MIN (next_timeout, 0.1);
+    if (next_timeout > 0.001) {
+      usleep ((int)(1000000*next_timeout)); // allow other threads a chance to run
+    }      
   }
 }