| … | |
… | |
| 138 | } |
138 | } |
| 139 | |
139 | |
| 140 | static void |
140 | static void |
| 141 | ev_x_cb (struct event *ev, int revents) |
141 | ev_x_cb (struct event *ev, int revents) |
| 142 | { |
142 | { |
| 143 | revents &= EV_READ | EV_WRITE | EV_TIMEOUT | EV_SIGNAL; |
143 | revents &= EV_READ | EV_WRITE | EV_TIMER | EV_SIGNAL; |
| 144 | |
144 | |
| 145 | ev->ev_res = revents; |
145 | ev->ev_res = revents; |
| 146 | ev->ev_callback (ev->ev_fd, (short)revents, ev->ev_arg); |
146 | ev->ev_callback (ev->ev_fd, (short)revents, ev->ev_arg); |
| 147 | } |
147 | } |
| 148 | |
148 | |
| … | |
… | |
| 325 | |
325 | |
| 326 | int event_base_loop (struct event_base *base, int flags) |
326 | int event_base_loop (struct event_base *base, int flags) |
| 327 | { |
327 | { |
| 328 | dLOOPbase; |
328 | dLOOPbase; |
| 329 | |
329 | |
| 330 | ev_loop (EV_A_ flags); |
330 | ev_run (EV_A_ flags); |
| 331 | |
331 | |
| 332 | return 0; |
332 | return 0; |
| 333 | } |
333 | } |
| 334 | |
334 | |
| 335 | int event_base_dispatch (struct event_base *base) |
335 | int event_base_dispatch (struct event_base *base) |
| … | |
… | |
| 340 | static void |
340 | static void |
| 341 | ev_x_loopexit_cb (int revents, void *base) |
341 | ev_x_loopexit_cb (int revents, void *base) |
| 342 | { |
342 | { |
| 343 | dLOOPbase; |
343 | dLOOPbase; |
| 344 | |
344 | |
| 345 | ev_unloop (EV_A_ EVUNLOOP_ONE); |
345 | ev_break (EV_A_ EVBREAK_ONE); |
| 346 | } |
346 | } |
| 347 | |
347 | |
| 348 | int event_base_loopexit (struct event_base *base, struct timeval *tv) |
348 | int event_base_loopexit (struct event_base *base, struct timeval *tv) |
| 349 | { |
349 | { |
| 350 | ev_tstamp after = ev_tv_get (tv); |
350 | ev_tstamp after = ev_tv_get (tv); |
