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