Home
last modified time | relevance | path

Searched refs:router_port (Results 1 – 7 of 7) sorted by last modified time

/unit/src/
H A Dnxt_application.c1059 nxt_port_t *my_port, *proto_port, *router_port; in nxt_unit_default_init() local
1071 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_unit_default_init()
1072 if (nxt_slow_path(router_port == NULL)) { in nxt_unit_default_init()
1088 init->router_port.id.pid = router_port->pid; in nxt_unit_default_init()
1089 init->router_port.id.id = router_port->id; in nxt_unit_default_init()
1090 init->router_port.in_fd = -1; in nxt_unit_default_init()
1091 init->router_port.out_fd = router_port->pair[1]; in nxt_unit_default_init()
H A Dnxt_router_access_log.c202 nxt_port_t *main_port, *router_port; in nxt_router_access_log_open() local
220 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_access_log_open()
222 stream = nxt_port_rpc_register_handler(task, router_port, in nxt_router_access_log_open()
231 stream, router_port->id, b); in nxt_router_access_log_open()
234 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_access_log_open()
332 nxt_port_t *main_port, *router_port; in nxt_router_access_log_reopen_handler() local
368 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_access_log_reopen_handler()
370 stream = nxt_port_rpc_register_handler(task, router_port, in nxt_router_access_log_reopen_handler()
379 stream, router_port->id, b); in nxt_router_access_log_reopen_handler()
382 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_access_log_reopen_handler()
H A Dnxt_router.c484 nxt_port_t *router_port; in nxt_router_start_app_process() local
490 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_start_app_process()
2541 nxt_port_t *main_port, *router_port; in nxt_router_listen_socket_rpc_create() local
2566 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_listen_socket_rpc_create()
2568 stream = nxt_port_rpc_register_handler(task, router_port, in nxt_router_listen_socket_rpc_create()
2577 stream, router_port->id, b); in nxt_router_listen_socket_rpc_create()
2580 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_listen_socket_rpc_create()
2771 nxt_port_t *router_port, *dport; in nxt_router_app_rpc_create() local
2808 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_app_rpc_create()
2810 rpc = nxt_port_rpc_register_handler_ex(task, router_port, in nxt_router_app_rpc_create()
[all …]
H A Dnxt_controller.c438 nxt_port_t *router_port; in nxt_controller_router_ready_handler() local
443 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_controller_router_ready_handler()
447 if (router_port != NULL) { in nxt_controller_router_ready_handler()
565 nxt_port_t *router_port, *controller_port; in nxt_controller_conf_send() local
570 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_controller_conf_send()
572 nxt_assert(router_port != NULL); in nxt_controller_conf_send()
609 rc = nxt_port_socket_write(task, router_port, in nxt_controller_conf_send()
1436 nxt_port_t *router_port; in nxt_controller_check_postpone_request() local
1448 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_controller_check_postpone_request()
1450 return (router_port == NULL); in nxt_controller_check_postpone_request()
[all …]
H A Dnxt_unit.c367 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()
624 lib->router_port = NULL; in nxt_unit_create()
911 router_port->in_fd = -1; in nxt_unit_read_env()
912 router_port->out_fd = router_fd; in nxt_unit_read_env()
[all …]
H A Dnxt_unit.h177 nxt_unit_port_t router_port; member
H A Dnxt_external.c70 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()