version 1.1, 2013/10/14 10:32:47
|
version 1.1.1.2, 2014/06/15 20:20:06
|
Line 67 static int fdevent_libev_event_set(fdevents *ev, int f
|
Line 67 static int fdevent_libev_event_set(fdevents *ev, int f
|
|
|
if (!watcher) { |
if (!watcher) { |
fdn->handler_ctx = watcher = calloc(1, sizeof(ev_io)); |
fdn->handler_ctx = watcher = calloc(1, sizeof(ev_io)); |
assert(watcher); | force_assert(watcher); |
|
|
ev_io_init(watcher, io_watcher_cb, fd, ev_events); |
ev_io_init(watcher, io_watcher_cb, fd, ev_events); |
watcher->data = ev; |
watcher->data = ev; |
Line 103 static int fdevent_libev_poll(fdevents *ev, int timeou
|
Line 103 static int fdevent_libev_poll(fdevents *ev, int timeou
|
ev_init(&timeout_watcher.w, NULL); |
ev_init(&timeout_watcher.w, NULL); |
ev_set_cb(&timeout_watcher.timer, timeout_watcher_cb); |
ev_set_cb(&timeout_watcher.timer, timeout_watcher_cb); |
timeout_watcher.timer.repeat = ((ev_tstamp) timeout_ms)/1000.0; |
timeout_watcher.timer.repeat = ((ev_tstamp) timeout_ms)/1000.0; |
assert(timeout_watcher.timer.repeat); | force_assert(timeout_watcher.timer.repeat); |
ev_timer_again(ev->libev_loop, &timeout_watcher.timer); |
ev_timer_again(ev->libev_loop, &timeout_watcher.timer); |
|
|
ev_loop(ev->libev_loop, EVLOOP_ONESHOT); |
ev_loop(ev->libev_loop, EVLOOP_ONESHOT); |