typedef struct ngx_http_chunked_s ngx_http_chunked_t;
typedef struct ngx_http_v2_stream_s ngx_http_v2_stream_t;
typedef struct ngx_http_v3_parse_s ngx_http_v3_parse_t;
-typedef struct ngx_http_v3_connection_s
- ngx_http_v3_connection_t;
+typedef struct ngx_http_v3_session_s ngx_http_v3_session_t;
typedef ngx_int_t (*ngx_http_header_handler_pt)(ngx_http_request_t *r,
ngx_table_elt_t *h, ngx_uint_t offset);
#endif
#if (NGX_HTTP_V3 || NGX_COMPAT)
- ngx_http_v3_connection_t *v3_session;
+ ngx_http_v3_session_t *v3_session;
#endif
ngx_chain_t *busy;
} ngx_http_v3_dynamic_table_t;
-struct ngx_http_v3_connection_s {
+struct ngx_http_v3_session_s {
ngx_http_v3_dynamic_table_t table;
ngx_event_t keepalive;
ngx_http_v3_push_resource(ngx_http_request_t *r, ngx_str_t *path,
ngx_chain_t ***ll)
{
- uint64_t push_id;
- ngx_int_t rc;
- ngx_chain_t *cl;
- ngx_connection_t *c;
- ngx_http_v3_srv_conf_t *h3scf;
- ngx_http_v3_connection_t *h3c;
+ uint64_t push_id;
+ ngx_int_t rc;
+ ngx_chain_t *cl;
+ ngx_connection_t *c;
+ ngx_http_v3_session_t *h3c;
+ ngx_http_v3_srv_conf_t *h3scf;
c = r->connection;
h3c = ngx_http_v3_get_session(c);
ngx_http_request_t *r;
ngx_http_log_ctx_t *ctx;
ngx_http_connection_t *hc;
+ ngx_http_v3_session_t *h3c;
ngx_http_core_srv_conf_t *cscf;
- ngx_http_v3_connection_t *h3c;
pc = pr->connection;
ngx_pool_cleanup_t *cln;
ngx_http_request_t *r;
ngx_http_connection_t *hc;
- ngx_http_v3_connection_t *h3c;
+ ngx_http_v3_session_t *h3c;
ngx_http_core_loc_conf_t *clcf;
ngx_http_core_srv_conf_t *cscf;
{
ngx_connection_t *c = data;
+ ngx_http_v3_session_t *h3c;
ngx_http_core_loc_conf_t *clcf;
- ngx_http_v3_connection_t *h3c;
h3c = ngx_http_v3_get_session(c);
ngx_connection_t *pc;
ngx_pool_cleanup_t *cln;
ngx_http_connection_t *hc;
- ngx_http_v3_connection_t *h3c;
+ ngx_http_v3_session_t *h3c;
pc = c->quic->parent;
hc = pc->data;
ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 init session");
- h3c = ngx_pcalloc(pc->pool, sizeof(ngx_http_v3_connection_t));
+ h3c = ngx_pcalloc(pc->pool, sizeof(ngx_http_v3_session_t));
if (h3c == NULL) {
return NGX_ERROR;
}
static void
ngx_http_v3_cleanup_session(void *data)
{
- ngx_http_v3_connection_t *h3c = data;
+ ngx_http_v3_session_t *h3c = data;
if (h3c->keepalive.timer_set) {
ngx_del_timer(&h3c->keepalive);
ngx_http_v3_close_uni_stream(ngx_connection_t *c)
{
ngx_pool_t *pool;
- ngx_http_v3_connection_t *h3c;
+ ngx_http_v3_session_t *h3c;
ngx_http_v3_uni_stream_t *us;
us = c->data;
ssize_t n;
ngx_int_t index, rc;
ngx_connection_t *c;
- ngx_http_v3_connection_t *h3c;
+ ngx_http_v3_session_t *h3c;
ngx_http_v3_uni_stream_t *us;
c = rev->data;
ngx_connection_t *
ngx_http_v3_create_push_stream(ngx_connection_t *c, uint64_t push_id)
{
- u_char *p, buf[NGX_HTTP_V3_VARLEN_INT_LEN * 2];
- size_t n;
- ngx_connection_t *sc;
- ngx_pool_cleanup_t *cln;
- ngx_http_v3_push_t *push;
- ngx_http_v3_connection_t *h3c;
+ u_char *p, buf[NGX_HTTP_V3_VARLEN_INT_LEN * 2];
+ size_t n;
+ ngx_connection_t *sc;
+ ngx_pool_cleanup_t *cln;
+ ngx_http_v3_push_t *push;
+ ngx_http_v3_session_t *h3c;
ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
"http3 create push stream id:%uL", push_id);
size_t n;
ngx_int_t index;
ngx_connection_t *sc;
- ngx_http_v3_connection_t *h3c;
+ ngx_http_v3_session_t *h3c;
ngx_http_v3_uni_stream_t *us;
switch (type) {
ngx_int_t
ngx_http_v3_set_max_push_id(ngx_connection_t *c, uint64_t max_push_id)
{
- ngx_http_v3_connection_t *h3c;
+ ngx_http_v3_session_t *h3c;
h3c = ngx_http_v3_get_session(c);
ngx_int_t
ngx_http_v3_cancel_push(ngx_connection_t *c, uint64_t push_id)
{
- ngx_queue_t *q;
- ngx_http_request_t *r;
- ngx_http_v3_push_t *push;
- ngx_http_v3_connection_t *h3c;
+ ngx_queue_t *q;
+ ngx_http_request_t *r;
+ ngx_http_v3_push_t *push;
+ ngx_http_v3_session_t *h3c;
h3c = ngx_http_v3_get_session(c);
u_char *p;
size_t size;
ngx_http_v3_header_t *h;
- ngx_http_v3_connection_t *h3c;
+ ngx_http_v3_session_t *h3c;
ngx_http_v3_dynamic_table_t *dt;
size = ngx_http_v3_table_entry_size(name, value);
ngx_connection_t *pc;
ngx_pool_cleanup_t *cln;
ngx_http_v3_header_t **elts;
+ ngx_http_v3_session_t *h3c;
ngx_http_v3_srv_conf_t *h3scf;
- ngx_http_v3_connection_t *h3c;
ngx_http_v3_dynamic_table_t *dt;
ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
size_t size, target;
ngx_uint_t n;
ngx_http_v3_header_t *h;
- ngx_http_v3_connection_t *h3c;
+ ngx_http_v3_session_t *h3c;
ngx_http_v3_dynamic_table_t *dt;
h3c = ngx_http_v3_get_session(c);
ngx_http_v3_duplicate(ngx_connection_t *c, ngx_uint_t index)
{
ngx_str_t name, value;
- ngx_http_v3_connection_t *h3c;
+ ngx_http_v3_session_t *h3c;
ngx_http_v3_dynamic_table_t *dt;
ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 duplicate %ui", index);
ngx_str_t *value)
{
ngx_http_v3_header_t *h;
- ngx_http_v3_connection_t *h3c;
+ ngx_http_v3_session_t *h3c;
ngx_http_v3_dynamic_table_t *dt;
h3c = ngx_http_v3_get_session(c);
ngx_uint_t max_entries, full_range, max_value,
max_wrapped, req_insert_count;
ngx_http_v3_srv_conf_t *h3scf;
- ngx_http_v3_connection_t *h3c;
+ ngx_http_v3_session_t *h3c;
ngx_http_v3_dynamic_table_t *dt;
/* QPACK 4.5.1.1. Required Insert Count */
size_t n;
ngx_pool_cleanup_t *cln;
ngx_http_v3_block_t *block;
+ ngx_http_v3_session_t *h3c;
ngx_http_v3_srv_conf_t *h3scf;
- ngx_http_v3_connection_t *h3c;
ngx_http_v3_dynamic_table_t *dt;
h3c = ngx_http_v3_get_session(c);
static ngx_int_t
ngx_http_v3_new_header(ngx_connection_t *c)
{
- ngx_queue_t *q;
- ngx_connection_t *bc;
- ngx_http_v3_block_t *block;
- ngx_http_v3_connection_t *h3c;
+ ngx_queue_t *q;
+ ngx_connection_t *bc;
+ ngx_http_v3_block_t *block;
+ ngx_http_v3_session_t *h3c;
h3c = ngx_http_v3_get_session(c);