Home
last modified time | relevance | path

Searched refs:fc_wnd (Results 1 – 9 of 9) sorted by relevance

/dports/net/mpich/mpich-3.4.3/modules/ucx/src/uct/ib/rc/base/
H A Drc_ep.h125 if ((_fc)->fc_wnd <= 0) { \
135 (_fc)->fc_wnd--; \
139 (_fc)->fc_wnd); \
145 if (ucs_unlikely((_ep)->fc.fc_wnd <= (_iface)->config.fc_soft_thresh)) { \
151 (_ep)->fc.fc_wnd = INT16_MAX; \
193 int16_t fc_wnd; member
294 return (fc->fc_wnd > 0) || !iface->config.fc_enabled; in uct_rc_fc_has_resources()
440 return (fc->fc_wnd == iface->config.fc_hard_thresh) ? in uct_rc_fc_req_moderation()
442 (fc->fc_wnd == iface->config.fc_soft_thresh) ? in uct_rc_fc_req_moderation()
H A Drc_ep.c74 fc->fc_wnd = winsize; in uct_rc_fc_init()
83 UCS_STATS_SET_COUNTER(fc->stats, UCT_RC_FC_STAT_FC_WND, fc->fc_wnd); in uct_rc_fc_init()
H A Drc_iface.c361 cur_wnd = ep->fc.fc_wnd; in uct_rc_iface_fc_handler()
364 ep->fc.fc_wnd = iface->config.fc_wnd_size; in uct_rc_iface_fc_handler()
365 UCS_STATS_SET_COUNTER(ep->fc.stats, UCT_RC_FC_STAT_FC_WND, ep->fc.fc_wnd); in uct_rc_iface_fc_handler()
/dports/net/mpich/mpich-3.4.3/modules/ucx/test/gtest/uct/ib/
H A Dtest_rc.cc445 wait_for_flag(&get_fc_ptr(e)->fc_wnd); in validate_grant()
446 EXPECT_GT(get_fc_ptr(e)->fc_wnd, 0); in validate_grant()
482 EXPECT_LE(get_fc_ptr(m_e1)->fc_wnd, 0); in test_pending_grant()
501 get_fc_ptr(m_e1)->fc_wnd = 0; in test_flush_fc_disabled()
506 get_fc_ptr(m_e1)->fc_wnd = 1; in test_flush_fc_disabled()
508 EXPECT_EQ(0, get_fc_ptr(m_e1)->fc_wnd); in test_flush_fc_disabled()
H A Dtest_dc.cc524 get_fc_ptr(m_e1, ep_index)->fc_wnd = 0; in UCS_TEST_P()
554 EXPECT_EQ(get_fc_ptr(m_e1)->fc_wnd, s_thresh - 1); in UCS_TEST_P()
676 get_fc_ptr(m_e1)->fc_wnd = 0;
H A Dtest_rc.h85 rc_iface(e)->config.fc_wnd_size = get_fc_ptr(e)->fc_wnd = wnd; in set_fc_attributes()
/dports/net/mpich/mpich-3.4.3/modules/ucx/src/uct/ib/dc/
H A Ddc_mlx5.c1021 cur_wnd = ep->fc.fc_wnd; in uct_dc_mlx5_iface_fc_handler()
1024 ep->fc.fc_wnd = rc_iface->config.fc_wnd_size; in uct_dc_mlx5_iface_fc_handler()
1030 UCS_STATS_SET_COUNTER(ep->fc.stats, UCT_RC_FC_STAT_FC_WND, ep->fc.fc_wnd); in uct_dc_mlx5_iface_fc_handler()
H A Ddc_mlx5_ep.c1077 if (uct_dc_mlx5_iface_dci_can_alloc(iface) && (ep->fc.fc_wnd > 0)) { in uct_dc_mlx5_ep_pending_add()
1274 if ((ep->fc.fc_wnd == iface->super.super.config.fc_hard_thresh) && in uct_dc_mlx5_ep_check_fc()
1287 ep->fc.fc_wnd = INT16_MAX; in uct_dc_mlx5_ep_check_fc()
H A Ddc_mlx5_ep.h556 if (ucs_unlikely((_ep)->fc.fc_wnd <= \