summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_process.c
diff options
context:
space:
mode:
authorMax Romanov <max.romanov@nginx.com>2020-10-28 00:01:46 +0300
committerMax Romanov <max.romanov@nginx.com>2020-10-28 00:01:46 +0300
commit80a8cb835bb780cdb3047b232809c5dfd6e0e794 (patch)
tree36398fd70b59279d7fe3fdb6a61bf86594c3e1ab /src/nxt_process.c
parentd8cc830ea0363009e40d6bf380db1147ad6fb41e (diff)
downloadunit-80a8cb835bb780cdb3047b232809c5dfd6e0e794.tar.gz
unit-80a8cb835bb780cdb3047b232809c5dfd6e0e794.tar.bz2
Preserving the app port write socket.
The socket is required for intercontextual communication in multithreaded apps.
Diffstat (limited to 'src/nxt_process.c')
-rw-r--r--src/nxt_process.c5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/nxt_process.c b/src/nxt_process.c
index 9be7974f..87419313 100644
--- a/src/nxt_process.c
+++ b/src/nxt_process.c
@@ -248,8 +248,6 @@ nxt_process_setup(nxt_task_t *task, nxt_process_t *process)
port = nxt_process_port_first(process);
- nxt_port_write_close(port);
-
nxt_port_enable(task, port, init->port_handlers);
ret = init->setup(task, process);
@@ -272,6 +270,9 @@ nxt_process_setup(nxt_task_t *task, nxt_process_t *process)
}
ret = init->start(task, &process->data);
+
+ nxt_port_write_close(port);
+
break;
default: