[PATCH 6 of 9] HTTP/3: unified hq code with HTTP/3 code
Roman Arutyunyan
arut at nginx.com
Tue Aug 23 12:51:15 UTC 2022
# HG changeset patch
# User Roman Arutyunyan <arut at nginx.com>
# Date 1661249481 -14400
# Tue Aug 23 14:11:21 2022 +0400
# Branch quic
# Node ID 462b1520751e1c7a06af9de3004358a0246f8792
# Parent 8b0ffd69cca1a9aff606f1c8e416024b1e818a5e
HTTP/3: unified hq code with HTTP/3 code.
The change removes hq-specific request handler. Now hq requests are handled
by the HTTP/3 request handler. This brings missing features like keepalive
timeout and reusable mode to hq.
diff --git a/src/http/v3/ngx_http_v3.c b/src/http/v3/ngx_http_v3.c
--- a/src/http/v3/ngx_http_v3.c
+++ b/src/http/v3/ngx_http_v3.c
@@ -17,10 +17,13 @@ static void ngx_http_v3_cleanup_session(
ngx_int_t
ngx_http_v3_init_session(ngx_connection_t *c)
{
- ngx_connection_t *pc;
- ngx_pool_cleanup_t *cln;
- ngx_http_connection_t *hc;
- ngx_http_v3_session_t *h3c;
+ ngx_connection_t *pc;
+ ngx_pool_cleanup_t *cln;
+ ngx_http_connection_t *hc;
+ ngx_http_v3_session_t *h3c;
+#if (NGX_HTTP_V3_HQ)
+ ngx_http_v3_srv_conf_t *h3scf;
+#endif
pc = c->quic->parent;
hc = pc->data;
@@ -39,6 +42,13 @@ ngx_http_v3_init_session(ngx_connection_
h3c->max_push_id = (uint64_t) -1;
h3c->goaway_push_id = (uint64_t) -1;
+#if (NGX_HTTP_V3_HQ)
+ h3scf = ngx_http_get_module_srv_conf(hc->conf_ctx, ngx_http_v3_module);
+ if (h3scf->hq) {
+ h3c->hq = 1;
+ }
+#endif
+
ngx_queue_init(&h3c->blocked);
ngx_queue_init(&h3c->pushing);
@@ -61,6 +71,12 @@ ngx_http_v3_init_session(ngx_connection_
hc->v3_session = h3c;
+#if (NGX_HTTP_V3_HQ)
+ if (h3c->hq) {
+ return NGX_OK;
+ }
+#endif
+
return ngx_http_v3_send_settings(c);
failed:
diff --git a/src/http/v3/ngx_http_v3.h b/src/http/v3/ngx_http_v3.h
--- a/src/http/v3/ngx_http_v3.h
+++ b/src/http/v3/ngx_http_v3.h
@@ -145,7 +145,10 @@ struct ngx_http_v3_session_s {
off_t total_bytes;
off_t payload_bytes;
- ngx_uint_t goaway; /* unsigned goaway:1; */
+ unsigned goaway:1;
+#if (NGX_HTTP_V3_HQ)
+ unsigned hq:1;
+#endif
ngx_connection_t *known_streams[NGX_HTTP_V3_MAX_KNOWN_STREAM];
};
diff --git a/src/http/v3/ngx_http_v3_request.c b/src/http/v3/ngx_http_v3_request.c
--- a/src/http/v3/ngx_http_v3_request.c
+++ b/src/http/v3/ngx_http_v3_request.c
@@ -10,10 +10,8 @@
#include <ngx_http.h>
-#if (NGX_HTTP_V3_HQ)
-static void ngx_http_v3_init_hq_stream(ngx_connection_t *c);
-#endif
static void ngx_http_v3_init_request_stream(ngx_connection_t *c);
+static void ngx_http_v3_cleanup_connection(void *data);
static void ngx_http_v3_wait_request_handler(ngx_event_t *rev);
static void ngx_http_v3_cleanup_request(void *data);
static void ngx_http_v3_process_request(ngx_event_t *rev);
@@ -86,13 +84,6 @@ ngx_http_v3_init(ngx_connection_t *c)
ngx_set_connection_log(c, clcf->error_log);
}
-#if (NGX_HTTP_V3_HQ)
- if (h3scf->hq) {
- ngx_http_v3_init_hq_stream(c);
- return;
- }
-#endif
-
if (ngx_http_v3_init_session(c) != NGX_OK) {
ngx_http_close_connection(c);
return;
@@ -107,83 +98,13 @@ ngx_http_v3_init(ngx_connection_t *c)
}
-#if (NGX_HTTP_V3_HQ)
-
-static void
-ngx_http_v3_init_hq_stream(ngx_connection_t *c)
-{
- uint64_t n;
- ngx_event_t *rev;
- ngx_http_connection_t *hc;
- ngx_http_core_loc_conf_t *clcf;
- ngx_http_core_srv_conf_t *cscf;
-
- ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 init hq stream");
-
-#if (NGX_STAT_STUB)
- (void) ngx_atomic_fetch_add(ngx_stat_active, 1);
-#endif
-
- hc = c->data;
-
- /* Use HTTP/3 General Protocol Error Code 0x101 for finalization */
-
- if (c->quic->id & NGX_QUIC_STREAM_UNIDIRECTIONAL) {
- ngx_quic_finalize_connection(c->quic->parent,
- NGX_HTTP_V3_ERR_GENERAL_PROTOCOL_ERROR,
- "unexpected uni stream");
- ngx_http_close_connection(c);
- return;
- }
-
- clcf = ngx_http_get_module_loc_conf(hc->conf_ctx, ngx_http_core_module);
-
- n = c->quic->id >> 2;
-
- if (n >= clcf->keepalive_requests) {
- ngx_quic_finalize_connection(c->quic->parent,
- NGX_HTTP_V3_ERR_GENERAL_PROTOCOL_ERROR,
- "reached maximum number of requests");
- ngx_http_close_connection(c);
- return;
- }
-
- if (ngx_current_msec - c->quic->parent->start_time
- > clcf->keepalive_time)
- {
- ngx_quic_finalize_connection(c->quic->parent,
- NGX_HTTP_V3_ERR_GENERAL_PROTOCOL_ERROR,
- "reached maximum time for requests");
- ngx_http_close_connection(c);
- return;
- }
-
- rev = c->read;
-
- if (rev->ready) {
- rev->handler(rev);
- return;
- }
-
- cscf = ngx_http_get_module_srv_conf(hc->conf_ctx, ngx_http_core_module);
-
- ngx_add_timer(rev, cscf->client_header_timeout);
- ngx_reusable_connection(c, 1);
-
- if (ngx_handle_read_event(rev, 0) != NGX_OK) {
- ngx_http_close_connection(c);
- return;
- }
-}
-
-#endif
-
-
static void
ngx_http_v3_init_request_stream(ngx_connection_t *c)
{
uint64_t n;
ngx_event_t *rev;
+ ngx_connection_t *pc;
+ ngx_pool_cleanup_t *cln;
ngx_http_connection_t *hc;
ngx_http_v3_session_t *h3c;
ngx_http_core_loc_conf_t *clcf;
@@ -216,24 +137,55 @@ ngx_http_v3_init_request_stream(ngx_conn
return;
}
+ pc = c->quic->parent;
+
if (n + 1 == clcf->keepalive_requests
- || ngx_current_msec - c->quic->parent->start_time
- > clcf->keepalive_time)
+ || ngx_current_msec - pc->start_time > clcf->keepalive_time)
{
h3c->goaway = 1;
- if (ngx_http_v3_send_goaway(c, (n + 1) << 2) != NGX_OK) {
- ngx_http_close_connection(c);
- return;
+#if (NGX_HTTP_V3_HQ)
+ if (!h3c->hq)
+#endif
+ {
+ if (ngx_http_v3_send_goaway(c, (n + 1) << 2) != NGX_OK) {
+ ngx_http_close_connection(c);
+ return;
+ }
}
ngx_http_v3_shutdown_connection(c, NGX_HTTP_V3_ERR_NO_ERROR,
"reached maximum number of requests");
}
+ cln = ngx_pool_cleanup_add(c->pool, 0);
+ if (cln == NULL) {
+ ngx_quic_finalize_connection(pc, NGX_HTTP_V3_ERR_INTERNAL_ERROR,
+ "internal error");
+ ngx_http_close_connection(c);
+ return;
+ }
+
+ cln->handler = ngx_http_v3_cleanup_connection;
+ cln->data = c;
+
+ if (h3c->nrequests++ == 0) {
+ ngx_reusable_connection(pc, 0);
+ }
+
+ if (h3c->keepalive.timer_set) {
+ ngx_del_timer(&h3c->keepalive);
+ }
+
rev = c->read;
- rev->handler = ngx_http_v3_wait_request_handler;
- c->write->handler = ngx_http_empty_handler;
+
+#if (NGX_HTTP_V3_HQ)
+ if (!h3c->hq)
+#endif
+ {
+ rev->handler = ngx_http_v3_wait_request_handler;
+ c->write->handler = ngx_http_empty_handler;
+ }
if (rev->ready) {
rev->handler(rev);
@@ -253,16 +205,36 @@ ngx_http_v3_init_request_stream(ngx_conn
static void
+ngx_http_v3_cleanup_connection(void *data)
+{
+ ngx_connection_t *c = data;
+
+ ngx_connection_t *pc;
+ ngx_http_v3_session_t *h3c;
+ ngx_http_core_loc_conf_t *clcf;
+
+ h3c = ngx_http_v3_get_session(c);
+
+ if (--h3c->nrequests == 0) {
+ pc = c->quic->parent;
+ ngx_reusable_connection(pc, 1);
+
+ clcf = ngx_http_v3_get_module_loc_conf(c, ngx_http_core_module);
+ ngx_add_timer(&h3c->keepalive, clcf->keepalive_timeout);
+ }
+}
+
+
+static void
ngx_http_v3_wait_request_handler(ngx_event_t *rev)
{
size_t size;
ssize_t n;
ngx_buf_t *b;
- ngx_connection_t *c, *pc;
+ ngx_connection_t *c;
ngx_pool_cleanup_t *cln;
ngx_http_request_t *r;
ngx_http_connection_t *hc;
- ngx_http_v3_session_t *h3c;
ngx_http_core_srv_conf_t *cscf;
c = rev->data;
@@ -382,16 +354,6 @@ ngx_http_v3_wait_request_handler(ngx_eve
cln->handler = ngx_http_v3_cleanup_request;
cln->data = r;
- h3c = ngx_http_v3_get_session(c);
- h3c->nrequests++;
-
- pc = c->quic->parent;
- ngx_reusable_connection(pc, 0);
-
- if (h3c->keepalive.timer_set) {
- ngx_del_timer(&h3c->keepalive);
- }
-
rev->handler = ngx_http_v3_process_request;
ngx_http_v3_process_request(rev);
}
@@ -404,13 +366,10 @@ ngx_http_v3_reset_connection(ngx_connect
h3scf = ngx_http_v3_get_module_srv_conf(c, ngx_http_v3_module);
+ if (h3scf->max_table_capacity > 0 && !c->read->eof
#if (NGX_HTTP_V3_HQ)
- if (h3scf->hq) {
- return;
- }
+ && !h3scf->hq
#endif
-
- if (h3scf->max_table_capacity > 0 && !c->read->eof
&& (c->quic->id & NGX_QUIC_STREAM_UNIDIRECTIONAL) == 0)
{
(void) ngx_http_v3_send_cancel_stream(c, c->quic->id);
@@ -433,24 +392,8 @@ ngx_http_v3_cleanup_request(void *data)
{
ngx_http_request_t *r = data;
- ngx_connection_t *c, *pc;
- ngx_http_v3_session_t *h3c;
- ngx_http_core_loc_conf_t *clcf;
-
- c = r->connection;
-
if (!r->response_sent) {
- c->error = 1;
- }
-
- h3c = ngx_http_v3_get_session(c);
-
- if (--h3c->nrequests == 0) {
- pc = c->quic->parent;
- ngx_reusable_connection(pc, 1);
-
- clcf = ngx_http_v3_get_module_loc_conf(c, ngx_http_core_module);
- ngx_add_timer(&h3c->keepalive, clcf->keepalive_timeout);
+ r->connection->error = 1;
}
}
diff --git a/src/http/v3/ngx_http_v3_uni.c b/src/http/v3/ngx_http_v3_uni.c
--- a/src/http/v3/ngx_http_v3_uni.c
+++ b/src/http/v3/ngx_http_v3_uni.c
@@ -37,8 +37,23 @@ void
ngx_http_v3_init_uni_stream(ngx_connection_t *c)
{
uint64_t n;
+#if (NGX_HTTP_V3_HQ)
+ ngx_http_v3_session_t *h3c;
+#endif
ngx_http_v3_uni_stream_t *us;
+#if (NGX_HTTP_V3_HQ)
+ h3c = ngx_http_v3_get_session(c);
+ if (h3c->hq) {
+ ngx_http_v3_finalize_connection(c,
+ NGX_HTTP_V3_ERR_STREAM_CREATION_ERROR,
+ "uni stream in hq mode");
+ c->data = NULL;
+ ngx_http_v3_close_uni_stream(c);
+ return;
+ }
+#endif
+
ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 init uni stream");
n = c->quic->id >> 2;
More information about the nginx-devel
mailing list