… | |
… | |
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 | } |