Mercurial > hg > nginx-quic
comparison src/event/quic/ngx_event_quic_ack.c @ 8545:4009f120cad4 quic
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); |