nxt_port_rpc.c (596:7d08f1a74b74) nxt_port_rpc.c (611:323e11065f83)
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>

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

101{
102 uint32_t stream;
103 nxt_port_rpc_reg_t *reg;
104 nxt_lvlhsh_query_t lhq;
105
106 nxt_assert(port->pair[0] != -1);
107
108 stream =
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>

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

101{
102 uint32_t stream;
103 nxt_port_rpc_reg_t *reg;
104 nxt_lvlhsh_query_t lhq;
105
106 nxt_assert(port->pair[0] != -1);
107
108 stream =
109 (uint32_t) nxt_atomic_fetch_add(&nxt_stream_ident, 1) & 0x3fffffff;
109 (uint32_t) nxt_atomic_fetch_add(&nxt_stream_ident, 1) & 0x3FFFFFFF;
110
111 reg = nxt_mp_zalloc(port->mem_pool, sizeof(nxt_port_rpc_reg_t) + ex_size);
112
113 if (nxt_slow_path(reg == NULL)) {
114 nxt_debug(task, "rpc: stream #%uD failed to allocate reg", stream);
115
116 return NULL;
117 }

--- 379 unchanged lines hidden --- 		110
111 reg = nxt_mp_zalloc(port->mem_pool, sizeof(nxt_port_rpc_reg_t) + ex_size);
112
113 if (nxt_slow_path(reg == NULL)) {
114 nxt_debug(task, "rpc: stream #%uD failed to allocate reg", stream);
115
116 return NULL;
117 }

--- 379 unchanged lines hidden ---