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
88 _NXT_PORT_MSG_NEW_PORT = nxt_port_handler_idx(new_port),
209 nxt_port_t *new_port; member
305 nxt_port_msg_new_port_t new_port; member
342 nxt_port_t *new_port, uint32_t stream);
H A Dnxt_unit.c1201 new_port.in_fd = -1; in nxt_unit_process_new_port()
1214 new_port.data = NULL; in nxt_unit_process_new_port()
5319 new_port.data = NULL; in nxt_unit_create_port()
5518 new_port = NULL; in nxt_unit_add_port()
5544 new_port->port = *port; in nxt_unit_add_port()
5553 new_port = NULL; in nxt_unit_add_port()
5560 new_port->use_count = 2; in nxt_unit_add_port()
5562 new_port->queue = queue; in nxt_unit_add_port()
5574 new_port->ready = 0; in nxt_unit_add_port()
5594 new_port->ready = 1; in nxt_unit_add_port()
[all …]
H A Dnxt_application.c82 .new_port = nxt_port_new_port_handler,
105 .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.c133 .new_port = nxt_controller_process_new_port_handler,
382 if (msg->u.new_port->type != NXT_PROCESS_ROUTER in nxt_controller_process_new_port_handler()
H A Dnxt_router.c290 .new_port = nxt_router_new_port_handler,
680 port = msg->u.new_port; in nxt_router_new_port_handler()
683 nxt_router_greet_controller(task, msg->u.new_port); in nxt_router_new_port_handler()
2865 port = msg->u.new_port; in nxt_router_app_prefork_ready()
4522 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)