Lines Matching refs:pktx
180 struct pkt_io_ctx *pktx);
183 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 pktx->pkt_count = 0; in pktx_init()
366 ngtcp2_path_storage_zero(&pktx->ps); in pktx_init()
367 pktx_update_time(pktx, cf); in pktx_init()
415 struct pkt_io_ctx *pktx) in quic_settings() argument
429 s->initial_ts = pktx->ts; in quic_settings()
795 struct pkt_io_ctx *pktx) in check_and_set_expiry() argument
801 if(!pktx) { in check_and_set_expiry()
803 pktx = &local_pktx; in check_and_set_expiry()
806 pktx_update_time(pktx, cf); in check_and_set_expiry()
811 if(expiry <= pktx->ts) { in check_and_set_expiry()
813 int rv = ngtcp2_conn_handle_expiry(ctx->qconn, pktx->ts); in check_and_set_expiry()
820 result = cf_progress_ingress(cf, data, pktx); in check_and_set_expiry()
823 result = cf_progress_egress(cf, data, pktx); in check_and_set_expiry()
830 if(expiry > pktx->ts) { in check_and_set_expiry()
831 ngtcp2_duration timeout = expiry - pktx->ts; in check_and_set_expiry()
1228 struct pkt_io_ctx pktx; in cf_ngtcp2_recv() local
1240 pktx_init(&pktx, cf, data); in cf_ngtcp2_recv()
1247 if(cf_progress_ingress(cf, data, &pktx)) { in cf_ngtcp2_recv()
1268 if(cf_progress_egress(cf, data, &pktx)) { in cf_ngtcp2_recv()
1273 CURLcode result2 = check_and_set_expiry(cf, data, &pktx); in cf_ngtcp2_recv()
1527 struct pkt_io_ctx pktx; in cf_ngtcp2_send() local
1534 pktx_init(&pktx, cf, data); in cf_ngtcp2_send()
1538 result = cf_progress_ingress(cf, data, &pktx); in cf_ngtcp2_send()
1602 result = cf_progress_egress(cf, data, &pktx); in cf_ngtcp2_send()
1609 result = check_and_set_expiry(cf, data, &pktx); in cf_ngtcp2_send()
1636 struct pkt_io_ctx *pktx = userp; in recv_pkt() local
1637 struct cf_ngtcp2_ctx *ctx = pktx->cf->ctx; in recv_pkt()
1642 ++pktx->pkt_count; in recv_pkt()
1649 rv = ngtcp2_conn_read_pkt(ctx->qconn, &path, &pi, pkt, pktlen, pktx->ts); in recv_pkt()
1651 CURL_TRC_CF(pktx->data, pktx->cf, "ingress, read_pkt -> %s (%d)", in recv_pkt()
1653 cf_ngtcp2_err_set(pktx->cf, pktx->data, rv); in recv_pkt()
1667 struct pkt_io_ctx *pktx) in cf_progress_ingress() argument
1674 if(!pktx) { in cf_progress_ingress()
1676 pktx = &local_pktx; in cf_progress_ingress()
1679 pktx_update_time(pktx, cf); in cf_progress_ingress()
1688 pktx_update_time(pktx, cf); in cf_progress_ingress()
1689 pktx->pkt_count = 0; in cf_progress_ingress()
1691 recv_pkt, pktx); in cf_progress_ingress()
1692 if(result || !pktx->pkt_count) /* error or got nothing */ in cf_progress_ingress()
1812 struct pkt_io_ctx *pktx) in cf_progress_egress() argument
1822 if(!pktx) { in cf_progress_egress()
1824 pktx = &local_pktx; in cf_progress_egress()
1827 pktx_update_time(pktx, cf); in cf_progress_egress()
1828 ngtcp2_path_storage_zero(&pktx->ps); in cf_progress_egress()
1861 read_pkt_to_send, pktx, &curlcode); in cf_progress_egress()
2021 struct pkt_io_ctx pktx; in cf_ngtcp2_shutdown() local
2031 pktx_init(&pktx, cf, data); in cf_ngtcp2_shutdown()
2039 result = cf_progress_egress(cf, data, &pktx); in cf_ngtcp2_shutdown()
2057 &ctx->last_error, pktx.ts); in cf_ngtcp2_shutdown()
2203 struct pkt_io_ctx *pktx) in cf_connect_start() argument
2240 quic_settings(ctx, data, pktx); in cf_connect_start()
2293 struct pkt_io_ctx pktx; in cf_ngtcp2_connect() local
2309 pktx_init(&pktx, cf, data); in cf_ngtcp2_connect()
2315 result = cf_connect_start(cf, data, &pktx); in cf_ngtcp2_connect()
2318 result = cf_progress_egress(cf, data, &pktx); in cf_ngtcp2_connect()
2323 result = cf_progress_ingress(cf, data, &pktx); in cf_ngtcp2_connect()
2327 result = cf_progress_egress(cf, data, &pktx); in cf_ngtcp2_connect()
2365 result = check_and_set_expiry(cf, data, &pktx); in cf_ngtcp2_connect()
