summaryrefslogtreecommitdiffstats
path: root/src/H5FDsubfiling/H5subfiling_common.h
diff options
context:
space:
mode:
authorjhendersonHDF <jhenderson@hdfgroup.org>2022-08-09 23:05:37 (GMT)
committerGitHub <noreply@github.com>2022-08-09 23:05:37 (GMT)
commitef33ac8bac5fd201b41d1a3084f03834f47729a2 (patch)
treead4756b872abff6d16f11d9a6c6c949e8f359cad /src/H5FDsubfiling/H5subfiling_common.h
parentb84241e57a97309b15846da4cc74611a66d92f6d (diff)
downloadhdf5-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.h27
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