diff options
| author | Max Romanov <max.romanov@nginx.com> | 2020-04-06 16:52:11 +0300 |
|---|---|---|
| committer | Max Romanov <max.romanov@nginx.com> | 2020-04-06 16:52:11 +0300 |
| commit | 792ef9d3c71c6843dbbde450a2d6d1ade538f1f3 (patch) | |
| tree | 5b2c15a2b3d6f7855b0209b74a6d855e30245b17 /src/nxt_process.h | |
| parent | a49023229ec0a404665a711fbf35f6b3bf715825 (diff) | |
| download | unit-792ef9d3c71c6843dbbde450a2d6d1ade538f1f3.tar.gz unit-792ef9d3c71c6843dbbde450a2d6d1ade538f1f3.tar.bz2 | |
Fixing 'find & add' racing condition in connected ports hash.
Missing error log messages added.
Diffstat (limited to '')
| -rw-r--r-- | src/nxt_process.h | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/nxt_process.h b/src/nxt_process.h index 343fffb8..0c51adfb 100644 --- a/src/nxt_process.h +++ b/src/nxt_process.h @@ -105,13 +105,11 @@ void nxt_process_use(nxt_task_t *task, nxt_process_t *process, int i); void nxt_process_close_ports(nxt_task_t *task, nxt_process_t *process); -void nxt_process_connected_port_add(nxt_process_t *process, nxt_port_t *port); - void nxt_process_connected_port_remove(nxt_process_t *process, nxt_port_t *port); -nxt_port_t *nxt_process_connected_port_find(nxt_process_t *process, - nxt_pid_t pid, nxt_port_id_t port_id); +nxt_port_t *nxt_process_connected_port_find_add(nxt_process_t *process, + nxt_port_t *port); void nxt_worker_process_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg); |