Searched refs:router_port (Results 1 – 7 of 7) sorted by relevance
/unit/src/ |
H A D | nxt_external.c | 70 nxt_port_t *my_port, *proto_port, *router_port; in nxt_external_start() local 80 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_external_start() 84 || router_port == NULL)) in nxt_external_start() 94 rc = nxt_external_fd_no_cloexec(task, router_port->pair[1]); in nxt_external_start() 130 router_port->pid, router_port->id, router_port->pair[1], in nxt_external_start()
|
H A D | nxt_router_access_log.c | 230 nxt_port_t *main_port, *router_port; in nxt_router_access_log_open() local 248 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_access_log_open() 250 stream = nxt_port_rpc_register_handler(task, router_port, in nxt_router_access_log_open() 259 stream, router_port->id, b); in nxt_router_access_log_open() 262 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_access_log_open() 360 nxt_port_t *main_port, *router_port; in nxt_router_access_log_reopen_handler() local 396 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_access_log_reopen_handler() 398 stream = nxt_port_rpc_register_handler(task, router_port, in nxt_router_access_log_reopen_handler() 407 stream, router_port->id, b); in nxt_router_access_log_reopen_handler() 410 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_access_log_reopen_handler()
|
H A D | nxt_controller.c | 470 nxt_port_t *router_port; in nxt_controller_router_ready_handler() local 475 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_controller_router_ready_handler() 479 if (router_port != NULL) { in nxt_controller_router_ready_handler() 598 nxt_port_t *router_port, *controller_port; in nxt_controller_conf_send() local 603 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_controller_conf_send() 605 nxt_assert(router_port != NULL); in nxt_controller_conf_send() 642 rc = nxt_port_socket_write(task, router_port, in nxt_controller_conf_send() 1549 nxt_port_t *router_port; in nxt_controller_check_postpone_request() local 1561 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_controller_check_postpone_request() 1563 return (router_port == NULL); in nxt_controller_check_postpone_request() [all …]
|
H A D | nxt_application.c | 1118 nxt_port_t *my_port, *proto_port, *router_port; in nxt_unit_default_init() local 1130 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_unit_default_init() 1131 if (nxt_slow_path(router_port == NULL)) { in nxt_unit_default_init() 1147 init->router_port.id.pid = router_port->pid; in nxt_unit_default_init() 1148 init->router_port.id.id = router_port->id; in nxt_unit_default_init() 1149 init->router_port.in_fd = -1; in nxt_unit_default_init() 1150 init->router_port.out_fd = router_port->pair[1]; in nxt_unit_default_init()
|
H A D | nxt_unit.c | 367 nxt_unit_port_t *router_port; member 454 router_port = init->router_port; in nxt_unit_init() 460 nxt_unit_port_id_init(&router_port.id, router_port.id.pid, in nxt_unit_init() 461 router_port.id.id); in nxt_unit_init() 491 rc = nxt_unit_fd_blocking(router_port.out_fd); in nxt_unit_init() 496 lib->router_port = nxt_unit_add_port(ctx, &router_port, NULL); in nxt_unit_init() 497 if (nxt_slow_path(lib->router_port == NULL)) { in nxt_unit_init() 629 lib->router_port = NULL; in nxt_unit_create() 925 router_port->in_fd = -1; in nxt_unit_read_env() 926 router_port->out_fd = router_fd; in nxt_unit_read_env() [all …]
|
H A D | nxt_unit.h | 177 nxt_unit_port_t router_port; member
|
H A D | nxt_router.c | 510 nxt_port_t *router_port; in nxt_router_start_app_process() local 516 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_start_app_process() 2795 nxt_port_t *main_port, *router_port; in nxt_router_listen_socket_rpc_create() local 2820 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_listen_socket_rpc_create() 2822 stream = nxt_port_rpc_register_handler(task, router_port, in nxt_router_listen_socket_rpc_create() 2831 stream, router_port->id, b); in nxt_router_listen_socket_rpc_create() 2834 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_listen_socket_rpc_create() 3025 nxt_port_t *router_port, *dport; in nxt_router_app_rpc_create() local 3062 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_app_rpc_create() 3064 rpc = nxt_port_rpc_register_handler_ex(task, router_port, in nxt_router_app_rpc_create() [all …]
|