--- gvpe/src/iom.C 2003/03/21 20:33:36 1.1 +++ gvpe/src/iom.C 2003/04/02 05:15:00 1.8 @@ -1,4 +1,3 @@ -#include /* iom.C -- I/O multiplexor @@ -25,7 +24,6 @@ #include #include "slog.h" - #include "iom.h" inline bool lowest_first (const time_watcher *a, const time_watcher *b) @@ -33,15 +31,34 @@ return a->at > b->at; } -timestamp NOW; +tstamp NOW; io_manager iom; -void time_watcher::set (timestamp when) +void time_watcher::set (tstamp when) { - iom.unreg (this); at = when; - iom.reg (this); + + if (registered) + iom.reschedule_time_watchers (); + else + iom.reg (this); +} + +void time_watcher::trigger () +{ + call (at); + + if (registered) + iom.reschedule_time_watchers (); + else + iom.reg (this); +} + +void time_watcher::start () +{ + if (!registered) + iom.reg (this); } void io_manager::reg (int fd, short events, io_watcher *w) @@ -80,29 +97,39 @@ } } +void io_manager::reschedule_time_watchers () +{ + make_heap (tw.begin (), tw.end (), lowest_first); +} + void io_manager::reg (time_watcher *w) { + if (w->registered) + slog (L_CRIT, "FATAL: io_manager::reg(time_watcher) called on already-registered watcher"); + + w->registered = true; + tw.push_back (w); push_heap (tw.begin (), tw.end (), lowest_first); } void io_manager::unreg (time_watcher *w) { - unsigned int sz = tw.size (); - unsigned int i = find (tw.begin (), tw.end (), w) - tw.begin (); - - if (i != sz) + if (w->registered) { - if (sz == 1) - tw.clear (); - else + unsigned int sz = tw.size (); + unsigned int i = find (tw.begin (), tw.end (), w) - tw.begin (); + + if (i != sz) { if (i != sz - 1) tw[i] = tw[sz - 1]; tw.pop_back (); - make_heap (tw.begin (), tw.end (), lowest_first); + reschedule_time_watchers (); } + + w->registered = false; } } @@ -112,7 +139,7 @@ gettimeofday (&tv, 0); - NOW = (timestamp)tv.tv_sec + (timestamp)tv.tv_usec / 1000000; + NOW = (tstamp)tv.tv_sec + (tstamp)tv.tv_usec / 1000000; } void io_manager::loop () @@ -121,37 +148,49 @@ for (;;) { - int timeout = tw.empty () ? -1 : (int) ((tw[0]->at - NOW) * 1000); - - //printf ("s%d t%d #%d <%f<%f<\n", pfs.size (), timeout, tw.size (), tw[0]->at - NOW, tw[1]->at - NOW); - - if (timeout >= 0) + while (tw[0]->at <= NOW) { - int fds = poll (&pfs[0], pfs.size (), timeout); + // remove the first watcher + time_watcher *w = tw[0]; - set_now (); + pop_heap (tw.begin (), tw.end (), lowest_first); + tw.pop_back (); - for (unsigned int i = iow.size (); fds && i--; ) - if (pfs[i].revents) - { - --fds; - iow[i]->call (pfs[i].revents); - } - } + w->registered = false; - while (!tw.empty () && tw[0]->at <= NOW) - { - pop_heap (tw.begin (), tw.end (), lowest_first); - time_watcher *w = tw[tw.size () - 1]; + // call it w->call (w->at); - push_heap (tw.begin (), tw.end (), lowest_first); + + // re-add it if necessary + if (w->at >= 0 && !w->registered) + reg (w); } + + int timeout = (int) ((tw[0]->at - NOW) * 1000); + + int fds = poll (&pfs[0], pfs.size (), timeout); + + set_now (); + + for (unsigned int i = 0; fds > 0 && i < iow.size (); ++i) + if (pfs[i].revents) + { + --fds; + iow[i]->call (pfs[i].fd, pfs[i].revents); + } } } +void io_manager::idle_cb (tstamp &ts) +{ + ts = NOW + 86400; // wake up every day, for no good reason +} + io_manager::io_manager () { set_now (); + idle = new time_watcher (this, &io_manager::idle_cb); + idle->start (0); } io_manager::~io_manager ()