Skip to content

Commit

Permalink
Merge pull request #12711 from wenduwan/v5.0.x_backport_pr12709
Browse files Browse the repository at this point in the history
Identify requests from the same instance.
  • Loading branch information
wenduwan authored Jul 25, 2024
2 parents e6e1538 + 709e350 commit 293d57e
Showing 1 changed file with 5 additions and 4 deletions.
9 changes: 5 additions & 4 deletions ompi/request/request.c
Original file line number Diff line number Diff line change
Expand Up @@ -253,7 +253,8 @@ int ompi_request_persistent_noop_create(ompi_request_t** request)
bool ompi_request_check_same_instance(ompi_request_t** requests,
int count)
{
ompi_request_t *req, *base = NULL;
ompi_instance_t* base_instance = NULL;
ompi_request_t *req;

for(int idx = 0; idx < count; idx++ ) {
req = requests[idx];
Expand All @@ -262,11 +263,11 @@ bool ompi_request_check_same_instance(ompi_request_t** requests,
/* Only PML requests have support for MPI sessions */
if(OMPI_REQUEST_PML != req->req_type)
continue;
if(NULL == base) {
base = req;
if(NULL == base_instance) {
base_instance = req->req_mpi_object.comm->instance;
continue;
}
if(base->req_mpi_object.comm != req->req_mpi_object.comm)
if(base_instance != req->req_mpi_object.comm->instance)
return false;
}
return true;
Expand Down

0 comments on commit 293d57e

Please sign in to comment.