nginx: src/http/v2/ngx_http

comparison src/http/v2/ngx_http_v2.c @ 6411:8ec349bb60b2

HTTP/2: always use temporary pool for processing headers. This is required for implementing per request timeouts. Previously, the temporary pool was used only during skipping of headers and the request pool was used otherwise. That required switching of pools if the request was closed while parsing. It wasn't a problem since the request could be closed only after the validation of the fully parsed header. With the per request timeouts, the request can be closed at any moment, and switching of pools in the middle of parsing header name or value becomes a problem. To overcome this, the temporary pool is now always created and used. Special checks are added to keep it when either the stream is being processed or until header block is fully parsed.

author	Valentin Bartenev <vbart@nginx.com>
date	Wed, 24 Feb 2016 16:05:47 +0300
parents	c6ccc1ea9450
children	4ba91a4c66a3

comparison

equal deleted inserted replaced

-:c6ccc1ea9450
+:8ec349bb60b2
 u_char *pos, u_char *end);
 static u_char *ngx_http_v2_state_skip_padded(ngx_http_v2_connection_t *h2c,
 u_char *pos, u_char *end);
 static u_char *ngx_http_v2_state_skip(ngx_http_v2_connection_t *h2c,
 u_char *pos, u_char *end);
-static u_char *ngx_http_v2_state_skip_headers(ngx_http_v2_connection_t *h2c,
-u_char *pos, u_char *end);
 static u_char *ngx_http_v2_state_save(ngx_http_v2_connection_t *h2c,
 u_char *pos, u_char *end, ngx_http_v2_handler_pt handler);
 static u_char *ngx_http_v2_connection_error(ngx_http_v2_connection_t *h2c,
 ngx_uint_t err);
 return ngx_http_v2_connection_error(h2c, NGX_HTTP_V2_PROTOCOL_ERROR);
 }
 h2c->last_sid = h2c->state.sid;
+h2c->state.pool = ngx_create_pool(1024, h2c->connection->log);
+if (h2c->state.pool == NULL) {
+return ngx_http_v2_connection_error(h2c, NGX_HTTP_V2_INTERNAL_ERROR);
+}
 if (depend == h2c->state.sid) {
 ngx_log_error(NGX_LOG_INFO, h2c->connection->log, 0,
 "client sent HEADERS frame for stream %ui "
 "with incorrect dependency", h2c->state.sid);
 {
 return ngx_http_v2_connection_error(h2c,
 NGX_HTTP_V2_INTERNAL_ERROR);
 }
-return ngx_http_v2_state_skip_headers(h2c, pos, end);
+return ngx_http_v2_state_header_block(h2c, pos, end);
 }
 h2scf = ngx_http_get_module_srv_conf(h2c->http_connection->conf_ctx,
 ngx_http_v2_module);
 {
 return ngx_http_v2_connection_error(h2c,
 NGX_HTTP_V2_INTERNAL_ERROR);
 }
-return ngx_http_v2_state_skip_headers(h2c, pos, end);
+return ngx_http_v2_state_header_block(h2c, pos, end);
 }
 node = ngx_http_v2_get_node_by_id(h2c, h2c->state.sid, 1);
 if (node == NULL) {
 stream = ngx_http_v2_create_stream(h2c);
 if (stream == NULL) {
 return ngx_http_v2_connection_error(h2c, NGX_HTTP_V2_INTERNAL_ERROR);
 }
+h2c->state.stream = stream;
+stream->pool = h2c->state.pool;
+h2c->state.keep_pool = 1;
 stream->request->request_length = h2c->state.length;
 stream->in_closed = h2c->state.flags & NGX_HTTP_V2_END_STREAM_FLAG;
 stream->node = node;
 node->stream = stream;
-h2c->state.stream = stream;
-h2c->state.pool = stream->request->pool;
 if (priority || node->parent == NULL) {
 node->weight = weight;
 ngx_http_v2_set_dependency(h2c, node, depend, excl);
 }
 return ngx_http_v2_state_header_complete(h2c, pos, end);
 error:
 h2c->state.stream = NULL;
-h2c->state.pool = NULL;
 return ngx_http_v2_state_header_complete(h2c, pos, end);
 }
 u_char *end)
 {
 ngx_http_v2_stream_t  *stream;
 if (h2c->state.length) {
-h2c->state.handler = h2c->state.pool ? ngx_http_v2_state_header_block
+h2c->state.handler = ngx_http_v2_state_header_block;
-: ngx_http_v2_state_skip_headers;
 return pos;
 }
 if (!(h2c->state.flags & NGX_HTTP_V2_END_HEADERS_FLAG)) {
 return ngx_http_v2_handle_continuation(h2c, pos, end,
 stream = h2c->state.stream;
 if (stream) {
 ngx_http_v2_run_request(stream->request);
+}
-} else if (h2c->state.pool) {
+if (!h2c->state.keep_pool) {
 ngx_destroy_pool(h2c->state.pool);
 }
 h2c->state.pool = NULL;
+h2c->state.keep_pool = 0;
 if (h2c->state.padding) {
 return ngx_http_v2_state_skip_padded(h2c, pos, end);
 }
 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, h2c->connection->log, 0,
 "http2 frame skip %uz", h2c->state.length);
 return ngx_http_v2_state_complete(h2c, pos + h2c->state.length, end);
-}
-static u_char *
-ngx_http_v2_state_skip_headers(ngx_http_v2_connection_t *h2c, u_char *pos,
-u_char *end)
-{
-h2c->state.pool = ngx_create_pool(1024, h2c->connection->log);
-if (h2c->state.pool == NULL) {
-return ngx_http_v2_connection_error(h2c, NGX_HTTP_V2_INTERNAL_ERROR);
-}
-return ngx_http_v2_state_header_block(h2c, pos, end);
 }
 static u_char *
 ngx_http_v2_state_save(ngx_http_v2_connection_t *h2c, u_char *pos, u_char *end,
 void
 ngx_http_v2_close_stream(ngx_http_v2_stream_t *stream, ngx_int_t rc)
 {
+ngx_pool_t                *pool;
 ngx_event_t               *ev;
 ngx_connection_t          *fc;
 ngx_http_v2_node_t        *node;
 ngx_http_v2_connection_t  *h2c;
 node->stream = NULL;
 ngx_queue_insert_tail(&h2c->closed, &node->reuse);
 h2c->closed_nodes++;
+/*
+* This pool keeps decoded request headers which can be used by log phase
+* handlers in ngx_http_free_request().
+*
+* The pointer is stored into local variable because the stream object
+* will be destroyed after a call to ngx_http_free_request().
+*/
+pool = stream->pool;
 ngx_http_free_request(stream->request, rc);
+if (pool != h2c->state.pool) {
+ngx_destroy_pool(pool);
+} else {
+/* pool will be destroyed when the complete header is parsed */
+h2c->state.keep_pool = 0;
+}
 ev = fc->read;
 if (ev->active || ev->disabled) {
 ngx_log_error(NGX_LOG_ALERT, h2c->connection->log, 0,
 c = h2c->connection;
 if (h2c->state.stream) {
 h2c->state.stream->out_closed = 1;
-h2c->state.pool = NULL;
 ngx_http_v2_close_stream(h2c->state.stream, NGX_HTTP_BAD_REQUEST);
 }
 h2c->blocked = 1;

Mercurial > hg > nginx

comparison src/http/v2/ngx_http_v2.c @ 6411:8ec349bb60b2