nxt_port.c (1008:84f2370bd642) nxt_port.c (1131:ec7d924d8dfb)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_runtime.h>

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

63 port->mem_pool = mp;
64 port->use_count = 1;
65
66 nxt_mp_cleanup(mp, nxt_port_mp_cleanup, task, port, mp);
67
68 nxt_queue_init(&port->messages);
69 nxt_thread_mutex_create(&port->write_mutex);
70 nxt_queue_init(&port->pending_requests);
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_runtime.h>

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

63 port->mem_pool = mp;
64 port->use_count = 1;
65
66 nxt_mp_cleanup(mp, nxt_port_mp_cleanup, task, port, mp);
67
68 nxt_queue_init(&port->messages);
69 nxt_thread_mutex_create(&port->write_mutex);
70 nxt_queue_init(&port->pending_requests);
71 nxt_queue_init(&port->active_websockets);
71
72 } else {
73 nxt_mp_destroy(mp);
74 }
75
76 nxt_thread_log_debug("port %p %d:%d new, type %d", port, pid, id, type);
77
78 return port;

--- 478 unchanged lines hidden --- 		72
73 } else {
74 nxt_mp_destroy(mp);
75 }
76
77 nxt_thread_log_debug("port %p %d:%d new, type %d", port, pid, id, type);
78
79 return port;

--- 478 unchanged lines hidden ---