added mpi_request_null checks for test_/wait_xxx

Signed-off-by: HawkmoonEternal <domi.huber@tum.de>
open-mpi · May 6, 2024 · da18f8e · da18f8e
1 parent 4890203
commit da18f8e
Show file tree

Hide file tree

Showing 6 changed files with 12 additions and 0 deletions.
diff --git a/ompi/mpi/c/testall.c b/ompi/mpi/c/testall.c
@@ -70,6 +70,8 @@ int MPI_Testall(int count, MPI_Request requests[], int *flag,
                 }
                 if (&ompi_request_empty == requests[i]) { 
                     continue;
+                } else if (&ompi_request_null == requests[i]) {
+                    continue;
                 } else if (NULL == requests[i]->req_mpi_object.comm) {
                     continue;
                 } else if (NULL == check_req) {

diff --git a/ompi/mpi/c/testany.c b/ompi/mpi/c/testany.c
@@ -69,6 +69,8 @@ int MPI_Testany(int count, MPI_Request requests[], int *indx, int *completed, MP
                 }
                 if (&ompi_request_empty == requests[i]) {
                     continue;
+                } else if (&ompi_request_null == requests[i]) {
+                    continue;
                 } else if (NULL == requests[i]->req_mpi_object.comm) {
                     continue;
                 } else if (NULL == check_req) {

diff --git a/ompi/mpi/c/testsome.c b/ompi/mpi/c/testsome.c
@@ -71,6 +71,8 @@ int MPI_Testsome(int incount, MPI_Request requests[],
                 }
                 if (&ompi_request_empty == requests[indx]) { 
                     continue;
+                } else if (&ompi_request_null == requests[indx]) {
+                    continue;
                 } else if (NULL == requests[indx]->req_mpi_object.comm) {
                     continue;
                 } else if (NULL == check_req) {

diff --git a/ompi/mpi/c/waitall.c b/ompi/mpi/c/waitall.c
@@ -68,6 +68,8 @@ int MPI_Waitall(int count, MPI_Request requests[], MPI_Status statuses[])
                 }
                 if (&ompi_request_empty == requests[i]) {
                     continue;
+                } else if (&ompi_request_null == requests[i]) {
+                    continue;
                 } else if (NULL == requests[i]->req_mpi_object.comm) {
                     continue;
                 } else if (NULL == check_req) {

diff --git a/ompi/mpi/c/waitany.c b/ompi/mpi/c/waitany.c
@@ -69,6 +69,8 @@ int MPI_Waitany(int count, MPI_Request requests[], int *indx, MPI_Status *status
                 }
                 if (requests[i] == &ompi_request_empty) {
                     continue;
+                } else if (&ompi_request_null == requests[i]) {
+                    continue;
                 } else if (NULL == requests[i]->req_mpi_object.comm) {
                     continue;
                 } else if (NULL == check_req) {

diff --git a/ompi/mpi/c/waitsome.c b/ompi/mpi/c/waitsome.c
@@ -71,6 +71,8 @@ int MPI_Waitsome(int incount, MPI_Request requests[],
                 }
                 if (&ompi_request_empty == requests[indx]) {
                     continue;
+                } else if (&ompi_request_null == requests[indx]) {
+                    continue;
                 } else if (NULL == requests[indx]->req_mpi_object.comm) {
                     continue;
                 } else if (NULL == check_req) {