--- gvpe/src/iom.C	2004/09/02 07:50:43	1.21
+++ gvpe/src/iom.C	2004/11/12 10:23:33	1.23
@@ -1,5 +1,5 @@
 /*
-    iom.C -- generic I/O multiplexor
+    iom.C -- generic I/O multiplexer
     Copyright (C) 2003, 2004 Marc Lehmann <pcg@goof.com>
  
     This program is free software; you can redistribute it and/or modify
@@ -154,9 +154,6 @@
 
   if (!w.active)
     {
-#if IOM_CHECK
-      queue.activity = true;
-#endif
       queue.push_back (&w);
       w.active = queue.size ();
     }
@@ -275,67 +272,71 @@
 
   for (;;)
     {
-      struct TIMEVAL *to = 0;
-      struct TIMEVAL tval;
 
-#if IOM_IDLE
-      if (iw.size ())
-        {
-          tval.tv_sec  = 0;
-          tval.TV_FRAC = 0;
-          to = &tval;
-        }
-      else
-#endif
-        {
 #if IOM_TIME
-          time_watcher *next;
-
-          for (;;)
-            {
-              next = tw[0]; // the first time-watcher must exist at ALL times
+      // call pending time watchers
+      {
+        bool activity;
 
-              for (int i = tw.size (); i--; )
-                if (!tw[i])
-                  tw.erase_unordered (i);
-                else if (tw[i]->at < next->at)
-                  next = tw[i];
+        do
+          {
+            activity = false;
 
-              if (next->at > NOW)
+            for (int i = tw.size (); i--; )
+              if (!tw[i])
+                tw.erase_unordered (i);
+              else if (tw[i]->at <= NOW + IOM_ACCURACY)
                 {
-                  if (next != tw[0])
-                    {
-                      double diff = next->at - NOW;
-                      tval.tv_sec  = (int)diff;
-                      tval.TV_FRAC = (int) ((diff - tval.tv_sec) * TV_MULT);
-                      to = &tval;
-                    }
-                  break;
-                }
-              else
-                {
-                  unreg (*next);
-                  next->call (*next);
+                  time_watcher &w = *tw[i];
+                  
+                  unreg (w);
+                  w.call (w);
+
+                  activity = true;
                 }
-            }
+          }
+        while (activity);
+      }
 #endif
-        }
 
 #if IOM_CHECK
-      tw.activity = false;
-
+      // call all check watchers
       for (int i = cw.size (); i--; )
         if (!cw[i])
           cw.erase_unordered (i);
         else
           cw[i]->call (*cw[i]);
+#endif
 
-      if (tw.activity)
+      struct TIMEVAL *to = 0;
+      struct TIMEVAL tval;
+
+#if IOM_IDLE
+      if (iw.size ())
         {
           tval.tv_sec  = 0;
           tval.TV_FRAC = 0;
           to = &tval;
         }
+      else
+#endif
+        {
+#if IOM_TIME
+          // find earliest active watcher
+          time_watcher *next = tw[0]; // the first time-watcher must exist at ALL times
+
+          for (io_manager_vec<time_watcher>::const_iterator i = tw.end (); i-- > tw.begin (); )
+            if (*i && (*i)->at < next->at)
+              next = *i;
+
+          if (next->at > NOW && next != tw[0])
+            {
+              double diff = next->at - NOW;
+              tval.tv_sec  = (int)diff;
+              tval.TV_FRAC = (int) ((diff - tval.tv_sec) * TV_MULT);
+              to = &tval;
+            }
+        }
 #endif
 
 #if IOM_IO || IOM_SIG
@@ -347,7 +348,7 @@
       int fds = 0;
 
 # if IOM_IO
-      for (io_manager_vec<io_watcher>::iterator i = iow.end (); i-- > iow.begin (); )
+      for (io_manager_vec<io_watcher>::const_iterator i = iow.end (); i-- > iow.begin (); )
         if (*i)
           {
             if ((*i)->events & EVENT_READ ) FD_SET ((*i)->fd, &rfd);
@@ -357,7 +358,7 @@
           }
 # endif
 
-      if (!to && !fds) //TODO: also check idle_watchers and check_watchers
+      if (!to && !fds) //TODO: also check idle_watchers and check_watchers?
         break; // no events
 
 # if IOM_SIG