--- rxvt-unicode/src/iom.h 2004/01/16 22:11:09 1.6 +++ rxvt-unicode/src/iom.h 2004/09/02 07:44:40 1.15 @@ -1,6 +1,6 @@ /* iom.h -- generic I/O multiplexor - Copyright (C) 2003 Marc Lehmann + Copyright (C) 2003, 2004 Marc Lehmann This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by @@ -17,105 +17,103 @@ Foundation, Inc. 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ -#ifndef VPE_IOM_H__ -#define VPE_IOM_H__ +#ifndef IOM_H__ +#define IOM_H__ -#include +// required: +// - a vector template like simplevec or stl's vector +// - defines for all watcher types required in your app +// edit iom_conf.h as appropriate. +#include "iom_conf.h" #include "callback.h" -#include "rxvtvec.h" #ifndef IOM_IO -# define IOM_IO 1 +# define IOM_IO 0 #endif #ifndef IOM_TIME -# define IOM_TIME 1 +# define IOM_TIME 0 #endif #ifndef IOM_CHECK -# define IOM_CHECK 1 +# define IOM_CHECK 0 #endif #ifndef IOM_IDLE # define IOM_IDLE 0 #endif +#ifndef IOM_SIG +# define IOM_SIG 0 +#endif typedef double tstamp; extern tstamp NOW; +struct watcher; #if IOM_IO - struct io_watcher; +struct io_watcher; #endif #if IOM_TIME - struct time_watcher; +struct time_watcher; #endif #if IOM_CHECK - struct check_watcher; +struct check_watcher; #endif #if IOM_IDLE - struct idle_watcher; +struct idle_watcher; +#endif +#if IOM_SIG +struct sig_watcher; #endif template -struct io_manager_vec : protected simplevec { - friend class io_manager; -protected: +struct io_manager_vec : vector { +#if IOM_CHECK + bool activity; +#endif + void erase_unordered (unsigned int pos) { - watcher *w = (*this)[size () - 1]; - pop_back (); + watcher *w = (*this)[this->size () - 1]; + this->pop_back (); - if (size ()) + if (this->size ()) if ((*this)[pos] = w) w->active = pos + 1; } }; +// only used as a namespace, and for initialisation purposes class io_manager { -#if IOM_IO - io_manager_vec iow; -#endif -#if IOM_CHECK - io_manager_vec cw; -#endif -#if IOM_TIME - io_manager_vec tw; -#endif -#if IOM_IDLE - io_manager_vec iw; -#endif - template - void reg (watcher *w, simplevec &queue); + static void reg (watcher &w, io_manager_vec &queue); template - void unreg (watcher *w, simplevec &queue); + static void unreg (watcher &w, io_manager_vec &queue); public: // register a watcher #if IOM_IO - void reg (io_watcher *w); void unreg (io_watcher *w); + static void reg (io_watcher &w); static void unreg (io_watcher &w); #endif #if IOM_TIME - void reg (time_watcher *w); void unreg (time_watcher *w); + static void reg (time_watcher &w); static void unreg (time_watcher &w); #endif #if IOM_CHECK - void reg (check_watcher *w); void unreg (check_watcher *w); + static void reg (check_watcher &w); static void unreg (check_watcher &w); #endif #if IOM_IDLE - void reg (idle_watcher *w); void unreg (idle_watcher *w); + static void reg (idle_watcher &w); static void unreg (idle_watcher &w); +#endif +#if IOM_SIG + static void reg (sig_watcher &w); static void unreg (sig_watcher &w); #endif - void loop (); - - io_manager (); - ~io_manager (); + static void loop (); }; -extern io_manager iom; // a singleton, together with it's construction/destruction problems. - struct watcher { int active; /* 0 == inactive, else index into respective vector */ - watcher() : active(0) { } + watcher () : active (0) { } }; #if IOM_IO @@ -128,13 +126,13 @@ void set (int fd_, short events_) { fd = fd_; events = events_; } void set (short events_) { set (fd, events_); } - void start () { iom.reg (this); } - void start (int fd_, short events_) { set (fd_, events_); iom.reg (this); } - void stop () { iom.unreg (this); } + void start () { io_manager::reg (*this); } + void start (int fd_, short events_) { set (fd_, events_); io_manager::reg (*this); } + void stop () { io_manager::unreg (*this); } template - io_watcher (O1 *object, void (O2::*method)(io_watcher &, short)) - : callback2(object,method) + io_watcher (O1 *object, void (O2::*method) (io_watcher &, short)) + : callback2 (object,method) { } ~io_watcher () { stop (); } }; @@ -147,14 +145,14 @@ void trigger (); void set (tstamp when) { at = when; } - void operator ()() { trigger (); } - void start () { iom.reg (this); } - void start (tstamp when) { set (when); iom.reg (this); } - void stop () { iom.unreg (this); } + void operator () () { trigger (); } + void start () { io_manager::reg (*this); } + void start (tstamp when) { set (when); io_manager::reg (*this); } + void stop () { io_manager::unreg (*this); } template - time_watcher (O1 *object, void (O2::*method)(time_watcher &)) - : callback1(object,method) + time_watcher (O1 *object, void (O2::*method) (time_watcher &)) + : callback1 (object,method), at (0) { } ~time_watcher () { stop (); } }; @@ -163,12 +161,12 @@ #if IOM_CHECK // run before checking for new events struct check_watcher : watcher, callback1 { - void start () { iom.reg (this); } - void stop () { iom.unreg (this); } + void start () { io_manager::reg (*this); } + void stop () { io_manager::unreg (*this); } template - check_watcher (O1 *object, void (O2::*method)(check_watcher &)) - : callback1(object,method) + check_watcher (O1 *object, void (O2::*method) (check_watcher &)) + : callback1 (object,method) { } ~check_watcher () { stop (); } }; @@ -177,16 +175,31 @@ #if IOM_IDLE // run after checking for any i/o, but before waiting struct idle_watcher : watcher, callback1 { - void start () { iom.reg (this); } - void stop () { iom.unreg (this); } + void start () { io_manager::reg (*this); } + void stop () { io_manager::unreg (*this); } template - idle_watcher (O1 *object, void (O2::*method)(idle_watcher &)) - : callback1(object,method) + idle_watcher (O1 *object, void (O2::*method) (idle_watcher &)) + : callback1 (object,method) { } ~idle_watcher () { stop (); } }; #endif +#if IOM_SIG +struct sig_watcher : watcher, callback1 { + int signum; + + void start (int signum); + void stop () { io_manager::unreg (*this); } + + template + sig_watcher (O1 *object, void (O2::*method) (sig_watcher &)) + : callback1 (object,method), signum (-1) + { } + ~sig_watcher () { stop (); } +}; +#endif + #endif