Skip to content

Commit

Permalink
HTTP/2: simplified checking the END_STREAM flag.
Browse files Browse the repository at this point in the history
No functional changes.
  • Loading branch information
VBart committed Oct 26, 2015
1 parent d418b92 commit f36f517
Showing 1 changed file with 3 additions and 5 deletions.
8 changes: 3 additions & 5 deletions src/http/v2/ngx_http_v2.c
Original file line number Diff line number Diff line change
Expand Up @@ -870,6 +870,8 @@ ngx_http_v2_state_data(ngx_http_v2_connection_t *h2c, u_char *pos, u_char *end)
return ngx_http_v2_state_skip_padded(h2c, pos, end);
}

stream->in_closed = h2c->state.flags & NGX_HTTP_V2_END_STREAM_FLAG;

h2c->state.stream = stream;

return ngx_http_v2_state_read_data(h2c, pos, end);
Expand Down Expand Up @@ -897,8 +899,6 @@ ngx_http_v2_state_read_data(ngx_http_v2_connection_t *h2c, u_char *pos,
}

if (stream->skip_data) {
stream->in_closed = h2c->state.flags & NGX_HTTP_V2_END_STREAM_FLAG;

ngx_log_debug1(NGX_LOG_DEBUG_HTTP, h2c->connection->log, 0,
"skipping http2 DATA frame, reason: %d",
stream->skip_data);
Expand Down Expand Up @@ -988,9 +988,7 @@ ngx_http_v2_state_read_data(ngx_http_v2_connection_t *h2c, u_char *pos,
ngx_http_v2_state_read_data);
}

if (h2c->state.flags & NGX_HTTP_V2_END_STREAM_FLAG) {
stream->in_closed = 1;

if (stream->in_closed) {
if (r->headers_in.content_length_n < 0) {
r->headers_in.content_length_n = rb->rest;

Expand Down

0 comments on commit f36f517

Please sign in to comment.