Lines Matching refs:q
116 struct cf_quic_ctx q; member
354 vquic_ctx_update_time(&ctx->q); in pktx_update_time()
355 pktx->ts = (ngtcp2_tstamp)ctx->q.last_op.tv_sec * NGTCP2_SECONDS + in pktx_update_time()
356 (ngtcp2_tstamp)ctx->q.last_op.tv_usec * NGTCP2_MICROSECONDS; in pktx_update_time()
851 Curl_pollset_check(data, ps, ctx->q.sockfd, &want_recv, &want_send); in cf_ngtcp2_adjust_pollset()
852 if(!want_send && !Curl_bufq_is_empty(&ctx->q.sendbuf)) in cf_ngtcp2_adjust_pollset()
867 !Curl_bufq_is_empty(&ctx->q.sendbuf); in cf_ngtcp2_adjust_pollset()
869 Curl_pollset_set(data, ps, ctx->q.sockfd, want_recv, want_send); in cf_ngtcp2_adjust_pollset()
1641 ngtcp2_addr_init(&path.local, (struct sockaddr *)&ctx->q.local_addr, in recv_pkt()
1642 (socklen_t)ctx->q.local_addrlen); in recv_pkt()
1680 return vquic_recv_packets(cf, data, &ctx->q, 1000, recv_pkt, pktx); in cf_progress_ingress()
1816 curlcode = vquic_flush(cf, data, &ctx->q); in cf_progress_egress()
1841 ctx->q.sendbuf.chunk_size / max_payload_size); in cf_progress_egress()
1845 nread = Curl_bufq_sipn(&ctx->q.sendbuf, max_payload_size, in cf_progress_egress()
1851 curlcode = vquic_send(cf, data, &ctx->q, gsolen); in cf_progress_egress()
1873 curlcode = vquic_send_tail_split(cf, data, &ctx->q, in cf_progress_egress()
1890 curlcode = vquic_send(cf, data, &ctx->q, gsolen); in cf_progress_egress()
1993 vquic_ctx_free(&ctx->q); in cf_ngtcp2_ctx_close()
2022 if(!Curl_bufq_is_empty(&ctx->q.sendbuf)) { in cf_ngtcp2_shutdown()
2025 if(!Curl_bufq_is_empty(&ctx->q.sendbuf)) { in cf_ngtcp2_shutdown()
2047 Curl_bufq_write(&ctx->q.sendbuf, (const unsigned char *)buffer, in cf_ngtcp2_shutdown()
2054 ctx->q.no_gso = TRUE; in cf_ngtcp2_shutdown()
2055 ctx->q.gsolen = (size_t)nwritten; in cf_ngtcp2_shutdown()
2056 ctx->q.split_len = 0; in cf_ngtcp2_shutdown()
2060 if(!Curl_bufq_is_empty(&ctx->q.sendbuf)) { in cf_ngtcp2_shutdown()
2062 result = vquic_flush(cf, data, &ctx->q); in cf_ngtcp2_shutdown()
2075 if(Curl_bufq_is_empty(&ctx->q.sendbuf)) { in cf_ngtcp2_shutdown()
2290 result = vquic_ctx_init(&ctx->q); in cf_connect_start()
2294 Curl_cf_socket_peek(cf->next, data, &ctx->q.sockfd, &sockaddr, NULL); in cf_connect_start()
2297 ctx->q.local_addrlen = sizeof(ctx->q.local_addr); in cf_connect_start()
2298 rv = getsockname(ctx->q.sockfd, (struct sockaddr *)&ctx->q.local_addr, in cf_connect_start()
2299 &ctx->q.local_addrlen); in cf_connect_start()
2304 (struct sockaddr *)&ctx->q.local_addr, in cf_connect_start()
2305 ctx->q.local_addrlen); in cf_connect_start()
2458 if(ctx->q.got_first_byte) { in cf_ngtcp2_query()
2459 timediff_t ms = Curl_timediff(ctx->q.first_byte_at, ctx->started_at); in cf_ngtcp2_query()
2467 if(ctx->q.got_first_byte) in cf_ngtcp2_query()
2468 *when = ctx->q.first_byte_at; in cf_ngtcp2_query()
2512 idletime = Curl_timediff(Curl_now(), ctx->q.last_io); in cf_ngtcp2_conn_is_alive()
