Lines Matching refs:pktx
181 struct pkt_io_ctx *pktx);
184 struct pkt_io_ctx *pktx);
349 static void pktx_update_time(struct pkt_io_ctx *pktx, in pktx_update_time() argument
355 pktx->ts = (ngtcp2_tstamp)ctx->q.last_op.tv_sec * NGTCP2_SECONDS + in pktx_update_time()
359 static void pktx_init(struct pkt_io_ctx *pktx, in pktx_init() argument
363 pktx->cf = cf; in pktx_init()
364 pktx->data = data; in pktx_init()
365 ngtcp2_path_storage_zero(&pktx->ps); in pktx_init()
366 pktx_update_time(pktx, cf); in pktx_init()
414 struct pkt_io_ctx *pktx) in quic_settings() argument
428 s->initial_ts = pktx->ts; in quic_settings()
794 struct pkt_io_ctx *pktx) in check_and_set_expiry() argument
800 if(!pktx) { in check_and_set_expiry()
802 pktx = &local_pktx; in check_and_set_expiry()
805 pktx_update_time(pktx, cf); in check_and_set_expiry()
810 if(expiry <= pktx->ts) { in check_and_set_expiry()
812 int rv = ngtcp2_conn_handle_expiry(ctx->qconn, pktx->ts); in check_and_set_expiry()
819 result = cf_progress_ingress(cf, data, pktx); in check_and_set_expiry()
822 result = cf_progress_egress(cf, data, pktx); in check_and_set_expiry()
829 if(expiry > pktx->ts) { in check_and_set_expiry()
830 ngtcp2_duration timeout = expiry - pktx->ts; in check_and_set_expiry()
1227 struct pkt_io_ctx pktx; in cf_ngtcp2_recv() local
1239 pktx_init(&pktx, cf, data); in cf_ngtcp2_recv()
1246 if(cf_progress_ingress(cf, data, &pktx)) { in cf_ngtcp2_recv()
1267 if(cf_progress_egress(cf, data, &pktx)) { in cf_ngtcp2_recv()
1272 CURLcode result2 = check_and_set_expiry(cf, data, &pktx); in cf_ngtcp2_recv()
1526 struct pkt_io_ctx pktx; in cf_ngtcp2_send() local
1533 pktx_init(&pktx, cf, data); in cf_ngtcp2_send()
1537 result = cf_progress_ingress(cf, data, &pktx); in cf_ngtcp2_send()
1601 result = cf_progress_egress(cf, data, &pktx); in cf_ngtcp2_send()
1608 result = check_and_set_expiry(cf, data, &pktx); in cf_ngtcp2_send()
1635 struct pkt_io_ctx *pktx = userp; in recv_pkt() local
1636 struct cf_ngtcp2_ctx *ctx = pktx->cf->ctx; in recv_pkt()
1647 rv = ngtcp2_conn_read_pkt(ctx->qconn, &path, &pi, pkt, pktlen, pktx->ts); in recv_pkt()
1649 CURL_TRC_CF(pktx->data, pktx->cf, "ingress, read_pkt -> %s (%d)", in recv_pkt()
1651 cf_ngtcp2_err_set(pktx->cf, pktx->data, rv); in recv_pkt()
1665 struct pkt_io_ctx *pktx) in cf_progress_ingress() argument
1671 if(!pktx) { in cf_progress_ingress()
1673 pktx = &local_pktx; in cf_progress_ingress()
1680 return vquic_recv_packets(cf, data, &ctx->q, 1000, recv_pkt, pktx); in cf_progress_ingress()
1797 struct pkt_io_ctx *pktx) in cf_progress_egress() argument
1807 if(!pktx) { in cf_progress_egress()
1809 pktx = &local_pktx; in cf_progress_egress()
1812 pktx_update_time(pktx, cf); in cf_progress_egress()
1813 ngtcp2_path_storage_zero(&pktx->ps); in cf_progress_egress()
1846 read_pkt_to_send, pktx, &curlcode); in cf_progress_egress()
2006 struct pkt_io_ctx pktx; in cf_ngtcp2_shutdown() local
2016 pktx_init(&pktx, cf, data); in cf_ngtcp2_shutdown()
2024 result = cf_progress_egress(cf, data, &pktx); in cf_ngtcp2_shutdown()
2042 &ctx->last_error, pktx.ts); in cf_ngtcp2_shutdown()
2254 struct pkt_io_ctx *pktx) in cf_connect_start() argument
2287 quic_settings(ctx, data, pktx); in cf_connect_start()
2342 struct pkt_io_ctx pktx; in cf_ngtcp2_connect() local
2358 pktx_init(&pktx, cf, data); in cf_ngtcp2_connect()
2364 result = cf_connect_start(cf, data, &pktx); in cf_ngtcp2_connect()
2367 result = cf_progress_egress(cf, data, &pktx); in cf_ngtcp2_connect()
2372 result = cf_progress_ingress(cf, data, &pktx); in cf_ngtcp2_connect()
2376 result = cf_progress_egress(cf, data, &pktx); in cf_ngtcp2_connect()
2414 result = check_and_set_expiry(cf, data, &pktx); in cf_ngtcp2_connect()
