summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_port.c
diff options
context:
space:
mode:
authorMax Romanov <max.romanov@nginx.com>2017-07-18 00:21:28 +0300
committerMax Romanov <max.romanov@nginx.com>2017-07-18 00:21:28 +0300
commit6b6fefa497fac704c729fcd784f0e2561ba9656a (patch)
treef60ac011ba9625a618294082989ae0e0dddfd990 /src/nxt_port.c
parent31e5992f88cd872cafa3b6384753d2970ba10041 (diff)
downloadunit-6b6fefa497fac704c729fcd784f0e2561ba9656a.tar.gz
unit-6b6fefa497fac704c729fcd784f0e2561ba9656a.tar.bz2
Request-app link introduced to prevent mp destroy for penging requests.
nxt_req_conn_link_t still used for lookup connection by request id. New nxt_req_app_link_t (ra) allocated from conn->mem_pool using mp_retain(). ra stored in app->requests if there is no free worker to process request.
Diffstat (limited to 'src/nxt_port.c')
-rw-r--r--src/nxt_port.c5
1 files changed, 5 insertions, 0 deletions
diff --git a/src/nxt_port.c b/src/nxt_port.c
index 3f3fdd19..3c6b60b7 100644
--- a/src/nxt_port.c
+++ b/src/nxt_port.c
@@ -41,6 +41,8 @@ nxt_port_new(nxt_port_id_t id, nxt_pid_t pid, nxt_process_type_t type)
nxt_mp_destroy(mp);
}
+ nxt_thread_log_debug("port %p %d:%d new, type %d", port, pid, id, type);
+
return port;
}
@@ -48,6 +50,9 @@ nxt_port_new(nxt_port_id_t id, nxt_pid_t pid, nxt_process_type_t type)
nxt_bool_t
nxt_port_release(nxt_port_t *port)
{
+ nxt_thread_log_debug("port %p %d:%d release, type %d", port, port->pid,
+ port->id, port->type);
+
if (port->pair[0] != -1) {
nxt_fd_close(port->pair[0]);
port->pair[0] = -1;