Lines Matching refs:ep
115 uv__os390_epoll* ep; in uv__platform_loop_init() local
117 ep = epoll_create1(0); in uv__platform_loop_init()
118 loop->ep = ep; in uv__platform_loop_init()
119 if (ep == NULL) in uv__platform_loop_init()
127 if (loop->ep != NULL) { in uv__platform_loop_delete()
128 epoll_queue_close(loop->ep); in uv__platform_loop_delete()
129 loop->ep = NULL; in uv__platform_loop_delete()
605 if (loop->ep != NULL) in uv__platform_invalidate_fd()
606 epoll_ctl(loop->ep, EPOLL_CTL_DEL, fd, &dummy); in uv__platform_invalidate_fd()
638 uv__os390_epoll* ep; in os390_regfileint() local
642 ep = handle->loop->ep; in os390_regfileint()
643 assert(ep->msg_queue != -1); in os390_regfileint()
646 reg_struct.__rfis_qid = ep->msg_queue; in os390_regfileint()
688 uv__os390_epoll* ep; in uv__fs_event_stop() local
695 ep = handle->loop->ep; in uv__fs_event_stop()
696 assert(ep->msg_queue != -1); in uv__fs_event_stop()
699 reg_struct.__rfis_qid = ep->msg_queue; in uv__fs_event_stop()
747 static int os390_message_queue_handler(uv__os390_epoll* ep) { in os390_message_queue_handler() argument
753 if (ep->msg_queue == -1) in os390_message_queue_handler()
756 msglen = msgrcv(ep->msg_queue, &msg, sizeof(msg), 0, IPC_NOWAIT); in os390_message_queue_handler()
817 uv__os390_epoll* ep; in uv__io_poll() local
864 if (epoll_ctl(loop->ep, op, w->fd, &e)) { in uv__io_poll()
871 if (epoll_ctl(loop->ep, EPOLL_CTL_MOD, w->fd, &e)) in uv__io_poll()
910 nfds = epoll_wait(loop->ep, events, in uv__io_poll()
971 ep = loop->ep; in uv__io_poll()
973 os390_message_queue_handler(ep); in uv__io_poll()
989 epoll_ctl(loop->ep, EPOLL_CTL_DEL, fd, pe); in uv__io_poll()
1067 loop->ep = NULL; in uv__io_fork()
