diff options
| author | Houjun Tang <htang4@lbl.gov> | 2022-07-11 20:59:19 (GMT) |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-07-11 20:59:19 (GMT) |
| commit | 663321087a73e760a028517584731eb8ef308ba2 (patch) | |
| tree | 06dffb3981cd8de69bc38c1efc047b961d1913a1 /src/H5FDmpi.c | |
| parent | 63ce6839b581c09676e3dc0eaad477870bd2537c (diff) | |
| download | hdf5-663321087a73e760a028517584731eb8ef308ba2.zip hdf5-663321087a73e760a028517584731eb8ef308ba2.tar.gz hdf5-663321087a73e760a028517584731eb8ef308ba2.tar.bz2 | |
Support for UnifyFS with MPI_File_sync (#1801)
* Initial implementation for supporting UnifyFS in HDF5 with MPI_File_sync after write
* Committing clang-format changes
* Fix format
* Fix env variable and return value check
* Fix flag retrieve
* Fix issues with getting/setting the flag
* Fix merge conflicts
* Update
* Committing clang-format changes
* Update based on suggestions
* Committing clang-format changes
Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>
Diffstat (limited to 'src/H5FDmpi.c')
| -rw-r--r-- | src/H5FDmpi.c | 37 |
1 files changed, 37 insertions, 0 deletions
diff --git a/src/H5FDmpi.c b/src/H5FDmpi.c index 45791e8..80f2ead 100644 --- a/src/H5FDmpi.c +++ b/src/H5FDmpi.c @@ -252,6 +252,43 @@ H5FD_mpi_haddr_to_MPIOff(haddr_t addr, MPI_Offset *mpi_off /*out*/) FUNC_LEAVE_NOAPI(ret_value) } +/*------------------------------------------------------------------------- + * Function: H5FD_mpi_get_file_sync_required + * + * Purpose: Retrieves the mpi_file_sync_required used for the file + * + * Return: Success: Non-negative + * + * Failure: Negative + * + * Programmer: Houjun Tang + * May 19, 2022 + * + *------------------------------------------------------------------------- + */ +herr_t +H5FD_mpi_get_file_sync_required(H5FD_t *file, hbool_t *file_sync_required) +{ + const H5FD_class_t *cls; + uint64_t flags = H5FD_CTL_ROUTE_TO_TERMINAL_VFD_FLAG; + void * file_sync_required_ptr = (void *)(&file_sync_required); + herr_t ret_value = SUCCEED; + + FUNC_ENTER_NOAPI(FAIL) + + HDassert(file); + cls = (const H5FD_class_t *)(file->cls); + HDassert(cls); + HDassert(cls->ctl); /* All MPI drivers must implement this */ + + /* Dispatch to driver */ + if ((cls->ctl)(file, H5FD_CTL_GET_MPI_FILE_SYNC_OPCODE, flags, NULL, file_sync_required_ptr) < 0) + HGOTO_ERROR(H5E_VFL, H5E_CANTGET, FAIL, "driver get_mpi_file_synce request failed") + +done: + FUNC_LEAVE_NOAPI(ret_value) +} /* end H5FD_mpi_get_file_sync_required() */ + #ifdef NOT_YET /*------------------------------------------------------------------------- |