Mercurial > hg > nginx-quic

comparison src/event/quic/ngx_event_quic_ack.c @ 8545:4009f120cad4 quic

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
QUIC: eliminated stream type from ngx_quic_stream_frame_t. The information about the type is contained in off/len/fin bits. Also, where possible, only the first stream type (0x08) is used for simplicity.
author Roman Arutyunyan <arut@nginx.com>
date Wed, 28 Jul 2021 13:21:47 +0300
parents 4715f3e669f1
children f3331deed357
comparison
equal deleted inserted replaced
8544:d0ef43a53a51 8545:4009f120cad4
237 case NGX_QUIC_FT_ACK: 237 case NGX_QUIC_FT_ACK:
238 case NGX_QUIC_FT_ACK_ECN: 238 case NGX_QUIC_FT_ACK_ECN:
239 ngx_quic_drop_ack_ranges(c, ctx, f->u.ack.largest); 239 ngx_quic_drop_ack_ranges(c, ctx, f->u.ack.largest);
240 break; 240 break;
241 241
242 case NGX_QUIC_FT_STREAM0: 242 case NGX_QUIC_FT_STREAM:
243 case NGX_QUIC_FT_STREAM1:
244 case NGX_QUIC_FT_STREAM2:
245 case NGX_QUIC_FT_STREAM3:
246 case NGX_QUIC_FT_STREAM4:
247 case NGX_QUIC_FT_STREAM5:
248 case NGX_QUIC_FT_STREAM6:
249 case NGX_QUIC_FT_STREAM7:
250 ngx_quic_handle_stream_ack(c, f); 243 ngx_quic_handle_stream_ack(c, f);
251 break; 244 break;
252 } 245 }
253 246
254 if (f->pnum == max) { 247 if (f->pnum == max) {
597 590
598 f->u.max_stream_data.limit = qs->recv_max_data; 591 f->u.max_stream_data.limit = qs->recv_max_data;
599 ngx_quic_queue_frame(qc, f); 592 ngx_quic_queue_frame(qc, f);
600 break; 593 break;
601 594
602 case NGX_QUIC_FT_STREAM0: 595 case NGX_QUIC_FT_STREAM:
603 case NGX_QUIC_FT_STREAM1:
604 case NGX_QUIC_FT_STREAM2:
605 case NGX_QUIC_FT_STREAM3:
606 case NGX_QUIC_FT_STREAM4:
607 case NGX_QUIC_FT_STREAM5:
608 case NGX_QUIC_FT_STREAM6:
609 case NGX_QUIC_FT_STREAM7:
610 qs = ngx_quic_find_stream(&qc->streams.tree, f->u.stream.stream_id); 596 qs = ngx_quic_find_stream(&qc->streams.tree, f->u.stream.stream_id);
611 597
612 if (qs && qs->connection->write->error) { 598 if (qs && qs->connection->write->error) {
613 /* RESET_STREAM was sent */ 599 /* RESET_STREAM was sent */
614 ngx_quic_free_frame(c, f); 600 ngx_quic_free_frame(c, f);