Lines Matching refs:conn_
116 conn_{nullptr},
149 ngtcp2_conn_del(conn_);
296 ngtcp2_conn_extend_max_stream_offset(conn_, stream_id, nconsumed);
297 ngtcp2_conn_extend_max_offset(conn_, nconsumed);
331 ngtcp2_conn_extend_max_streams_bidi(conn_, 1);
438 auto rv = ngtcp2_conn_shutdown_stream_write(conn_, 0, stream_id,
500 auto path = ngtcp2_conn_get_path(conn_);
542 auto rv = ngtcp2_conn_submit_new_token(conn_, token.data(), tokenlen);
742 rv = ngtcp2_conn_server_new(&conn_, &initial_hd.scid, &scid, &path,
750 ngtcp2_conn_set_tls_native_handle(conn_, handler_->get_ssl());
798 auto max_udp_payload_size = ngtcp2_conn_get_max_tx_udp_payload_size(conn_);
801 ngtcp2_conn_get_path_max_tx_udp_payload_size(conn_);
803 auto max_pktcnt = ngtcp2_conn_get_send_quantum(conn_) / max_udp_payload_size;
820 if (httpconn_ && ngtcp2_conn_get_max_data_left(conn_)) {
843 conn_, &ps.path, &pi, bufpos, max_udp_payload_size, &ndatalen, flags,
907 ngtcp2_conn_update_pkt_tx_time(conn_, ts);
960 ngtcp2_conn_update_pkt_tx_time(conn_, ts);
980 ngtcp2_conn_update_pkt_tx_time(conn_, ts);
996 ngtcp2_conn_update_pkt_tx_time(conn_, ts);
1004 ngtcp2_conn_update_pkt_tx_time(conn_, ts);
1522 std::vector<ngtcp2_cid> scids(ngtcp2_conn_get_scid(conn_, nullptr) + 1);
1523 ngtcp2_conn_get_scid(conn_, scids.data());
1535 if (!ngtcp2_conn_in_closing_period(conn_) &&
1536 !ngtcp2_conn_in_draining_period(conn_)) {
1547 !ngtcp2_conn_get_handshake_completed(conn_)) {
1552 conn_, &ps.path, &pi, conn_close_.data(), conn_close_.size(), &ccerr,
1571 static_cast<ev_tstamp>(ngtcp2_conn_get_pto(conn_) * 3) / NGTCP2_SECONDS;
1801 rv = ngtcp2_conn_read_pkt(conn_, &path, &pi, data, datalen, quic_timestamp());
1836 &last_error_, ngtcp2_conn_get_tls_alert(conn_), nullptr, 0);
1948 if (ngtcp2_conn_in_closing_period(conn_) ||
1949 ngtcp2_conn_in_draining_period(conn_)) {
1963 conn_, &ps.path, &pi, conn_close_.data(), conn_close_.size(),
1989 rv = ngtcp2_conn_handle_expiry(conn_, ts);
2005 auto expiry_ts = ngtcp2_conn_get_expiry(conn_);
2526 ngtcp2_conn_extend_max_streams_bidi(conn_, 1);
2569 ngtcp2_conn_shutdown_stream_read(conn_, 0, stream_id, app_error_code);
2596 ngtcp2_conn_shutdown_stream_write(conn_, 0, stream_id, app_error_code);
2609 if (ngtcp2_conn_get_streams_uni_left(conn_) < 3) {
2647 auto params = ngtcp2_conn_get_local_transport_params(conn_);
2654 rv = ngtcp2_conn_open_uni_stream(conn_, &ctrl_stream_id, nullptr);
2669 rv = ngtcp2_conn_open_uni_stream(conn_, &qpack_enc_stream_id, nullptr);
2675 rv = ngtcp2_conn_open_uni_stream(conn_, &qpack_dec_stream_id, nullptr);
2749 auto rv = ngtcp2_conn_shutdown_stream(conn_, 0, stream_id, app_error_code);
2761 auto rv = ngtcp2_conn_shutdown_stream_read(conn_, 0, stream_id,
2773 ngtcp2_conn_extend_max_stream_offset(conn_, stream_id, nconsumed);
2774 ngtcp2_conn_extend_max_offset(conn_, nconsumed);
2841 auto t = ngtcp2_conn_get_pto(conn_);
2904 ngtcp2_conn *Http3Upstream::get_conn() const { return conn_; }