nxt_port_rpc.c (1558:026e4b909b61) nxt_port_rpc.c (1996:35873fa78fed)
1
2/*
3 * Copyright (C) Max Romanov
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_port_rpc.h>

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

388
389 nxt_memzero(&msg, sizeof(msg));
390 nxt_memzero(&buf, sizeof(buf));
391
392 msg.fd[0] = -1;
393 msg.fd[1] = -1;
394 msg.buf = &buf;
395 msg.port = port;
1
2/*
3 * Copyright (C) Max Romanov
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_port_rpc.h>

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

388
389 nxt_memzero(&msg, sizeof(msg));
390 nxt_memzero(&buf, sizeof(buf));
391
392 msg.fd[0] = -1;
393 msg.fd[1] = -1;
394 msg.buf = &buf;
395 msg.port = port;
396
397 msg.port_msg.pid = peer;
396 msg.u.removed_pid = peer;
397 msg.port_msg.pid = nxt_pid;
398 msg.port_msg.type = _NXT_PORT_MSG_REMOVE_PID;
399
400 peer_link = lhq.value;
401 last = 0;
402
403 while (last == 0) {
404
405 reg = nxt_queue_link_data(peer_link, nxt_port_rpc_reg_t, link);

--- 117 unchanged lines hidden ---
398 msg.port_msg.type = _NXT_PORT_MSG_REMOVE_PID;
399
400 peer_link = lhq.value;
401 last = 0;
402
403 while (last == 0) {
404
405 reg = nxt_queue_link_data(peer_link, nxt_port_rpc_reg_t, link);

--- 117 unchanged lines hidden ---