Lines Matching refs:urxe
238 QUIC_URXE *urxe = ossl_list_urxe_head(&demux->urx_free), *unext; in demux_recv() local
243 assert(urxe->demux_state == URXE_DEMUX_STATE_FREE); in demux_recv()
256 ++i, urxe = ossl_list_urxe_next(urxe)) { in demux_recv()
257 if (urxe == NULL) { in demux_recv()
266 urxe = demux_reserve_urxe(demux, urxe, demux->mtu); in demux_recv()
267 if (urxe == NULL) in demux_recv()
273 msg[i].data = ossl_quic_urxe_data(urxe); in demux_recv()
274 msg[i].data_len = urxe->alloc_len; in demux_recv()
275 msg[i].peer = &urxe->peer; in demux_recv()
276 BIO_ADDR_clear(&urxe->peer); in demux_recv()
278 msg[i].local = &urxe->local; in demux_recv()
280 BIO_ADDR_clear(&urxe->local); in demux_recv()
299 urxe = ossl_list_urxe_head(&demux->urx_free); in demux_recv()
300 for (i = 0; i < rd; ++i, urxe = unext) { in demux_recv()
301 unext = ossl_list_urxe_next(urxe); in demux_recv()
303 urxe->data_len = msg[i].data_len; in demux_recv()
305 urxe->time = now; in demux_recv()
306 urxe->datagram_id = demux->next_datagram_id++; in demux_recv()
308 ossl_list_urxe_remove(&demux->urx_free, urxe); in demux_recv()
309 ossl_list_urxe_insert_tail(&demux->urx_pending, urxe); in demux_recv()
310 urxe->demux_state = URXE_DEMUX_STATE_PENDING; in demux_recv()
413 QUIC_URXE *urxe; in ossl_quic_demux_inject() local
419 urxe = ossl_list_urxe_head(&demux->urx_free); in ossl_quic_demux_inject()
421 assert(urxe->demux_state == URXE_DEMUX_STATE_FREE); in ossl_quic_demux_inject()
423 urxe = demux_reserve_urxe(demux, urxe, buf_len); in ossl_quic_demux_inject()
424 if (urxe == NULL) in ossl_quic_demux_inject()
427 memcpy(ossl_quic_urxe_data(urxe), buf, buf_len); in ossl_quic_demux_inject()
428 urxe->data_len = buf_len; in ossl_quic_demux_inject()
431 urxe->peer = *peer; in ossl_quic_demux_inject()
433 BIO_ADDR_clear(&urxe->peer); in ossl_quic_demux_inject()
436 urxe->local = *local; in ossl_quic_demux_inject()
438 BIO_ADDR_clear(&urxe->local); in ossl_quic_demux_inject()
440 urxe->time in ossl_quic_demux_inject()
444 ossl_list_urxe_remove(&demux->urx_free, urxe); in ossl_quic_demux_inject()
445 ossl_list_urxe_insert_tail(&demux->urx_pending, urxe); in ossl_quic_demux_inject()
446 urxe->demux_state = URXE_DEMUX_STATE_PENDING; in ossl_quic_demux_inject()
