IntenseWebs/nginx
3
0
Fork 0
mirror of https://github.com/nginx/nginx.git synced 2025-02-25 18:55:26 -06:00
Code Issues Packages Projects Releases Wiki Activity

QUIC: refactored multiple QUIC packets handling.

Browse Source 
Single UDP datagram may contain multiple QUIC datagrams.  In order to
facilitate handling of such cases, 'first' flag in the ngx_quic_header_t
structure is introduced.
This commit is contained in:
Vladimir Homutov 2021-11-29 11:49:09 +03:00
parent e165526e43
commit b8aa869a6f
3 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/event/quic/ngx_event_quic.c
View File

@ -358,7 +358,7 @@ ngx_quic_process_stateless_reset(ngx_connection_t *c, ngx_quic_header_t *pkt)
qc = ngx_quic_get_connection(c);
/* A stateless reset uses an entire UDP datagram */
if (pkt->raw->start != pkt->data) {
if (!pkt->first) {
return NGX_DECLINED;
}
@ -666,7 +666,7 @@ static ngx_int_t
ngx_quic_input(ngx_connection_t *c, ngx_buf_t *b, ngx_quic_conf_t *conf)
{
size_t size;
u_char *p;
u_char *p, *start;
ngx_int_t rc;
ngx_uint_t good;
ngx_quic_header_t pkt;
@ -676,7 +676,7 @@ ngx_quic_input(ngx_connection_t *c, ngx_buf_t *b, ngx_quic_conf_t *conf)
size = b->last - b->pos;
p = b->pos;
p = start = b->pos;
while (p < b->last) {
@ -685,6 +685,7 @@ ngx_quic_input(ngx_connection_t *c, ngx_buf_t *b, ngx_quic_conf_t *conf)
pkt.data = p;
pkt.len = b->last - p;
pkt.log = c->log;
pkt.first = (p == start) ? 1 : 0;
pkt.flags = p[0];
pkt.raw->pos++;
@ -979,9 +980,11 @@ ngx_quic_process_payload(ngx_connection_t *c, ngx_quic_header_t *pkt)
pkt->decrypted = 1;
if (pkt->first) {
if (ngx_quic_update_paths(c, pkt) != NGX_OK) {
return NGX_ERROR;
}
}
if (c->ssl == NULL) {
if (ngx_quic_init_connection(c) != NGX_OK) {

5
src/event/quic/ngx_event_quic_migration.c
View File

@ -388,13 +388,8 @@ ngx_quic_update_paths(ngx_connection_t *c, ngx_quic_header_t *pkt)
update:
if (pkt->raw->start == pkt->data) {
len = pkt->raw->last - pkt->raw->start;
} else {
len = 0;
}
/* TODO: this may be too late in some cases;
* for example, if error happens during decrypt(), we cannot
* send CC, if error happens in 1st packet, due to amplification

1
src/event/quic/ngx_event_quic_transport.h
View File

@ -334,6 +334,7 @@ typedef struct {
unsigned decrypted:1;
unsigned validated:1;
unsigned retried:1;
unsigned first:1;
} ngx_quic_header_t;