Lines Matching refs:pktx
278 static void pktx_update_time(struct pkt_io_ctx *pktx,
284 pktx->ts = ctx->q.last_op.tv_sec * NGTCP2_SECONDS +
288 static void pktx_init(struct pkt_io_ctx *pktx,
292 pktx->cf = cf;
293 pktx->data = data;
294 pktx->pkt_count = 0;
295 ngtcp2_path_storage_zero(&pktx->ps);
296 pktx_update_time(pktx, cf);
301 struct pkt_io_ctx *pktx);
304 struct pkt_io_ctx *pktx);
350 struct pkt_io_ctx *pktx)
364 s->initial_ts = pktx->ts;
694 struct pkt_io_ctx *pktx)
700 if(!pktx) {
702 pktx = &local_pktx;
705 pktx_update_time(pktx, cf);
710 if(expiry <= pktx->ts) {
712 int rv = ngtcp2_conn_handle_expiry(ctx->qconn, pktx->ts);
719 result = cf_progress_ingress(cf, data, pktx);
722 result = cf_progress_egress(cf, data, pktx);
729 if(expiry > pktx->ts) {
730 ngtcp2_duration timeout = expiry - pktx->ts;
1121 struct pkt_io_ctx pktx;
1132 pktx_init(&pktx, cf, data);
1150 if(cf_progress_ingress(cf, data, &pktx)) {
1181 if(cf_progress_egress(cf, data, &pktx)) {
1186 CURLcode result2 = check_and_set_expiry(cf, data, &pktx);
1434 struct pkt_io_ctx pktx;
1441 pktx_init(&pktx, cf, data);
1444 result = cf_progress_ingress(cf, data, &pktx);
1504 result = cf_progress_egress(cf, data, &pktx);
1523 result = check_and_set_expiry(cf, data, &pktx);
1551 struct pkt_io_ctx *pktx = userp;
1552 struct cf_ngtcp2_ctx *ctx = pktx->cf->ctx;
1557 ++pktx->pkt_count;
1564 rv = ngtcp2_conn_read_pkt(ctx->qconn, &path, &pi, pkt, pktlen, pktx->ts);
1566 CURL_TRC_CF(pktx->data, pktx->cf, "ingress, read_pkt -> %s (%d)",
1591 struct pkt_io_ctx *pktx)
1599 if(!pktx) {
1601 pktx = &local_pktx;
1604 pktx_update_time(pktx, cf);
1612 pktx->pkt_count = 0;
1614 recv_pkt, pktx);
1617 if(pktx->pkt_count < pkts_chunk) /* got less than we could */
1620 result = cf_progress_egress(cf, data, pktx);
1743 struct pkt_io_ctx *pktx)
1753 if(!pktx) {
1755 pktx = &local_pktx;
1758 pktx_update_time(pktx, cf);
1759 ngtcp2_path_storage_zero(&pktx->ps);
1792 read_pkt_to_send, pktx, &curlcode);
1956 struct pkt_io_ctx pktx;
1960 pktx_init(&pktx, cf, data);
1964 &ctx->last_error, pktx.ts);
2029 struct pkt_io_ctx *pktx)
2067 quic_settings(ctx, data, pktx);
2119 struct pkt_io_ctx pktx;
2135 pktx_init(&pktx, cf, data);
2147 result = cf_connect_start(cf, data, &pktx);
2150 result = cf_progress_egress(cf, data, &pktx);
2155 result = cf_progress_ingress(cf, data, &pktx);
2159 result = cf_progress_egress(cf, data, &pktx);
2199 result = check_and_set_expiry(cf, data, &pktx);