Skip to content
Snippets Groups Projects

Consolidation with CDI-PIO (develop)

Merged Sergey Kosukhin requested to merge m300488/develop-rebase into develop
8 files
+ 51
6
Compare changes
  • Side-by-side
  • Inline
Files
8
@@ -299,7 +299,7 @@ flushReblockBuffer(aFiledataM *of, int blockBufIdx)
MPI_Offset ofs = (MPI_Offset) blockSize
* (((MPI_Offset) of->pending[blockBufIdx].pass * (MPI_Offset) sizePio * of->numBlockBuf)
+ (MPI_Offset) blockBufIdx * (MPI_Offset) sizePio + (MPI_Offset) rankPio);
int wsize = of->pos >= ofs + blockSize ? blockSize : (int) (of->pos - ofs);
int wsize = (of->pos >= ofs + blockSize) ? blockSize : (int) (of->pos - ofs);
xmpi(MPI_File_write_at(of->fh, ofs, blockBuf, wsize, MPI_UNSIGNED_CHAR, MPI_STATUS_IGNORE));
of->pending[blockBufIdx].pass = -1;
of->numMsg = numMsg;
Loading