Lines Matching refs:qconn
92 quiche_conn *qconn; member
157 if(ctx->qconn) in cf_quiche_ctx_close()
158 quiche_conn_free(ctx->qconn); in cf_quiche_ctx_close()
254 if(ctx->qconn && !stream->closed) { in h3_data_done()
255 quiche_conn_stream_shutdown(ctx->qconn, stream->id, in h3_data_done()
258 quiche_conn_stream_shutdown(ctx->qconn, stream->id, in h3_data_done()
425 nread = quiche_h3_recv_body(ctx->h3c, ctx->qconn, stream->id, in stream_resp_read()
571 curl_int64_t stream3_id = quiche_h3_conn_poll(ctx->h3c, ctx->qconn, &ev); in cf_poll_events()
630 nread = quiche_conn_recv(ctx->qconn, (unsigned char *)pkt, pktlen, in recv_pkt()
634 if(quiche_conn_is_draining(ctx->qconn)) { in recv_pkt()
638 if(quiche_conn_is_closed(ctx->qconn)) { in recv_pkt()
673 DEBUGASSERT(ctx->qconn); in cf_process_ingress()
708 nwritten = quiche_conn_send(ctx->qconn, buf, buflen, &x->send_info); in read_pkt_to_send()
738 expiry_ns = quiche_conn_timeout_as_nanos(ctx->qconn); in cf_flush_egress()
740 quiche_conn_on_timeout(ctx->qconn); in cf_flush_egress()
741 if(quiche_conn_is_closed(ctx->qconn)) { in cf_flush_egress()
742 if(quiche_conn_is_timed_out(ctx->qconn)) in cf_flush_egress()
766 gsolen = quiche_conn_max_send_udp_payload_size(ctx->qconn); in cf_flush_egress()
801 timeout_ns = quiche_conn_timeout_as_nanos(ctx->qconn); in cf_flush_egress()
892 else if(quiche_conn_is_draining(ctx->qconn)) { in cf_quiche_recv()
926 nwritten = quiche_h3_send_body(ctx->h3c, ctx->qconn, stream->id, in cf_quiche_send_body()
931 if(!quiche_conn_stream_writable(ctx->qconn, stream->id, len)) { in cf_quiche_send_body()
1033 stream3_id = quiche_h3_send_request(ctx->h3c, ctx->qconn, nva, nheader, in h3_open_stream()
1160 ctx->qconn, (curl_uint64_t)stream->id, 1) > 0); in stream_is_writeable()
1170 if(!ctx->qconn) in cf_quiche_adjust_pollset()
1327 ctx->qconn = quiche_conn_new_with_tls((const uint8_t *)ctx->scid, in cf_quiche_ctx_open()
1334 if(!ctx->qconn) { in cf_quiche_ctx_open()
1345 quiche_conn_set_qlog_fd(ctx->qconn, qfd, in cf_quiche_ctx_open()
1405 if(!ctx->qconn) { in cf_quiche_connect()
1423 if(quiche_conn_is_established(ctx->qconn)) { in cf_quiche_connect()
1437 ctx->h3c = quiche_h3_conn_new_with_transport(ctx->qconn, ctx->h3config); in cf_quiche_connect()
1448 else if(quiche_conn_is_draining(ctx->qconn)) { in cf_quiche_connect()
1475 if(cf->shutdown || !ctx || !ctx->qconn) { in cf_quiche_shutdown()
1486 err = quiche_conn_close(ctx->qconn, TRUE, 0, NULL, 0); in cf_quiche_shutdown()
1544 max_streams += quiche_conn_peer_streams_left_bidi(ctx->qconn); in cf_quiche_query()
1588 if(!ctx->qconn) in cf_quiche_conn_is_alive()
1591 if(quiche_conn_is_closed(ctx->qconn)) { in cf_quiche_conn_is_alive()
1592 if(quiche_conn_is_timed_out(ctx->qconn)) in cf_quiche_conn_is_alive()
