Home
last modified time | relevance | path

Searched refs:queue_fd (Results 1 – 4 of 4) sorted by relevance

/unit/src/
H A Dnxt_port.c75 port->queue_fd = -1; in nxt_port_new()
111 if (port->queue_fd != -1) { in nxt_port_close()
112 nxt_fd_close(port->queue_fd); in nxt_port_close()
113 port->queue_fd = -1; in nxt_port_close()
254 new_port->pair[1], new_port->queue_fd, in nxt_port_send_port()
334 port->queue_fd = msg->fd[0]; in nxt_port_process_ready_handler()
H A Dnxt_unit.c62 int queue_fd);
152 nxt_unit_port_t *port, int queue_fd);
443 queue_fd = -1; in nxt_unit_init()
504 if (nxt_slow_path(queue_fd == -1)) { in nxt_unit_init()
565 nxt_unit_close(queue_fd); in nxt_unit_init()
575 if (queue_fd != -1) { in nxt_unit_init()
576 nxt_unit_close(queue_fd); in nxt_unit_init()
5129 queue_fd = -1; in nxt_unit_ctx_alloc()
5162 nxt_unit_close(queue_fd); in nxt_unit_ctx_alloc()
5168 if (queue_fd != -1) { in nxt_unit_ctx_alloc()
[all …]
H A Dnxt_port.h272 nxt_fd_t queue_fd; member
H A Dnxt_router.c376 nxt_fd_t port_fd, queue_fd; in nxt_router_start_app_process_handler() local
397 queue_fd = -1; in nxt_router_start_app_process_handler()
426 queue_fd = app->shared_port->queue_fd; in nxt_router_start_app_process_handler()
440 port_fd, queue_fd, stream, port->id, b); in nxt_router_start_app_process_handler()
2326 port->queue_fd = fd; in nxt_router_app_queue_init()
2354 port->queue_fd = fd; in nxt_router_port_queue_init()
2859 nxt_fd_t port_fd, queue_fd; in nxt_router_app_rpc_create() local
2889 queue_fd = app->shared_port->queue_fd; in nxt_router_app_rpc_create()
2896 queue_fd = -1; in nxt_router_app_rpc_create()
2916 port_fd, queue_fd, stream, router_port->id, b); in nxt_router_app_rpc_create()