Home
last modified time | relevance | path

Searched refs:queue_fd (Results 1 – 4 of 4) sorted by last modified time

/unit/src/
H A Dnxt_router.c372 nxt_fd_t port_fd, queue_fd; in nxt_router_start_app_process_handler() local
393 queue_fd = -1; in nxt_router_start_app_process_handler()
422 queue_fd = app->shared_port->queue_fd; in nxt_router_start_app_process_handler()
436 port_fd, queue_fd, stream, port->id, b); in nxt_router_start_app_process_handler()
2235 port->queue_fd = fd; in nxt_router_app_queue_init()
2263 port->queue_fd = fd; in nxt_router_port_queue_init()
2768 nxt_fd_t port_fd, queue_fd; in nxt_router_app_rpc_create() local
2798 queue_fd = app->shared_port->queue_fd; in nxt_router_app_rpc_create()
2805 queue_fd = -1; in nxt_router_app_rpc_create()
2825 port_fd, queue_fd, stream, router_port->id, b); in nxt_router_app_rpc_create()
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()
5115 queue_fd = -1; in nxt_unit_ctx_alloc()
5148 nxt_unit_close(queue_fd); in nxt_unit_ctx_alloc()
5154 if (queue_fd != -1) { in nxt_unit_ctx_alloc()
[all …]
H A Dnxt_port.h267 nxt_fd_t queue_fd; member
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()