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 D | test_ud_timer.cc | 56 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 D | test_ud.cc | 135 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 D | ud_ep.c | 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() 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 D | ud_ep.h | 237 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()
|