Fixed application crash handling in router.
Before this fix, request in router may hang until timeout expired if application crashed during request processing.
This commit is contained in:
parent
9ea4be7e4e
commit
ce17fef73d
1 changed files with 4 additions and 4 deletions
|
@ -928,10 +928,6 @@ nxt_router_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg)
|
|||
|
||||
nxt_port_remove_pid_handler(task, msg);
|
||||
|
||||
if (msg->port_msg.stream == 0) {
|
||||
return;
|
||||
}
|
||||
|
||||
nxt_queue_each(engine, &nxt_router->engines, nxt_event_engine_t, link0)
|
||||
{
|
||||
nxt_port_post(task, engine->port, nxt_router_app_process_remove_pid,
|
||||
|
@ -939,6 +935,10 @@ nxt_router_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg)
|
|||
}
|
||||
nxt_queue_loop;
|
||||
|
||||
if (msg->port_msg.stream == 0) {
|
||||
return;
|
||||
}
|
||||
|
||||
msg->port_msg.type = _NXT_PORT_MSG_RPC_ERROR;
|
||||
|
||||
nxt_port_rpc_handler(task, msg);
|
||||
|
|
Loading…
Reference in a new issue