diff options
author | jhendersonHDF <jhenderson@hdfgroup.org> | 2022-08-09 23:05:37 (GMT) |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-08-09 23:05:37 (GMT) |
commit | ef33ac8bac5fd201b41d1a3084f03834f47729a2 (patch) | |
tree | ad4756b872abff6d16f11d9a6c6c949e8f359cad /src/H5FDsubfiling/H5subfiling_common.h | |
parent | b84241e57a97309b15846da4cc74611a66d92f6d (diff) | |
download | hdf5-ef33ac8bac5fd201b41d1a3084f03834f47729a2.zip hdf5-ef33ac8bac5fd201b41d1a3084f03834f47729a2.tar.gz hdf5-ef33ac8bac5fd201b41d1a3084f03834f47729a2.tar.bz2 |
Subfiling VFD - tidying up and fixing a few new testing failures (#1977)
* Rename Subfiling IOC "thread_pool_count" field to "thread_pool_size"
* Add simple HDF5 example for Subfiling VFD
* Subfiling VFD - never cache app topology as it may change
* Subfiling VFD - cleanup unused funtionality and tidy up some TODOs
* Subfiling VFD - tidy up subfiling error handling in H5subfiling_common.c
* Subfiling VFD - show number of failed I/O requests on close
* Subfiling VFD - Update file cmp callback after switching to MPI I/O VFD
* Amend RELEASE.txt with info about h5fuse.sh and Subfiling limitations
* Subfiling VFD - switch to using H5_basename and H5_dirname
Diffstat (limited to 'src/H5FDsubfiling/H5subfiling_common.h')
-rw-r--r-- | src/H5FDsubfiling/H5subfiling_common.h | 27 |
1 files changed, 8 insertions, 19 deletions
diff --git a/src/H5FDsubfiling/H5subfiling_common.h b/src/H5FDsubfiling/H5subfiling_common.h index 3195c9d..6e2965f 100644 --- a/src/H5FDsubfiling/H5subfiling_common.h +++ b/src/H5FDsubfiling/H5subfiling_common.h @@ -23,6 +23,7 @@ #include "H5Iprivate.h" #include "H5FDsubfiling.h" +#include "H5FDioc.h" /* * Some definitions for debugging the Subfiling feature @@ -189,25 +190,15 @@ typedef struct { */ typedef struct { /* {Datasize, Offset, FileID} */ - int64_t header[3]; /* The basic RPC input plus */ - int tag; /* the supplied OPCODE tag */ - int source; /* Rank of who sent the message */ - int subfile_rank; /* The IOC rank */ - int64_t context_id; /* context to be used to complete */ - double start_time; /* the request, + time of receipt */ - /* from which we calc Time(queued) */ - void *buffer; /* for writes, we keep the buffer */ - /* around for awhile... */ - volatile int in_progress; /* Not used! */ - volatile int serialize; /* worker thread needs to wait while true */ - volatile int dependents; //* If current work item has dependents */ - int depend_id; /* work queue index of the dependent */ + int64_t header[3]; /* The basic RPC input plus */ + int tag; /* the supplied OPCODE tag */ + int source; /* Rank of who sent the message */ + int subfile_rank; /* The IOC rank */ + int64_t context_id; /* context to be used to complete */ + double start_time; /* the request, + time of receipt */ + /* from which we calc Time(queued) */ } sf_work_request_t; -extern int sf_verbose_flag; - -extern app_layout_t *sf_app_layout; - #ifdef __cplusplus extern "C" { #endif @@ -225,8 +216,6 @@ H5_DLL herr_t H5_get_num_iocs_from_config_file(FILE *config_file, int *n_io_con H5_DLL void H5_subfiling_log(int64_t sf_context_id, const char *fmt, ...); -void set_verbose_flag(int subfile_rank, int new_value); - #ifdef __cplusplus } #endif |