Lines Matching refs:ooo_pkts
131 ucs_frag_list_init(ep->tx.psn-1, &ep->rx.ooo_pkts, 0 /*TODO: ooo support */ in uct_ud_ep_reset()
426 ucs_frag_list_cleanup(&self->rx.ooo_pkts); in UCS_CLASS_CLEANUP_FUNC()
470 ucs_frag_list_cleanup(&ep->rx.ooo_pkts); in uct_ud_ep_connect_to_iface()
487 ucs_frag_list_cleanup(&ep->rx.ooo_pkts); in uct_ud_ep_disconnect_from_iface()
576 ucs_frag_list_cleanup(&ep->rx.ooo_pkts); in uct_ud_ep_connect_to_ep()
661 ep->rx.ooo_pkts.head_sn = neth->psn; in uct_ud_ep_rx_creq()
669 ep->rx.ooo_pkts.head_sn = neth->psn; in uct_ud_ep_rx_creq()
674 ep->dest_ep_id, ep->rx.ooo_pkts.head_sn); in uct_ud_ep_rx_creq()
702 ucs_assertv_always(ep->rx.ooo_pkts.head_sn == neth->psn, in uct_ud_ep_rx_creq()
706 ep->rx.ooo_pkts.head_sn, neth->psn, ep->flags, in uct_ud_ep_rx_creq()
734 if (UCT_UD_PSN_COMPARE(neth->psn, <, ep->rx.ooo_pkts.head_sn)) { in uct_ud_ep_rx_ctl()
738 ep->rx.ooo_pkts.head_sn = neth->psn; in uct_ud_ep_rx_ctl()
762 iface, ep, ep->conn_id, ep->rx.ooo_pkts.head_sn, in uct_ud_ep_prepare_creq()
837 ep->rx.ooo_pkts.head_sn, neth->psn); in uct_ud_ep_process_rx()
840 if (ucs_unlikely(UCT_UD_PSN_COMPARE(neth->psn, >, ep->rx.ooo_pkts.head_sn + 1))) { in uct_ud_ep_process_rx()
859 ooo_type = ucs_frag_list_insert(&ep->rx.ooo_pkts, &skb->u.ooo.elem, neth->psn); in uct_ud_ep_process_rx()
866 ep->rx.ooo_pkts.head_sn, neth->psn); in uct_ud_ep_process_rx()
1050 ep->rx.ooo_pkts.head_sn, ep->flags, ep->tx.pending.ops, in uct_ud_ep_prepare_crep()