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