summaryrefslogtreecommitdiffstats
path: root/src/H5Fvfd_swmr.c
diff options
context:
space:
mode:
authorgithub-actions <41898282+github-actions[bot]@users.noreply.github.com>2021-11-17 17:30:05 (GMT)
committergithub-actions <41898282+github-actions[bot]@users.noreply.github.com>2021-11-17 17:30:05 (GMT)
commit68ddc3029a1e55cb1f995c0b69233c7c06ff94da (patch)
tree52023b9307db6664c1b6286a07697d891d75db54 /src/H5Fvfd_swmr.c
parent97a37aa84913808792418e6814126bdee856288e (diff)
downloadhdf5-68ddc3029a1e55cb1f995c0b69233c7c06ff94da.zip
hdf5-68ddc3029a1e55cb1f995c0b69233c7c06ff94da.tar.gz
hdf5-68ddc3029a1e55cb1f995c0b69233c7c06ff94da.tar.bz2
Committing clang-format changes
Diffstat (limited to 'src/H5Fvfd_swmr.c')
-rw-r--r--src/H5Fvfd_swmr.c278
1 files changed, 141 insertions, 137 deletions
diff --git a/src/H5Fvfd_swmr.c b/src/H5Fvfd_swmr.c
index fe07e74..2ac5e6c 100644
--- a/src/H5Fvfd_swmr.c
+++ b/src/H5Fvfd_swmr.c
@@ -25,7 +25,7 @@
/****************/
#include "H5Fmodule.h" /* This source code file is part of the H5F module */
-#define H5FD_FRIEND /*suppress error about including H5FDpkg */
+#define H5FD_FRIEND /*suppress error about including H5FDpkg */
/***********/
/* Headers */
@@ -108,8 +108,9 @@ static herr_t H5F__vfd_swmr_writer__wait_a_tick(H5F_t *);
static herr_t H5F__vfd_swmr_construct_ud_hdr(H5F_vfd_swmr_updater_t *updater);
static herr_t H5F__vfd_swmr_construct_ud_cl(H5F_vfd_swmr_updater_t *updater);
static herr_t H5F__generate_updater_file(H5F_t *f, uint32_t num_entries, uint16_t flags,
- uint8_t *md_file_hdr_image_ptr, size_t md_file_hdr_image_len,
- uint8_t *md_file_index_image_ptr, uint64_t md_file_index_offset, size_t md_file_index_image_len);
+ uint8_t *md_file_hdr_image_ptr, size_t md_file_hdr_image_len,
+ uint8_t *md_file_index_image_ptr, uint64_t md_file_index_offset,
+ size_t md_file_index_image_len);
/*********************/
/* Package Variables */
@@ -177,12 +178,12 @@ H5FL_DEFINE(eot_queue_entry_t);
herr_t
H5F_vfd_swmr_init(H5F_t *f, hbool_t file_create)
{
- hsize_t md_size; /* Size of the metadata file */
- haddr_t hdr_addr; /* Address returned from H5MV_alloc() */
- H5F_shared_t *shared = f->shared;
- uint8_t md_idx_image[H5FD_MD_INDEX_SIZE(0)]; /* Buffer for metadata file index */
- uint8_t md_hdr_image[H5FD_MD_HEADER_SIZE]; /* Buffer for metadata file header */
- herr_t ret_value = SUCCEED; /* Return value */
+ hsize_t md_size; /* Size of the metadata file */
+ haddr_t hdr_addr; /* Address returned from H5MV_alloc() */
+ H5F_shared_t *shared = f->shared;
+ uint8_t md_idx_image[H5FD_MD_INDEX_SIZE(0)]; /* Buffer for metadata file index */
+ uint8_t md_hdr_image[H5FD_MD_HEADER_SIZE]; /* Buffer for metadata file header */
+ herr_t ret_value = SUCCEED; /* Return value */
FUNC_ENTER_NOAPI(FAIL)
@@ -201,8 +202,8 @@ H5F_vfd_swmr_init(H5F_t *f, hbool_t file_create)
shared->tick_num = 0;
/* Create the metadata file */
- if (((shared->vfd_swmr_md_fd = HDopen(shared->vfd_swmr_config.md_file_path, O_CREAT | O_RDWR | O_TRUNC,
- H5_POSIX_CREATE_MODE_RW))) < 0)
+ if (((shared->vfd_swmr_md_fd = HDopen(shared->vfd_swmr_config.md_file_path,
+ O_CREAT | O_RDWR | O_TRUNC, H5_POSIX_CREATE_MODE_RW))) < 0)
HGOTO_ERROR(H5E_FILE, H5E_CANTOPENFILE, FAIL, "unable to create the metadata file")
md_size = (hsize_t)shared->vfd_swmr_config.md_pages_reserved * shared->fs_page_size;
@@ -213,7 +214,7 @@ H5F_vfd_swmr_init(H5F_t *f, hbool_t file_create)
HDassert(H5F_addr_eq(hdr_addr, H5FD_MD_HEADER_OFF));
shared->writer_index_offset = H5FD_MD_HEADER_SIZE;
- shared->vfd_swmr_md_eoa = (haddr_t)md_size;
+ shared->vfd_swmr_md_eoa = (haddr_t)md_size;
/* When opening an existing HDF5 file, create header and empty
* index in the metadata file
@@ -225,29 +226,27 @@ H5F_vfd_swmr_init(H5F_t *f, hbool_t file_create)
if (H5F__vfd_swmr_construct_write_md_hdr(shared, 0, md_hdr_image) < 0)
HGOTO_ERROR(H5E_FILE, H5E_CANTSET, FAIL, "fail to create header in md");
-
}
/* For VFD SWMR testing: invoke callback if set to generate metadata file checksum */
- if(shared->generate_md_ck_cb) {
- if(shared->generate_md_ck_cb(shared->vfd_swmr_config.md_file_path, shared->updater_seq_num) < 0)
+ if (shared->generate_md_ck_cb) {
+ if (shared->generate_md_ck_cb(shared->vfd_swmr_config.md_file_path, shared->updater_seq_num) < 0)
HGOTO_ERROR(H5E_FILE, H5E_SYSTEM, FAIL, "error from generate_md_ck_cb()")
}
/* Generate updater files if configuration indicates so */
- if(shared->vfd_swmr_config.generate_updater_files) {
+ if (shared->vfd_swmr_config.generate_updater_files) {
shared->updater_seq_num = 0;
- if(H5F__generate_updater_file(f, 0, file_create ? CREATE_METADATA_FILE_ONLY_FLAG : 0,
- md_hdr_image, H5FD_MD_HEADER_SIZE,
- md_idx_image, shared->writer_index_offset, H5FD_MD_INDEX_SIZE(0)) < 0)
+ if (H5F__generate_updater_file(f, 0, file_create ? CREATE_METADATA_FILE_ONLY_FLAG : 0,
+ md_hdr_image, H5FD_MD_HEADER_SIZE, md_idx_image,
+ shared->writer_index_offset, H5FD_MD_INDEX_SIZE(0)) < 0)
HGOTO_ERROR(H5E_FILE, H5E_SYSTEM, FAIL, "can't generate updater file")
}
- shared->tick_num = 1;
+ shared->tick_num = 1;
if (H5PB_vfd_swmr__set_tick(shared) < 0)
HGOTO_ERROR(H5E_FILE, H5E_SYSTEM, FAIL, "Can't update page buffer current tick")
-
}
else { /* VFD SWMR reader */
@@ -323,8 +322,8 @@ H5F_vfd_swmr_close_or_flush(H5F_t *f, hbool_t closing)
{
H5F_shared_t * shared = f->shared;
shadow_defree_t *curr;
- uint8_t md_idx_image[H5FD_MD_INDEX_SIZE(0)]; /* Buffer for metadata file index */
- uint8_t md_hdr_image[H5FD_MD_HEADER_SIZE]; /* Buffer for metadata file header */
+ uint8_t md_idx_image[H5FD_MD_INDEX_SIZE(0)]; /* Buffer for metadata file index */
+ uint8_t md_hdr_image[H5FD_MD_HEADER_SIZE]; /* Buffer for metadata file header */
herr_t ret_value = SUCCEED;
FUNC_ENTER_NOAPI(FAIL)
@@ -348,8 +347,8 @@ H5F_vfd_swmr_close_or_flush(H5F_t *f, hbool_t closing)
shared->vfd_swmr_md_fd = -1;
/* For VFD SWMR testing: invoke callback if set to generate metadata file checksum */
- if(shared->generate_md_ck_cb) {
- if(shared->generate_md_ck_cb(shared->vfd_swmr_config.md_file_path, shared->updater_seq_num) < 0)
+ if (shared->generate_md_ck_cb) {
+ if (shared->generate_md_ck_cb(shared->vfd_swmr_config.md_file_path, shared->updater_seq_num) < 0)
HGOTO_ERROR(H5E_FILE, H5E_SYSTEM, FAIL, "error from generate_md_ck_cb()")
}
@@ -370,10 +369,10 @@ H5F_vfd_swmr_close_or_flush(H5F_t *f, hbool_t closing)
HDassert(TAILQ_EMPTY(&shared->shadow_defrees));
- if(shared->vfd_swmr_config.generate_updater_files) {
- if(H5F__generate_updater_file(f, 0, FINAL_UPDATE_FLAG,
- md_hdr_image, H5FD_MD_HEADER_SIZE,
- md_idx_image, shared->writer_index_offset, H5FD_MD_INDEX_SIZE(0)) < 0)
+ if (shared->vfd_swmr_config.generate_updater_files) {
+ if (H5F__generate_updater_file(f, 0, FINAL_UPDATE_FLAG, md_hdr_image, H5FD_MD_HEADER_SIZE,
+ md_idx_image, shared->writer_index_offset,
+ H5FD_MD_INDEX_SIZE(0)) < 0)
HGOTO_ERROR(H5E_FILE, H5E_SYSTEM, FAIL, "can't generate updater file")
}
}
@@ -462,11 +461,11 @@ H5F_update_vfd_swmr_metadata_file(H5F_t *f, uint32_t num_entries, H5FD_vfd_swmr_
H5F_shared_t * shared = f->shared;
shadow_defree_t *prev;
shadow_defree_t *shadow_defree;
- haddr_t md_addr; /* Address in the metadata file */
- uint32_t i; /* Local index variable */
- uint8_t *md_idx_image = NULL;
- uint8_t md_hdr_image[H5FD_MD_HEADER_SIZE]; /* Buffer for metadata file header */
- herr_t ret_value = SUCCEED; /* Return value */
+ haddr_t md_addr; /* Address in the metadata file */
+ uint32_t i; /* Local index variable */
+ uint8_t * md_idx_image = NULL;
+ uint8_t md_hdr_image[H5FD_MD_HEADER_SIZE]; /* Buffer for metadata file header */
+ herr_t ret_value = SUCCEED; /* Return value */
FUNC_ENTER_NOAPI(FAIL)
@@ -512,7 +511,7 @@ H5F_update_vfd_swmr_metadata_file(H5F_t *f, uint32_t num_entries, H5FD_vfd_swmr_
/* Compute checksum and update the index entry */
index[i].md_file_page_offset = md_addr / shared->fs_page_size;
- index[i].checksum = H5_checksum_metadata(index[i].entry_ptr, index[i].length, 0);
+ index[i].checksum = H5_checksum_metadata(index[i].entry_ptr, index[i].length, 0);
#if 0 /* JRM */
HDfprintf(stderr,
@@ -530,22 +529,22 @@ H5F_update_vfd_swmr_metadata_file(H5F_t *f, uint32_t num_entries, H5FD_vfd_swmr_
HDassert(shared->fs_page_size == 4096);
#endif /* JRM */
- if(shared->vfd_swmr_config.maintain_metadata_file) {
+ if (shared->vfd_swmr_config.maintain_metadata_file) {
/* Seek and write the entry to the metadata file */
if (HDlseek(shared->vfd_swmr_md_fd, (HDoff_t)md_addr, SEEK_SET) < 0)
HGOTO_ERROR(H5E_FILE, H5E_SEEKERROR, FAIL, "unable to seek in the metadata file")
- if (HDwrite(shared->vfd_swmr_md_fd, index[i].entry_ptr, index[i].length) != (ssize_t)index[i].length)
+ if (HDwrite(shared->vfd_swmr_md_fd, index[i].entry_ptr, index[i].length) !=
+ (ssize_t)index[i].length)
HGOTO_ERROR(H5E_FILE, H5E_WRITEERROR, FAIL,
"error in writing the page/multi-page entry to metadata file")
}
- if(!shared->vfd_swmr_config.generate_updater_files)
+ if (!shared->vfd_swmr_config.generate_updater_files)
index[i].entry_ptr = NULL;
-
}
if ((md_idx_image = HDmalloc(H5FD_MD_INDEX_SIZE(num_entries))) == NULL)
@@ -572,7 +571,7 @@ H5F_update_vfd_swmr_metadata_file(H5F_t *f, uint32_t num_entries, H5FD_vfd_swmr_
* --remove the associated entries from the list
*/
- /* if (shared->tick_num <= shared->vfd_swmr_config.max_lag),
+ /* if (shared->tick_num <= shared->vfd_swmr_config.max_lag),
it is too early for any reclamations to be due.
*/
if (shared->tick_num > shared->vfd_swmr_config.max_lag) {
@@ -594,23 +593,21 @@ H5F_update_vfd_swmr_metadata_file(H5F_t *f, uint32_t num_entries, H5FD_vfd_swmr_
}
}
-
/* For VFD SWMR testing: invoke callback if set to generate metadata file checksum */
- if(shared->generate_md_ck_cb) {
- if(shared->generate_md_ck_cb(shared->vfd_swmr_config.md_file_path, shared->updater_seq_num) < 0)
+ if (shared->generate_md_ck_cb) {
+ if (shared->generate_md_ck_cb(shared->vfd_swmr_config.md_file_path, shared->updater_seq_num) < 0)
HGOTO_ERROR(H5E_FILE, H5E_SYSTEM, FAIL, "error from generate_md_ck_cb()")
}
/* Generate updater files with num_entries */
- if(shared->vfd_swmr_config.generate_updater_files)
- if(H5F__generate_updater_file(f, num_entries, 0,
- md_hdr_image, H5FD_MD_HEADER_SIZE,
- md_idx_image, shared->writer_index_offset, H5FD_MD_INDEX_SIZE(num_entries)) < 0)
+ if (shared->vfd_swmr_config.generate_updater_files)
+ if (H5F__generate_updater_file(f, num_entries, 0, md_hdr_image, H5FD_MD_HEADER_SIZE, md_idx_image,
+ shared->writer_index_offset, H5FD_MD_INDEX_SIZE(num_entries)) < 0)
HGOTO_ERROR(H5E_FILE, H5E_SYSTEM, FAIL, "can't generate updater file")
done:
- if (md_idx_image)
+ if (md_idx_image)
HDfree(md_idx_image);
FUNC_LEAVE_NOAPI(ret_value)
@@ -1632,8 +1629,8 @@ done:
static herr_t
H5F__vfd_swmr_construct_write_md_hdr(H5F_shared_t *shared, uint32_t num_entries, uint8_t *image)
{
- uint8_t *p = NULL; /* Pointer to buffer */
- uint32_t metadata_chksum; /* Computed metadata checksum value */
+ uint8_t *p = NULL; /* Pointer to buffer */
+ uint32_t metadata_chksum; /* Computed metadata checksum value */
/* Size of header and index */
const size_t hdr_size = H5FD_MD_HEADER_SIZE;
ssize_t nwritten;
@@ -1665,7 +1662,7 @@ H5F__vfd_swmr_construct_write_md_hdr(H5F_shared_t *shared, uint32_t num_entries,
/* Sanity checks on header */
HDassert(p - image == (ptrdiff_t)hdr_size);
- if(shared->vfd_swmr_config.maintain_metadata_file) {
+ if (shared->vfd_swmr_config.maintain_metadata_file) {
/* Set to beginning of the file */
if (HDlseek(shared->vfd_swmr_md_fd, H5FD_MD_HEADER_OFF, SEEK_SET) < 0)
@@ -1710,7 +1707,7 @@ static herr_t
H5F__vfd_swmr_construct_write_md_idx(H5F_shared_t *shared, uint32_t num_entries,
struct H5FD_vfd_swmr_idx_entry_t index[], uint8_t *image)
{
- uint8_t *p = NULL; /* Pointer to buffer */
+ uint8_t *p = NULL; /* Pointer to buffer */
uint32_t metadata_chksum; /* Computed metadata checksum value */
/* Size of index */
const size_t idx_size = H5FD_MD_INDEX_SIZE(num_entries);
@@ -1757,7 +1754,7 @@ H5F__vfd_swmr_construct_write_md_idx(H5F_shared_t *shared, uint32_t num_entries,
/* Verify the md file descriptor exists */
HDassert(shared->vfd_swmr_md_fd >= 0);
- if(shared->vfd_swmr_config.maintain_metadata_file) {
+ if (shared->vfd_swmr_config.maintain_metadata_file) {
if (HDlseek(shared->vfd_swmr_md_fd, (HDoff_t)shared->writer_index_offset, SEEK_SET) < 0)
HGOTO_ERROR(H5E_VFL, H5E_SEEKERROR, FAIL, "unable to seek in metadata file")
@@ -2081,10 +2078,10 @@ H5F_post_vfd_swmr_log_entry(H5F_t *f, int entry_type_code, char *log_info)
static herr_t
H5F__vfd_swmr_construct_ud_hdr(H5F_vfd_swmr_updater_t *updater)
{
- uint8_t *p = NULL; /* Pointer to buffer */
- uint8_t *image = (uint8_t *)updater->header_image_ptr;
- uint32_t metadata_chksum; /* Computed metadata checksum value */
- herr_t ret_value = SUCCEED; /* Return value */
+ uint8_t *p = NULL; /* Pointer to buffer */
+ uint8_t *image = (uint8_t *)updater->header_image_ptr;
+ uint32_t metadata_chksum; /* Computed metadata checksum value */
+ herr_t ret_value = SUCCEED; /* Return value */
FUNC_ENTER_STATIC_NOERR
@@ -2097,7 +2094,8 @@ H5F__vfd_swmr_construct_ud_hdr(H5F_vfd_swmr_updater_t *updater)
HDmemcpy(p, H5F_UD_HEADER_MAGIC, (size_t)H5_SIZEOF_MAGIC);
p += H5_SIZEOF_MAGIC;
- /* Encode version number, flags, page size, sequence number, tick number, change list offset, change list length */
+ /* Encode version number, flags, page size, sequence number, tick number, change list offset, change list
+ * length */
UINT16ENCODE(p, H5F_UD_VERSION);
UINT16ENCODE(p, updater->flags);
UINT32ENCODE(p, updater->page_size);
@@ -2139,11 +2137,11 @@ H5F__vfd_swmr_construct_ud_hdr(H5F_vfd_swmr_updater_t *updater)
static herr_t
H5F__vfd_swmr_construct_ud_cl(H5F_vfd_swmr_updater_t *updater)
{
- uint8_t *p = NULL; /* Pointer to buffer */
+ uint8_t *p = NULL; /* Pointer to buffer */
uint8_t *image = (uint8_t *)updater->change_list_image_ptr;
- uint32_t metadata_chksum; /* Computed metadata checksum value */
- unsigned i; /* Local index variable */
- herr_t ret_value = SUCCEED; /* Return value */
+ uint32_t metadata_chksum; /* Computed metadata checksum value */
+ unsigned i; /* Local index variable */
+ herr_t ret_value = SUCCEED; /* Return value */
FUNC_ENTER_STATIC_NOERR
@@ -2166,8 +2164,8 @@ H5F__vfd_swmr_construct_ud_cl(H5F_vfd_swmr_updater_t *updater)
UINT32ENCODE(p, updater->md_file_header_len);
/* Calculate checksum on the image of the metadata file header */
- updater->md_file_header_image_chksum = H5_checksum_metadata(
- updater->md_file_header_image_ptr, (size_t)updater->md_file_header_len, 0);
+ updater->md_file_header_image_chksum =
+ H5_checksum_metadata(updater->md_file_header_image_ptr, (size_t)updater->md_file_header_len, 0);
/* Encode Metadata File Header Checksum */
UINT32ENCODE(p, updater->md_file_header_image_chksum);
@@ -2182,8 +2180,8 @@ H5F__vfd_swmr_construct_ud_cl(H5F_vfd_swmr_updater_t *updater)
UINT32ENCODE(p, updater->md_file_index_len);
/* Calculate checksum on the image of the metadata file index */
- updater->md_file_index_image_chksum = H5_checksum_metadata(
- updater->md_file_index_image_ptr, (size_t)updater->md_file_index_len, 0);
+ updater->md_file_index_image_chksum =
+ H5_checksum_metadata(updater->md_file_index_image_ptr, (size_t)updater->md_file_index_len, 0);
/* Encode Metadata File Index Checksum */
UINT32ENCODE(p, updater->md_file_index_image_chksum);
@@ -2221,7 +2219,7 @@ H5F__vfd_swmr_construct_ud_cl(H5F_vfd_swmr_updater_t *updater)
* --determine num_change_list entries
* --allocate buffers
* --construct on disk image (serialize) of the updater header and change list
- * --create updater file using a temporay file name:
+ * --create updater file using a temporay file name:
* --<shared->vfd_swmr_config.updater_file_path>.ud_tmp
* --allocate space and write the following to the updater file
* --updater file header
@@ -2243,50 +2241,49 @@ H5F__vfd_swmr_construct_ud_cl(H5F_vfd_swmr_updater_t *updater)
*-------------------------------------------------------------------------
*/
static herr_t
-H5F__generate_updater_file(H5F_t *f, uint32_t num_entries, uint16_t flags,
- uint8_t *md_file_hdr_image_ptr, size_t md_file_hdr_image_len,
- uint8_t *md_file_index_image_ptr, uint64_t md_file_index_offset,
- size_t md_file_index_image_len)
+H5F__generate_updater_file(H5F_t *f, uint32_t num_entries, uint16_t flags, uint8_t *md_file_hdr_image_ptr,
+ size_t md_file_hdr_image_len, uint8_t *md_file_index_image_ptr,
+ uint64_t md_file_index_offset, size_t md_file_index_image_len)
{
- H5F_shared_t *shared = f->shared; /* shared file pointer */
- H5F_vfd_swmr_updater_t updater; /* Updater struct */
- uint32_t next_page_offset;
- H5FD_t *ud_file = NULL; /* Low-level file struct */
- char namebuf[H5F__MAX_VFD_SWMR_FILE_NAME_LEN];
- char newname[H5F__MAX_VFD_SWMR_FILE_NAME_LEN];
- unsigned i;
- hsize_t alloc_size;
- herr_t ret_value = SUCCEED; /* Return value */
+ H5F_shared_t * shared = f->shared; /* shared file pointer */
+ H5F_vfd_swmr_updater_t updater; /* Updater struct */
+ uint32_t next_page_offset;
+ H5FD_t * ud_file = NULL; /* Low-level file struct */
+ char namebuf[H5F__MAX_VFD_SWMR_FILE_NAME_LEN];
+ char newname[H5F__MAX_VFD_SWMR_FILE_NAME_LEN];
+ unsigned i;
+ hsize_t alloc_size;
+ herr_t ret_value = SUCCEED; /* Return value */
FUNC_ENTER_NOAPI(FAIL)
/* Updater file header fields */
- updater.version = H5F_UD_VERSION;
- updater.flags = flags;
- updater.page_size = (uint32_t)shared->fs_page_size;
- updater.sequence_number = shared->updater_seq_num;
- updater.tick_num = shared->tick_num;
- updater.header_image_ptr = NULL;
- updater.header_image_len = H5F_UD_HEADER_SIZE;
+ updater.version = H5F_UD_VERSION;
+ updater.flags = flags;
+ updater.page_size = (uint32_t)shared->fs_page_size;
+ updater.sequence_number = shared->updater_seq_num;
+ updater.tick_num = shared->tick_num;
+ updater.header_image_ptr = NULL;
+ updater.header_image_len = H5F_UD_HEADER_SIZE;
updater.change_list_image_ptr = NULL;
- updater.change_list_offset = 0;
- updater.change_list_len = 0;
+ updater.change_list_offset = 0;
+ updater.change_list_len = 0;
/* Updater file change list fields */
/* md_file_header related fields */
updater.md_file_header_ud_file_page_offset = 0;
- updater.md_file_header_image_ptr = md_file_hdr_image_ptr; /* parameter */
- updater.md_file_header_len = md_file_hdr_image_len; /* parameter */
-
+ updater.md_file_header_image_ptr = md_file_hdr_image_ptr; /* parameter */
+ updater.md_file_header_len = md_file_hdr_image_len; /* parameter */
+
/* md_file_index related fields */
updater.md_file_index_ud_file_page_offset = 0;
- updater.md_file_index_image_ptr = md_file_index_image_ptr; /* parameter */
- updater.md_file_index_md_file_offset = md_file_index_offset; /* parameter */
- updater.md_file_index_len = md_file_index_image_len; /* parameter */
+ updater.md_file_index_image_ptr = md_file_index_image_ptr; /* parameter */
+ updater.md_file_index_md_file_offset = md_file_index_offset; /* parameter */
+ updater.md_file_index_len = md_file_index_image_len; /* parameter */
updater.num_change_list_entries = 0;
- updater.change_list = NULL;
+ updater.change_list = NULL;
/* Scan index to determine updater.num_change_list_entries */
for (i = 0; i < num_entries; i++) {
@@ -2297,18 +2294,18 @@ H5F__generate_updater_file(H5F_t *f, uint32_t num_entries, uint16_t flags,
if (flags == CREATE_METADATA_FILE_ONLY_FLAG)
HDassert(updater.sequence_number == 0);
- /* For file creation, just generate a header with this flag set */
+ /* For file creation, just generate a header with this flag set */
else {
/* Update 2 updater file header fields: change_list_len, change_list_offset */
- updater.change_list_len = H5F_UD_CL_SIZE(updater.num_change_list_entries);
+ updater.change_list_len = H5F_UD_CL_SIZE(updater.num_change_list_entries);
updater.change_list_offset = updater.header_image_len;
}
-
/* Create the updater file with a temporary file name */
HDsprintf(namebuf, "%s.ud_tmp", shared->vfd_swmr_config.updater_file_path);
- if((ud_file = H5FD_open(namebuf, H5F_ACC_TRUNC|H5F_ACC_RDWR|H5F_ACC_CREAT, H5P_FILE_ACCESS_DEFAULT, HADDR_UNDEF)) == NULL)
+ if ((ud_file = H5FD_open(namebuf, H5F_ACC_TRUNC | H5F_ACC_RDWR | H5F_ACC_CREAT, H5P_FILE_ACCESS_DEFAULT,
+ HADDR_UNDEF)) == NULL)
HGOTO_ERROR(H5E_FILE, H5E_CANTINIT, FAIL, "fail to open updater file");
if ((updater.header_image_ptr = HDmalloc(updater.header_image_len)) == NULL)
@@ -2319,37 +2316,39 @@ H5F__generate_updater_file(H5F_t *f, uint32_t num_entries, uint16_t flags,
HGOTO_ERROR(H5E_FILE, H5E_CANTSET, FAIL, "fail to create updater file header ");
/* Allocate space in updater file for updater file header */
- if(H5FD__alloc_real(ud_file, H5FD_MEM_DEFAULT, updater.header_image_len, NULL, NULL) == HADDR_UNDEF)
+ if (H5FD__alloc_real(ud_file, H5FD_MEM_DEFAULT, updater.header_image_len, NULL, NULL) == HADDR_UNDEF)
HGOTO_ERROR(H5E_FILE, H5E_CANTINIT, FAIL, "unable to allocate file memory")
/* Write updater file header */
- if(H5FD_write(ud_file, H5FD_MEM_DEFAULT, H5F_UD_HEADER_OFF, updater.header_image_len, updater.header_image_ptr) < 0)
+ if (H5FD_write(ud_file, H5FD_MEM_DEFAULT, H5F_UD_HEADER_OFF, updater.header_image_len,
+ updater.header_image_ptr) < 0)
HGOTO_ERROR(H5E_FILE, H5E_WRITEERROR, FAIL, "ud file write failed")
-
if (flags != CREATE_METADATA_FILE_ONLY_FLAG) {
- next_page_offset = ((uint32_t)(updater.header_image_len + updater.change_list_len) / updater.page_size) + 1;
+ next_page_offset =
+ ((uint32_t)(updater.header_image_len + updater.change_list_len) / updater.page_size) + 1;
- if(updater.num_change_list_entries) {
+ if (updater.num_change_list_entries) {
/* Allocate space for change list entries */
- if((updater.change_list = HDmalloc(sizeof(H5F_vfd_swmr_updater_cl_entry_t) *
- updater.num_change_list_entries)) == NULL)
+ if ((updater.change_list = HDmalloc(sizeof(H5F_vfd_swmr_updater_cl_entry_t) *
+ updater.num_change_list_entries)) == NULL)
HGOTO_ERROR(H5E_RESOURCE, H5E_NOSPACE, FAIL, "memory allocation failed for ud cl")
-
/* Initialize change list entries */
for (i = 0; i < num_entries; i++) {
if (shared->mdf_idx[i].entry_ptr != NULL &&
shared->mdf_idx[i].tick_of_last_change == shared->tick_num) {
- updater.change_list[i].entry_image_ptr = shared->mdf_idx[i].entry_ptr;
+ updater.change_list[i].entry_image_ptr = shared->mdf_idx[i].entry_ptr;
updater.change_list[i].entry_image_ud_file_page_offset = 0;
- updater.change_list[i].entry_image_md_file_page_offset = (uint32_t)shared->mdf_idx[i].md_file_page_offset;
- updater.change_list[i].entry_image_h5_file_page_offset = (uint32_t)shared->mdf_idx[i].hdf5_page_offset;
- updater.change_list[i].entry_image_len = shared->mdf_idx[i].length;
+ updater.change_list[i].entry_image_md_file_page_offset =
+ (uint32_t)shared->mdf_idx[i].md_file_page_offset;
+ updater.change_list[i].entry_image_h5_file_page_offset =
+ (uint32_t)shared->mdf_idx[i].hdf5_page_offset;
+ updater.change_list[i].entry_image_len = shared->mdf_idx[i].length;
updater.change_list[i].entry_image_checksum = shared->mdf_idx[i].checksum;
shared->mdf_idx[i].entry_ptr = NULL;
@@ -2357,9 +2356,10 @@ H5F__generate_updater_file(H5F_t *f, uint32_t num_entries, uint16_t flags,
}
/* Set up page aligned space for all metadata pages */
- for(i = 0; i < updater.num_change_list_entries; i++) {
+ for (i = 0; i < updater.num_change_list_entries; i++) {
updater.change_list[i].entry_image_ud_file_page_offset = next_page_offset;
- next_page_offset += (((uint32_t)updater.change_list[i].entry_image_len / updater.page_size) + 1);
+ next_page_offset +=
+ (((uint32_t)updater.change_list[i].entry_image_len / updater.page_size) + 1);
}
}
@@ -2378,51 +2378,55 @@ H5F__generate_updater_file(H5F_t *f, uint32_t num_entries, uint16_t flags,
HGOTO_ERROR(H5E_FILE, H5E_CANTSET, FAIL, "fail to create updater file cl");
/* Allocate space in updater file for updater file change list */
- if(H5FD__alloc_real(ud_file, H5FD_MEM_DEFAULT, updater.header_image_len+updater.change_list_len, NULL, NULL) == HADDR_UNDEF)
+ if (H5FD__alloc_real(ud_file, H5FD_MEM_DEFAULT, updater.header_image_len + updater.change_list_len,
+ NULL, NULL) == HADDR_UNDEF)
HGOTO_ERROR(H5E_FILE, H5E_CANTINIT, FAIL, "unable to allocate file memory")
/* Write updater file change list */
- if(H5FD_write(ud_file, H5FD_MEM_DEFAULT, updater.header_image_len,
- updater.change_list_len, updater.change_list_image_ptr) < 0)
+ if (H5FD_write(ud_file, H5FD_MEM_DEFAULT, updater.header_image_len, updater.change_list_len,
+ updater.change_list_image_ptr) < 0)
HGOTO_ERROR(H5E_FILE, H5E_WRITEERROR, FAIL, "ud file write failed")
-
/* Allocate and write metadata pages */
for (i = 0; i < updater.num_change_list_entries; i++) {
- alloc_size = updater.change_list[i].entry_image_ud_file_page_offset * updater.page_size +
+ alloc_size = updater.change_list[i].entry_image_ud_file_page_offset * updater.page_size +
updater.change_list[i].entry_image_len;
- if(H5FD__alloc_real(ud_file, H5FD_MEM_DEFAULT, alloc_size, NULL, NULL) == HADDR_UNDEF)
+ if (H5FD__alloc_real(ud_file, H5FD_MEM_DEFAULT, alloc_size, NULL, NULL) == HADDR_UNDEF)
HGOTO_ERROR(H5E_FILE, H5E_CANTINIT, FAIL, "unable to allocate file memory")
- if(H5FD_write(ud_file, H5FD_MEM_DEFAULT,
- updater.change_list[i].entry_image_ud_file_page_offset * updater.page_size,
- updater.change_list[i].entry_image_len,
- updater.change_list[i].entry_image_ptr) < 0)
+ if (H5FD_write(ud_file, H5FD_MEM_DEFAULT,
+ updater.change_list[i].entry_image_ud_file_page_offset * updater.page_size,
+ updater.change_list[i].entry_image_len,
+ updater.change_list[i].entry_image_ptr) < 0)
HGOTO_ERROR(H5E_FILE, H5E_WRITEERROR, FAIL, "ud file write failed")
}
/* Allocate and write metadata file index */
- alloc_size = updater.md_file_index_ud_file_page_offset * updater.page_size + updater.md_file_index_len;
- if(H5FD__alloc_real(ud_file, H5FD_MEM_DEFAULT, alloc_size, NULL, NULL) == HADDR_UNDEF)
+ alloc_size =
+ updater.md_file_index_ud_file_page_offset * updater.page_size + updater.md_file_index_len;
+ if (H5FD__alloc_real(ud_file, H5FD_MEM_DEFAULT, alloc_size, NULL, NULL) == HADDR_UNDEF)
HGOTO_ERROR(H5E_FILE, H5E_CANTINIT, FAIL, "unable to allocate file memory")
- if(H5FD_write(ud_file, H5FD_MEM_DEFAULT, updater.md_file_index_ud_file_page_offset * updater.page_size,
- updater.md_file_index_len, updater.md_file_index_image_ptr) < 0)
+ if (H5FD_write(ud_file, H5FD_MEM_DEFAULT,
+ updater.md_file_index_ud_file_page_offset * updater.page_size,
+ updater.md_file_index_len, updater.md_file_index_image_ptr) < 0)
HGOTO_ERROR(H5E_FILE, H5E_WRITEERROR, FAIL, "ud file write failed")
/* Allocate and write metadata file header */
- alloc_size = updater.md_file_header_ud_file_page_offset * updater.page_size + updater.md_file_header_len;
- if(H5FD__alloc_real(ud_file, H5FD_MEM_DEFAULT, alloc_size, NULL, NULL) == HADDR_UNDEF)
+ alloc_size =
+ updater.md_file_header_ud_file_page_offset * updater.page_size + updater.md_file_header_len;
+ if (H5FD__alloc_real(ud_file, H5FD_MEM_DEFAULT, alloc_size, NULL, NULL) == HADDR_UNDEF)
HGOTO_ERROR(H5E_FILE, H5E_CANTINIT, FAIL, "unable to allocate file memory")
- if(H5FD_write(ud_file, H5FD_MEM_DEFAULT, updater.md_file_header_ud_file_page_offset * updater.page_size,
- updater.md_file_header_len, updater.md_file_header_image_ptr) < 0)
+ if (H5FD_write(ud_file, H5FD_MEM_DEFAULT,
+ updater.md_file_header_ud_file_page_offset * updater.page_size,
+ updater.md_file_header_len, updater.md_file_header_image_ptr) < 0)
HGOTO_ERROR(H5E_FILE, H5E_WRITEERROR, FAIL, "ud file write failed")
}
/* Close the updater file and rename the file */
- if(H5FD_close(ud_file) < 0)
+ if (H5FD_close(ud_file) < 0)
HGOTO_ERROR(H5E_FILE, H5E_CANTCLOSEFILE, FAIL, "unable to close updater file")
HDsprintf(newname, "%s.%lu", shared->vfd_swmr_config.updater_file_path, shared->updater_seq_num);
HDrename(namebuf, newname);
@@ -2430,13 +2434,13 @@ H5F__generate_updater_file(H5F_t *f, uint32_t num_entries, uint16_t flags,
++shared->updater_seq_num;
done:
- if(updater.header_image_ptr)
+ if (updater.header_image_ptr)
HDfree(updater.header_image_ptr);
- if(updater.change_list_image_ptr)
+ if (updater.change_list_image_ptr)
HDfree(updater.change_list_image_ptr);
- if(updater.change_list)
+ if (updater.change_list)
HDfree(updater.change_list);
FUNC_LEAVE_NOAPI(ret_value)
-} /* H5F__generate_updater_file() */
+} /* H5F__generate_updater_file() */