Mercurial > hg > nginx-quic
view src/event/quic/ngx_event_quic.h @ 9078:9553eea74f2a quic
QUIC: optimized immediate close.
Previously, before sending CONNECTION_CLOSE to client, all pending frames
were sent. This is redundant and could prevent CONNECTION_CLOSE from being
sent due to congestion control. Now pending frames are freed and
CONNECTION_CLOSE is sent without congestion control, as advised by RFC 9002:
Packets containing frames besides ACK or CONNECTION_CLOSE frames
count toward congestion control limits and are considered to be in flight.
author | Roman Arutyunyan <arut@nginx.com> |
---|---|
date | Tue, 02 May 2023 17:54:53 +0400 |
parents | 35e27117b593 |
children | b9230e37b8a1 |
line wrap: on
line source
/* * Copyright (C) Nginx, Inc. */ #ifndef _NGX_EVENT_QUIC_H_INCLUDED_ #define _NGX_EVENT_QUIC_H_INCLUDED_ #include <ngx_config.h> #include <ngx_core.h> #define NGX_QUIC_MAX_UDP_PAYLOAD_SIZE 65527 #define NGX_QUIC_DEFAULT_ACK_DELAY_EXPONENT 3 #define NGX_QUIC_DEFAULT_MAX_ACK_DELAY 25 #define NGX_QUIC_DEFAULT_HOST_KEY_LEN 32 #define NGX_QUIC_SR_KEY_LEN 32 #define NGX_QUIC_AV_KEY_LEN 32 #define NGX_QUIC_SR_TOKEN_LEN 16 #define NGX_QUIC_MIN_INITIAL_SIZE 1200 #define NGX_QUIC_STREAM_SERVER_INITIATED 0x01 #define NGX_QUIC_STREAM_UNIDIRECTIONAL 0x02 typedef ngx_int_t (*ngx_quic_init_pt)(ngx_connection_t *c); typedef void (*ngx_quic_shutdown_pt)(ngx_connection_t *c); typedef enum { NGX_QUIC_STREAM_SEND_READY = 0, NGX_QUIC_STREAM_SEND_SEND, NGX_QUIC_STREAM_SEND_DATA_SENT, NGX_QUIC_STREAM_SEND_DATA_RECVD, NGX_QUIC_STREAM_SEND_RESET_SENT, NGX_QUIC_STREAM_SEND_RESET_RECVD } ngx_quic_stream_send_state_e; typedef enum { NGX_QUIC_STREAM_RECV_RECV = 0, NGX_QUIC_STREAM_RECV_SIZE_KNOWN, NGX_QUIC_STREAM_RECV_DATA_RECVD, NGX_QUIC_STREAM_RECV_DATA_READ, NGX_QUIC_STREAM_RECV_RESET_RECVD, NGX_QUIC_STREAM_RECV_RESET_READ } ngx_quic_stream_recv_state_e; typedef struct { uint64_t size; uint64_t offset; uint64_t last_offset; ngx_chain_t *chain; ngx_chain_t *last_chain; } ngx_quic_buffer_t; typedef struct { ngx_ssl_t *ssl; ngx_flag_t retry; ngx_flag_t gso_enabled; ngx_flag_t disable_active_migration; ngx_msec_t timeout; ngx_str_t host_key; size_t mtu; size_t stream_buffer_size; ngx_uint_t max_concurrent_streams_bidi; ngx_uint_t max_concurrent_streams_uni; ngx_uint_t active_connection_id_limit; ngx_int_t stream_close_code; ngx_int_t stream_reject_code_uni; ngx_int_t stream_reject_code_bidi; ngx_quic_init_pt init; ngx_quic_shutdown_pt shutdown; u_char av_token_key[NGX_QUIC_AV_KEY_LEN]; u_char sr_token_key[NGX_QUIC_SR_KEY_LEN]; } ngx_quic_conf_t; struct ngx_quic_stream_s { ngx_rbtree_node_t node; ngx_queue_t queue; ngx_connection_t *parent; ngx_connection_t *connection; uint64_t id; uint64_t sent; uint64_t acked; uint64_t send_max_data; uint64_t send_offset; uint64_t send_final_size; uint64_t recv_max_data; uint64_t recv_offset; uint64_t recv_window; uint64_t recv_last; uint64_t recv_final_size; ngx_quic_buffer_t send; ngx_quic_buffer_t recv; ngx_quic_stream_send_state_e send_state; ngx_quic_stream_recv_state_e recv_state; unsigned cancelable:1; unsigned fin_acked:1; }; void ngx_quic_recvmsg(ngx_event_t *ev); void ngx_quic_rbtree_insert_value(ngx_rbtree_node_t *temp, ngx_rbtree_node_t *node, ngx_rbtree_node_t *sentinel); void ngx_quic_run(ngx_connection_t *c, ngx_quic_conf_t *conf); ngx_connection_t *ngx_quic_open_stream(ngx_connection_t *c, ngx_uint_t bidi); void ngx_quic_finalize_connection(ngx_connection_t *c, ngx_uint_t err, const char *reason); void ngx_quic_shutdown_connection(ngx_connection_t *c, ngx_uint_t err, const char *reason); ngx_int_t ngx_quic_reset_stream(ngx_connection_t *c, ngx_uint_t err); ngx_int_t ngx_quic_shutdown_stream(ngx_connection_t *c, int how); void ngx_quic_cancelable_stream(ngx_connection_t *c); ngx_int_t ngx_quic_get_packet_dcid(ngx_log_t *log, u_char *data, size_t len, ngx_str_t *dcid); ngx_int_t ngx_quic_derive_key(ngx_log_t *log, const char *label, ngx_str_t *secret, ngx_str_t *salt, u_char *out, size_t len); #endif /* _NGX_EVENT_QUIC_H_INCLUDED_ */