Lines Matching refs:quic
86 ngtcp2_conn_extend_max_stream_offset(quic.conn, stream_id, nconsumed); in quic_recv_stream_data()
87 ngtcp2_conn_extend_max_offset(quic.conn, nconsumed); in quic_recv_stream_data()
256 assert(quic.qlog_file != nullptr); in quic_write_qlog()
257 fwrite(data, 1, datalen, quic.qlog_file); in quic_write_qlog()
296 return c->quic.conn; in get_conn()
307 quic.conn_ref.get_conn = get_conn; in quic_init()
308 quic.conn_ref.user_data = this; in quic_init()
310 SSL_set_app_data(ssl, &quic.conn_ref); in quic_init()
375 assert(quic.qlog_file == nullptr); in quic_init()
382 quic.qlog_file = fopen(path.c_str(), "w"); in quic_init()
383 if (quic.qlog_file == nullptr) { in quic_init()
426 rv = ngtcp2_conn_client_new(&quic.conn, &dcid, &scid, &path, quic_version, in quic_init()
432 ngtcp2_conn_set_tls_native_handle(quic.conn, ssl); in quic_init()
438 ngtcp2_conn_del(quic.conn); in quic_free()
439 if (quic.qlog_file != nullptr) { in quic_free()
440 fclose(quic.qlog_file); in quic_free()
441 quic.qlog_file = nullptr; in quic_free()
446 if (!quic.conn) { in quic_close_connection()
455 quic.conn, &ps.path, nullptr, buf.data(), buf.size(), &quic.last_error, in quic_close_connection()
472 rv = ngtcp2_conn_submit_crypto_data(quic.conn, level, data, datalen); in quic_write_client_handshake()
497 rv = ngtcp2_conn_handle_expiry(quic.conn, now); in quic_pkt_timeout()
499 ngtcp2_connection_close_error_set_transport_error_liberr(&quic.last_error, in quic_pkt_timeout()
508 auto expiry = ngtcp2_conn_get_expiry(quic.conn); in quic_restart_pkt_timer()
512 quic.pkt_timer.repeat = t; in quic_restart_pkt_timer()
513 ev_timer_again(worker->loop, &quic.pkt_timer); in quic_restart_pkt_timer()
531 assert(quic.conn); in read_quic()
546 rv = ngtcp2_conn_read_pkt(quic.conn, &path, &pi, buf.data(), nread, in read_quic()
551 if (!quic.last_error.error_code) { in read_quic()
554 &quic.last_error, ngtcp2_conn_get_tls_alert(quic.conn), nullptr, in read_quic()
558 &quic.last_error, rv, nullptr, 0); in read_quic()
578 if (quic.close_requested) { in write_quic()
582 if (quic.tx.send_blocked) { in write_quic()
588 if (quic.tx.send_blocked) { in write_quic()
596 ngtcp2_conn_get_max_tx_udp_payload_size(quic.conn); in write_quic()
599 ngtcp2_conn_get_path_max_tx_udp_payload_size(quic.conn); in write_quic()
602 ngtcp2_conn_get_send_quantum(quic.conn) / max_udp_payload_size; in write_quic()
603 uint8_t *bufpos = quic.tx.data.get(); in write_quic()
616 if (session && ngtcp2_conn_get_max_data_left(quic.conn)) { in write_quic()
633 quic.conn, &ps.path, nullptr, bufpos, max_udp_payload_size, &ndatalen, in write_quic()
655 &quic.last_error, nwrite, nullptr, 0); in write_quic()
664 if (bufpos - quic.tx.data.get()) { in write_quic()
665 auto data = quic.tx.data.get(); in write_quic()
666 auto datalen = bufpos - quic.tx.data.get(); in write_quic()
683 auto data = quic.tx.data.get(); in write_quic()
684 auto datalen = bufpos - quic.tx.data.get(); in write_quic()
698 bufpos = quic.tx.data.get(); in write_quic()
711 auto data = quic.tx.data.get(); in write_quic()
712 auto datalen = bufpos - quic.tx.data.get() - nwrite; in write_quic()
733 auto data = quic.tx.data.get(); in write_quic()
734 auto datalen = bufpos - quic.tx.data.get(); in write_quic()
750 assert(quic.tx.num_blocked || !quic.tx.send_blocked); in on_send_blocked()
751 assert(quic.tx.num_blocked < 2); in on_send_blocked()
753 quic.tx.send_blocked = true; in on_send_blocked()
755 auto &p = quic.tx.blocked[quic.tx.num_blocked++]; in on_send_blocked()
768 assert(quic.tx.send_blocked); in send_blocked_packet()
770 for (; quic.tx.num_blocked_sent < quic.tx.num_blocked; in send_blocked_packet()
771 ++quic.tx.num_blocked_sent) { in send_blocked_packet()
772 auto &p = quic.tx.blocked[quic.tx.num_blocked_sent]; in send_blocked_packet()
783 quic.tx.send_blocked = false; in send_blocked_packet()
784 quic.tx.num_blocked = 0; in send_blocked_packet()
785 quic.tx.num_blocked_sent = 0; in send_blocked_packet()