Home
last modified time | relevance | path

Searched refs:new_port (Results 1 – 8 of 8) sorted by relevance

/unit/src/
H A Dnxt_port.c204 nxt_port_t *new_port, uint32_t stream) in nxt_port_send_new_port() argument
210 new_port->pair[1], new_port->pid); in nxt_port_send_new_port()
220 if (nxt_proc_send_matrix[port->type][new_port->type]) { in nxt_port_send_new_port()
221 (void) nxt_port_send_port(task, port, new_port, stream); in nxt_port_send_new_port()
242 new_port->pair[1], port->pid); in nxt_port_send_port()
247 msg->id = new_port->id; in nxt_port_send_port()
248 msg->pid = new_port->pid; in nxt_port_send_port()
251 msg->type = new_port->type; in nxt_port_send_port()
254 new_port->pair[1], new_port->queue_fd, in nxt_port_send_port()
280 msg->u.new_port = port; in nxt_port_new_port_handler()
[all …]
H A Dnxt_port.h27 nxt_port_handler_t new_port; member
91 _NXT_PORT_MSG_NEW_PORT = nxt_port_handler_idx(new_port),
210 nxt_port_t *new_port; member
306 nxt_port_msg_new_port_t new_port; member
343 nxt_port_t *new_port, uint32_t stream);
H A Dnxt_unit.c1197 new_port.in_fd = -1; in nxt_unit_process_new_port()
1210 new_port.data = NULL; in nxt_unit_process_new_port()
5308 new_port.data = NULL; in nxt_unit_create_port()
5506 new_port = NULL; in nxt_unit_add_port()
5532 new_port->port = *port; in nxt_unit_add_port()
5541 new_port = NULL; in nxt_unit_add_port()
5548 new_port->use_count = 2; in nxt_unit_add_port()
5550 new_port->queue = queue; in nxt_unit_add_port()
5562 new_port->ready = 0; in nxt_unit_add_port()
5582 new_port->ready = 1; in nxt_unit_add_port()
[all …]
H A Dnxt_application.c89 .new_port = nxt_port_new_port_handler,
112 .new_port = nxt_port_new_port_handler,
H A Dnxt_main_process.c347 port = msg->u.new_port; in nxt_main_new_port_handler()
595 .new_port = nxt_main_new_port_handler,
H A Dnxt_controller.c141 .new_port = nxt_controller_process_new_port_handler,
390 if (msg->u.new_port->type != NXT_PROCESS_ROUTER in nxt_controller_process_new_port_handler()
H A Dnxt_router.c268 .new_port = nxt_router_new_port_handler,
659 port = msg->u.new_port; in nxt_router_new_port_handler()
662 nxt_router_greet_controller(task, msg->u.new_port); in nxt_router_new_port_handler()
2939 port = msg->u.new_port; in nxt_router_app_prefork_ready()
4218 port = msg->u.new_port; in nxt_router_app_port_ready()
/unit/go/
H A Dport.go99 new_port := &port{
108 add_port(new_port)