Skip to content

Commit 62511fa

Browse files
authored
Merge pull request #8406 from vspetrov/v4.0.x_pml_ucx_check_selected_fix
V4.0.x PML/UCX: don't do pml check during add_proc
2 parents a42f3b4 + d3a5736 commit 62511fa

File tree

1 file changed

+0
-17
lines changed

1 file changed

+0
-17
lines changed

ompi/mca/pml/ucx/pml_ucx.c

Lines changed: 0 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -410,17 +410,7 @@ static ucp_ep_h mca_pml_ucx_add_proc_common(ompi_proc_t *proc)
410410

411411
static ucp_ep_h mca_pml_ucx_add_proc(ompi_communicator_t *comm, int dst)
412412
{
413-
ompi_proc_t *proc0 = ompi_comm_peer_lookup(comm, 0);
414413
ompi_proc_t *proc_peer = ompi_comm_peer_lookup(comm, dst);
415-
int ret;
416-
417-
/* Note, mca_pml_base_pml_check_selected, doesn't use 3rd argument */
418-
if (OMPI_SUCCESS != (ret = mca_pml_base_pml_check_selected("ucx",
419-
&proc0,
420-
dst))) {
421-
return NULL;
422-
}
423-
424414
return mca_pml_ucx_add_proc_common(proc_peer);
425415
}
426416

@@ -429,13 +419,6 @@ int mca_pml_ucx_add_procs(struct ompi_proc_t **procs, size_t nprocs)
429419
ompi_proc_t *proc;
430420
ucp_ep_h ep;
431421
size_t i;
432-
int ret;
433-
434-
if (OMPI_SUCCESS != (ret = mca_pml_base_pml_check_selected("ucx",
435-
procs,
436-
nprocs))) {
437-
return ret;
438-
}
439422

440423
for (i = 0; i < nprocs; ++i) {
441424
proc = procs[(i + OMPI_PROC_MY_NAME->vpid) % nprocs];

0 commit comments

Comments
 (0)