diff options
Diffstat (limited to 'src/nxt_port.c')
| -rw-r--r-- | src/nxt_port.c | 22 |
1 files changed, 21 insertions, 1 deletions
diff --git a/src/nxt_port.c b/src/nxt_port.c index 249a287c..404e6424 100644 --- a/src/nxt_port.c +++ b/src/nxt_port.c @@ -52,7 +52,7 @@ nxt_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) { nxt_port_handler_t *handlers; - if (nxt_fast_path(msg->port_msg.type <= NXT_PORT_MSG_MAX)) { + if (nxt_fast_path(msg->port_msg.type < NXT_PORT_MSG_MAX)) { nxt_debug(task, "port %d: message type:%uD", msg->port->socket.fd, msg->port_msg.type); @@ -292,6 +292,26 @@ nxt_port_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) void +nxt_port_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) +{ + nxt_pid_t pid; + nxt_runtime_t *rt; + nxt_process_t *process; + + nxt_debug(task, "port remove pid handler"); + + rt = task->thread->runtime; + pid = msg->port_msg.stream; + + process = nxt_runtime_process_find(rt, pid); + + if (process) { + nxt_runtime_process_remove(rt, process); + } +} + + +void nxt_port_empty_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) { nxt_debug(task, "port empty handler"); |