nxt_port_rpc.c (425:1da949cf0a34) nxt_port_rpc.c (427:05ae752c6cfb)
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>

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

309 return;
310 }
311
312 nxt_debug(task, "rpc: stream #%uD %shandler, type %d", stream,
313 (last ? "last " : ""), type);
314
315 reg = lhq.value;
316
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>

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

309 return;
310 }
311
312 nxt_debug(task, "rpc: stream #%uD %shandler, type %d", stream,
313 (last ? "last " : ""), type);
314
315 reg = lhq.value;
316
317 if (reg->peer != -1) {
318 nxt_assert(reg->peer == msg->port_msg.pid);
319 }
320
321 if (type == _NXT_PORT_MSG_RPC_ERROR) {
322 reg->error_handler(task, msg, reg->data);
323
324 } else {
325 reg->ready_handler(task, msg, reg->data);
326 }
327
328 if (last == 0) {

--- 131 unchanged lines hidden ---
317 if (type == _NXT_PORT_MSG_RPC_ERROR) {
318 reg->error_handler(task, msg, reg->data);
319
320 } else {
321 reg->ready_handler(task, msg, reg->data);
322 }
323
324 if (last == 0) {

--- 131 unchanged lines hidden ---