summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_router.c
diff options
context:
space:
mode:
authorIgor Sysoev <igor@sysoev.ru>2019-08-26 18:29:00 +0300
committerIgor Sysoev <igor@sysoev.ru>2019-08-26 18:29:00 +0300
commite2abfaf381984b9c441555a3614336b64008c80d (patch)
tree7e0dab421f7e5588a7e350009d688771a04b321c /src/nxt_router.c
parent129882413013adc803d855b3ba413b55882c4293 (diff)
downloadunit-e2abfaf381984b9c441555a3614336b64008c80d.tar.gz
unit-e2abfaf381984b9c441555a3614336b64008c80d.tar.bz2
Adding body handler to nxt_http_request_header_send().
Diffstat (limited to '')
-rw-r--r--src/nxt_router.c7
1 files changed, 1 insertions, 6 deletions
diff --git a/src/nxt_router.c b/src/nxt_router.c
index b87f588f..c3bcc51c 100644
--- a/src/nxt_router.c
+++ b/src/nxt_router.c
@@ -3531,7 +3531,7 @@ nxt_router_response_ready_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg,
nxt_buf_chain_add(&r->out, b);
}
- nxt_http_request_header_send(task, r);
+ nxt_http_request_header_send(task, r, nxt_http_request_send_body);
if (r->websocket_handshake
&& r->status == NXT_HTTP_SWITCHING_PROTOCOLS)
@@ -3575,11 +3575,6 @@ nxt_router_response_ready_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg,
} else {
r->state = &nxt_http_request_send_state;
}
-
- if (r->out) {
- nxt_work_queue_add(&task->thread->engine->fast_work_queue,
- nxt_http_request_send_body, task, r, NULL);
- }
}
return;