nxt_port.c (349:ae438f16b44e) nxt_port.c (352:47649fbbcb53)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_runtime.h>

--- 234 unchanged lines hidden (view full) ---

243 nxt_process_t *process;
244 nxt_runtime_t *rt;
245 nxt_port_msg_new_port_t *new_port_msg;
246
247 rt = task->thread->runtime;
248
249 new_port_msg = (nxt_port_msg_new_port_t *) msg->buf->mem.pos;
250
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_runtime.h>

--- 234 unchanged lines hidden (view full) ---

243 nxt_process_t *process;
244 nxt_runtime_t *rt;
245 nxt_port_msg_new_port_t *new_port_msg;
246
247 rt = task->thread->runtime;
248
249 new_port_msg = (nxt_port_msg_new_port_t *) msg->buf->mem.pos;
250
251 /* TODO check b size and make plain */
252
251 nxt_debug(task, "new port %d received for process %PI:%d",
252 msg->fd, new_port_msg->pid, new_port_msg->id);
253
254 port = nxt_runtime_port_find(rt, new_port_msg->pid, new_port_msg->id);
255 if (port != NULL) {
256 nxt_debug(task, "port %PI:%d already exists", new_port_msg->pid,
257 new_port_msg->id);
258

--- 300 unchanged lines hidden ---
253 nxt_debug(task, "new port %d received for process %PI:%d",
254 msg->fd, new_port_msg->pid, new_port_msg->id);
255
256 port = nxt_runtime_port_find(rt, new_port_msg->pid, new_port_msg->id);
257 if (port != NULL) {
258 nxt_debug(task, "port %PI:%d already exists", new_port_msg->pid,
259 new_port_msg->id);
260

--- 300 unchanged lines hidden ---