Lines Matching refs:fd

178     engine->u.kqueue.fd = -1;  in nxt_kqueue_create()
193 engine->u.kqueue.fd = kqueue(); in nxt_kqueue_create()
194 if (engine->u.kqueue.fd == -1) { in nxt_kqueue_create()
199 nxt_debug(&engine->task, "kqueue(): %d", engine->u.kqueue.fd); in nxt_kqueue_create()
222 nxt_fd_t fd; in nxt_kqueue_free() local
224 fd = engine->u.kqueue.fd; in nxt_kqueue_free()
226 nxt_debug(&engine->task, "kqueue %d free", fd); in nxt_kqueue_free()
228 if (fd != -1 && engine->u.kqueue.pid == nxt_pid) { in nxt_kqueue_free()
231 if (close(fd) != 0) { in nxt_kqueue_free()
233 fd, nxt_errno); in nxt_kqueue_free()
307 if (kev->ident == (uintptr_t) ev->fd) { in nxt_kqueue_close()
423 engine->u.kqueue.fd, ev->file->fd, EVFILT_VNODE, flags, fflags); in nxt_kqueue_enable_file()
427 kev->ident = ev->file->fd; in nxt_kqueue_enable_file()
450 engine->u.kqueue.fd, ev->fd, filter, flags); in nxt_kqueue_fd_set()
454 kev->ident = ev->fd; in nxt_kqueue_fd_set()
473 engine->u.kqueue.fd, nchanges); in nxt_kqueue_get_kevent()
475 ret = kevent(engine->u.kqueue.fd, engine->u.kqueue.changes, nchanges, in nxt_kqueue_get_kevent()
480 engine->u.kqueue.fd, nxt_errno); in nxt_kqueue_get_kevent()
531 nxt_debug(task, "kqueue fd error handler fd:%d", ev->fd); in nxt_kqueue_fd_error_handler()
537 ev->fd, ev->kq_errno); in nxt_kqueue_fd_error_handler()
555 nxt_debug(task, "kqueue file error handler fd:%d", ev->file->fd); in nxt_kqueue_file_error_handler()
588 engine->u.kqueue.fd, signo, sigev->name); in nxt_kqueue_add_signal()
597 if (kevent(engine->u.kqueue.fd, &kev, 1, NULL, 0, NULL) == 0) { in nxt_kqueue_add_signal()
625 if (kevent(engine->u.kqueue.fd, &kev, 1, NULL, 0, NULL) == 0) { in nxt_kqueue_enable_post()
630 engine->u.kqueue.fd, nxt_errno); in nxt_kqueue_enable_post()
653 if (kevent(engine->u.kqueue.fd, &kev, 1, NULL, 0, NULL) != 0) { in nxt_kqueue_signal()
655 engine->u.kqueue.fd, nxt_errno); in nxt_kqueue_signal()
690 engine->u.kqueue.fd, engine->u.kqueue.nchanges, timeout); in nxt_kqueue_poll()
692 nevents = kevent(engine->u.kqueue.fd, in nxt_kqueue_poll()
700 nxt_debug(&engine->task, "kevent(%d): %d", engine->u.kqueue.fd, nevents); in nxt_kqueue_poll()
706 engine->u.kqueue.fd, err); in nxt_kqueue_poll()
733 engine->u.kqueue.fd, kev->data, kev->ident, kev->filter); in nxt_kqueue_poll()
753 nxt_debug(ev->task, "blocked read event fd:%d", ev->fd); in nxt_kqueue_poll()
784 nxt_debug(ev->task, "blocked write event fd:%d", ev->fd); in nxt_kqueue_poll()
834 engine->u.kqueue.fd, kev->filter, kev->ident); in nxt_kqueue_poll()
862 switch (nxt_socket_connect(task, c->socket.fd, c->remote)) { in nxt_kqueue_conn_io_connect()
899 nxt_debug(task, "kqueue conn connected fd:%d", c->socket.fd); in nxt_kqueue_conn_connected()
920 lev->socket.fd, lev->socket.kq_available); in nxt_kqueue_listen_handler()
952 s = accept(lev->socket.fd, sa, &socklen); in nxt_kqueue_conn_io_accept()
955 c->socket.fd = s; in nxt_kqueue_conn_io_accept()
957 nxt_debug(task, "accept(%d): %d", lev->socket.fd, s); in nxt_kqueue_conn_io_accept()
979 nxt_debug(task, "kqueue conn read fd:%d", c->socket.fd); in nxt_kqueue_conn_io_read()
982 nxt_debug(task, "kevent fd:%d eof", c->socket.fd); in nxt_kqueue_conn_io_read()
1020 c->socket.fd, c->socket.kq_available, c->socket.kq_eof); in nxt_kqueue_conn_io_recvbuf()