Lines Matching refs:fd
279 int fd = fdn->fd; in fdevent_sched_run() local
281 if (0 != closesocket(fd)) /* WSAPoll() valid only on SOCKET */ in fdevent_sched_run()
283 if (0 != close(fd)) in fdevent_sched_run()
285 log_perror(ev->errh, __FILE__, __LINE__, "close failed %d", fd); in fdevent_sched_run()
292 ev->fdarray[fd] = NULL; in fdevent_sched_run()
318 return epoll_ctl(ev->epoll_fd, EPOLL_CTL_DEL, fdn->fd, NULL); in fdevent_linux_sysepoll_event_del()
325 int fd = fdn->fde_ndx = fdn->fd; in fdevent_linux_sysepoll_event_set() local
332 return epoll_ctl(ev->epoll_fd, op, fd, &ep); in fdevent_linux_sysepoll_event_set()
402 int fd = fdn->fd; in fdevent_freebsd_kqueue_event_del() local
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()
425 int fd = fdn->fde_ndx = fdn->fd; in fdevent_freebsd_kqueue_event_set() local
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()
529 return port_dissociate(ev->port_fd, PORT_SOURCE_FD, fdn->fd); in fdevent_solaris_port_event_del()
535 int fd = fdn->fde_ndx = fdn->fd; in fdevent_solaris_port_event_set() local
537 return port_associate(ev->port_fd,PORT_SOURCE_FD,fd,(int)ud,(void*)ud); in fdevent_solaris_port_event_set()
570 int fd = (int)ev->port_events[i].portev_object; in fdevent_solaris_port_poll() local
571 fdnode * const fdn = ev->fdarray[fd]; in fdevent_solaris_port_poll()
575 if (port_associate(pfd,PORT_SOURCE_FD,fd,(int)ud,(void*)ud) < 0) in fdevent_solaris_port_poll()
633 pfd.fd = fdn->fd; in fdevent_solaris_devpoll_event_del()
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()
731 int fd = fdn->fd; in fdevent_poll_event_del() local
733 if ((uint32_t)k >= ev->used || ev->pollfds[k].fd != fd) in fdevent_poll_event_del()
736 ev->pollfds[k].fd = -1; in fdevent_poll_event_del()
754 int fd = fdn->fd; in fdevent_poll_event_set() local
762 if ((uint32_t)k >= ev->used || ev->pollfds[k].fd != fd) in fdevent_poll_event_set()
782 ev->pollfds[k].fd = fd; in fdevent_poll_event_set()
796 fdnode *fdn = fdarray[pfds[i].fd]; in fdevent_poll_poll()
854 int fd = fdn->fd; in fdevent_select_event_del() local
855 FD_CLR(fd, &(ev->select_set_read)); in fdevent_select_event_del()
856 FD_CLR(fd, &(ev->select_set_write)); in fdevent_select_event_del()
857 FD_CLR(fd, &(ev->select_set_error)); in fdevent_select_event_del()
864 int fd = fdn->fde_ndx = fdn->fd; in fdevent_select_event_set() local
867 force_assert(fd < ((int)FD_SETSIZE)); in fdevent_select_event_set()
870 FD_SET(fd, &(ev->select_set_read)); in fdevent_select_event_set()
872 FD_CLR(fd, &(ev->select_set_read)); in fdevent_select_event_set()
875 FD_SET(fd, &(ev->select_set_write)); in fdevent_select_event_set()
877 FD_CLR(fd, &(ev->select_set_write)); in fdevent_select_event_set()
879 FD_SET(fd, &(ev->select_set_error)); in fdevent_select_event_set()
881 if (fd > ev->select_max_fd) ev->select_max_fd = fd; in fdevent_select_event_set()