| /libev/ |
| H A D | ev_epoll.c | 87 oldmask = anfds [fd].emask; in epoll_modify()
88 anfds [fd].emask = nev; in epoll_modify()
91 ev.data.u64 = (uint64_t)(uint32_t)fd in epoll_modify()
134 fd_kill (EV_A_ fd); in epoll_modify()
138 --anfds [fd].egen; in epoll_modify()
169 int want = anfds [fd].events; in epoll_poll()
188 anfds [fd].emask = want; in epoll_poll()
211 fd_event (EV_A_ fd, got); in epoll_poll()
225 int fd = epoll_eperms [i]; in epoll_poll() local
229 fd_event (EV_A_ fd, events); in epoll_poll()
[all …]
|
| H A D | ev_kqueue.c | 64 kqueue_modify (EV_P_ int fd, int oev, int nev) in kqueue_modify() argument
69 kqueue_change (EV_A_ fd, EVFILT_READ , EV_DELETE, 0); in kqueue_modify()
72 kqueue_change (EV_A_ fd, EVFILT_WRITE, EV_DELETE, 0); in kqueue_modify()
115 int fd = kqueue_events [i].ident; in kqueue_poll() local
122 if (anfds [fd].events) in kqueue_poll()
125 kqueue_modify (EV_A_ fd, 0, anfds [fd].events); in kqueue_poll()
128 if (fd_valid (fd)) in kqueue_poll()
129 kqueue_modify (EV_A_ fd, 0, anfds [fd].events); in kqueue_poll()
131 fd_kill (EV_A_ fd); in kqueue_poll()
134 fd_kill (EV_A_ fd); in kqueue_poll()
[all …]
|
| H A D | ev_poll.c | 52 poll_modify (EV_P_ int fd, int oev, int nev) in poll_modify() argument
59 array_needsize (int, pollidxs, pollidxmax, fd + 1, pollidx_init); in poll_modify()
61 idx = pollidxs [fd]; in poll_modify()
65 pollidxs [fd] = idx = pollcnt++; in poll_modify()
67 polls [idx].fd = fd; in poll_modify()
70 assert (polls [idx].fd == fd); in poll_modify()
78 pollidxs [fd] = -1; in poll_modify()
83 pollidxs [polls [idx].fd] = idx; in poll_modify()
117 fd_kill (EV_A_ p->fd); in poll_poll()
121 p->fd, in poll_poll()
|
| H A D | ev_select.c | 71 select_modify (EV_P_ int fd, int oev, int nev) in select_modify() argument
80 SOCKET handle = anfds [fd].handle; in select_modify()
82 int handle = fd; in select_modify()
108 int word = fd / NFDBITS; in select_modify()
109 fd_mask mask = 1UL << (fd % NFDBITS); in select_modify()
221 int fd; in select_poll() local
223 for (fd = 0; fd < anfdmax; ++fd) in select_poll()
224 if (anfds [fd].events) in select_poll()
228 SOCKET handle = anfds [fd].handle; in select_poll()
230 int handle = fd; in select_poll()
[all …]
|
| H A D | ev.c | 1564 # define EV_FD_TO_WIN32_HANDLE(fd) _get_osfhandle (fd) argument
1570 # define EV_WIN32_CLOSE_FD(fd) close (fd) argument
2059 if (fd >= 0 && fd < anfdmax) in ev_feed_fd_event()
2167 int fd; in fd_ebadf() local
2169 for (fd = 0; fd < anfdmax; ++fd) in fd_ebadf()
2179 int fd; in fd_enomem() local
2181 for (fd = anfdmax; fd--; ) in fd_enomem()
2193 int fd; in fd_rearm_all() local
2195 for (fd = 0; fd < anfdmax; ++fd) in fd_rearm_all()
3831 int fd = w->fd; in ev_io_start() local
[all …]
|
| H A D | ev++.h | 269 ev_once (EV_AX_ fd, events, timeout, cb, arg); in throw()
309 void once (int fd, int events, tstamp timeout) throw () in once()
311 once (fd, events, timeout, simpler_func_thunk<cb>); in once()
325 once (fd, events, timeout, simplest_func_thunk<cb>); in once()
335 void feed_fd_event (int fd, int revents) throw () in feed_fd_event()
337 ev_feed_fd_event (EV_AX_ fd, revents); in feed_fd_event()
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()
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_port.c | 59 port_associate_and_check (EV_P_ int fd, int ev) in port_associate_and_check() argument
63 backend_fd, PORT_SOURCE_FD, fd, in port_associate_and_check()
71 fd_kill (EV_A_ fd); in port_associate_and_check()
78 port_modify (EV_P_ int fd, int oev, int nev) in port_modify() argument
86 port_dissociate (backend_fd, PORT_SOURCE_FD, fd); in port_modify()
89 port_associate_and_check (EV_A_ fd, nev); in port_modify()
118 int fd = port_events [i].portev_object; in port_poll() local
122 fd, in port_poll()
127 fd_change (EV_A_ fd, EV__IOFDSET); in port_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
216 ev->ev_fd = fd; 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()
388 int fd; member
398 once->cb (once->fd, (short)revents, once->arg); in ev_x_once_cb()
402 int event_base_once (struct event_base *base, int fd, short events, void (*cb)(int, short, void *),… in event_base_once() argument
410 once->fd = fd; in event_base_once()
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 | Changes | 13 TODO: embed watchers need updating when fd changes
18 - when epoll detects unremovable fds in the fd set, rebuild
44 - mark event pipe fd as cloexec after a fork (analyzed by Sami Farin).
94 on fork, at the cost of one extra fd.
133 - fix two problems in the native win32 backend, where reuse of fd's
230 symbols to make it easier for apps to do their own fd management.
234 on fd creation, to avoid races.
255 on fd creation, to avoid race conditions.
403 - work around yet another windows bug: FD_SET actually adds fd's
414 - pass in the write fd set as except fd set under windows. windows
[all …]
|
| 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 *),…
167 int event_base_priority_init (struct event_base *base, int fd);
|
| H A D | ev.h | 321 int fd; /* 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…
748 EV_API_DECL void ev_feed_fd_event (EV_P_ int fd, int revents) EV_THROW;
|
| H A D | ev.pod | 873 - Queue all outstanding I/O (fd) events.
1730 close that fd, and create a new dummy fd. This will gracefully refuse
1743 =item ev_io_set (ev_io *, int fd, int events)
1749 =item int fd [read-only]
3057 struct pollfd *fd = fds + i;
3059 if (revents & EV_READ ) fd->revents |= fd->events & POLLIN;
3060 if (revents & EV_WRITE) fd->revents |= fd->events & POLLOUT;
3595 ev_io_init (&w.io, my_cb, fd, EV_READ);
4186 myclass (int fd)
4551 =item EV_FD_TO_WIN32_HANDLE(fd)
[all …]
|
| H A D | ev_vars.h | 66 VAR (backend_modify, void (*backend_modify)(EV_P_ int fd, int oev, int nev))
|