diff options
| author | Max Romanov <max.romanov@nginx.com> | 2020-10-28 00:01:46 +0300 |
|---|---|---|
| committer | Max Romanov <max.romanov@nginx.com> | 2020-10-28 00:01:46 +0300 |
| commit | ccee391ab28d2742a98c612c42a37d6dcdbcd5f7 (patch) | |
| tree | 1636eeb079cb22307c4048c05d0db6d61d1e65af /src/nxt_router.c | |
| parent | 735bb2f1276a7d768cffd1e780114a10018980cb (diff) | |
| download | unit-ccee391ab28d2742a98c612c42a37d6dcdbcd5f7.tar.gz unit-ccee391ab28d2742a98c612c42a37d6dcdbcd5f7.tar.bz2 | |
Router: broadcasting the SHM_ACK message to all process ports.
Diffstat (limited to 'src/nxt_router.c')
| -rw-r--r-- | src/nxt_router.c | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/nxt_router.c b/src/nxt_router.c index 15706428..cf627746 100644 --- a/src/nxt_router.c +++ b/src/nxt_router.c @@ -5389,8 +5389,7 @@ nxt_router_oosm_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) nxt_thread_mutex_unlock(&process->incoming.mutex); if (ack) { - (void) nxt_port_socket_write(task, msg->port, NXT_PORT_MSG_SHM_ACK, - -1, 0, 0, NULL); + nxt_process_broadcast_shm_ack(task, process); } } |