aboutsummaryrefslogtreecommitdiff
path: root/src/http/v3/ngx_http_v3_streams.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/http/v3/ngx_http_v3_streams.c')
-rw-r--r--src/http/v3/ngx_http_v3_streams.c76
1 files changed, 1 insertions, 75 deletions
diff --git a/src/http/v3/ngx_http_v3_streams.c b/src/http/v3/ngx_http_v3_streams.c
index 292e6653b..0e55dbe0d 100644
--- a/src/http/v3/ngx_http_v3_streams.c
+++ b/src/http/v3/ngx_http_v3_streams.c
@@ -24,86 +24,12 @@ typedef struct {
} ngx_http_v3_push_t;
-static void ngx_http_v3_keepalive_handler(ngx_event_t *ev);
-static void ngx_http_v3_cleanup_session(void *data);
static void ngx_http_v3_close_uni_stream(ngx_connection_t *c);
static void ngx_http_v3_uni_read_handler(ngx_event_t *rev);
static void ngx_http_v3_dummy_write_handler(ngx_event_t *wev);
static void ngx_http_v3_push_cleanup(void *data);
static ngx_connection_t *ngx_http_v3_get_uni_stream(ngx_connection_t *c,
ngx_uint_t type);
-static ngx_int_t ngx_http_v3_send_settings(ngx_connection_t *c);
-
-
-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;
-
- pc = c->quic->parent;
- hc = pc->data;
-
- if (hc->v3_session) {
- return NGX_OK;
- }
-
- ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 init session");
-
- h3c = ngx_pcalloc(pc->pool, sizeof(ngx_http_v3_session_t));
- if (h3c == NULL) {
- return NGX_ERROR;
- }
-
- h3c->max_push_id = (uint64_t) -1;
-
- ngx_queue_init(&h3c->blocked);
- ngx_queue_init(&h3c->pushing);
-
- h3c->keepalive.log = pc->log;
- h3c->keepalive.data = pc;
- h3c->keepalive.handler = ngx_http_v3_keepalive_handler;
- h3c->keepalive.cancelable = 1;
-
- cln = ngx_pool_cleanup_add(pc->pool, 0);
- if (cln == NULL) {
- return NGX_ERROR;
- }
-
- cln->handler = ngx_http_v3_cleanup_session;
- cln->data = h3c;
-
- hc->v3_session = h3c;
-
- return ngx_http_v3_send_settings(c);
-}
-
-
-static void
-ngx_http_v3_keepalive_handler(ngx_event_t *ev)
-{
- ngx_connection_t *c;
-
- c = ev->data;
-
- ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 keepalive handler");
-
- ngx_quic_finalize_connection(c, NGX_HTTP_V3_ERR_NO_ERROR,
- "keepalive timeout");
-}
-
-
-static void
-ngx_http_v3_cleanup_session(void *data)
-{
- ngx_http_v3_session_t *h3c = data;
-
- if (h3c->keepalive.timer_set) {
- ngx_del_timer(&h3c->keepalive);
- }
-}
void
@@ -445,7 +371,7 @@ failed:
}
-static ngx_int_t
+ngx_int_t
ngx_http_v3_send_settings(ngx_connection_t *c)
{
u_char *p, buf[NGX_HTTP_V3_VARLEN_INT_LEN * 6];