Mercurial > hg > nginx
annotate src/event/quic/ngx_event_quic_socket.c @ 8955:32daba3aabb2 quic
QUIC: got rid of ngx_quic_create_temp_socket().
It was mostly copy of the ngx_quic_listen(). Now ngx_quic_listen() no
longer generates server id and increments seqnum. Instead, the server
id is generated when the socket is created.
The ngx_quic_alloc_socket() function is renamed to ngx_quic_create_socket().
| author | Vladimir Homutov <vl@nginx.com> |
|---|---|
| date | Mon, 27 Dec 2021 13:49:56 +0300 |
| parents | fb41e37ddeb0 |
| children | 1e2f4e9c8195 |
| rev | line source |
|---|---|
| 8763 | 1 |
| 2 /* | |
| 3 * Copyright (C) Nginx, Inc. | |
| 4 */ | |
| 5 | |
| 6 | |
| 7 #include <ngx_config.h> | |
| 8 #include <ngx_core.h> | |
| 9 #include <ngx_event.h> | |
| 10 #include <ngx_event_quic_connection.h> | |
| 11 | |
| 12 | |
| 13 ngx_int_t | |
| 14 ngx_quic_open_sockets(ngx_connection_t *c, ngx_quic_connection_t *qc, | |
| 15 ngx_quic_header_t *pkt) | |
| 16 { | |
| 17 ngx_quic_path_t *path; | |
|
8955
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
18 ngx_quic_socket_t *qsock, *tmp; |
| 8763 | 19 ngx_quic_client_id_t *cid; |
| 20 | |
| 21 /* | |
| 22 * qc->nclient_ids = 0 | |
| 23 * qc->nsockets = 0 | |
| 24 * qc->max_retired_seqnum = 0 | |
| 25 * qc->client_seqnum = 0 | |
| 26 */ | |
| 27 | |
| 28 ngx_queue_init(&qc->sockets); | |
| 29 ngx_queue_init(&qc->free_sockets); | |
| 30 | |
| 31 ngx_queue_init(&qc->paths); | |
| 32 ngx_queue_init(&qc->free_paths); | |
| 33 | |
| 34 ngx_queue_init(&qc->client_ids); | |
| 35 ngx_queue_init(&qc->free_client_ids); | |
| 36 | |
| 37 qc->tp.original_dcid.len = pkt->odcid.len; | |
| 38 qc->tp.original_dcid.data = ngx_pstrdup(c->pool, &pkt->odcid); | |
| 39 if (qc->tp.original_dcid.data == NULL) { | |
| 40 return NGX_ERROR; | |
| 41 } | |
| 42 | |
|
8955
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
43 /* socket to use for further processing (id auto-generated) */ |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
44 qsock = ngx_quic_create_socket(c, qc); |
| 8763 | 45 if (qsock == NULL) { |
| 46 return NGX_ERROR; | |
| 47 } | |
| 48 | |
|
8955
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
49 /* socket is listening at new server id */ |
| 8763 | 50 if (ngx_quic_listen(c, qc, qsock) != NGX_OK) { |
| 51 return NGX_ERROR; | |
| 52 } | |
| 53 | |
| 54 qc->tp.initial_scid.len = qsock->sid.len; | |
| 55 qc->tp.initial_scid.data = ngx_pnalloc(c->pool, qsock->sid.len); | |
| 56 if (qc->tp.initial_scid.data == NULL) { | |
| 57 goto failed; | |
| 58 } | |
| 59 ngx_memcpy(qc->tp.initial_scid.data, qsock->sid.id, qsock->sid.len); | |
| 60 | |
| 61 /* for all packets except first, this is set at udp layer */ | |
| 62 c->udp = &qsock->udp; | |
| 63 | |
| 64 /* ngx_quic_get_connection(c) macro is now usable */ | |
| 65 | |
| 66 /* we have a client identified by scid */ | |
| 67 cid = ngx_quic_create_client_id(c, &pkt->scid, 0, NULL); | |
| 68 if (cid == NULL) { | |
| 69 goto failed; | |
| 70 } | |
| 71 | |
| 72 /* the client arrived from this path */ | |
| 73 path = ngx_quic_add_path(c, c->sockaddr, c->socklen); | |
| 74 if (path == NULL) { | |
| 75 goto failed; | |
| 76 } | |
| 77 | |
| 78 if (pkt->validated) { | |
| 79 path->state = NGX_QUIC_PATH_VALIDATED; | |
|
8940
fb41e37ddeb0
QUIC: decoupled path state and limitation status.
Vladimir Homutov <vl@nginx.com>
parents:
8939
diff
changeset
|
80 path->limited = 0; |
| 8763 | 81 } |
| 82 | |
| 83 /* now bind socket to client and path */ | |
| 84 ngx_quic_connect(c, qsock, path, cid); | |
| 85 | |
|
8955
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
86 tmp = ngx_pcalloc(c->pool, sizeof(ngx_quic_socket_t)); |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
87 if (tmp == NULL) { |
| 8763 | 88 goto failed; |
| 89 } | |
| 90 | |
|
8955
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
91 tmp->sid.seqnum = NGX_QUIC_UNSET_PN; /* temporary socket */ |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
92 |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
93 ngx_memcpy(tmp->sid.id, pkt->odcid.data, pkt->odcid.len); |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
94 tmp->sid.len = pkt->odcid.len; |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
95 |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
96 if (ngx_quic_listen(c, qc, tmp) != NGX_OK) { |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
97 goto failed; |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
98 } |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
99 |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
100 ngx_quic_connect(c, tmp, path, cid); |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
101 |
| 8763 | 102 /* use this socket as default destination */ |
| 103 qc->socket = qsock; | |
| 104 | |
| 105 ngx_log_debug4(NGX_LOG_DEBUG_EVENT, c->log, 0, | |
| 106 "quic active socket is #%uL:%uL:%uL (%s)", | |
| 107 qsock->sid.seqnum, qsock->cid->seqnum, qsock->path->seqnum, | |
| 108 ngx_quic_path_state_str(qsock->path)); | |
| 109 | |
| 110 return NGX_OK; | |
| 111 | |
| 112 failed: | |
| 113 | |
| 114 ngx_rbtree_delete(&c->listening->rbtree, &qsock->udp.node); | |
| 115 c->udp = NULL; | |
| 116 | |
| 117 return NGX_ERROR; | |
| 118 } | |
| 119 | |
| 120 | |
| 121 ngx_quic_socket_t * | |
|
8955
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
122 ngx_quic_create_socket(ngx_connection_t *c, ngx_quic_connection_t *qc) |
| 8763 | 123 { |
| 124 ngx_queue_t *q; | |
| 125 ngx_quic_socket_t *sock; | |
| 126 | |
| 127 if (!ngx_queue_empty(&qc->free_sockets)) { | |
| 128 | |
| 129 q = ngx_queue_head(&qc->free_sockets); | |
| 130 sock = ngx_queue_data(q, ngx_quic_socket_t, queue); | |
| 131 | |
| 132 ngx_queue_remove(&sock->queue); | |
| 133 | |
| 134 ngx_memzero(sock, sizeof(ngx_quic_socket_t)); | |
| 135 | |
| 136 } else { | |
| 137 | |
| 138 sock = ngx_pcalloc(c->pool, sizeof(ngx_quic_socket_t)); | |
| 139 if (sock == NULL) { | |
| 140 return NULL; | |
| 141 } | |
| 142 } | |
| 143 | |
|
8955
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
144 sock->sid.len = NGX_QUIC_SERVER_CID_LEN; |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
145 if (ngx_quic_create_server_id(c, sock->sid.id) != NGX_OK) { |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
146 return NULL; |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
147 } |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
148 |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
149 sock->sid.seqnum = qc->server_seqnum++; |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
150 |
| 8763 | 151 return sock; |
| 152 } | |
| 153 | |
| 154 | |
| 155 void | |
| 156 ngx_quic_close_socket(ngx_connection_t *c, ngx_quic_socket_t *qsock) | |
| 157 { | |
| 158 ngx_quic_connection_t *qc; | |
| 159 | |
| 160 qc = ngx_quic_get_connection(c); | |
| 161 | |
| 162 ngx_queue_remove(&qsock->queue); | |
| 163 ngx_queue_insert_head(&qc->free_sockets, &qsock->queue); | |
| 164 | |
| 165 ngx_rbtree_delete(&c->listening->rbtree, &qsock->udp.node); | |
| 166 qc->nsockets--; | |
| 167 | |
| 168 if (qsock->path) { | |
| 169 ngx_quic_unref_path(c, qsock->path); | |
| 170 } | |
| 171 | |
| 172 if (qsock->cid) { | |
| 173 ngx_quic_unref_client_id(c, qsock->cid); | |
| 174 } | |
| 175 | |
| 176 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0, | |
| 177 "quic socket #%L closed nsock:%ui", | |
| 178 (int64_t) qsock->sid.seqnum, qc->nsockets); | |
| 179 } | |
| 180 | |
| 181 | |
|
8911
b09f055daa4e
QUIC: fixed handling of RETIRE_CONNECTION_ID frame.
Vladimir Homutov <vl@nginx.com>
parents:
8888
diff
changeset
|
182 void |
| 8763 | 183 ngx_quic_unref_path(ngx_connection_t *c, ngx_quic_path_t *path) |
| 184 { | |
| 185 ngx_quic_connection_t *qc; | |
| 186 | |
| 187 path->refcnt--; | |
| 188 | |
| 189 if (path->refcnt) { | |
| 190 return; | |
| 191 } | |
| 192 | |
| 193 qc = ngx_quic_get_connection(c); | |
| 194 | |
| 195 ngx_queue_remove(&path->queue); | |
| 196 ngx_queue_insert_head(&qc->free_paths, &path->queue); | |
| 197 | |
| 198 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0, | |
| 199 "quic path #%uL addr:%V removed", | |
| 200 path->seqnum, &path->addr_text); | |
| 201 } | |
| 202 | |
| 203 | |
| 204 ngx_int_t | |
| 205 ngx_quic_listen(ngx_connection_t *c, ngx_quic_connection_t *qc, | |
| 206 ngx_quic_socket_t *qsock) | |
| 207 { | |
| 208 ngx_str_t id; | |
| 209 ngx_quic_server_id_t *sid; | |
| 210 | |
| 211 sid = &qsock->sid; | |
| 212 | |
| 213 id.data = sid->id; | |
| 214 id.len = sid->len; | |
| 215 | |
| 216 ngx_insert_udp_connection(c, &qsock->udp, &id); | |
| 217 | |
| 218 ngx_queue_insert_tail(&qc->sockets, &qsock->queue); | |
| 219 | |
| 220 qc->nsockets++; | |
| 221 qsock->quic = qc; | |
| 222 | |
| 223 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0, | |
|
8955
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
224 "quic socket #%L listening at sid:%xV nsock:%ui", |
|
32daba3aabb2
QUIC: got rid of ngx_quic_create_temp_socket().
Vladimir Homutov <vl@nginx.com>
parents:
8940
diff
changeset
|
225 (int64_t) sid->seqnum, &id, qc->nsockets); |
| 8763 | 226 |
| 227 return NGX_OK; | |
| 228 } | |
| 229 | |
| 230 | |
| 231 void | |
| 232 ngx_quic_connect(ngx_connection_t *c, ngx_quic_socket_t *sock, | |
| 233 ngx_quic_path_t *path, ngx_quic_client_id_t *cid) | |
| 234 { | |
| 235 sock->path = path; | |
| 236 path->refcnt++; | |
| 237 | |
| 238 sock->cid = cid; | |
| 239 cid->refcnt++; | |
| 240 | |
| 241 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0, | |
| 242 "quic socket #%L connected to cid #%uL path:%uL", | |
| 243 (int64_t) sock->sid.seqnum, | |
| 244 sock->cid->seqnum, path->seqnum); | |
| 245 } | |
| 246 | |
| 247 | |
| 248 void | |
| 249 ngx_quic_close_sockets(ngx_connection_t *c) | |
| 250 { | |
| 251 ngx_queue_t *q; | |
| 252 ngx_quic_socket_t *qsock; | |
| 253 ngx_quic_connection_t *qc; | |
| 254 | |
| 255 qc = ngx_quic_get_connection(c); | |
| 256 | |
| 257 while (!ngx_queue_empty(&qc->sockets)) { | |
| 258 q = ngx_queue_head(&qc->sockets); | |
| 259 qsock = ngx_queue_data(q, ngx_quic_socket_t, queue); | |
| 260 | |
| 261 ngx_quic_close_socket(c, qsock); | |
| 262 } | |
| 263 } | |
| 264 | |
| 265 | |
| 266 ngx_quic_socket_t * | |
| 267 ngx_quic_find_socket(ngx_connection_t *c, uint64_t seqnum) | |
| 268 { | |
| 269 ngx_queue_t *q; | |
| 270 ngx_quic_socket_t *qsock; | |
| 271 ngx_quic_connection_t *qc; | |
| 272 | |
| 273 qc = ngx_quic_get_connection(c); | |
| 274 | |
| 275 for (q = ngx_queue_head(&qc->sockets); | |
| 276 q != ngx_queue_sentinel(&qc->sockets); | |
| 277 q = ngx_queue_next(q)) | |
| 278 { | |
| 279 qsock = ngx_queue_data(q, ngx_quic_socket_t, queue); | |
| 280 | |
| 281 if (qsock->sid.seqnum == seqnum) { | |
| 282 return qsock; | |
| 283 } | |
| 284 } | |
| 285 | |
| 286 return NULL; | |
| 287 } | |
| 288 | |
| 289 | |
| 290 ngx_quic_socket_t * | |
| 291 ngx_quic_get_unconnected_socket(ngx_connection_t *c) | |
| 292 { | |
| 293 ngx_queue_t *q; | |
| 294 ngx_quic_socket_t *sock; | |
| 295 ngx_quic_connection_t *qc; | |
| 296 | |
| 297 qc = ngx_quic_get_connection(c); | |
| 298 | |
| 299 for (q = ngx_queue_head(&qc->sockets); | |
| 300 q != ngx_queue_sentinel(&qc->sockets); | |
| 301 q = ngx_queue_next(q)) | |
| 302 { | |
| 303 sock = ngx_queue_data(q, ngx_quic_socket_t, queue); | |
| 304 | |
| 305 if (sock->cid == NULL) { | |
| 306 return sock; | |
| 307 } | |
| 308 } | |
| 309 | |
| 310 return NULL; | |
| 8888 | 311 } |