nxt_port.c (382:0b999f4f3545) nxt_port.c (425:1da949cf0a34)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_runtime.h>

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

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

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

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

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

--- 480 unchanged lines hidden ---