From f23f985899760fafd853e993d9023b1339f09533 Mon Sep 17 00:00:00 2001 From: Max Romanov Date: Wed, 2 Aug 2017 13:22:07 +0300 Subject: Runtime processes protected with mutex. --- src/nxt_master_process.c | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'src/nxt_master_process.c') diff --git a/src/nxt_master_process.c b/src/nxt_master_process.c index 2bc97c1c..41e659a4 100644 --- a/src/nxt_master_process.c +++ b/src/nxt_master_process.c @@ -406,7 +406,7 @@ nxt_master_create_worker_process(nxt_task_t *task, nxt_runtime_t *rt, port = nxt_port_new(0, 0, init->type); if (nxt_slow_path(port == NULL)) { - nxt_runtime_process_destroy(rt, process); + nxt_runtime_process_remove(rt, process); return NXT_ERROR; } @@ -658,7 +658,9 @@ nxt_master_cleanup_worker_process(nxt_task_t *task, nxt_pid_t pid) if (!nxt_exiting) { nxt_runtime_process_each(rt, process) { - if (process->pid == nxt_pid) { + if (process->pid == nxt_pid || + process->pid == pid || + nxt_queue_is_empty(&process->ports)) { continue; } -- cgit