nxt_port.c (197:ae8f843e1fd4) nxt_port.c (240:36bafba970b5)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_runtime.h>

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

173 nxt_runtime_process_each(rt, process)
174 {
175 if (process->pid == new_port->pid || process->pid == nxt_pid) {
176 continue;
177 }
178
179 port = nxt_process_port_first(process);
180
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_runtime.h>

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

173 nxt_runtime_process_each(rt, process)
174 {
175 if (process->pid == new_port->pid || process->pid == nxt_pid) {
176 continue;
177 }
178
179 port = nxt_process_port_first(process);
180
181 if (port->type == NXT_PROCESS_MASTER ||
181 if (port->type == NXT_PROCESS_MAIN ||
182 port->type == NXT_PROCESS_CONTROLLER ||
183 port->type == NXT_PROCESS_ROUTER) {
184
185 (void) nxt_port_send_port(task, port, new_port, stream);
186 }
187 }
188 nxt_runtime_process_loop;
189}

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

275nxt_port_ready_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg)
276{
277 nxt_port_t *port;
278 nxt_process_t *process;
279 nxt_runtime_t *rt;
280
281 rt = task->thread->runtime;
282
182 port->type == NXT_PROCESS_CONTROLLER ||
183 port->type == NXT_PROCESS_ROUTER) {
184
185 (void) nxt_port_send_port(task, port, new_port, stream);
186 }
187 }
188 nxt_runtime_process_loop;
189}

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

275nxt_port_ready_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg)
276{
277 nxt_port_t *port;
278 nxt_process_t *process;
279 nxt_runtime_t *rt;
280
281 rt = task->thread->runtime;
282
283 nxt_assert(nxt_runtime_is_master(rt));
283 nxt_assert(nxt_runtime_is_main(rt));
284
285 process = nxt_runtime_process_get(rt, msg->port_msg.pid);
286 if (nxt_slow_path(process == NULL)) {
287 return;
288 }
289
290 process->ready = 1;
291

--- 155 unchanged lines hidden --- 		284
285 process = nxt_runtime_process_get(rt, msg->port_msg.pid);
286 if (nxt_slow_path(process == NULL)) {
287 return;
288 }
289
290 process->ready = 1;
291

--- 155 unchanged lines hidden ---