• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
2  * nghttp2 - HTTP/2 C Library
3  *
4  * Copyright (c) 2019 nghttp2 contributors
5  *
6  * Permission is hereby granted, free of charge, to any person obtaining
7  * a copy of this software and associated documentation files (the
8  * "Software"), to deal in the Software without restriction, including
9  * without limitation the rights to use, copy, modify, merge, publish,
10  * distribute, sublicense, and/or sell copies of the Software, and to
11  * permit persons to whom the Software is furnished to do so, subject to
12  * the following conditions:
13  *
14  * The above copyright notice and this permission notice shall be
15  * included in all copies or substantial portions of the Software.
16  *
17  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
18  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
19  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
20  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
21  * LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
22  * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
23  * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
24  */
25 #include "h2load_quic.h"
26 
27 #include <netinet/udp.h>
28 
29 #include <iostream>
30 
31 #ifdef HAVE_LIBNGTCP2_CRYPTO_QUICTLS
32 #  include <ngtcp2/ngtcp2_crypto_quictls.h>
33 #endif // HAVE_LIBNGTCP2_CRYPTO_QUICTLS
34 #ifdef HAVE_LIBNGTCP2_CRYPTO_BORINGSSL
35 #  include <ngtcp2/ngtcp2_crypto_boringssl.h>
36 #endif // HAVE_LIBNGTCP2_CRYPTO_BORINGSSL
37 
38 #include "ssl_compat.h"
39 
40 #ifdef NGHTTP2_OPENSSL_IS_WOLFSSL
41 #  include <wolfssl/options.h>
42 #  include <wolfssl/openssl/err.h>
43 #  include <wolfssl/openssl/rand.h>
44 #else // !NGHTTP2_OPENSSL_IS_WOLFSSL
45 #  include <openssl/err.h>
46 #  include <openssl/rand.h>
47 #endif // !NGHTTP2_OPENSSL_IS_WOLFSSL
48 
49 #include "h2load_http3_session.h"
50 
51 namespace h2load {
52 
53 namespace {
handshake_completed(ngtcp2_conn * conn,void * user_data)54 int handshake_completed(ngtcp2_conn *conn, void *user_data) {
55   auto c = static_cast<Client *>(user_data);
56 
57   if (c->quic_handshake_completed() != 0) {
58     return NGTCP2_ERR_CALLBACK_FAILURE;
59   }
60 
61   return 0;
62 }
63 } // namespace
64 
quic_handshake_completed()65 int Client::quic_handshake_completed() { return connection_made(); }
66 
67 namespace {
recv_stream_data(ngtcp2_conn * conn,uint32_t flags,int64_t stream_id,uint64_t offset,const uint8_t * data,size_t datalen,void * user_data,void * stream_user_data)68 int recv_stream_data(ngtcp2_conn *conn, uint32_t flags, int64_t stream_id,
69                      uint64_t offset, const uint8_t *data, size_t datalen,
70                      void *user_data, void *stream_user_data) {
71   auto c = static_cast<Client *>(user_data);
72   if (c->quic_recv_stream_data(flags, stream_id, data, datalen) != 0) {
73     // TODO Better to do this gracefully rather than
74     // NGTCP2_ERR_CALLBACK_FAILURE.  Perhaps, call
75     // ngtcp2_conn_write_application_close() ?
76     return NGTCP2_ERR_CALLBACK_FAILURE;
77   }
78   return 0;
79 }
80 } // namespace
81 
quic_recv_stream_data(uint32_t flags,int64_t stream_id,const uint8_t * data,size_t datalen)82 int Client::quic_recv_stream_data(uint32_t flags, int64_t stream_id,
83                                   const uint8_t *data, size_t datalen) {
84   if (worker->current_phase == Phase::MAIN_DURATION) {
85     worker->stats.bytes_total += datalen;
86   }
87 
88   auto s = static_cast<Http3Session *>(session.get());
89   auto nconsumed = s->read_stream(flags, stream_id, data, datalen);
90   if (nconsumed == -1) {
91     return -1;
92   }
93 
94   ngtcp2_conn_extend_max_stream_offset(quic.conn, stream_id, nconsumed);
95   ngtcp2_conn_extend_max_offset(quic.conn, nconsumed);
96 
97   return 0;
98 }
99 
100 namespace {
acked_stream_data_offset(ngtcp2_conn * conn,int64_t stream_id,uint64_t offset,uint64_t datalen,void * user_data,void * stream_user_data)101 int acked_stream_data_offset(ngtcp2_conn *conn, int64_t stream_id,
102                              uint64_t offset, uint64_t datalen, void *user_data,
103                              void *stream_user_data) {
104   auto c = static_cast<Client *>(user_data);
105   if (c->quic_acked_stream_data_offset(stream_id, datalen) != 0) {
106     return NGTCP2_ERR_CALLBACK_FAILURE;
107   }
108   return 0;
109 }
110 } // namespace
111 
quic_acked_stream_data_offset(int64_t stream_id,size_t datalen)112 int Client::quic_acked_stream_data_offset(int64_t stream_id, size_t datalen) {
113   auto s = static_cast<Http3Session *>(session.get());
114   if (s->add_ack_offset(stream_id, datalen) != 0) {
115     return -1;
116   }
117   return 0;
118 }
119 
120 namespace {
stream_close(ngtcp2_conn * conn,uint32_t flags,int64_t stream_id,uint64_t app_error_code,void * user_data,void * stream_user_data)121 int stream_close(ngtcp2_conn *conn, uint32_t flags, int64_t stream_id,
122                  uint64_t app_error_code, void *user_data,
123                  void *stream_user_data) {
124   auto c = static_cast<Client *>(user_data);
125 
126   if (!(flags & NGTCP2_STREAM_CLOSE_FLAG_APP_ERROR_CODE_SET)) {
127     app_error_code = NGHTTP3_H3_NO_ERROR;
128   }
129 
130   if (c->quic_stream_close(stream_id, app_error_code) != 0) {
131     return NGTCP2_ERR_CALLBACK_FAILURE;
132   }
133   return 0;
134 }
135 } // namespace
136 
quic_stream_close(int64_t stream_id,uint64_t app_error_code)137 int Client::quic_stream_close(int64_t stream_id, uint64_t app_error_code) {
138   auto s = static_cast<Http3Session *>(session.get());
139   if (s->close_stream(stream_id, app_error_code) != 0) {
140     return -1;
141   }
142   return 0;
143 }
144 
145 namespace {
stream_reset(ngtcp2_conn * conn,int64_t stream_id,uint64_t final_size,uint64_t app_error_code,void * user_data,void * stream_user_data)146 int stream_reset(ngtcp2_conn *conn, int64_t stream_id, uint64_t final_size,
147                  uint64_t app_error_code, void *user_data,
148                  void *stream_user_data) {
149   auto c = static_cast<Client *>(user_data);
150   if (c->quic_stream_reset(stream_id, app_error_code) != 0) {
151     return NGTCP2_ERR_CALLBACK_FAILURE;
152   }
153   return 0;
154 }
155 } // namespace
156 
quic_stream_reset(int64_t stream_id,uint64_t app_error_code)157 int Client::quic_stream_reset(int64_t stream_id, uint64_t app_error_code) {
158   auto s = static_cast<Http3Session *>(session.get());
159   if (s->shutdown_stream_read(stream_id) != 0) {
160     return -1;
161   }
162   return 0;
163 }
164 
165 namespace {
stream_stop_sending(ngtcp2_conn * conn,int64_t stream_id,uint64_t app_error_code,void * user_data,void * stream_user_data)166 int stream_stop_sending(ngtcp2_conn *conn, int64_t stream_id,
167                         uint64_t app_error_code, void *user_data,
168                         void *stream_user_data) {
169   auto c = static_cast<Client *>(user_data);
170   if (c->quic_stream_stop_sending(stream_id, app_error_code) != 0) {
171     return NGTCP2_ERR_CALLBACK_FAILURE;
172   }
173   return 0;
174 }
175 } // namespace
176 
quic_stream_stop_sending(int64_t stream_id,uint64_t app_error_code)177 int Client::quic_stream_stop_sending(int64_t stream_id,
178                                      uint64_t app_error_code) {
179   auto s = static_cast<Http3Session *>(session.get());
180   if (s->shutdown_stream_read(stream_id) != 0) {
181     return -1;
182   }
183   return 0;
184 }
185 
186 namespace {
extend_max_local_streams_bidi(ngtcp2_conn * conn,uint64_t max_streams,void * user_data)187 int extend_max_local_streams_bidi(ngtcp2_conn *conn, uint64_t max_streams,
188                                   void *user_data) {
189   auto c = static_cast<Client *>(user_data);
190 
191   if (c->quic_extend_max_local_streams() != 0) {
192     return NGTCP2_ERR_CALLBACK_FAILURE;
193   }
194 
195   return 0;
196 }
197 } // namespace
198 
quic_extend_max_local_streams()199 int Client::quic_extend_max_local_streams() {
200   auto s = static_cast<Http3Session *>(session.get());
201   if (s->extend_max_local_streams() != 0) {
202     return NGTCP2_ERR_CALLBACK_FAILURE;
203   }
204   return 0;
205 }
206 
207 namespace {
extend_max_stream_data(ngtcp2_conn * conn,int64_t stream_id,uint64_t max_data,void * user_data,void * stream_user_data)208 int extend_max_stream_data(ngtcp2_conn *conn, int64_t stream_id,
209                            uint64_t max_data, void *user_data,
210                            void *stream_user_data) {
211   auto c = static_cast<Client *>(user_data);
212 
213   if (c->quic_extend_max_stream_data(stream_id) != 0) {
214     return NGTCP2_ERR_CALLBACK_FAILURE;
215   }
216 
217   return 0;
218 }
219 } // namespace
220 
quic_extend_max_stream_data(int64_t stream_id)221 int Client::quic_extend_max_stream_data(int64_t stream_id) {
222   auto s = static_cast<Http3Session *>(session.get());
223   if (s->unblock_stream(stream_id) != 0) {
224     return -1;
225   }
226   return 0;
227 }
228 
229 namespace {
get_new_connection_id(ngtcp2_conn * conn,ngtcp2_cid * cid,uint8_t * token,size_t cidlen,void * user_data)230 int get_new_connection_id(ngtcp2_conn *conn, ngtcp2_cid *cid, uint8_t *token,
231                           size_t cidlen, void *user_data) {
232   if (RAND_bytes(cid->data, cidlen) != 1) {
233     return NGTCP2_ERR_CALLBACK_FAILURE;
234   }
235 
236   cid->datalen = cidlen;
237 
238   if (RAND_bytes(token, NGTCP2_STATELESS_RESET_TOKENLEN) != 1) {
239     return NGTCP2_ERR_CALLBACK_FAILURE;
240   }
241 
242   return 0;
243 }
244 } // namespace
245 
246 namespace {
debug_log_printf(void * user_data,const char * fmt,...)247 void debug_log_printf(void *user_data, const char *fmt, ...) {
248   va_list ap;
249 
250   va_start(ap, fmt);
251   vfprintf(stderr, fmt, ap);
252   va_end(ap);
253 
254   fprintf(stderr, "\n");
255 }
256 } // namespace
257 
258 namespace {
generate_cid(ngtcp2_cid & dest)259 int generate_cid(ngtcp2_cid &dest) {
260   dest.datalen = 8;
261 
262   if (RAND_bytes(dest.data, dest.datalen) != 1) {
263     return -1;
264   }
265 
266   return 0;
267 }
268 } // namespace
269 
270 namespace {
quic_timestamp()271 ngtcp2_tstamp quic_timestamp() {
272   return std::chrono::duration_cast<std::chrono::nanoseconds>(
273            std::chrono::steady_clock::now().time_since_epoch())
274     .count();
275 }
276 } // namespace
277 
278 // qlog write callback -- excerpted from ngtcp2/examples/client_base.cc
279 namespace {
qlog_write_cb(void * user_data,uint32_t flags,const void * data,size_t datalen)280 void qlog_write_cb(void *user_data, uint32_t flags, const void *data,
281                    size_t datalen) {
282   auto c = static_cast<Client *>(user_data);
283   c->quic_write_qlog(data, datalen);
284 }
285 } // namespace
286 
quic_write_qlog(const void * data,size_t datalen)287 void Client::quic_write_qlog(const void *data, size_t datalen) {
288   assert(quic.qlog_file != nullptr);
289   fwrite(data, 1, datalen, quic.qlog_file);
290 }
291 
292 namespace {
rand(uint8_t * dest,size_t destlen,const ngtcp2_rand_ctx * rand_ctx)293 void rand(uint8_t *dest, size_t destlen, const ngtcp2_rand_ctx *rand_ctx) {
294   util::random_bytes(dest, dest + destlen,
295                      *static_cast<std::mt19937 *>(rand_ctx->native_handle));
296 }
297 } // namespace
298 
299 namespace {
recv_rx_key(ngtcp2_conn * conn,ngtcp2_encryption_level level,void * user_data)300 int recv_rx_key(ngtcp2_conn *conn, ngtcp2_encryption_level level,
301                 void *user_data) {
302   if (level != NGTCP2_ENCRYPTION_LEVEL_1RTT) {
303     return 0;
304   }
305 
306   auto c = static_cast<Client *>(user_data);
307 
308   if (c->quic_make_http3_session() != 0) {
309     return NGTCP2_ERR_CALLBACK_FAILURE;
310   }
311 
312   return 0;
313 }
314 } // namespace
315 
quic_make_http3_session()316 int Client::quic_make_http3_session() {
317   auto s = std::make_unique<Http3Session>(this);
318   if (s->init_conn() == -1) {
319     return -1;
320   }
321   session = std::move(s);
322 
323   return 0;
324 }
325 
326 namespace {
get_conn(ngtcp2_crypto_conn_ref * conn_ref)327 ngtcp2_conn *get_conn(ngtcp2_crypto_conn_ref *conn_ref) {
328   auto c = static_cast<Client *>(conn_ref->user_data);
329   return c->quic.conn;
330 }
331 } // namespace
332 
quic_init(const sockaddr * local_addr,socklen_t local_addrlen,const sockaddr * remote_addr,socklen_t remote_addrlen)333 int Client::quic_init(const sockaddr *local_addr, socklen_t local_addrlen,
334                       const sockaddr *remote_addr, socklen_t remote_addrlen) {
335   int rv;
336 
337   if (!ssl) {
338     ssl = SSL_new(worker->ssl_ctx);
339 
340     quic.conn_ref.get_conn = get_conn;
341     quic.conn_ref.user_data = this;
342 
343     SSL_set_app_data(ssl, &quic.conn_ref);
344     SSL_set_connect_state(ssl);
345     SSL_set_quic_use_legacy_codepoint(ssl, 0);
346   }
347 
348   auto callbacks = ngtcp2_callbacks{
349     ngtcp2_crypto_client_initial_cb,
350     nullptr, // recv_client_initial
351     ngtcp2_crypto_recv_crypto_data_cb,
352     h2load::handshake_completed,
353     nullptr, // recv_version_negotiation
354     ngtcp2_crypto_encrypt_cb,
355     ngtcp2_crypto_decrypt_cb,
356     ngtcp2_crypto_hp_mask_cb,
357     h2load::recv_stream_data,
358     h2load::acked_stream_data_offset,
359     nullptr, // stream_open
360     h2load::stream_close,
361     nullptr, // recv_stateless_reset
362     ngtcp2_crypto_recv_retry_cb,
363     h2load::extend_max_local_streams_bidi,
364     nullptr, // extend_max_local_streams_uni
365     h2load::rand,
366     get_new_connection_id,
367     nullptr, // remove_connection_id
368     ngtcp2_crypto_update_key_cb,
369     nullptr, // path_validation
370     nullptr, // select_preferred_addr
371     h2load::stream_reset,
372     nullptr, // extend_max_remote_streams_bidi
373     nullptr, // extend_max_remote_streams_uni
374     h2load::extend_max_stream_data,
375     nullptr, // dcid_status
376     nullptr, // handshake_confirmed
377     nullptr, // recv_new_token
378     ngtcp2_crypto_delete_crypto_aead_ctx_cb,
379     ngtcp2_crypto_delete_crypto_cipher_ctx_cb,
380     nullptr, // recv_datagram
381     nullptr, // ack_datagram
382     nullptr, // lost_datagram
383     ngtcp2_crypto_get_path_challenge_data_cb,
384     h2load::stream_stop_sending,
385     nullptr, // version_negotiation
386     h2load::recv_rx_key,
387     nullptr, // recv_tx_key
388   };
389 
390   ngtcp2_cid scid, dcid;
391   if (generate_cid(scid) != 0) {
392     return -1;
393   }
394   if (generate_cid(dcid) != 0) {
395     return -1;
396   }
397 
398   auto config = worker->config;
399 
400   ngtcp2_settings settings;
401   ngtcp2_settings_default(&settings);
402   if (config->verbose) {
403     settings.log_printf = debug_log_printf;
404   }
405   settings.initial_ts = quic_timestamp();
406   settings.rand_ctx.native_handle = &worker->randgen;
407   if (!config->qlog_file_base.empty()) {
408     assert(quic.qlog_file == nullptr);
409     auto path = config->qlog_file_base;
410     path += '.';
411     path += util::utos(worker->id);
412     path += '.';
413     path += util::utos(id);
414     path += ".sqlog";
415     quic.qlog_file = fopen(path.c_str(), "w");
416     if (quic.qlog_file == nullptr) {
417       std::cerr << "Failed to open a qlog file: " << path << std::endl;
418       return -1;
419     }
420     settings.qlog_write = qlog_write_cb;
421   }
422   if (config->max_udp_payload_size) {
423     settings.max_tx_udp_payload_size = config->max_udp_payload_size;
424     settings.no_tx_udp_payload_size_shaping = 1;
425   }
426 
427   ngtcp2_transport_params params;
428   ngtcp2_transport_params_default(&params);
429   auto max_stream_data =
430     std::min((1 << 26) - 1, (1 << config->window_bits) - 1);
431   params.initial_max_stream_data_bidi_local = max_stream_data;
432   params.initial_max_stream_data_uni = max_stream_data;
433   params.initial_max_data = (1 << config->connection_window_bits) - 1;
434   params.initial_max_streams_bidi = 0;
435   params.initial_max_streams_uni = 100;
436   params.max_idle_timeout = 30 * NGTCP2_SECONDS;
437 
438   auto path = ngtcp2_path{
439     {
440       const_cast<sockaddr *>(local_addr),
441       local_addrlen,
442     },
443     {
444       const_cast<sockaddr *>(remote_addr),
445       remote_addrlen,
446     },
447   };
448 
449   assert(config->alpn_list.size());
450 
451   uint32_t quic_version;
452 
453   if (config->alpn_list[0] == NGHTTP3_ALPN_H3) {
454     quic_version = NGTCP2_PROTO_VER_V1;
455   } else {
456     quic_version = NGTCP2_PROTO_VER_MIN;
457   }
458 
459   rv = ngtcp2_conn_client_new(&quic.conn, &dcid, &scid, &path, quic_version,
460                               &callbacks, &settings, &params, nullptr, this);
461   if (rv != 0) {
462     return -1;
463   }
464 
465   ngtcp2_conn_set_tls_native_handle(quic.conn, ssl);
466 
467   return 0;
468 }
469 
quic_free()470 void Client::quic_free() {
471   ngtcp2_conn_del(quic.conn);
472   if (quic.qlog_file != nullptr) {
473     fclose(quic.qlog_file);
474     quic.qlog_file = nullptr;
475   }
476 }
477 
quic_close_connection()478 void Client::quic_close_connection() {
479   if (!quic.conn) {
480     return;
481   }
482 
483   std::array<uint8_t, NGTCP2_MAX_UDP_PAYLOAD_SIZE> buf;
484   ngtcp2_path_storage ps;
485   ngtcp2_path_storage_zero(&ps);
486 
487   auto nwrite = ngtcp2_conn_write_connection_close(
488     quic.conn, &ps.path, nullptr, buf.data(), buf.size(), &quic.last_error,
489     quic_timestamp());
490 
491   if (nwrite <= 0) {
492     return;
493   }
494 
495   write_udp(reinterpret_cast<sockaddr *>(ps.path.remote.addr),
496             ps.path.remote.addrlen, buf.data(), nwrite, 0);
497 }
498 
quic_write_client_handshake(ngtcp2_encryption_level level,const uint8_t * data,size_t datalen)499 int Client::quic_write_client_handshake(ngtcp2_encryption_level level,
500                                         const uint8_t *data, size_t datalen) {
501   int rv;
502 
503   assert(level < 2);
504 
505   rv = ngtcp2_conn_submit_crypto_data(quic.conn, level, data, datalen);
506   if (rv != 0) {
507     std::cerr << "ngtcp2_conn_submit_crypto_data: " << ngtcp2_strerror(rv)
508               << std::endl;
509     return -1;
510   }
511 
512   return 0;
513 }
514 
quic_pkt_timeout_cb(struct ev_loop * loop,ev_timer * w,int revents)515 void quic_pkt_timeout_cb(struct ev_loop *loop, ev_timer *w, int revents) {
516   auto c = static_cast<Client *>(w->data);
517 
518   if (c->quic_pkt_timeout() != 0) {
519     c->fail();
520     c->worker->free_client(c);
521     delete c;
522     return;
523   }
524 }
525 
quic_pkt_timeout()526 int Client::quic_pkt_timeout() {
527   int rv;
528   auto now = quic_timestamp();
529 
530   rv = ngtcp2_conn_handle_expiry(quic.conn, now);
531   if (rv != 0) {
532     ngtcp2_ccerr_set_liberr(&quic.last_error, rv, nullptr, 0);
533     return -1;
534   }
535 
536   return write_quic();
537 }
538 
quic_restart_pkt_timer()539 void Client::quic_restart_pkt_timer() {
540   auto expiry = ngtcp2_conn_get_expiry(quic.conn);
541   auto now = quic_timestamp();
542   auto t =
543     expiry > now ? static_cast<ev_tstamp>(expiry - now) / NGTCP2_SECONDS : 1e-9;
544   quic.pkt_timer.repeat = t;
545   ev_timer_again(worker->loop, &quic.pkt_timer);
546 }
547 
read_quic()548 int Client::read_quic() {
549   std::array<uint8_t, 64_k> buf;
550   sockaddr_union su;
551   int rv;
552   size_t pktcnt = 0;
553   ngtcp2_pkt_info pi{};
554 
555   iovec msg_iov;
556   msg_iov.iov_base = buf.data();
557   msg_iov.iov_len = buf.size();
558 
559   msghdr msg{};
560   msg.msg_name = &su;
561   msg.msg_iov = &msg_iov;
562   msg.msg_iovlen = 1;
563 
564   uint8_t msg_ctrl[CMSG_SPACE(sizeof(int))];
565   msg.msg_control = msg_ctrl;
566 
567   auto ts = quic_timestamp();
568 
569   for (;;) {
570     msg.msg_namelen = sizeof(su);
571     msg.msg_controllen = sizeof(msg_ctrl);
572 
573     auto nread = recvmsg(fd, &msg, 0);
574     if (nread == -1) {
575       return 0;
576     }
577 
578     auto gso_size = util::msghdr_get_udp_gro(&msg);
579     if (gso_size == 0) {
580       gso_size = static_cast<size_t>(nread);
581     }
582 
583     assert(quic.conn);
584 
585     if (gso_size) {
586       worker->stats.udp_dgram_recv += (nread + gso_size - 1) / gso_size;
587     } else {
588       ++worker->stats.udp_dgram_recv;
589     }
590 
591     auto path = ngtcp2_path{
592       {
593         &local_addr.su.sa,
594         static_cast<socklen_t>(local_addr.len),
595       },
596       {
597         &su.sa,
598         msg.msg_namelen,
599       },
600     };
601 
602     auto data = buf.data();
603 
604     for (;;) {
605       auto datalen = std::min(static_cast<size_t>(nread), gso_size);
606 
607       ++pktcnt;
608 
609       rv = ngtcp2_conn_read_pkt(quic.conn, &path, &pi, data, datalen, ts);
610       if (rv != 0) {
611         if (!quic.last_error.error_code) {
612           if (rv == NGTCP2_ERR_CRYPTO) {
613             ngtcp2_ccerr_set_tls_alert(&quic.last_error,
614                                        ngtcp2_conn_get_tls_alert(quic.conn),
615                                        nullptr, 0);
616           } else {
617             ngtcp2_ccerr_set_liberr(&quic.last_error, rv, nullptr, 0);
618           }
619         }
620 
621         return -1;
622       }
623 
624       nread -= datalen;
625       if (nread == 0) {
626         break;
627       }
628 
629       data += datalen;
630     }
631 
632     if (pktcnt >= 100) {
633       break;
634     }
635   }
636 
637   return 0;
638 }
639 
write_quic()640 int Client::write_quic() {
641   int rv;
642 
643   ev_io_stop(worker->loop, &wev);
644 
645   if (quic.close_requested) {
646     return -1;
647   }
648 
649   if (quic.tx.send_blocked) {
650     rv = send_blocked_packet();
651     if (rv != 0) {
652       return -1;
653     }
654 
655     if (quic.tx.send_blocked) {
656       return 0;
657     }
658   }
659 
660   std::array<nghttp3_vec, 16> vec;
661   auto max_udp_payload_size =
662     ngtcp2_conn_get_max_tx_udp_payload_size(quic.conn);
663   auto path_max_udp_payload_size =
664     ngtcp2_conn_get_path_max_tx_udp_payload_size(quic.conn);
665   uint8_t *bufpos = quic.tx.data.get();
666   auto bufleft = std::max(ngtcp2_conn_get_send_quantum(quic.conn),
667                           path_max_udp_payload_size);
668   ngtcp2_path_storage ps;
669   size_t gso_size = 0;
670 
671   ngtcp2_path_storage_zero(&ps);
672 
673   auto s = static_cast<Http3Session *>(session.get());
674   auto ts = quic_timestamp();
675 
676   for (;;) {
677     int64_t stream_id = -1;
678     int fin = 0;
679     ssize_t sveccnt = 0;
680 
681     if (session && ngtcp2_conn_get_max_data_left(quic.conn)) {
682       sveccnt = s->write_stream(stream_id, fin, vec.data(), vec.size());
683       if (sveccnt == -1) {
684         return -1;
685       }
686     }
687 
688     ngtcp2_ssize ndatalen;
689     auto v = vec.data();
690     auto vcnt = static_cast<size_t>(sveccnt);
691 
692     uint32_t flags = NGTCP2_WRITE_STREAM_FLAG_MORE;
693     if (fin) {
694       flags |= NGTCP2_WRITE_STREAM_FLAG_FIN;
695     }
696 
697     auto buflen = bufleft >= max_udp_payload_size ? max_udp_payload_size
698                                                   : path_max_udp_payload_size;
699     auto nwrite = ngtcp2_conn_writev_stream(
700       quic.conn, &ps.path, nullptr, bufpos, buflen, &ndatalen, flags, stream_id,
701       reinterpret_cast<const ngtcp2_vec *>(v), vcnt, ts);
702     if (nwrite < 0) {
703       switch (nwrite) {
704       case NGTCP2_ERR_STREAM_DATA_BLOCKED:
705         assert(ndatalen == -1);
706         s->block_stream(stream_id);
707         continue;
708       case NGTCP2_ERR_STREAM_SHUT_WR:
709         assert(ndatalen == -1);
710         s->shutdown_stream_write(stream_id);
711         continue;
712       case NGTCP2_ERR_WRITE_MORE:
713         assert(ndatalen >= 0);
714         if (s->add_write_offset(stream_id, ndatalen) != 0) {
715           return -1;
716         }
717         continue;
718       }
719 
720       ngtcp2_ccerr_set_liberr(&quic.last_error, nwrite, nullptr, 0);
721       return -1;
722     } else if (ndatalen >= 0 && s->add_write_offset(stream_id, ndatalen) != 0) {
723       return -1;
724     }
725 
726     quic_restart_pkt_timer();
727 
728     if (nwrite == 0) {
729       if (bufpos - quic.tx.data.get()) {
730         auto data = quic.tx.data.get();
731         auto datalen = bufpos - quic.tx.data.get();
732         rv = write_udp(ps.path.remote.addr, ps.path.remote.addrlen, data,
733                        datalen, gso_size);
734         if (rv == 1) {
735           on_send_blocked(ps.path.remote, data, datalen, gso_size);
736           signal_write();
737           return 0;
738         }
739       }
740       return 0;
741     }
742 
743     auto first_pkt = bufpos == quic.tx.data.get();
744     (void)first_pkt;
745 
746     bufpos += nwrite;
747     bufleft -= nwrite;
748 
749 #ifdef UDP_SEGMENT
750     if (worker->config->no_udp_gso) {
751 #endif // UDP_SEGMENT
752       auto data = quic.tx.data.get();
753       auto datalen = bufpos - quic.tx.data.get();
754       rv = write_udp(ps.path.remote.addr, ps.path.remote.addrlen, data, datalen,
755                      0);
756       if (rv == 1) {
757         on_send_blocked(ps.path.remote, data, datalen, 0);
758         signal_write();
759         return 0;
760       }
761 
762       if (bufleft < path_max_udp_payload_size) {
763         signal_write();
764         return 0;
765       }
766 
767       bufpos = quic.tx.data.get();
768 
769 #ifdef UDP_SEGMENT
770       continue;
771     }
772 #endif // UDP_SEGMENT
773 
774 #ifdef UDP_SEGMENT
775     if (first_pkt) {
776       gso_size = nwrite;
777     } else if (static_cast<size_t>(nwrite) > gso_size ||
778                (gso_size > path_max_udp_payload_size &&
779                 static_cast<size_t>(nwrite) != gso_size)) {
780       auto data = quic.tx.data.get();
781       auto datalen = bufpos - quic.tx.data.get() - nwrite;
782       rv = write_udp(ps.path.remote.addr, ps.path.remote.addrlen, data, datalen,
783                      gso_size);
784       if (rv == 1) {
785         on_send_blocked(ps.path.remote, data, datalen, gso_size);
786         on_send_blocked(ps.path.remote, bufpos - nwrite, nwrite, 0);
787       } else {
788         auto data = bufpos - nwrite;
789         rv = write_udp(ps.path.remote.addr, ps.path.remote.addrlen, data,
790                        nwrite, 0);
791         if (rv == 1) {
792           on_send_blocked(ps.path.remote, data, nwrite, 0);
793         }
794       }
795 
796       signal_write();
797       return 0;
798     }
799 
800     // Assume that the path does not change.
801     if (bufleft < path_max_udp_payload_size ||
802         static_cast<size_t>(nwrite) < gso_size) {
803       auto data = quic.tx.data.get();
804       auto datalen = bufpos - quic.tx.data.get();
805       rv = write_udp(ps.path.remote.addr, ps.path.remote.addrlen, data, datalen,
806                      gso_size);
807       if (rv == 1) {
808         on_send_blocked(ps.path.remote, data, datalen, gso_size);
809       }
810       signal_write();
811       return 0;
812     }
813 #endif // UDP_SEGMENT
814   }
815 }
816 
on_send_blocked(const ngtcp2_addr & remote_addr,const uint8_t * data,size_t datalen,size_t gso_size)817 void Client::on_send_blocked(const ngtcp2_addr &remote_addr,
818                              const uint8_t *data, size_t datalen,
819                              size_t gso_size) {
820   assert(quic.tx.num_blocked || !quic.tx.send_blocked);
821   assert(quic.tx.num_blocked < 2);
822 
823   quic.tx.send_blocked = true;
824 
825   auto &p = quic.tx.blocked[quic.tx.num_blocked++];
826 
827   memcpy(&p.remote_addr.su, remote_addr.addr, remote_addr.addrlen);
828 
829   p.remote_addr.len = remote_addr.addrlen;
830   p.data = data;
831   p.datalen = datalen;
832   p.gso_size = gso_size;
833 }
834 
send_blocked_packet()835 int Client::send_blocked_packet() {
836   int rv;
837 
838   assert(quic.tx.send_blocked);
839 
840   for (; quic.tx.num_blocked_sent < quic.tx.num_blocked;
841        ++quic.tx.num_blocked_sent) {
842     auto &p = quic.tx.blocked[quic.tx.num_blocked_sent];
843 
844     rv = write_udp(&p.remote_addr.su.sa, p.remote_addr.len, p.data, p.datalen,
845                    p.gso_size);
846     if (rv == 1) {
847       signal_write();
848 
849       return 0;
850     }
851   }
852 
853   quic.tx.send_blocked = false;
854   quic.tx.num_blocked = 0;
855   quic.tx.num_blocked_sent = 0;
856 
857   return 0;
858 }
859 
860 } // namespace h2load
861