Deleted
Added
nxt_port.c (277:6baa1731cc6f) | nxt_port.c (318:c2442f5e054d) |
---|---|
1 2/* 3 * Copyright (C) Igor Sysoev 4 * Copyright (C) NGINX, Inc. 5 */ 6 7#include <nxt_main.h> 8#include <nxt_runtime.h> --- 13 unchanged lines hidden (view full) --- 22 nxt_port_t *port; 23 24 port = obj; 25 mp = data; 26 27 nxt_assert(port->pair[0] == -1); 28 nxt_assert(port->pair[1] == -1); 29 | 1 2/* 3 * Copyright (C) Igor Sysoev 4 * Copyright (C) NGINX, Inc. 5 */ 6 7#include <nxt_main.h> 8#include <nxt_runtime.h> --- 13 unchanged lines hidden (view full) --- 22 nxt_port_t *port; 23 24 port = obj; 25 mp = data; 26 27 nxt_assert(port->pair[0] == -1); 28 nxt_assert(port->pair[1] == -1); 29 |
30 nxt_assert(port->app_req_id == 0); | 30 nxt_assert(port->app_stream == 0); |
31 nxt_assert(port->app_link.next == NULL); 32 33 nxt_assert(nxt_queue_is_empty(&port->messages)); 34 nxt_assert(nxt_lvlhsh_is_empty(&port->rpc_streams)); 35 nxt_assert(nxt_lvlhsh_is_empty(&port->rpc_peers)); 36 37 nxt_mp_free(mp, port); 38} --- 14 unchanged lines hidden (view full) --- 53 54 port = nxt_mp_zalloc(mp, sizeof(nxt_port_t)); 55 56 if (nxt_fast_path(port != NULL)) { 57 port->id = id; 58 port->pid = pid; 59 port->type = type; 60 port->mem_pool = mp; | 31 nxt_assert(port->app_link.next == NULL); 32 33 nxt_assert(nxt_queue_is_empty(&port->messages)); 34 nxt_assert(nxt_lvlhsh_is_empty(&port->rpc_streams)); 35 nxt_assert(nxt_lvlhsh_is_empty(&port->rpc_peers)); 36 37 nxt_mp_free(mp, port); 38} --- 14 unchanged lines hidden (view full) --- 53 54 port = nxt_mp_zalloc(mp, sizeof(nxt_port_t)); 55 56 if (nxt_fast_path(port != NULL)) { 57 port->id = id; 58 port->pid = pid; 59 port->type = type; 60 port->mem_pool = mp; |
61 port->next_stream = 1; | |
62 63 nxt_mp_cleanup(mp, nxt_port_mp_cleanup, task, port, mp); 64 65 nxt_queue_init(&port->messages); 66 67 } else { 68 nxt_mp_destroy(mp); 69 } --- 376 unchanged lines hidden --- | 61 62 nxt_mp_cleanup(mp, nxt_port_mp_cleanup, task, port, mp); 63 64 nxt_queue_init(&port->messages); 65 66 } else { 67 nxt_mp_destroy(mp); 68 } --- 376 unchanged lines hidden --- |