|
|
| version 1.1.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); |