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()
5277 nxt_unit_port_t new_port, *port; in nxt_unit_create_port() local
5323 nxt_unit_port_id_init(&new_port.id, lib->pid, process->next_port_id++); in nxt_unit_create_port()
5325 new_port.in_fd = port_sockets[0]; in nxt_unit_create_port()
5326 new_port.out_fd = port_sockets[1]; in nxt_unit_create_port()
5327 new_port.data = NULL; in nxt_unit_create_port()
5333 port = nxt_unit_add_port(ctx, &new_port, NULL); in nxt_unit_create_port()
5354 nxt_port_msg_new_port_t new_port; in nxt_unit_send_port() member
5368 m.new_port.id = port->id.id; in nxt_unit_send_port()
5369 m.new_port.pid = port->id.pid; in nxt_unit_send_port()
5370 m.new_port.type = NXT_PROCESS_APP; in nxt_unit_send_port()
5371 m.new_port.max_size = 16 * 1024; in nxt_unit_send_port()
5372 m.new_port.max_share = 64 * 1024; in nxt_unit_send_port()
5439 nxt_unit_port_impl_t *new_port, *old_port_impl; in nxt_unit_add_port() local
5525 new_port = NULL; in nxt_unit_add_port()
5543 new_port = nxt_unit_malloc(ctx, sizeof(nxt_unit_port_impl_t)); in nxt_unit_add_port()
5544 if (nxt_slow_path(new_port == NULL)) { in nxt_unit_add_port()
5551 new_port->port = *port; in nxt_unit_add_port()
5553 rc = nxt_unit_port_hash_add(&lib->ports, &new_port->port); in nxt_unit_add_port()
5558 nxt_unit_free(ctx, new_port); in nxt_unit_add_port()
5560 new_port = NULL; in nxt_unit_add_port()
5565 nxt_queue_insert_tail(&process->ports, &new_port->link); in nxt_unit_add_port()
5567 new_port->use_count = 2; in nxt_unit_add_port()
5568 new_port->process = process; in nxt_unit_add_port()
5569 new_port->queue = queue; in nxt_unit_add_port()
5570 new_port->from_socket = 0; in nxt_unit_add_port()
5571 new_port->socket_rbuf = NULL; in nxt_unit_add_port()
5573 nxt_queue_init(&new_port->awaiting_req); in nxt_unit_add_port()
5578 new_port->ready = ready; in nxt_unit_add_port()
5581 new_port->ready = 0; in nxt_unit_add_port()
5594 if (lib->callbacks.add_port != NULL && new_port != NULL && ready) { in nxt_unit_add_port()
5595 lib->callbacks.add_port(ctx, &new_port->port); in nxt_unit_add_port()
5601 new_port->ready = 1; in nxt_unit_add_port()
5603 if (!nxt_queue_is_empty(&new_port->awaiting_req)) { in nxt_unit_add_port()
5604 nxt_queue_add(&awaiting_req, &new_port->awaiting_req); in nxt_unit_add_port()
5605 nxt_queue_init(&new_port->awaiting_req); in nxt_unit_add_port()
5613 return (new_port == NULL) ? NULL : &new_port->port; in nxt_unit_add_port()