Skip to content

Commit e0bec07

Browse files
committed
osc/rdma: Don't add a peer just by looking for it
Signed-off-by: Joseph Schuchart <[email protected]>
1 parent 8dcca83 commit e0bec07

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

ompi/mca/osc/rdma/osc_rdma_component.c

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1650,9 +1650,9 @@ int ompi_osc_rdma_shared_query(
16501650
int actual_rank = rank;
16511651
ompi_osc_rdma_module_t *module = GET_MODULE(win);
16521652

1653-
peer = ompi_osc_rdma_module_peer (module, actual_rank);
1653+
peer = ompi_osc_module_get_peer (module, actual_rank);
16541654
if (NULL == peer) {
1655-
return OMPI_ERR_BAD_PARAM;
1655+
return OMPI_ERR_NOT_SUPPORTED;
16561656
}
16571657

16581658
/* currently only supported for allocated windows */
@@ -1667,7 +1667,7 @@ int ompi_osc_rdma_shared_query(
16671667
if (MPI_PROC_NULL == rank) {
16681668
/* iterate until we find a rank that has a non-zero size */
16691669
for (int i = 0 ; i < ompi_comm_size(module->comm) ; ++i) {
1670-
peer = ompi_osc_rdma_module_peer (module, i);
1670+
peer = ompi_osc_module_get_peer (module, i);
16711671
ompi_osc_rdma_peer_extended_t *ex_peer = (ompi_osc_rdma_peer_extended_t *) peer;
16721672
if (!ompi_osc_rdma_peer_local_base(peer)) {
16731673
continue;

0 commit comments

Comments
 (0)