Home
last modified time | relevance | path

Searched refs:ooo_pkts (Results 1 – 4 of 4) sorted by relevance

/dports/net/mpich/mpich-3.4.3/modules/ucx/test/gtest/uct/ib/
H A Dtest_ud_timer.cc56 while ((ucs_get_time() < deadline) && (ucs_frag_list_sn(&ep(m_e2)->rx.ooo_pkts) < sn)) { in wait_for_rx_sn()
86 EXPECT_EQ(1, ucs_frag_list_sn(&ep(m_e2)->rx.ooo_pkts));
101 EXPECT_EQ(N, ucs_frag_list_sn(&ep(m_e2)->rx.ooo_pkts));
172 EXPECT_EQ(0, ucs_frag_list_sn(&ep(m_e2)->rx.ooo_pkts));
177 EXPECT_EQ(1, ucs_frag_list_sn(&ep(m_e2)->rx.ooo_pkts));
193 EXPECT_EQ(0, ucs_frag_list_sn(&ep(m_e2)->rx.ooo_pkts));
198 EXPECT_EQ(N, ucs_frag_list_sn(&ep(m_e2)->rx.ooo_pkts));
217 EXPECT_EQ(rx_limit, ucs_frag_list_sn(&ep(m_e2)->rx.ooo_pkts));
231 EXPECT_EQ(N, ucs_frag_list_sn(&ep(m_e2)->rx.ooo_pkts));
H A Dtest_ud.cc135 while ((ucs_frag_list_sn(&ep->rx.ooo_pkts) < value - no_creq_cnt(ep)) && in validate_recv()
139 EXPECT_EQ(value - no_creq_cnt(ep), ucs_frag_list_sn(&ep->rx.ooo_pkts)); in validate_recv()
145 EXPECT_EQ(1, ucs_frag_list_sn(&ep(m_e2)->rx.ooo_pkts)); in validate_flush()
382 EXPECT_EQ(1, ucs_frag_list_sn(&ep(m_e1, 0)->rx.ooo_pkts));
653 EXPECT_EQ(1, ucs_frag_list_sn(&ep(m_e1, 0)->rx.ooo_pkts));
665 EXPECT_EQ(1, ucs_frag_list_sn(&ep(m_e1, 0)->rx.ooo_pkts)); in UCS_TEST_P()
669 EXPECT_EQ(1, ucs_frag_list_sn(&ep(m_e1, 1)->rx.ooo_pkts)); in UCS_TEST_P()
679 EXPECT_EQ(1, ucs_frag_list_sn(&ep(m_e1)->rx.ooo_pkts));
686 EXPECT_EQ(1, ucs_frag_list_sn(&ep(m_e2)->rx.ooo_pkts));
/dports/net/mpich/mpich-3.4.3/modules/ucx/src/uct/ib/ud/base/
H A Dud_ep.c426 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()
738 ep->rx.ooo_pkts.head_sn = neth->psn; in uct_ud_ep_rx_ctl()
837 ep->rx.ooo_pkts.head_sn, neth->psn); in uct_ud_ep_process_rx()
[all …]
H A Dud_ep.h237 ucs_frag_list_t ooo_pkts; /* Out of order packets that can not be processed yet, member
361 neth->ack_psn = ep->rx.acked_psn = ucs_frag_list_sn(&ep->rx.ooo_pkts); in uct_ud_neth_init_data()