Lines Matching refs:fdn
278 for (fdnode *fdn = ev->pendclose; fdn; ) { in fdevent_sched_run() local
279 int fd = fdn->fd; in fdevent_sched_run()
289 fdnode * const fdn_tmp = fdn; in fdevent_sched_run()
290 fdn = (fdnode *)fdn->ctx; /* next */ in fdevent_sched_run()
316 fdevent_linux_sysepoll_event_del (fdevents *ev, fdnode *fdn) in fdevent_linux_sysepoll_event_del() argument
318 return epoll_ctl(ev->epoll_fd, EPOLL_CTL_DEL, fdn->fd, NULL); in fdevent_linux_sysepoll_event_del()
322 fdevent_linux_sysepoll_event_set (fdevents *ev, fdnode *fdn, int events) in fdevent_linux_sysepoll_event_set() argument
324 int op = (-1 == fdn->fde_ndx) ? EPOLL_CTL_ADD : EPOLL_CTL_MOD; in fdevent_linux_sysepoll_event_set()
325 int fd = fdn->fde_ndx = fdn->fd; in fdevent_linux_sysepoll_event_set()
331 ep.data.ptr = fdn; in fdevent_linux_sysepoll_event_set()
341 fdnode * const fdn = (fdnode *)epoll_events[i].data.ptr; in fdevent_linux_sysepoll_poll() local
343 if ((fdevent_handler)NULL != fdn->handler) in fdevent_linux_sysepoll_poll()
344 (*fdn->handler)(fdn->ctx, revents); in fdevent_linux_sysepoll_poll()
398 fdevent_freebsd_kqueue_event_del (fdevents *ev, fdnode *fdn) in fdevent_freebsd_kqueue_event_del() argument
402 int fd = fdn->fd; in fdevent_freebsd_kqueue_event_del()
404 int oevents = fdn->events; in fdevent_freebsd_kqueue_event_del()
407 EV_SET(&kev[n], fd, EVFILT_READ, EV_DELETE, 0, 0, fdn); in fdevent_freebsd_kqueue_event_del()
411 EV_SET(&kev[n], fd, EVFILT_WRITE, EV_DELETE, 0, 0, fdn); in fdevent_freebsd_kqueue_event_del()
421 fdevent_freebsd_kqueue_event_set (fdevents *ev, fdnode *fdn, int events) in fdevent_freebsd_kqueue_event_set() argument
425 int fd = fdn->fde_ndx = fdn->fd; in fdevent_freebsd_kqueue_event_set()
427 int oevents = fdn->events; in fdevent_freebsd_kqueue_event_set()
432 EV_SET(&kev[n], fd, EVFILT_READ, EV_ADD, 0, 0, fdn); in fdevent_freebsd_kqueue_event_set()
436 EV_SET(&kev[n], fd, EVFILT_READ, EV_DELETE, 0, 0, fdn); in fdevent_freebsd_kqueue_event_set()
441 EV_SET(&kev[n], fd, EVFILT_WRITE, EV_ADD, 0, 0, fdn); in fdevent_freebsd_kqueue_event_set()
445 EV_SET(&kev[n], fd, EVFILT_WRITE, EV_DELETE, 0, 0, fdn); in fdevent_freebsd_kqueue_event_set()
465 fdnode * const fdn = (fdnode *)kq_results[i].udata; in fdevent_freebsd_kqueue_poll() local
468 if ((fdevent_handler)NULL != fdn->handler) { in fdevent_freebsd_kqueue_poll()
474 (*fdn->handler)(fdn->ctx, revents); in fdevent_freebsd_kqueue_poll()
527 fdevent_solaris_port_event_del (fdevents *ev, fdnode *fdn) in fdevent_solaris_port_event_del() argument
529 return port_dissociate(ev->port_fd, PORT_SOURCE_FD, fdn->fd); in fdevent_solaris_port_event_del()
533 fdevent_solaris_port_event_set (fdevents *ev, fdnode *fdn, int events) in fdevent_solaris_port_event_set() argument
535 int fd = fdn->fde_ndx = fdn->fd; in fdevent_solaris_port_event_set()
571 fdnode * const fdn = ev->fdarray[fd]; in fdevent_solaris_port_poll() local
574 if (0 == ((uintptr_t)fdn & 0x3)) { in fdevent_solaris_port_poll()
577 (*fdn->handler)(fdn->ctx, revents); in fdevent_solaris_port_poll()
580 fdn->fde_ndx = -1; in fdevent_solaris_port_poll()
630 fdevent_solaris_devpoll_event_del (fdevents *ev, fdnode *fdn) in fdevent_solaris_devpoll_event_del() argument
633 pfd.fd = fdn->fd; in fdevent_solaris_devpoll_event_del()
640 fdevent_solaris_devpoll_event_set (fdevents *ev, fdnode *fdn, int events) in fdevent_solaris_devpoll_event_set() argument
643 pfd.fd = fdn->fde_ndx = fdn->fd; in fdevent_solaris_devpoll_event_set()
666 fdnode * const fdn = fdarray[devpollfds[i].fd]; in fdevent_solaris_devpoll_poll() local
668 if (0 == ((uintptr_t)fdn & 0x3)) in fdevent_solaris_devpoll_poll()
669 (*fdn->handler)(fdn->ctx, revents); in fdevent_solaris_devpoll_poll()
729 fdevent_poll_event_del (fdevents *ev, fdnode *fdn) in fdevent_poll_event_del() argument
731 int fd = fdn->fd; in fdevent_poll_event_del()
732 int k = fdn->fde_ndx; in fdevent_poll_event_del()
752 fdevent_poll_event_set (fdevents *ev, fdnode *fdn, int events) in fdevent_poll_event_set() argument
754 int fd = fdn->fd; in fdevent_poll_event_set()
755 int k = fdn->fde_ndx; in fdevent_poll_event_set()
781 fdn->fde_ndx = k; in fdevent_poll_event_set()
796 fdnode *fdn = fdarray[pfds[i].fd]; in fdevent_poll_poll() local
797 if (0 == ((uintptr_t)fdn & 0x3)) in fdevent_poll_poll()
798 (*fdn->handler)(fdn->ctx, pfds[i].revents); in fdevent_poll_poll()
852 fdevent_select_event_del (fdevents *ev, fdnode *fdn) in fdevent_select_event_del() argument
854 int fd = fdn->fd; in fdevent_select_event_del()
862 fdevent_select_event_set (fdevents *ev, fdnode *fdn, int events) in fdevent_select_event_set() argument
864 int fd = fdn->fde_ndx = fdn->fd; in fdevent_select_event_set()
907 const fdnode *fdn = ev->fdarray[ndx]; in fdevent_select_poll() local
908 if (0 == ((uintptr_t)fdn & 0x3)) in fdevent_select_poll()
909 (*fdn->handler)(fdn->ctx, revents); in fdevent_select_poll()