| … | |
… | |
| 180 | ev_timer_set (&ev->to, tv_get (tv), 0.); |
180 | ev_timer_set (&ev->to, tv_get (tv), 0.); |
| 181 | ev_timer_start (&ev->to); |
181 | ev_timer_start (&ev->to); |
| 182 | ++x_actives; |
182 | ++x_actives; |
| 183 | } |
183 | } |
| 184 | |
184 | |
| 185 | if (ev->ev_events & (EV_READ|EV_WRITE)) |
185 | if (ev->ev_events & (EV_READ | EV_WRITE)) |
| 186 | { |
186 | { |
| 187 | if (ev_is_active (&ev->io)) |
187 | if (ev_is_active (&ev->io)) |
| 188 | { |
188 | { |
| 189 | ev_io_stop (&ev->io); |
189 | ev_io_stop (&ev->io); |
| 190 | --x_actives; |
190 | --x_actives; |
| 191 | } |
191 | } |
| 192 | |
192 | |
| 193 | ev_io_set (&ev->io, ev->ev_fd, ev->ev_events); |
193 | ev_io_set (&ev->io, ev->ev_fd, ev->ev_events & (EV_READ | EV_WRITE)); |
| 194 | ev_io_start (&ev->io); |
194 | ev_io_start (&ev->io); |
| 195 | ++x_actives; |
195 | ++x_actives; |
| 196 | } |
196 | } |
| 197 | |
197 | |
| 198 | if (ev->ev_events & EV_SIGNAL) |
198 | if (ev->ev_events & EV_SIGNAL) |
| … | |
… | |
| 333 | |
333 | |
| 334 | once->fd = fd; |
334 | once->fd = fd; |
| 335 | once->cb = cb; |
335 | once->cb = cb; |
| 336 | once->arg = arg; |
336 | once->arg = arg; |
| 337 | |
337 | |
| 338 | ev_once (fd, events & (EV_READ|EV_WRITE), tv_get (tv), x_once_cb, (void *)once); |
338 | ev_once (fd, events & (EV_READ | EV_WRITE), tv_get (tv), x_once_cb, (void *)once); |
| 339 | |
339 | |
| 340 | return 0; |
340 | return 0; |
| 341 | } |
341 | } |
| 342 | |
342 | |
| 343 | int event_base_priority_init (struct event_base *base, int npri) |
343 | int event_base_priority_init (struct event_base *base, int npri) |
