| … | |
… | |
| 165 | x_cb (ev, revents); |
165 | x_cb (ev, revents); |
| 166 | } |
166 | } |
| 167 | |
167 | |
| 168 | void event_set (struct event *ev, int fd, short events, void (*cb)(int, short, void *), void *arg) |
168 | void event_set (struct event *ev, int fd, short events, void (*cb)(int, short, void *), void *arg) |
| 169 | { |
169 | { |
|
|
170 | printf ("event set %p\n", ev);//D |
| 170 | if (events & EV_SIGNAL) |
171 | if (events & EV_SIGNAL) |
| 171 | ev_watcher_init (&ev->iosig.sig, x_cb_sig); |
172 | ev_watcher_init (&ev->iosig.sig, x_cb_sig); |
| 172 | else |
173 | else |
| 173 | ev_watcher_init (&ev->iosig.io, x_cb_io); |
174 | ev_watcher_init (&ev->iosig.io, x_cb_io); |
| 174 | |
175 | |
| … | |
… | |
| 188 | return event_base_once (x_cur, fd, events, cb, arg, tv); |
189 | return event_base_once (x_cur, fd, events, cb, arg, tv); |
| 189 | } |
190 | } |
| 190 | |
191 | |
| 191 | int event_add (struct event *ev, struct timeval *tv) |
192 | int event_add (struct event *ev, struct timeval *tv) |
| 192 | { |
193 | { |
|
|
194 | printf ("event add %p %p\n", ev, &ev->to);//D |
| 193 | dLOOPev; |
195 | dLOOPev; |
| 194 | |
196 | |
| 195 | /* disable all watchers */ |
197 | /* disable all watchers */ |
| 196 | event_del (ev); |
198 | event_del (ev); |
| 197 | |
199 | |
| … | |
… | |
| 215 | return 0; |
217 | return 0; |
| 216 | } |
218 | } |
| 217 | |
219 | |
| 218 | int event_del (struct event *ev) |
220 | int event_del (struct event *ev) |
| 219 | { |
221 | { |
|
|
222 | printf ("event del %p\n", ev);//D |
| 220 | dLOOPev; |
223 | dLOOPev; |
| 221 | |
224 | |
| 222 | if (ev->ev_events & EV_SIGNAL) |
225 | if (ev->ev_events & EV_SIGNAL) |
| 223 | { |
226 | { |
| 224 | /* sig */ |
227 | /* sig */ |
| … | |
… | |
| 230 | /* io */ |
233 | /* io */ |
| 231 | if (ev_is_active (&ev->iosig.io)) |
234 | if (ev_is_active (&ev->iosig.io)) |
| 232 | ev_io_stop (EV_A_ &ev->iosig.io); |
235 | ev_io_stop (EV_A_ &ev->iosig.io); |
| 233 | } |
236 | } |
| 234 | |
237 | |
|
|
238 | printf ("to %p %d\n", &ev->to, ev->to.active);//D |
| 235 | if (ev_is_active (&ev->to)) |
239 | if (ev_is_active (&ev->to)) |
| 236 | ev_timer_stop (EV_A_ &ev->to); |
240 | ev_timer_stop (EV_A_ &ev->to); |
| 237 | |
241 | |
| 238 | return 0; |
242 | return 0; |
| 239 | } |
243 | } |
