diff options
| -rw-r--r-- | src/nxt_port.c | 2 | ||||
| -rw-r--r-- | src/nxt_port_rpc.c | 38 | ||||
| -rw-r--r-- | src/nxt_port_rpc.h | 1 |
3 files changed, 41 insertions, 0 deletions
diff --git a/src/nxt_port.c b/src/nxt_port.c index 64dd4dd5..7e5722d0 100644 --- a/src/nxt_port.c +++ b/src/nxt_port.c @@ -86,6 +86,8 @@ nxt_port_close(nxt_task_t *task, nxt_port_t *port) port->id, port->type); if (port->pair[0] != -1) { + nxt_port_rpc_close(task, port); + nxt_fd_close(port->pair[0]); port->pair[0] = -1; } diff --git a/src/nxt_port_rpc.c b/src/nxt_port_rpc.c index b53fbb78..d5ec289c 100644 --- a/src/nxt_port_rpc.c +++ b/src/nxt_port_rpc.c @@ -461,3 +461,41 @@ nxt_port_rpc_cancel(nxt_task_t *task, nxt_port_t *port, uint32_t stream) nxt_port_use(task, port, -1); } + +static nxt_buf_t nxt_port_close_dummy_buf; + +void +nxt_port_rpc_close(nxt_task_t *task, nxt_port_t *port) +{ + nxt_lvlhsh_each_t lhe; + nxt_port_rpc_reg_t *reg; + nxt_port_recv_msg_t msg; + + for ( ;; ) { + nxt_memzero(&lhe, sizeof(nxt_lvlhsh_each_t)); + + lhe.proto = &lvlhsh_rpc_reg_proto; + + reg = nxt_lvlhsh_each(&port->rpc_streams, &lhe); + if (reg == NULL) { + return; + } + + msg.fd = -1; + msg.buf = &nxt_port_close_dummy_buf; + msg.port = port; + msg.port_msg.stream = reg->stream; + msg.port_msg.pid = nxt_pid; + msg.port_msg.type = _NXT_PORT_MSG_RPC_ERROR; + msg.port_msg.last = 1; + msg.port_msg.mmap = 0; + msg.port_msg.nf = 0; + msg.port_msg.mf = 0; + msg.port_msg.tracking = 0; + msg.size = sizeof(msg.port_msg); + msg.cancelled = 0; + msg.u.data = NULL; + + nxt_port_rpc_handler(task, &msg); + } +} diff --git a/src/nxt_port_rpc.h b/src/nxt_port_rpc.h index 2152e68d..8011e474 100644 --- a/src/nxt_port_rpc.h +++ b/src/nxt_port_rpc.h @@ -26,6 +26,7 @@ void nxt_port_rpc_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg); void nxt_port_rpc_remove_peer(nxt_task_t *task, nxt_port_t *port, nxt_pid_t peer); void nxt_port_rpc_cancel(nxt_task_t *task, nxt_port_t *port, uint32_t stream); +void nxt_port_rpc_close(nxt_task_t *task, nxt_port_t *port); #endif /* _NXT_PORT_RPC_H_INCLUDED_ */ |