Home
last modified time | relevance | path

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

/unit/src/
H A Dnxt_port.c264 nxt_port_msg_new_port_t *new_port_msg; in nxt_port_new_port_handler() local
268 new_port_msg = (nxt_port_msg_new_port_t *) msg->buf->mem.pos; in nxt_port_new_port_handler()
273 msg->fd[0], new_port_msg->pid, new_port_msg->id); in nxt_port_new_port_handler()
275 port = nxt_runtime_port_find(rt, new_port_msg->pid, new_port_msg->id); in nxt_port_new_port_handler()
277 nxt_debug(task, "port %PI:%d already exists", new_port_msg->pid, in nxt_port_new_port_handler()
278 new_port_msg->id); in nxt_port_new_port_handler()
287 port = nxt_runtime_process_port_create(task, rt, new_port_msg->pid, in nxt_port_new_port_handler()
288 new_port_msg->id, in nxt_port_new_port_handler()
289 new_port_msg->type); in nxt_port_new_port_handler()
298 port->max_size = new_port_msg->max_size; in nxt_port_new_port_handler()
[all …]
H A Dnxt_unit.c1186 nxt_port_msg_new_port_t *new_port_msg; in nxt_unit_process_new_port() local
1203 new_port_msg = recv_msg->start; in nxt_unit_process_new_port()
1206 recv_msg->stream, (int) new_port_msg->pid, in nxt_unit_process_new_port()
1207 (int) new_port_msg->id, recv_msg->fd[0], recv_msg->fd[1]); in nxt_unit_process_new_port()
1213 nxt_unit_port_id_init(&new_port.id, new_port_msg->pid, new_port_msg->id); in nxt_unit_process_new_port()