Lines Matching refs:new_port

1185     nxt_unit_port_t          new_port, *port;  in nxt_unit_process_new_port()  local
1213 nxt_unit_port_id_init(&new_port.id, new_port_msg->pid, new_port_msg->id); in nxt_unit_process_new_port()
1215 new_port.in_fd = -1; in nxt_unit_process_new_port()
1216 new_port.out_fd = recv_msg->fd[0]; in nxt_unit_process_new_port()
1228 new_port.data = NULL; in nxt_unit_process_new_port()
1232 port = nxt_unit_add_port(ctx, &new_port, mem); in nxt_unit_process_new_port()
5276 nxt_unit_port_t new_port, *port; in nxt_unit_create_port() local
5322 nxt_unit_port_id_init(&new_port.id, lib->pid, process->next_port_id++); in nxt_unit_create_port()
5324 new_port.in_fd = port_sockets[0]; in nxt_unit_create_port()
5325 new_port.out_fd = port_sockets[1]; in nxt_unit_create_port()
5326 new_port.data = NULL; in nxt_unit_create_port()
5332 port = nxt_unit_add_port(ctx, &new_port, NULL); in nxt_unit_create_port()
5353 nxt_port_msg_new_port_t new_port; in nxt_unit_send_port() member
5367 m.new_port.id = port->id.id; in nxt_unit_send_port()
5368 m.new_port.pid = port->id.pid; in nxt_unit_send_port()
5369 m.new_port.type = NXT_PROCESS_APP; in nxt_unit_send_port()
5370 m.new_port.max_size = 16 * 1024; in nxt_unit_send_port()
5371 m.new_port.max_share = 64 * 1024; in nxt_unit_send_port()
5438 nxt_unit_port_impl_t *new_port, *old_port_impl; in nxt_unit_add_port() local
5524 new_port = NULL; in nxt_unit_add_port()
5542 new_port = nxt_unit_malloc(ctx, sizeof(nxt_unit_port_impl_t)); in nxt_unit_add_port()
5543 if (nxt_slow_path(new_port == NULL)) { in nxt_unit_add_port()
5550 new_port->port = *port; in nxt_unit_add_port()
5552 rc = nxt_unit_port_hash_add(&lib->ports, &new_port->port); in nxt_unit_add_port()
5557 nxt_unit_free(ctx, new_port); in nxt_unit_add_port()
5559 new_port = NULL; in nxt_unit_add_port()
5564 nxt_queue_insert_tail(&process->ports, &new_port->link); in nxt_unit_add_port()
5566 new_port->use_count = 2; in nxt_unit_add_port()
5567 new_port->process = process; in nxt_unit_add_port()
5568 new_port->queue = queue; in nxt_unit_add_port()
5569 new_port->from_socket = 0; in nxt_unit_add_port()
5570 new_port->socket_rbuf = NULL; in nxt_unit_add_port()
5572 nxt_queue_init(&new_port->awaiting_req); in nxt_unit_add_port()
5577 new_port->ready = ready; in nxt_unit_add_port()
5580 new_port->ready = 0; in nxt_unit_add_port()
5593 if (lib->callbacks.add_port != NULL && new_port != NULL && ready) { in nxt_unit_add_port()
5594 lib->callbacks.add_port(ctx, &new_port->port); in nxt_unit_add_port()
5600 new_port->ready = 1; in nxt_unit_add_port()
5602 if (!nxt_queue_is_empty(&new_port->awaiting_req)) { in nxt_unit_add_port()
5603 nxt_queue_add(&awaiting_req, &new_port->awaiting_req); in nxt_unit_add_port()
5604 nxt_queue_init(&new_port->awaiting_req); in nxt_unit_add_port()
5612 return (new_port == NULL) ? NULL : &new_port->port; in nxt_unit_add_port()