… | |
… | |
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) |
… | |
… | |
232 | } |
232 | } |
233 | |
233 | |
234 | return 0; |
234 | return 0; |
235 | } |
235 | } |
236 | |
236 | |
237 | void event_active (struct event *ev, int fd, short events) |
|
|
238 | { |
|
|
239 | /* unclear what this does, likely internal-use */ |
|
|
240 | } |
|
|
241 | |
|
|
242 | int event_pending (struct event *ev, short events, struct timeval *tv) |
237 | int event_pending (struct event *ev, short events, struct timeval *tv) |
243 | { |
238 | { |
244 | short revents; |
239 | short revents; |
245 | |
240 | |
246 | if (ev->io.pending) |
241 | if (ev->io.pending) |
… | |
… | |
333 | |
328 | |
334 | once->fd = fd; |
329 | once->fd = fd; |
335 | once->cb = cb; |
330 | once->cb = cb; |
336 | once->arg = arg; |
331 | once->arg = arg; |
337 | |
332 | |
338 | ev_once (fd, events & (EV_READ|EV_WRITE), tv_get (tv), x_once_cb, (void *)once); |
333 | ev_once (fd, events & (EV_READ | EV_WRITE), tv_get (tv), x_once_cb, (void *)once); |
339 | |
334 | |
340 | return 0; |
335 | return 0; |
341 | } |
336 | } |
342 | |
337 | |
343 | int event_base_priority_init (struct event_base *base, int npri) |
338 | int event_base_priority_init (struct event_base *base, int npri) |