Lines Matching refs:qconn
120 ngtcp2_conn *qconn; member
261 if(!stream->closed && ctx->qconn && ctx->h3conn) { in cf_ngtcp2_stream_close()
265 ngtcp2_conn_set_stream_user_data(ctx->qconn, stream->id, NULL); in cf_ngtcp2_stream_close()
267 (void)ngtcp2_conn_shutdown_stream(ctx->qconn, 0, stream->id, in cf_ngtcp2_stream_close()
377 return ctx->qconn; in get_conn()
471 ngtcp2_conn_get_tls_alert(ctx->qconn), in cf_ngtcp2_err_set()
808 expiry = ngtcp2_conn_get_expiry(ctx->qconn); in check_and_set_expiry()
812 int rv = ngtcp2_conn_handle_expiry(ctx->qconn, pktx->ts); in check_and_set_expiry()
826 expiry = ngtcp2_conn_get_expiry(ctx->qconn); in check_and_set_expiry()
848 if(!ctx->qconn) in cf_ngtcp2_adjust_pollset()
861 c_exhaust = want_send && (!ngtcp2_conn_get_cwnd_left(ctx->qconn) || in cf_ngtcp2_adjust_pollset()
862 !ngtcp2_conn_get_max_data_left(ctx->qconn)); in cf_ngtcp2_adjust_pollset()
956 ngtcp2_conn_extend_max_stream_offset(ctx->qconn, stream->id, blen); in cb_h3_recv_data()
957 ngtcp2_conn_extend_max_offset(ctx->qconn, blen); in cb_h3_recv_data()
974 ngtcp2_conn_extend_max_stream_offset(ctx->qconn, stream3_id, consumed); in cb_h3_deferred_consume()
975 ngtcp2_conn_extend_max_offset(ctx->qconn, consumed); in cb_h3_deferred_consume()
1083 rv = ngtcp2_conn_shutdown_stream_read(ctx->qconn, 0, stream_id, in cb_h3_stop_sending()
1103 rv = ngtcp2_conn_shutdown_stream_write(ctx->qconn, 0, stream_id, in cb_h3_reset_stream()
1138 if(ngtcp2_conn_get_streams_uni_left(ctx->qconn) < 3) { in init_ngh3_conn()
1154 rc = ngtcp2_conn_open_uni_stream(ctx->qconn, &ctrl_stream_id, NULL); in init_ngh3_conn()
1166 rc = ngtcp2_conn_open_uni_stream(ctx->qconn, &qpack_enc_stream_id, NULL); in init_ngh3_conn()
1172 rc = ngtcp2_conn_open_uni_stream(ctx->qconn, &qpack_dec_stream_id, NULL); in init_ngh3_conn()
1235 DEBUGASSERT(ctx->qconn); in cf_ngtcp2_recv()
1450 rc = ngtcp2_conn_open_bidi_stream(ctx->qconn, &sid, data); in h3_stream_open()
1531 DEBUGASSERT(ctx->qconn); in cf_ngtcp2_send()
1647 rv = ngtcp2_conn_read_pkt(ctx->qconn, &path, &pi, pkt, pktlen, pktx->ts); in recv_pkt()
1715 if(ctx->h3conn && ngtcp2_conn_get_max_data_left(ctx->qconn)) { in read_pkt_to_send()
1729 n = ngtcp2_conn_writev_stream(ctx->qconn, &x->ps.path, in read_pkt_to_send()
1836 max_payload_size = ngtcp2_conn_get_max_tx_udp_payload_size(ctx->qconn); in cf_progress_egress()
1838 ngtcp2_conn_get_path_max_tx_udp_payload_size(ctx->qconn); in cf_progress_egress()
1996 if(ctx->qconn) in cf_ngtcp2_ctx_close()
1997 ngtcp2_conn_del(ctx->qconn); in cf_ngtcp2_ctx_close()
2009 if(cf->shutdown || !ctx->qconn) { in cf_ngtcp2_shutdown()
2039 ctx->qconn, NULL, /* path */ in cf_ngtcp2_shutdown()
2100 if(ctx && ctx->qconn) { in cf_ngtcp2_close()
2308 rc = ngtcp2_conn_client_new(&ctx->qconn, &ctx->dcid, &ctx->scid, in cf_connect_start()
2317 ngtcp2_conn_set_tls_native_handle(ctx->qconn, ctx->tls.ossl.ssl); in cf_connect_start()
2319 ngtcp2_conn_set_tls_native_handle(ctx->qconn, ctx->tls.gtls.session); in cf_connect_start()
2321 ngtcp2_conn_set_tls_native_handle(ctx->qconn, ctx->tls.wssl.handle); in cf_connect_start()
2362 if(!ctx->qconn) { in cf_ngtcp2_connect()
2380 if(ngtcp2_conn_get_handshake_completed(ctx->qconn)) { in cf_ngtcp2_connect()
2395 if(result == CURLE_RECV_ERROR && ctx->qconn && in cf_ngtcp2_connect()
2396 ngtcp2_conn_in_draining_period(ctx->qconn)) { in cf_ngtcp2_connect()
2413 if(!result && ctx->qconn) { in cf_ngtcp2_connect()
2437 if(!ctx->qconn || ctx->shutdown_started) { in cf_ngtcp2_query()
2495 if(!ctx->qconn || ctx->shutdown_started) in cf_ngtcp2_conn_is_alive()
2503 rp = ngtcp2_conn_get_remote_transport_params(ctx->qconn); in cf_ngtcp2_conn_is_alive()
