Skip to content

Commit c5654c4

Browse files
committed
UCP/WIREUP: Moved gather_pending_requests to be executed only when reconfig occurs
1 parent a14734d commit c5654c4

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/ucp/wireup/wireup.c

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1854,8 +1854,6 @@ ucs_status_t ucp_wireup_init_lanes(ucp_ep_h ep, unsigned ep_init_flags,
18541854
}
18551855

18561856
ucs_queue_head_init(&replay_pending_queue);
1857-
ucp_wireup_gather_pending_requests(ep, &replay_pending_queue);
1858-
18591857
status = ucp_wireup_try_select_lanes(ep, ep_init_flags, &tl_bitmap,
18601858
remote_address, addr_indices, &key,
18611859
dst_mds_mem);
@@ -1895,6 +1893,11 @@ ucs_status_t ucp_wireup_init_lanes(ucp_ep_h ep, unsigned ep_init_flags,
18951893
}
18961894
}
18971895

1896+
if ((ep->cfg_index != UCP_WORKER_CFG_INDEX_NULL) &&
1897+
!ucp_ep_config_is_equal(&ucp_ep_config(ep)->key, &key)) {
1898+
ucp_wireup_gather_pending_requests(ep, &replay_pending_queue);
1899+
}
1900+
18981901
status = ucp_wireup_check_config_intersect(ep, &key, remote_address,
18991902
addr_indices,
19001903
&connect_lane_bitmap,

0 commit comments

Comments
 (0)