use MPI-IO explicit file offset subroutines only

MPI_File_read_at MPI_File_read_at_all MPI_File_write_at MPI_File_write_at_all
Parallel-NetCDF · Feb 15, 2025 · b0596c1 · b0596c1
1 parent 7d05e3a
commit b0596c1
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/src/drivers/ncmpio/ncmpio_intra_node.c b/src/drivers/ncmpio/ncmpio_intra_node.c
@@ -1164,7 +1164,7 @@ intra_node_aggregation(NC           *ncp,
 
         /* pack recv_buf, data received from non-aggregators, into wr_buf, a
          * contiguous buffer, wr_buf, which will later be used in a call to
-         * MPI_File_write_all()
+         * MPI_File_write_at_all()
          */
         char *ptr = wr_buf;
         buf_count = 0;

diff --git a/src/drivers/ncmpio/ncmpio_wait.c b/src/drivers/ncmpio/ncmpio_wait.c
@@ -66,21 +66,21 @@ ncmpio_getput_zero_req(NC *ncp, int reqMode)
 
     if (fIsSet(reqMode, NC_REQ_RD)) {
         if (ncp->nprocs > 1)
-            TRACE_IO(MPI_File_read_all)(fh, NULL, 0, MPI_BYTE, &mpistatus);
+            TRACE_IO(MPI_File_read_at_all)(fh, 0, NULL, 0, MPI_BYTE, &mpistatus);
         else
-            TRACE_IO(MPI_File_read)(fh, NULL, 0, MPI_BYTE, &mpistatus);
+            TRACE_IO(MPI_File_read_at)(fh, 0, NULL, 0, MPI_BYTE, &mpistatus);
         if (mpireturn != MPI_SUCCESS) {
-            err = ncmpii_error_mpi2nc(mpireturn, "MPI_File_read_all");
+            err = ncmpii_error_mpi2nc(mpireturn, "MPI_File_read_at_all");
             err = (err == NC_EFILE) ? NC_EREAD : err;
             DEBUG_ASSIGN_ERROR(status, err)
         }
     } else { /* write request */
         if (ncp->nprocs > 1)
-            TRACE_IO(MPI_File_write_all)(fh, NULL, 0, MPI_BYTE, &mpistatus);
+            TRACE_IO(MPI_File_write_at_all)(fh, 0, NULL, 0, MPI_BYTE, &mpistatus);
         else
-            TRACE_IO(MPI_File_write)(fh, NULL, 0, MPI_BYTE, &mpistatus);
+            TRACE_IO(MPI_File_write_at)(fh, 0, NULL, 0, MPI_BYTE, &mpistatus);
         if (mpireturn != MPI_SUCCESS) {
-            err = ncmpii_error_mpi2nc(mpireturn, "MPI_File_write_all");
+            err = ncmpii_error_mpi2nc(mpireturn, "MPI_File_write_at_all");
             err = (err == NC_EFILE) ? NC_EWRITE : err;
             DEBUG_ASSIGN_ERROR(status, err)
         }
@@ -2074,7 +2074,7 @@ req_aggregation(NC     *ncp,
         buf_len = 0;
     }
 
-    /* call MPI_File_read/MPI_File_write */
+    /* call MPI_File_read_at_all/MPI_File_write_at_all */
     err = ncmpio_read_write(ncp, rw_flag, coll_indep, offset, buf_len, buf_type,
                             buf, ((buf_type == MPI_BYTE) ? 1 : 0));
     if (status == NC_NOERR) status = err;
@@ -2498,7 +2498,7 @@ mgetput(NC     *ncp,
         buf_count = 0;
     }
 
-    /* call MPI_File_read/MPI_File_write */
+    /* call MPI_File_read_at_all/MPI_File_write_at_all */
     err = ncmpio_read_write(ncp, rw_flag, coll_indep, offset, buf_count,
                             buf_type, buf, ((buf_type == MPI_BYTE) ? 1 : 0));
     if (status == NC_NOERR) status = err;