Home
last modified time | relevance | path

Searched refs:in_fd (Results 1 – 7 of 7) sorted by relevance

/unit/go/
H A Dport.go104 rcv: getUnixConn(int(p.in_fd)),
110 p.in_fd = -1
/unit/src/python/
H A Dnxt_python_asgi.c383 if (port == NULL || port->in_fd == -1) { in nxt_py_asgi_remove_reader()
389 nxt_unit_debug(ctx, "asgi_remove_reader %d %p", port->in_fd, port); in nxt_py_asgi_remove_reader()
391 fd = PyLong_FromLong(port->in_fd); in nxt_py_asgi_remove_reader()
938 if (port->in_fd == -1) { in nxt_py_asgi_add_port()
944 if (nxt_slow_path(ioctl(port->in_fd, FIONBIO, &nb) == -1)) { in nxt_py_asgi_add_port()
946 port->in_fd, strerror(errno), errno); in nxt_py_asgi_add_port()
951 nxt_unit_debug(ctx, "asgi_add_port %d %p %p", port->in_fd, ctx, port); in nxt_py_asgi_add_port()
964 nxt_unit_debug(ctx, "asgi_add_reader %d %p %p", port->in_fd, ctx, port); in nxt_py_asgi_add_reader()
968 fd = PyLong_FromLong(port->in_fd); in nxt_py_asgi_add_reader()
1025 if (port->in_fd == -1 || ctx == NULL) { in nxt_py_asgi_remove_port()
[all …]
/unit/src/
H A Dnxt_unit.c919 ready_port->in_fd = -1; in nxt_unit_read_env()
925 router_port->in_fd = -1; in nxt_unit_read_env()
1215 new_port.in_fd = -1; in nxt_unit_process_new_port()
1529 port->in_fd = -1; in nxt_unit_request_check_response_port()
5407 if (port->in_fd != -1) { in nxt_unit_port_release()
5410 port->in_fd = -1; in nxt_unit_port_release()
5458 old_port->in_fd = port->in_fd; in nxt_unit_add_port()
5459 port->in_fd = -1; in nxt_unit_add_port()
5462 if (port->in_fd != -1) { in nxt_unit_add_port()
5464 port->in_fd = -1; in nxt_unit_add_port()
[all …]
H A Dnxt_linux_sendfile.c28 static ssize_t nxt_sys_sendfile(int out_fd, int in_fd, off_t *offset, in nxt_sys_sendfile() argument
H A Dnxt_unit.h81 int in_fd; member
H A Dnxt_application.c1083 init->ready_port.in_fd = -1; in nxt_unit_default_init()
1090 init->router_port.in_fd = -1; in nxt_unit_default_init()
1095 init->read_port.in_fd = my_port->pair[0]; in nxt_unit_default_init()
/unit/src/nodejs/unit-http/
H A Dunit.cpp479 if (port->in_fd != -1) { in add_port()
480 if (fcntl(port->in_fd, F_SETFL, O_NONBLOCK) == -1) { in add_port()
482 port->in_fd, strerror(errno), errno); in add_port()
496 err = uv_poll_init(loop, &data->poll, port->in_fd); in add_port()