technocloud-public/nginx-unit
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Double buf completion call on connection timeout fixed.

Browse Source
This commit is contained in:
Max Romanov
2017-06-26 19:58:43 +03:00
parent d62e6c3b18
commit 44b3ad17f4
1 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/nxt_router.c
View File

@@ -985,24 +985,20 @@ nxt_router_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg)
size_t dump_size; size_t dump_size;
nxt_buf_t *b, *i, *last; nxt_buf_t *b, *i, *last;
nxt_conn_t *c; nxt_conn_t *c;
nxt_work_queue_t *wq;
nxt_req_conn_link_t *rc; nxt_req_conn_link_t *rc;
nxt_event_engine_t *engine; nxt_event_engine_t *engine;
b = msg->buf; b = msg->buf;
engine = task->thread->engine; engine = task->thread->engine;
wq = &engine->fast_work_queue;
rc = nxt_event_engine_request_find(engine, msg->port_msg.stream); rc = nxt_event_engine_request_find(engine, msg->port_msg.stream);
if (nxt_slow_path(rc == NULL)) { if (nxt_slow_path(rc == NULL)) {
nxt_debug(task, "request id %08uxD not found", msg->port_msg.stream); nxt_debug(task, "request id %08uxD not found", msg->port_msg.stream);
/* complete buffer(s) */ /* Mark buffers as read. */
for (i = b; i != NULL; i = i->next) { for (i = b; i != NULL; i = i->next) {
i->mem.pos = i->mem.free; i->mem.pos = i->mem.free;
nxt_work_queue_add(wq, i->completion_handler, task, i, i->parent);
} }
return; return;