… | |
… | |
25 | #include "rxvtvec.h" |
25 | #include "rxvtvec.h" |
26 | #include "callback.h" |
26 | #include "callback.h" |
27 | |
27 | |
28 | #define IOM_IO 1 |
28 | #define IOM_IO 1 |
29 | #define IOM_TIME 1 |
29 | #define IOM_TIME 1 |
30 | #undef IOM_CHECK |
30 | #define IOM_CHECK 1 |
|
|
31 | #define IOM_IDLE 0 |
31 | |
32 | |
32 | #if IOM_IO |
33 | #if IOM_IO |
33 | typedef double tstamp; |
34 | typedef double tstamp; |
34 | extern tstamp NOW; |
35 | extern tstamp NOW; |
35 | |
36 | |
… | |
… | |
39 | struct time_watcher; |
40 | struct time_watcher; |
40 | #endif |
41 | #endif |
41 | #if IOM_CHECK |
42 | #if IOM_CHECK |
42 | struct check_watcher; |
43 | struct check_watcher; |
43 | #endif |
44 | #endif |
|
|
45 | #if IOM_IDLE |
|
|
46 | struct idle_watcher; |
|
|
47 | #endif |
44 | |
48 | |
45 | class io_manager { |
49 | class io_manager { |
46 | #if IOM_IO |
50 | #if IOM_IO |
47 | simplevec<io_watcher *> iow; |
51 | simplevec<io_watcher *> iow; |
48 | #endif |
52 | #endif |
49 | #if IOM_CHECK |
53 | #if IOM_CHECK |
50 | simplevec<check_watcher *> cw; |
54 | simplevec<check_watcher *> cw; |
51 | #endif |
55 | #endif |
52 | #if IOM_TIME |
56 | #if IOM_TIME |
53 | simplevec<time_watcher *> tw; |
57 | simplevec<time_watcher *> tw; |
54 | |
58 | #endif |
55 | void idle_cb (time_watcher &w); time_watcher *idle; |
59 | #if IOM_IDLE |
|
|
60 | simplevec<idle_watcher *> iw; |
56 | #endif |
61 | #endif |
57 | |
62 | |
58 | template<class watcher> |
63 | template<class watcher> |
59 | void reg (watcher *w, simplevec<watcher *> &queue); |
64 | void reg (watcher *w, simplevec<watcher *> &queue); |
60 | |
65 | |
… | |
… | |
62 | void unreg (watcher *w, simplevec<watcher *> &queue); |
67 | void unreg (watcher *w, simplevec<watcher *> &queue); |
63 | |
68 | |
64 | public: |
69 | public: |
65 | // register a watcher |
70 | // register a watcher |
66 | #if IOM_IO |
71 | #if IOM_IO |
67 | void reg (io_watcher *w); void unreg (io_watcher *w); |
72 | void reg (io_watcher *w); void unreg (io_watcher *w); |
68 | #endif |
73 | #endif |
69 | #if IOM_TIME |
74 | #if IOM_TIME |
70 | void reg (time_watcher *w); void unreg (time_watcher *w); |
75 | void reg (time_watcher *w); void unreg (time_watcher *w); |
71 | #endif |
76 | #endif |
72 | #if IOM_CHECK |
77 | #if IOM_CHECK |
73 | void reg (check_watcher *w); void unreg (check_watcher *w); |
78 | void reg (check_watcher *w); void unreg (check_watcher *w); |
|
|
79 | #endif |
|
|
80 | #if IOM_IDLE |
|
|
81 | void reg (idle_watcher *w); void unreg (idle_watcher *w); |
74 | #endif |
82 | #endif |
75 | |
83 | |
76 | void loop (); |
84 | void loop (); |
77 | |
85 | |
78 | io_manager (); |
86 | io_manager (); |
… | |
… | |
93 | : callback2<void, io_watcher &, short>(object,method) |
101 | : callback2<void, io_watcher &, short>(object,method) |
94 | { } |
102 | { } |
95 | |
103 | |
96 | ~io_watcher (); |
104 | ~io_watcher (); |
97 | |
105 | |
98 | void set(int fd_, short events_) { fd = fd_; events = events_; } |
106 | void set (int fd_, short events_) { fd = fd_; events = events_; } |
99 | |
107 | |
100 | void set(short events_) { set (fd, events_); } |
108 | void set (short events_) { set (fd, events_); } |
|
|
109 | void start () { iom.reg (this); } |
101 | void start (int fd_, short events_) { set (fd_, events_); iom.reg (this); } |
110 | void start (int fd_, short events_) { set (fd_, events_); iom.reg (this); } |
102 | void stop () { iom.unreg (this); } |
111 | void stop () { iom.unreg (this); } |
103 | }; |
112 | }; |
104 | #endif |
113 | #endif |
105 | |
114 | |
… | |
… | |
145 | void start () { iom.reg (this); } |
154 | void start () { iom.reg (this); } |
146 | void stop () { iom.unreg (this); } |
155 | void stop () { iom.unreg (this); } |
147 | }; |
156 | }; |
148 | #endif |
157 | #endif |
149 | |
158 | |
|
|
159 | #if IOM_IDLE |
|
|
160 | // run after checking for any i/o, but before waiting |
|
|
161 | struct idle_watcher : callback1<void, idle_watcher &> { |
|
|
162 | template<class O1, class O2> |
|
|
163 | idle_watcher (O1 *object, void (O2::*method)(idle_watcher &)) |
|
|
164 | : callback1<void, idle_watcher &>(object,method) |
|
|
165 | { } |
|
|
166 | |
|
|
167 | ~idle_watcher (); |
|
|
168 | |
|
|
169 | void start () { iom.reg (this); } |
|
|
170 | void stop () { iom.unreg (this); } |
|
|
171 | }; |
150 | #endif |
172 | #endif |
151 | |
173 | |
|
|
174 | #endif |
|
|
175 | |