Mercurial > hg > nginx

changeset 8760:baf9551b4a5b quic

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
QUIC: renamed stream field from c to connection.
author Roman Arutyunyan <arut@nginx.com>
date Mon, 19 Apr 2021 17:21:07 +0300
parents 515ac3c8435c
children 225e9f1dfe7c
files src/event/quic/ngx_event_quic.h src/event/quic/ngx_event_quic_ack.c src/event/quic/ngx_event_quic_streams.c
diffstat 3 files changed, 44 insertions(+), 41 deletions(-) [+]
line wrap: on
line diff
--- a/src/event/quic/ngx_event_quic.h
+++ b/src/event/quic/ngx_event_quic.h
@@ -75,7 +75,7 @@ typedef struct ngx_quic_frames_stream_s 
 struct ngx_quic_stream_s {
     ngx_rbtree_node_t          node;
     ngx_connection_t          *parent;
-    ngx_connection_t          *c;
+    ngx_connection_t          *connection;
     uint64_t                   id;
     uint64_t                   acked;
     uint64_t                   send_max_data;
--- a/src/event/quic/ngx_event_quic_ack.c
+++ b/src/event/quic/ngx_event_quic_ack.c
@@ -517,7 +517,7 @@ ngx_quic_resend_frames(ngx_connection_t 
         case NGX_QUIC_FT_STREAM7:
             sn = ngx_quic_find_stream(&qc->streams.tree, f->u.stream.stream_id);
 
-            if (sn && sn->c->write->error) {
+            if (sn && sn->connection->write->error) {
                 /* RESET_STREAM was sent */
                 ngx_quic_free_frame(c, f);
                 break;
--- a/src/event/quic/ngx_event_quic_streams.c
+++ b/src/event/quic/ngx_event_quic_streams.c
@@ -89,7 +89,7 @@ ngx_quic_open_stream(ngx_connection_t *c
         return NULL;
     }
 
-    return sn->c;
+    return sn->connection;
 }
 
 
@@ -172,11 +172,11 @@ ngx_quic_close_streams(ngx_connection_t 
     {
         qs = (ngx_quic_stream_t *) node;
 
-        rev = qs->c->read;
+        rev = qs->connection->read;
         rev->error = 1;
         rev->ready = 1;
 
-        wev = qs->c->write;
+        wev = qs->connection->write;
         wev->error = 1;
         wev->ready = 1;
 
@@ -319,7 +319,7 @@ ngx_quic_create_client_stream(ngx_connec
             return NULL;
         }
 
-        sn->c->listening->handler(sn->c);
+        sn->connection->listening->handler(sn->connection);
 
         if (qc->shutdown) {
             return NGX_QUIC_STREAM_GONE;
@@ -335,6 +335,7 @@ ngx_quic_create_stream(ngx_connection_t 
 {
     ngx_log_t              *log;
     ngx_pool_t             *pool;
+    ngx_connection_t       *sc;
     ngx_quic_stream_t      *sn;
     ngx_pool_cleanup_t     *cln;
     ngx_quic_connection_t  *qc;
@@ -382,36 +383,38 @@ ngx_quic_create_stream(ngx_connection_t 
     *log = *c->log;
     pool->log = log;
 
-    sn->c = ngx_get_connection(-1, log);
-    if (sn->c == NULL) {
+    sc = ngx_get_connection(-1, log);
+    if (sc == NULL) {
         ngx_destroy_pool(pool);
         return NULL;
     }
 
-    sn->c->quic = sn;
-    sn->c->type = SOCK_STREAM;
-    sn->c->pool = pool;
-    sn->c->ssl = c->ssl;
-    sn->c->sockaddr = c->sockaddr;
-    sn->c->listening = c->listening;
-    sn->c->addr_text = c->addr_text;
-    sn->c->local_sockaddr = c->local_sockaddr;
-    sn->c->local_socklen = c->local_socklen;
-    sn->c->number = ngx_atomic_fetch_add(ngx_connection_counter, 1);
+    sn->connection = sc;
 
-    sn->c->recv = ngx_quic_stream_recv;
-    sn->c->send = ngx_quic_stream_send;
-    sn->c->send_chain = ngx_quic_stream_send_chain;
+    sc->quic = sn;
+    sc->type = SOCK_STREAM;
+    sc->pool = pool;
+    sc->ssl = c->ssl;
+    sc->sockaddr = c->sockaddr;
+    sc->listening = c->listening;
+    sc->addr_text = c->addr_text;
+    sc->local_sockaddr = c->local_sockaddr;
+    sc->local_socklen = c->local_socklen;
+    sc->number = ngx_atomic_fetch_add(ngx_connection_counter, 1);
 
-    sn->c->read->log = log;
-    sn->c->write->log = log;
+    sc->recv = ngx_quic_stream_recv;
+    sc->send = ngx_quic_stream_send;
+    sc->send_chain = ngx_quic_stream_send_chain;
 
-    log->connection = sn->c->number;
+    sc->read->log = log;
+    sc->write->log = log;
+
+    log->connection = sc->number;
 
     if ((id & NGX_QUIC_STREAM_UNIDIRECTIONAL) == 0
         || (id & NGX_QUIC_STREAM_SERVER_INITIATED))
     {
-        sn->c->write->ready = 1;
+        sc->write->ready = 1;
     }
 
     if (id & NGX_QUIC_STREAM_UNIDIRECTIONAL) {
@@ -429,13 +432,13 @@ ngx_quic_create_stream(ngx_connection_t 
 
     cln = ngx_pool_cleanup_add(pool, 0);
     if (cln == NULL) {
-        ngx_close_connection(sn->c);
+        ngx_close_connection(sc);
         ngx_destroy_pool(pool);
         return NULL;
     }
 
     cln->handler = ngx_quic_stream_cleanup_handler;
-    cln->data = sn->c;
+    cln->data = sc;
 
     ngx_rbtree_insert(&qc->streams.tree, &sn->node);
 
@@ -841,7 +844,7 @@ ngx_quic_handle_stream_frame(ngx_connect
             return NGX_OK;
         }
 
-        sc = sn->c;
+        sc = sn->connection;
         fs = sn->fs;
         b = sn->b;
         window = b->end - b->last;
@@ -921,7 +924,7 @@ ngx_quic_stream_input(ngx_connection_t *
                              cl->buf->last - cl->buf->pos);
     }
 
-    rev = sn->c->read;
+    rev = sn->connection->read;
     rev->ready = 1;
 
     if (f->fin) {
@@ -965,7 +968,7 @@ ngx_quic_handle_max_data_frame(ngx_conne
              node = ngx_rbtree_next(tree, node))
         {
             qs = (ngx_quic_stream_t *) node;
-            wev = qs->c->write;
+            wev = qs->connection->write;
 
             if (wev->active) {
                 wev->ready = 1;
@@ -1023,7 +1026,7 @@ ngx_quic_handle_stream_data_blocked_fram
         b = sn->b;
         n = b->end - b->last;
 
-        sn->c->listening->handler(sn->c);
+        sn->connection->listening->handler(sn->connection);
 
     } else {
         b = sn->b;
@@ -1081,7 +1084,7 @@ ngx_quic_handle_max_stream_data_frame(ng
             sn->send_max_data = f->limit;
         }
 
-        sn->c->listening->handler(sn->c);
+        sn->connection->listening->handler(sn->connection);
 
         return NGX_OK;
     }
@@ -1090,10 +1093,10 @@ ngx_quic_handle_max_stream_data_frame(ng
         return NGX_OK;
     }
 
-    sent = sn->c->sent;
+    sent = sn->connection->sent;
 
     if (sent >= sn->send_max_data) {
-        wev = sn->c->write;
+        wev = sn->connection->write;
 
         if (wev->active) {
             wev->ready = 1;
@@ -1138,7 +1141,7 @@ ngx_quic_handle_reset_stream_frame(ngx_c
             return NGX_OK;
         }
 
-        sc = sn->c;
+        sc = sn->connection;
 
         rev = sc->read;
         rev->error = 1;
@@ -1149,7 +1152,7 @@ ngx_quic_handle_reset_stream_frame(ngx_c
         return NGX_OK;
     }
 
-    rev = sn->c->read;
+    rev = sn->connection->read;
     rev->error = 1;
     rev->ready = 1;
 
@@ -1192,7 +1195,7 @@ ngx_quic_handle_stop_sending_frame(ngx_c
             return NGX_OK;
         }
 
-        sc = sn->c;
+        sc = sn->connection;
 
         wev = sc->write;
         wev->error = 1;
@@ -1203,7 +1206,7 @@ ngx_quic_handle_stop_sending_frame(ngx_c
         return NGX_OK;
     }
 
-    wev = sn->c->write;
+    wev = sn->connection->write;
     wev->error = 1;
     wev->ready = 1;
 
@@ -1259,8 +1262,8 @@ ngx_quic_handle_stream_ack(ngx_connectio
         return;
     }
 
-    wev = sn->c->write;
-    sent = sn->c->sent;
+    wev = sn->connection->write;
+    sent = sn->connection->sent;
     unacked = sent - sn->acked;
 
     if (unacked >= NGX_QUIC_STREAM_BUFSIZE && wev->active) {
@@ -1270,7 +1273,7 @@ ngx_quic_handle_stream_ack(ngx_connectio
 
     sn->acked += f->u.stream.length;
 
-    ngx_log_debug3(NGX_LOG_DEBUG_EVENT, sn->c->log, 0,
+    ngx_log_debug3(NGX_LOG_DEBUG_EVENT, sn->connection->log, 0,
                    "quic stream ack len:%uL acked:%uL unacked:%uL",
                    f->u.stream.length, sn->acked, sent - sn->acked);
 }