• Home
  • Raw
  • Download

Lines Matching refs:conn_

116       conn_{nullptr},
149 ngtcp2_conn_del(conn_); in ~Http3Upstream()
296 ngtcp2_conn_extend_max_stream_offset(conn_, stream_id, nconsumed); in recv_stream_data()
297 ngtcp2_conn_extend_max_offset(conn_, nconsumed); in recv_stream_data()
331 ngtcp2_conn_extend_max_streams_bidi(conn_, 1); in stream_close()
485 auto path = ngtcp2_conn_get_path(conn_); in handshake_completed()
501 auto rv = ngtcp2_conn_submit_new_token(conn_, token.data(), tokenlen); in handshake_completed()
692 rv = ngtcp2_conn_server_new(&conn_, &initial_hd.scid, &scid, &path, in init()
700 ngtcp2_conn_set_tls_native_handle(conn_, handler_->get_ssl()); in init()
742 auto max_udp_payload_size = ngtcp2_conn_get_max_tx_udp_payload_size(conn_); in write_streams()
745 ngtcp2_conn_get_path_max_tx_udp_payload_size(conn_); in write_streams()
747 auto max_pktcnt = ngtcp2_conn_get_send_quantum(conn_) / max_udp_payload_size; in write_streams()
764 if (httpconn_ && ngtcp2_conn_get_max_data_left(conn_)) { in write_streams()
787 conn_, &ps.path, &pi, bufpos, max_udp_payload_size, &ndatalen, flags, in write_streams()
848 ngtcp2_conn_update_pkt_tx_time(conn_, ts); in write_streams()
856 ngtcp2_conn_update_pkt_tx_time(conn_, ts); in write_streams()
911 ngtcp2_conn_update_pkt_tx_time(conn_, ts); in write_streams()
929 ngtcp2_conn_update_pkt_tx_time(conn_, ts); in write_streams()
947 ngtcp2_conn_update_pkt_tx_time(conn_, ts); in write_streams()
955 ngtcp2_conn_update_pkt_tx_time(conn_, ts); in write_streams()
1475 std::vector<ngtcp2_cid> scids(ngtcp2_conn_get_num_scid(conn_) + 1); in on_handler_delete()
1476 ngtcp2_conn_get_scid(conn_, scids.data()); in on_handler_delete()
1490 if (!ngtcp2_conn_is_in_closing_period(conn_) && in on_handler_delete()
1491 !ngtcp2_conn_is_in_draining_period(conn_)) { in on_handler_delete()
1502 conn_, &ps.path, &pi, conn_close_.data(), conn_close_.size(), &ccerr, in on_handler_delete()
1521 static_cast<ev_tstamp>(ngtcp2_conn_get_pto(conn_) * 3) / NGTCP2_SECONDS; in on_handler_delete()
1753 rv = ngtcp2_conn_read_pkt(conn_, &path, &pi, data, datalen, quic_timestamp()); in on_read()
1794 &last_error_, ngtcp2_conn_get_tls_alert(conn_), nullptr, 0); in on_read()
1907 if (ngtcp2_conn_is_in_closing_period(conn_) || in handle_error()
1908 ngtcp2_conn_is_in_draining_period(conn_)) { in handle_error()
1922 conn_, &ps.path, &pi, conn_close_.data(), conn_close_.size(), in handle_error()
1948 rv = ngtcp2_conn_handle_expiry(conn_, ts); in handle_expiry()
1965 auto expiry_ts = ngtcp2_conn_get_expiry(conn_); in reset_timer()
2486 ngtcp2_conn_extend_max_streams_bidi(conn_, 1); in http_stream_close()
2528 auto rv = ngtcp2_conn_shutdown_stream_read(conn_, stream_id, app_error_code); in http_stop_sending()
2554 auto rv = ngtcp2_conn_shutdown_stream_write(conn_, stream_id, app_error_code); in http_reset_stream()
2567 if (ngtcp2_conn_get_max_local_streams_uni(conn_) < 3) { in setup_httpconn()
2605 auto params = ngtcp2_conn_get_local_transport_params(conn_); in setup_httpconn()
2612 rv = ngtcp2_conn_open_uni_stream(conn_, &ctrl_stream_id, nullptr); in setup_httpconn()
2627 rv = ngtcp2_conn_open_uni_stream(conn_, &qpack_enc_stream_id, nullptr); in setup_httpconn()
2633 rv = ngtcp2_conn_open_uni_stream(conn_, &qpack_dec_stream_id, nullptr); in setup_httpconn()
2707 auto rv = ngtcp2_conn_shutdown_stream(conn_, stream_id, app_error_code); in shutdown_stream()
2720 ngtcp2_conn_shutdown_stream_read(conn_, stream_id, NGHTTP3_H3_NO_ERROR); in shutdown_stream_read()
2731 ngtcp2_conn_extend_max_stream_offset(conn_, stream_id, nconsumed); in consume()
2732 ngtcp2_conn_extend_max_offset(conn_, nconsumed); in consume()
2795 auto t = ngtcp2_conn_get_pto(conn_); in start_graceful_shutdown()
2858 ngtcp2_conn *Http3Upstream::get_conn() const { return conn_; } in get_conn()