diff options
Diffstat (limited to '')
| -rw-r--r-- | src/nxt_main_process.c | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/nxt_main_process.c b/src/nxt_main_process.c index 819b797b..d6743b68 100644 --- a/src/nxt_main_process.c +++ b/src/nxt_main_process.c @@ -764,6 +764,7 @@ nxt_main_cleanup_worker_process(nxt_task_t *task, nxt_pid_t pid) nxt_port_t *port; nxt_runtime_t *rt; nxt_process_t *process; + nxt_process_type_t ptype; nxt_process_init_t *init; rt = task->thread->runtime; @@ -773,6 +774,8 @@ nxt_main_cleanup_worker_process(nxt_task_t *task, nxt_pid_t pid) if (process) { init = process->init; + ptype = nxt_process_type(process); + nxt_process_close_ports(task, process); if (!nxt_exiting) { @@ -787,6 +790,10 @@ nxt_main_cleanup_worker_process(nxt_task_t *task, nxt_pid_t pid) port = nxt_process_port_first(process); + if (nxt_proc_remove_notify_martix[ptype][port->type] == 0) { + continue; + } + buf = nxt_buf_mem_ts_alloc(task, task->thread->engine->mem_pool, sizeof(pid)); buf->mem.free = nxt_cpymem(buf->mem.free, &pid, sizeof(pid)); |