[nginx] HTTP/2: refactored ngx_http_v2_send_output_queue().
Maxim Dounin
mdounin at mdounin.ru
Tue Oct 18 14:48:28 UTC 2016
details: http://hg.nginx.org/nginx/rev/edffb7defebe
branches: stable-1.10
changeset: 6764:edffb7defebe
user: Valentin Bartenev <vbart at nginx.com>
date: Tue Jul 19 20:34:02 2016 +0300
description:
HTTP/2: refactored ngx_http_v2_send_output_queue().
Now it returns NGX_AGAIN if there's still data to be sent.
diffstat:
src/http/v2/ngx_http_v2.c | 20 ++++++++++----------
1 files changed, 10 insertions(+), 10 deletions(-)
diffs (44 lines):
diff --git a/src/http/v2/ngx_http_v2.c b/src/http/v2/ngx_http_v2.c
--- a/src/http/v2/ngx_http_v2.c
+++ b/src/http/v2/ngx_http_v2.c
@@ -478,7 +478,7 @@ ngx_http_v2_send_output_queue(ngx_http_v
wev = c->write;
if (!wev->ready) {
- return NGX_OK;
+ return NGX_AGAIN;
}
cl = NULL;
@@ -549,15 +549,6 @@ ngx_http_v2_send_output_queue(ngx_http_v
c->tcp_nodelay = NGX_TCP_NODELAY_SET;
}
- if (!wev->ready) {
- ngx_add_timer(wev, clcf->send_timeout);
-
- } else {
- if (wev->timer_set) {
- ngx_del_timer(wev);
- }
- }
-
for ( /* void */ ; out; out = fn) {
fn = out->next;
@@ -582,6 +573,15 @@ ngx_http_v2_send_output_queue(ngx_http_v
h2c->last_out = frame;
+ if (!wev->ready) {
+ ngx_add_timer(wev, clcf->send_timeout);
+ return NGX_AGAIN;
+ }
+
+ if (wev->timer_set) {
+ ngx_del_timer(wev);
+ }
+
return NGX_OK;
error:
More information about the nginx-devel
mailing list