Skip to content

Commit 1b7215a

Browse files
committed
Identify requests from the same instance.
The prior version identified requests from the same communicator instead of instance. Signed-off-by: George Bosilca <gbosilca@nvidia.com>
1 parent ce2310a commit 1b7215a

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

ompi/request/request.c

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -253,7 +253,8 @@ int ompi_request_persistent_noop_create(ompi_request_t** request)
253253
bool ompi_request_check_same_instance(ompi_request_t** requests,
254254
int count)
255255
{
256-
ompi_request_t *req, *base = NULL;
256+
ompi_instance_t* base_instance = NULL;
257+
ompi_request_t *req;
257258

258259
for(int idx = 0; idx < count; idx++ ) {
259260
req = requests[idx];
@@ -262,11 +263,11 @@ bool ompi_request_check_same_instance(ompi_request_t** requests,
262263
/* Only PML requests have support for MPI sessions */
263264
if(OMPI_REQUEST_PML != req->req_type)
264265
continue;
265-
if(NULL == base) {
266-
base = req;
266+
if(NULL == base_instance) {
267+
base_instance = req->req_mpi_object.comm->instance;
267268
continue;
268269
}
269-
if(base->req_mpi_object.comm != req->req_mpi_object.comm)
270+
if(base_instance != req->req_mpi_object.comm->instance)
270271
return false;
271272
}
272273
return true;

0 commit comments

Comments
 (0)