Lines Matching refs:ev
12 fdevents *ev = w->data; in io_watcher_cb() local
13 fdnode *fdn = ev->fdarray[w->fd]; in io_watcher_cb()
21 switch (r = (*fdn->handler)(ev->srv, fdn->ctx, r)) { in io_watcher_cb()
32 log_error_write(ev->srv, __FILE__, __LINE__, "d", r); in io_watcher_cb()
37 static void fdevent_libev_free(fdevents *ev) { in fdevent_libev_free() argument
38 UNUSED(ev); in fdevent_libev_free()
41 static int fdevent_libev_event_del(fdevents *ev, int fde_ndx, int fd) { in fdevent_libev_event_del() argument
47 fdn = ev->fdarray[fd]; in fdevent_libev_event_del()
52 ev_io_stop(ev->libev_loop, watcher); in fdevent_libev_event_del()
59 static int fdevent_libev_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_libev_event_set() argument
60 fdnode *fdn = ev->fdarray[fd]; in fdevent_libev_event_set()
73 watcher->data = ev; in fdevent_libev_event_set()
74 ev_io_start(ev->libev_loop, watcher); in fdevent_libev_event_set()
77 ev_io_stop(ev->libev_loop, watcher); in fdevent_libev_event_set()
79 ev_io_start(ev->libev_loop, watcher); in fdevent_libev_event_set()
93 static int fdevent_libev_poll(fdevents *ev, int timeout_ms) { in fdevent_libev_poll() argument
98 ev_timer_start(ev->libev_loop, &timeout_watcher); in fdevent_libev_poll()
100 ev_loop(ev->libev_loop, EVLOOP_ONESHOT); in fdevent_libev_poll()
102 ev_timer_stop(ev->libev_loop, &timeout_watcher); in fdevent_libev_poll()
107 static int fdevent_libev_event_get_revent(fdevents *ev, size_t ndx) { in fdevent_libev_event_get_revent() argument
108 UNUSED(ev); in fdevent_libev_event_get_revent()
114 static int fdevent_libev_event_get_fd(fdevents *ev, size_t ndx) { in fdevent_libev_event_get_fd() argument
115 UNUSED(ev); in fdevent_libev_event_get_fd()
121 static int fdevent_libev_event_next_fdndx(fdevents *ev, int ndx) { in fdevent_libev_event_next_fdndx() argument
122 UNUSED(ev); in fdevent_libev_event_next_fdndx()
128 static int fdevent_libev_reset(fdevents *ev) { in fdevent_libev_reset() argument
129 UNUSED(ev); in fdevent_libev_reset()
136 int fdevent_libev_init(fdevents *ev) { in fdevent_libev_init() argument
137 ev->type = FDEVENT_HANDLER_LIBEV; in fdevent_libev_init()
139 ev->x = fdevent_libev_##x; in fdevent_libev_init()
152 if (NULL == (ev->libev_loop = ev_default_loop(0))) { in fdevent_libev_init()
153 log_error_write(ev->srv, __FILE__, __LINE__, "S", in fdevent_libev_init()
163 int fdevent_libev_init(fdevents *ev) { in fdevent_libev_init() argument
164 UNUSED(ev); in fdevent_libev_init()
166 log_error_write(ev->srv, __FILE__, __LINE__, "S", in fdevent_libev_init()