| /libev/ |
| H A D | ev++.h | 269 ev_once (EV_AX_ fd, events, timeout, cb, arg); in throw()
311 once (fd, events, timeout, simpler_func_thunk<cb>); in once()
325 once (fd, events, timeout, simplest_func_thunk<cb>); in once()
497 void operator ()(int events = EV_UNDEF) in operator()
501 (static_cast<ev_watcher *>(this), events); in operator()
615 void set (int fd, int events) throw () in EV_BEGIN_WATCHER()
619 ev_io_set (static_cast<ev_io *>(this), fd, events); in EV_BEGIN_WATCHER()
623 void set (int events) throw () in set() argument
627 ev_io_set (static_cast<ev_io *>(this), fd, events); in set()
631 void start (int fd, int events) throw () in start() argument
[all …]
|
| H A D | ev_select.c | 224 if (anfds [fd].events) in select_poll()
226 int events = 0; in select_poll() local
233 if (FD_ISSET (handle, (fd_set *)vec_ro)) events |= EV_READ; in select_poll()
234 if (FD_ISSET (handle, (fd_set *)vec_wo)) events |= EV_WRITE; in select_poll()
239 if (expect_true (events)) in select_poll()
240 fd_event (EV_A_ fd, events); in select_poll()
260 int events = 0; in select_poll() local
262 events |= word_r & mask ? EV_READ : 0; in select_poll()
263 events |= word_w & mask ? EV_WRITE : 0; in select_poll()
265 if (expect_true (events)) in select_poll()
[all …]
|
| H A D | ev_epoll.c | 93 ev.events = (nev & EV_READ ? EPOLLIN : 0) in epoll_modify()
169 int want = anfds [fd].events; in epoll_poll()
170 int got = (ev->events & (EPOLLOUT | EPOLLERR | EPOLLHUP) ? EV_WRITE : 0) in epoll_poll()
171 | (ev->events & (EPOLLIN | EPOLLERR | EPOLLHUP) ? EV_READ : 0); in epoll_poll()
199 ev->events = (want & EV_READ ? EPOLLIN : 0) in epoll_poll()
226 unsigned char events = anfds [fd].events & (EV_READ | EV_WRITE); in epoll_poll() local
228 if (anfds [fd].emask & EV_EMASK_EPERM && events) in epoll_poll()
229 fd_event (EV_A_ fd, events); in epoll_poll()
|
| H A D | event.c | 206 void event_set (struct event *ev, int fd, short events, void (*cb)(int, short, void *), void *arg) in event_set() argument
208 if (events & EV_SIGNAL) in event_set()
217 ev->ev_events = events; in event_set()
225 int event_once (int fd, short events, void (*cb)(int, short, void *), void *arg, struct timeval *tv) in event_once() argument
227 return event_base_once (ev_x_cur, fd, events, cb, arg, tv); in event_once()
303 int event_pending (struct event *ev, short events, struct timeval *tv) in event_pending() argument
334 return events & revents; in event_pending()
402 int event_base_once (struct event_base *base, int fd, short events, void (*cb)(int, short, void *),… in event_base_once() argument
414 ev_once (EV_A_ fd, events & (EV_READ | EV_WRITE), ev_tv_get (tv), ev_x_once_cb, (void *)once); in event_base_once()
|
| H A D | ev.c | 2038 int ev = w->events & revents; in fd_event_nocheck()
2088 anfd->events = 0; in fd_reify()
2108 anfd->events = 0; in fd_reify()
2111 anfd->events |= (unsigned char)w->events; in fd_reify()
2113 if (o_events != anfd->events) in fd_reify()
2170 if (anfds [fd].events) in fd_ebadf()
2182 if (anfds [fd].events) in fd_enomem()
2196 if (anfds [fd].events) in fd_rearm_all()
2198 anfds [fd].events = 0; in fd_rearm_all()
3796 return p->events; in ev_clear_pending()
[all …]
|
| H A D | ev.pod | 809 handling events. It will ask the operating system for any new events, call
967 time collecting I/O events, so you can handle more events per iteration,
1522 other events are pending:
1587 receive future events.
1638 events for them, only one file descriptor might actually receive events.
1746 receive events for and C<events> is either C<EV_READ>, C<EV_WRITE> or
2844 Idle watchers trigger events when no other events of the same or higher
2846 as receiving "events").
3543 events precedence.
3560 the given events.
[all …]
|
| H A D | ev_kqueue.c | 122 if (anfds [fd].events) in kqueue_poll()
125 kqueue_modify (EV_A_ fd, 0, anfds [fd].events); in kqueue_poll()
129 kqueue_modify (EV_A_ fd, 0, anfds [fd].events); in kqueue_poll()
|
| H A D | ev.h | 322 int events; /* ro */
654 EV_API_DECL void ev_once (EV_P_ int fd, int events, ev_tstamp timeout, void (*cb)(int revents, void…
693 #define ev_io_set(ev,fd_,events_) do { (ev)->fd = (fd_); (ev)->events = (events_) | EV__…
707 #define ev_io_init(ev,cb,fd,events) do { ev_init ((ev), (cb)); ev_io_set ((ev),(fd),(event…
|
| H A D | event.h | 148 void event_set (struct event *ev, int fd, short events, void (*cb)(int, short, void *), void *arg);
149 int event_once (int fd, short events, void (*cb)(int, short, void *), void *arg, struct timeval *tv…
166 int event_base_once (struct event_base *base, int fd, short events, void (*cb)(int, short, void *),…
|
| H A D | Changes | 42 - events on files were not always generated properly with the
144 backend, by generating events on our own.
183 - add (undocumented) EV_ENABLE when adding events with kqueue,
268 for new events.
287 that has active kernel events but no registered watchers
365 spurious notifications or unwanted events. this is very costly,
|
| H A D | ev_poll.c | 73 polls [idx].events = in poll_modify()
|