Deleted Added
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>

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

211 peer_link = lhq.value;
212 nxt_queue_insert_after(peer_link, &reg->link);
213
214 nxt_debug(task, "rpc: stream #%uD assigned duplicate pid %PI (%p)",
215 reg->stream, reg->peer, reg->link.next);
216 break;
217
218 default:
219 nxt_log_error(NXT_LOG_ERR, task->log, "rpc: failed to add "
220 "peer for stream #%uD (%d)", reg->stream, ret);
221
222 reg->peer = -1;
223 break;
224 }
225
226}
227

--- 228 unchanged lines hidden ---