Mercurial > hg > nginx

comparison src/event/ngx_event_quic.c @ 8630:279ad36f2f4b quic

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
QUIC: renamed c->qs to c->quic.
author Roman Arutyunyan <arut@nginx.com>
date Tue, 10 Nov 2020 19:40:00 +0000
parents feec2cc762f6
children e167c7b4cff4
comparison
equal deleted inserted replaced
8629:feec2cc762f6 8630:279ad36f2f4b
5229 size_t rcvbuf_size; 5229 size_t rcvbuf_size;
5230 uint64_t id; 5230 uint64_t id;
5231 ngx_quic_stream_t *qs, *sn; 5231 ngx_quic_stream_t *qs, *sn;
5232 ngx_quic_connection_t *qc; 5232 ngx_quic_connection_t *qc;
5233 5233
5234 qs = c->qs; 5234 qs = c->quic;
5235 qc = ngx_quic_get_connection(qs->parent); 5235 qc = ngx_quic_get_connection(qs->parent);
5236 5236
5237 if (bidi) { 5237 if (bidi) {
5238 if (qc->streams.server_streams_bidi 5238 if (qc->streams.server_streams_bidi
5239 >= qc->streams.server_max_streams_bidi) 5239 >= qc->streams.server_max_streams_bidi)
5480 if (sn->c == NULL) { 5480 if (sn->c == NULL) {
5481 ngx_destroy_pool(pool); 5481 ngx_destroy_pool(pool);
5482 return NULL; 5482 return NULL;
5483 } 5483 }
5484 5484
5485 sn->c->qs = sn; 5485 sn->c->quic = sn;
5486 sn->c->type = SOCK_STREAM; 5486 sn->c->type = SOCK_STREAM;
5487 sn->c->pool = pool; 5487 sn->c->pool = pool;
5488 sn->c->ssl = c->ssl; 5488 sn->c->ssl = c->ssl;
5489 sn->c->sockaddr = c->sockaddr; 5489 sn->c->sockaddr = c->sockaddr;
5490 sn->c->listening = c->listening; 5490 sn->c->listening = c->listening;
5546 ngx_connection_t *pc; 5546 ngx_connection_t *pc;
5547 ngx_quic_frame_t *frame; 5547 ngx_quic_frame_t *frame;
5548 ngx_quic_stream_t *qs; 5548 ngx_quic_stream_t *qs;
5549 ngx_quic_connection_t *qc; 5549 ngx_quic_connection_t *qc;
5550 5550
5551 qs = c->qs; 5551 qs = c->quic;
5552 b = qs->b; 5552 b = qs->b;
5553 pc = qs->parent; 5553 pc = qs->parent;
5554 qc = ngx_quic_get_connection(pc); 5554 qc = ngx_quic_get_connection(pc);
5555 rev = c->read; 5555 rev = c->read;
5556 5556
5676 ngx_connection_t *pc; 5676 ngx_connection_t *pc;
5677 ngx_quic_frame_t *frame; 5677 ngx_quic_frame_t *frame;
5678 ngx_quic_stream_t *qs; 5678 ngx_quic_stream_t *qs;
5679 ngx_quic_connection_t *qc; 5679 ngx_quic_connection_t *qc;
5680 5680
5681 qs = c->qs; 5681 qs = c->quic;
5682 pc = qs->parent; 5682 pc = qs->parent;
5683 qc = ngx_quic_get_connection(pc); 5683 qc = ngx_quic_get_connection(pc);
5684 wev = c->write; 5684 wev = c->write;
5685 5685
5686 if (wev->error) { 5686 if (wev->error) {
5795 size_t size; 5795 size_t size;
5796 uint64_t sent, unacked; 5796 uint64_t sent, unacked;
5797 ngx_quic_stream_t *qs; 5797 ngx_quic_stream_t *qs;
5798 ngx_quic_connection_t *qc; 5798 ngx_quic_connection_t *qc;
5799 5799
5800 qs = c->qs; 5800 qs = c->quic;
5801 qc = ngx_quic_get_connection(qs->parent); 5801 qc = ngx_quic_get_connection(qs->parent);
5802 5802
5803 size = NGX_QUIC_STREAM_BUFSIZE; 5803 size = NGX_QUIC_STREAM_BUFSIZE;
5804 sent = c->sent; 5804 sent = c->sent;
5805 unacked = sent - qs->acked; 5805 unacked = sent - qs->acked;
5853 ngx_connection_t *pc; 5853 ngx_connection_t *pc;
5854 ngx_quic_frame_t *frame; 5854 ngx_quic_frame_t *frame;
5855 ngx_quic_stream_t *qs; 5855 ngx_quic_stream_t *qs;
5856 ngx_quic_connection_t *qc; 5856 ngx_quic_connection_t *qc;
5857 5857
5858 qs = c->qs; 5858 qs = c->quic;
5859 pc = qs->parent; 5859 pc = qs->parent;
5860 qc = ngx_quic_get_connection(pc); 5860 qc = ngx_quic_get_connection(pc);
5861 5861
5862 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, 5862 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
5863 "quic stream id:0x%xL cleanup", qs->id); 5863 "quic stream id:0x%xL cleanup", qs->id);