--- gvpe/src/iom.h	2003/03/21 20:33:36	1.1
+++ gvpe/src/iom.h	2003/04/02 03:06:22	1.8
@@ -23,22 +23,26 @@
 
 #include <sys/poll.h>
 
+#include "callback.h"
 #include "slog.h"
 
-typedef double timestamp;
+typedef double tstamp;
 
-extern timestamp NOW;
+extern tstamp NOW;
 
-template<class R, class A> class callback;
 struct io_watcher;
 struct time_watcher;
 
 class io_manager {
   vector<pollfd> pfs;
-  vector<io_watcher *> iow;
+  vector<const io_watcher *> iow;
   vector<time_watcher *> tw; // actually a heap
+
+  void idle_cb (tstamp &ts); time_watcher *idle;
 public:
 
+  void reschedule_time_watchers ();
+
   // register a watcher
   void reg (int fd, short events, io_watcher *w);
   void unreg (io_watcher *w);
@@ -53,75 +57,69 @@
 
 extern io_manager iom;
 
-template<class R, class A>
-class callback {
-  struct object { };
-
-  void *obj;
-  R (object::*meth)(A arg);
-
-  // a proxy is a kind of recipe on how to call a specific class method
-  struct proxy_base {
-    virtual R call (void *obj, void (object::*meth)(A), A arg) = 0;
-  };
+struct io_watcher : callback<void, short> {
   template<class O1, class O2>
-  struct proxy : proxy_base {
-    virtual R call (void *obj, void (object::*meth)(A), A arg)
-      {
-        ((reinterpret_cast<O1 *>(obj)) ->* (reinterpret_cast<void (O2::*)(A)>(meth)))
-          (arg);
-      }
-  };
+  io_watcher (O1 *object, void (O2::*method)(short revents))
+    : callback<void, short>(object,method)
+    { }
 
-  proxy_base *prxy;
+  ~io_watcher ()
+    {
+      iom.unreg (this);
+    }
 
-public:
-  template<class O1, class O2>
-  callback (O1 *object, void (O2::*method)(A))
+  void start (int fd, short events)
     {
-      static proxy<O1,O2> p;
-      obj  = reinterpret_cast<void *>(object);
-      meth = reinterpret_cast<void (object::*)(A)>(method);
-      prxy = &p;
+      iom.reg (fd, events, this);
     }
 
-  R call(A arg)
+  void stop ()
     {
-      return prxy->call (obj, meth, arg);
+      iom.unreg (this);
     }
 };
 
-struct io_watcher : callback<void, short> {
+#define TSTAMP_CANCEL -1.
+
+struct time_watcher : callback<void, tstamp &> {
+  bool registered; // already registered?
+  tstamp at;
+
   template<class O1, class O2>
-  io_watcher (int fd, short events, O1 *object, void (O2::*method)(short revents))
-    : callback<void, short>(object,method)
-    {
-      iom.reg (fd, events, this);
-    }
+  time_watcher (O1 *object, void (O2::*method)(tstamp &))
+    : callback<void, tstamp &>(object,method)
+    , registered(false)
+    { }
 
-  ~io_watcher ()
+  ~time_watcher ()
     {
       iom.unreg (this);
     }
-};
 
-struct time_watcher : callback<void, timestamp &> {
-  timestamp at;
+  void set (tstamp when);
+  void trigger ();
 
-  void set (timestamp when);
+  void operator ()()
+    {
+      trigger ();
+    }
 
-  template<class O1, class O2>
-  time_watcher (timestamp when, O1 *object, void (O2::*method)(timestamp &))
-    : callback<void, timestamp &>(object,method)
-    , at(when)
+  void start ();
+  void start (tstamp when)
     {
-      iom.reg (this);
+      set (when);
     }
 
-  ~time_watcher ()
+  void stop ()
     {
       iom.unreg (this);
     }
+
+  void reset (tstamp when = TSTAMP_CANCEL)
+    {
+      stop ();
+      at = when;
+    }
 };
 
 #endif