Skip to content

Commit

Permalink
Keep the non-blocking collective tags globally in sync.
Browse files Browse the repository at this point in the history
Signed-off-by: George Bosilca <[email protected]>
  • Loading branch information
bosilca committed Sep 18, 2020
1 parent c98e387 commit 77eaa5c
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions ompi/mca/coll/libnbc/nbc_ialltoallv.c
Original file line number Diff line number Diff line change
Expand Up @@ -74,13 +74,20 @@ static int nbc_alltoallv_init(const void* sendbuf, const int *sendcounts, const
}
}
span = opal_datatype_span(&recvtype->super, count, &gap);
/**
* If this process has no data to send or receive it can bail out early,
* but it needs to increase the nonblocking tag to stay in sycn with the
* rest of the processses.
*/
if (OPAL_UNLIKELY(0 == span)) {
ompi_coll_base_nbc_reserve_tags(comm, 1);
return nbc_get_noop_request(persistent, request);
}
tmpbuf = malloc(span);
if (OPAL_UNLIKELY(NULL == tmpbuf)) {
return OMPI_ERR_OUT_OF_RESOURCE;
}

sendcounts = recvcounts;
sdispls = rdispls;
} else {
Expand Down

0 comments on commit 77eaa5c

Please sign in to comment.