Home
last modified time | relevance | path

Searched refs:controller_port (Results 1 – 2 of 2) sorted by relevance

/unit/src/
H A Dnxt_controller.c573 nxt_port_t *router_port, *controller_port; in nxt_controller_conf_send() local
583 controller_port = rt->port_by_type[NXT_PROCESS_CONTROLLER]; in nxt_controller_conf_send()
610 stream = nxt_port_rpc_register_handler(task, controller_port, in nxt_controller_conf_send()
622 nxt_port_rpc_cancel(task, controller_port, stream); in nxt_controller_conf_send()
1506 nxt_port_t *router_port, *controller_port; in nxt_controller_process_status() local
1522 controller_port = rt->port_by_type[NXT_PROCESS_CONTROLLER]; in nxt_controller_process_status()
1524 stream = nxt_port_rpc_register_handler(task, controller_port, in nxt_controller_process_status()
1536 nxt_port_rpc_cancel(task, controller_port, stream); in nxt_controller_process_status()
1929 nxt_port_t *router_port, *controller_port; in nxt_controller_process_control() local
1980 controller_port = rt->port_by_type[NXT_PROCESS_CONTROLLER]; in nxt_controller_process_control()
[all …]
H A Dnxt_router.c84 nxt_port_t *controller_port);
317 nxt_port_t *controller_port; in nxt_router_start() local
353 controller_port = rt->port_by_type[NXT_PROCESS_CONTROLLER]; in nxt_router_start()
354 if (controller_port != NULL) { in nxt_router_start()
355 nxt_router_greet_controller(task, controller_port); in nxt_router_start()
363 nxt_router_greet_controller(nxt_task_t *task, nxt_port_t *controller_port) in nxt_router_greet_controller() argument
365 nxt_port_socket_write(task, controller_port, NXT_PORT_MSG_PROCESS_READY, in nxt_router_greet_controller()