Lines Matching refs:fd

237     engine->u.epoll.fd = -1;  in nxt_epoll_create()
242 engine->u.epoll.signalfd.fd = -1; in nxt_epoll_create()
255 engine->u.epoll.fd = epoll_create(1); in nxt_epoll_create()
256 if (engine->u.epoll.fd == -1) { in nxt_epoll_create()
261 nxt_debug(&engine->task, "epoll_create(): %d", engine->u.epoll.fd); in nxt_epoll_create()
317 int fd; in nxt_epoll_free() local
319 nxt_debug(&engine->task, "epoll %d free", engine->u.epoll.fd); in nxt_epoll_free()
323 fd = engine->u.epoll.signalfd.fd; in nxt_epoll_free()
325 if (fd != -1 && close(fd) != 0) { in nxt_epoll_free()
326 nxt_alert(&engine->task, "signalfd close(%d) failed %E", fd, nxt_errno); in nxt_epoll_free()
333 fd = engine->u.epoll.eventfd.fd; in nxt_epoll_free()
335 if (fd != -1 && close(fd) != 0) { in nxt_epoll_free()
336 nxt_alert(&engine->task, "eventfd close(%d) failed %E", fd, nxt_errno); in nxt_epoll_free()
341 fd = engine->u.epoll.fd; in nxt_epoll_free()
343 if (fd != -1 && close(fd) != 0) { in nxt_epoll_free()
344 nxt_alert(&engine->task, "epoll close(%d) failed %E", fd, nxt_errno); in nxt_epoll_free()
593 engine->u.epoll.fd, ev->fd, op, events); in nxt_epoll_change()
616 engine->u.epoll.fd, engine->u.epoll.nchanges); in nxt_epoll_commit_changes()
626 engine->u.epoll.fd, ev->fd, change->op, in nxt_epoll_commit_changes()
629 ret = epoll_ctl(engine->u.epoll.fd, change->op, ev->fd, &change->event); in nxt_epoll_commit_changes()
633 engine->u.epoll.fd, change->op, ev->fd, nxt_errno); in nxt_epoll_commit_changes()
668 int fd; in nxt_epoll_add_signal() local
685 fd = signalfd(-1, &engine->signals->sigmask, 0); in nxt_epoll_add_signal()
687 if (fd == -1) { in nxt_epoll_add_signal()
689 engine->u.epoll.signalfd.fd, nxt_errno); in nxt_epoll_add_signal()
693 engine->u.epoll.signalfd.fd = fd; in nxt_epoll_add_signal()
695 if (nxt_fd_nonblocking(&engine->task, fd) != NXT_OK) { in nxt_epoll_add_signal()
699 nxt_debug(&engine->task, "signalfd(): %d", fd); in nxt_epoll_add_signal()
710 if (epoll_ctl(engine->u.epoll.fd, EPOLL_CTL_ADD, fd, &ee) != 0) { in nxt_epoll_add_signal()
712 engine->u.epoll.fd, EPOLL_CTL_ADD, fd, nxt_errno); in nxt_epoll_add_signal()
734 n = read(ev->fd, &sfd, sizeof(struct signalfd_siginfo)); in nxt_epoll_signalfd_handler()
736 nxt_debug(task, "read signalfd(%d): %d", ev->fd, n); in nxt_epoll_signalfd_handler()
739 nxt_alert(task, "read signalfd(%d) failed %E", ev->fd, nxt_errno); in nxt_epoll_signalfd_handler()
743 nxt_debug(task, "signalfd(%d) signo:%d", ev->fd, sfd.ssi_signo); in nxt_epoll_signalfd_handler()
770 engine->u.epoll.eventfd.fd = eventfd(0, 0); in nxt_epoll_enable_post()
772 if (engine->u.epoll.eventfd.fd == -1) { in nxt_epoll_enable_post()
777 ret = nxt_fd_nonblocking(&engine->task, engine->u.epoll.eventfd.fd); in nxt_epoll_enable_post()
782 nxt_debug(&engine->task, "eventfd(): %d", engine->u.epoll.eventfd.fd); in nxt_epoll_enable_post()
793 ret = epoll_ctl(engine->u.epoll.fd, EPOLL_CTL_ADD, in nxt_epoll_enable_post()
794 engine->u.epoll.eventfd.fd, &ee); in nxt_epoll_enable_post()
801 engine->u.epoll.fd, EPOLL_CTL_ADD, engine->u.epoll.eventfd.fd, in nxt_epoll_enable_post()
831 n = read(engine->u.epoll.eventfd.fd, &events, sizeof(uint64_t)); in nxt_epoll_eventfd_handler()
834 engine->u.epoll.eventfd.fd, n, events); in nxt_epoll_eventfd_handler()
838 engine->u.epoll.eventfd.fd, nxt_errno); in nxt_epoll_eventfd_handler()
859 ret = write(engine->u.epoll.eventfd.fd, &event, sizeof(uint64_t)); in nxt_epoll_signal()
863 engine->u.epoll.eventfd.fd, nxt_errno); in nxt_epoll_signal()
893 engine->u.epoll.fd, timeout); in nxt_epoll_poll()
895 nevents = epoll_wait(engine->u.epoll.fd, engine->u.epoll.events, in nxt_epoll_poll()
902 nxt_debug(&engine->task, "epoll_wait(%d): %d", engine->u.epoll.fd, nevents); in nxt_epoll_poll()
908 engine->u.epoll.fd, err); in nxt_epoll_poll()
920 ev->fd, events, ev, ev->read, ev->write); in nxt_epoll_poll()
1028 s = accept4(lev->socket.fd, sa, &socklen, SOCK_NONBLOCK); in nxt_epoll_conn_io_accept4()
1031 c->socket.fd = s; in nxt_epoll_conn_io_accept4()
1033 nxt_debug(task, "accept4(%d): %d", lev->socket.fd, s); in nxt_epoll_conn_io_accept4()
1069 switch (nxt_socket_connect(task, c->socket.fd, c->remote)) { in nxt_epoll_edge_conn_io_connect()
1136 nxt_debug(task, "epoll event conn connected fd:%d", c->socket.fd); in nxt_epoll_edge_conn_connected()