implement MPIIO sync

master
Shane Snyder 2018-04-27 11:33:52 -05:00
parent 9b75f071f4
commit 76f3d341b9
1 changed files with 4 additions and 1 deletions

View File

@ -342,6 +342,8 @@ static IOR_offset_t MPIIO_Xfer(int access, void *fd, IOR_size_t * buffer,
} }
} }
} }
if((access == WRITE) && (param->fsyncPerWrite == TRUE))
MPIIO_Fsync(fd, param);
return (length); return (length);
} }
@ -350,7 +352,8 @@ static IOR_offset_t MPIIO_Xfer(int access, void *fd, IOR_size_t * buffer,
*/ */
static void MPIIO_Fsync(void *fd, IOR_param_t * param) static void MPIIO_Fsync(void *fd, IOR_param_t * param)
{ {
; if (MPI_File_sync(*(MPI_File *)fd) != MPI_SUCCESS)
EWARN("fsync() failed");
} }
/* /*