Changeset 12404 for trunk/Ohana/src/opihi/pantasks/task_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/task_threads.c (modified) (2 diffs)

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

@@ -14 +14 @@
 void *CheckTasksThread (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 ();
-    CheckTasks ();
+    next_timeout = CheckTasks ();
     SerialThreadUnlock ();
     if (VerboseMode() == 2) fprintf (stderr, "T");
-    // fprintf (stderr, "T");
-    usleep (1000); // 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
+    }      
   }
 }
 
-/* the threaded version of pantasks does not worry about limiting the 
-   time spent in one of the test loops -- comms with the client are
-   in a separate thread anyway...
-*/
-
-int TestElapsedCheck () {
-  return (FALSE);
-}
+// I sleep for a small amount of time here, based on how long until the next expected
+// timeout.  this enforces a certain granularity in the task creation, but prevents the task
+// thread from driving the load up to silly levels.