|
esdm_config_t * | esdm_config_init () |
|
esdm_config_t * | esdm_config_init_from_str (const char *str) |
|
esdm_config_t * | esdmI_getConfig () |
|
esdm_status | esdm_config_finalize (esdm_instance_t *esdm) |
|
char * | esdm_config_gather () |
|
esdm_config_backends_t * | esdm_config_get_backends (esdm_instance_t *esdm) |
|
esdm_config_backend_t * | esdm_config_get_metadata_coordinator (esdm_instance_t *esdm) |
|
esdm_instance_t * | esdmI_esdm () |
|
esdm_modules_t * | esdm_get_modules () |
|
esdm_modules_t * | esdm_modules_init (esdm_instance_t *esdm) |
|
esdm_backend_t * | esdm_modules_fastestBackend (esdm_modules_t *modules) |
|
esdm_backend_t * | esdm_modules_randomWeightedBackend (esdm_modules_t *modules) |
|
esdm_status | esdm_modules_finalize () |
|
esdm_backend_t ** | esdm_modules_makeBackendRecommendation (esdm_modules_t *modules, esdm_dataspace_t *space, int64_t *out_moduleCount, int64_t *out_maxFragmentSize) |
|
esdm_status | esdm_modules_register () |
|
esdm_status | esdm_modules_get_by_type (esdm_module_type_t type, esdm_module_type_array_t **array) |
|
esdm_scheduler_t * | esdm_scheduler_init (esdm_instance_t *esdm) |
|
esdm_status | esdm_scheduler_finalize (esdm_instance_t *esdm) |
|
esdm_status | esdm_scheduler_status_init (io_request_status_t *status) |
|
esdm_status | esdm_scheduler_status_finalize (io_request_status_t *status) |
|
esdm_status | esdm_scheduler_read_blocking (esdm_instance_t *esdm, esdm_dataset_t *dataset, void *buf, esdm_dataspace_t *memspace, esdmI_hypercubeSet_t **out_fillRegion, bool allowWriteback, bool requestIsInternal) |
|
esdm_status | esdm_scheduler_write_blocking (esdm_instance_t *esdm, esdm_dataset_t *dataset, void *buf, esdm_dataspace_t *memspace, bool requestIsInternal) |
|
esdm_status | esdmI_scheduler_writeFragmentBlocking (esdm_instance_t *esdm, esdm_fragment_t *fragment, bool requestIsInternal) |
|
void | esdmI_scheduler_writeFragmentNonblocking (esdm_instance_t *esdm, esdm_fragment_t *fragment, bool requestIsInternal, io_request_status_t *status) |
|
esdm_status | esdmI_scheduler_readSingleFragmentBlocking (esdm_instance_t *esdm, esdm_dataset_t *dataset, void *buffer, esdm_dataspace_t *memspace, esdm_fragment_t *fragment) |
|
esdm_status | esdm_scheduler_enqueue (esdm_instance_t *esdm, io_request_status_t *status, io_operation_t type, esdm_dataset_t *dataset, void *buf, esdm_dataspace_t *memspace) |
|
esdm_status | esdm_scheduler_wait (io_request_status_t *status) |
|
esdm_status | esdmI_readWithFillRegion (esdm_dataset_t *dataset, void *buf, esdm_dataspace_t *memspace, esdmI_hypercubeSet_t **out_fillRegion) |
|
void | fetch_performance_from_backend (gpointer key, gpointer value, gpointer user_data) |
|
esdm_performance_t * | esdm_performance_init (esdm_instance_t *esdm) |
|
esdm_status | esdm_performance_recommendation (esdm_instance_t *esdm, esdm_fragment_t *in, esdm_fragment_t *out) |
|
esdm_status | esdm_performance_finalize () |
|
esdm_readTimes_t | esdmI_performance_read () |
|
esdm_readTimes_t | esdmI_performance_read_add (const esdm_readTimes_t *a, const esdm_readTimes_t *b) |
|
esdm_readTimes_t | esdmI_performance_read_sub (const esdm_readTimes_t *minuend, const esdm_readTimes_t *subtrahend) |
|
void | esdmI_performance_read_print (FILE *stream, const char *linePrefix, const char *indentation, const esdm_readTimes_t *start, const esdm_readTimes_t *end) |
|
esdm_writeTimes_t | esdmI_performance_write () |
|
esdm_writeTimes_t | esdmI_performance_write_add (const esdm_writeTimes_t *a, const esdm_writeTimes_t *b) |
|
esdm_writeTimes_t | esdmI_performance_write_sub (const esdm_writeTimes_t *minuend, const esdm_writeTimes_t *subtrahend) |
|
void | esdmI_performance_write_print (FILE *stream, const char *linePrefix, const char *indentation, const esdm_writeTimes_t *start, const esdm_writeTimes_t *end) |
|
esdm_copyTimes_t | esdmI_performance_copy () |
|
esdm_copyTimes_t | esdmI_performance_copy_add (const esdm_copyTimes_t *a, const esdm_copyTimes_t *b) |
|
esdm_copyTimes_t | esdmI_performance_copy_sub (const esdm_copyTimes_t *minuend, const esdm_copyTimes_t *subtrahend) |
|
void | esdmI_performance_copy_print (FILE *stream, const char *linePrefix, const char *indentation, const esdm_copyTimes_t *start, const esdm_copyTimes_t *end) |
|
esdm_backendTimes_t | esdmI_performance_backend () |
|
esdm_backendTimes_t | esdmI_performance_backend_add (const esdm_backendTimes_t *a, const esdm_backendTimes_t *b) |
|
esdm_backendTimes_t | esdmI_performance_backend_sub (const esdm_backendTimes_t *minuend, const esdm_backendTimes_t *subtrahend) |
|
void | esdmI_performance_backend_print (FILE *stream, const char *linePrefix, const char *indentation, const esdm_backendTimes_t *start, const esdm_backendTimes_t *end) |
|
esdm_fragmentsTimes_t | esdmI_performance_fragments () |
|
esdm_fragmentsTimes_t | esdmI_performance_fragments_add (const esdm_fragmentsTimes_t *a, const esdm_fragmentsTimes_t *b) |
|
esdm_fragmentsTimes_t | esdmI_performance_fragments_sub (const esdm_fragmentsTimes_t *minuend, const esdm_fragmentsTimes_t *subtrahend) |
|
void | esdmI_performance_fragments_print (FILE *stream, const char *linePrefix, const char *indentation, const esdm_fragmentsTimes_t *start, const esdm_fragmentsTimes_t *end) |
|
int | esdmI_backend_finalize (esdm_backend_t *b) |
|
int | esdmI_backend_performance_estimate (esdm_backend_t *b, esdm_fragment_t *fragment, float *out_time) |
|
float | esdmI_backend_estimate_throughput (esdm_backend_t *b) |
|
int | esdmI_backend_fragment_create (esdm_backend_t *b, esdm_fragment_t *fragment) |
|
int | esdmI_backend_fragment_retrieve (esdm_backend_t *b, esdm_fragment_t *fragment) |
|
int | esdmI_backend_fragment_update (esdm_backend_t *b, esdm_fragment_t *fragment) |
|
int | esdmI_backend_fragment_delete (esdm_backend_t *b, esdm_fragment_t *fragment) |
|
int | esdmI_backend_fragment_metadata_create (esdm_backend_t *b, esdm_fragment_t *fragment, smd_string_stream_t *stream) |
|
void * | esdmI_backend_fragment_metadata_load (esdm_backend_t *b, esdm_fragment_t *fragment, json_t *metadata) |
|
int | esdmI_backend_fragment_metadata_free (esdm_backend_t *b, void *options) |
|
int | esdmI_backend_mkfs (esdm_backend_t *b, int format_flags) |
|
int | esdmI_backend_fsck (esdm_backend_t *b) |
|
int | esdmI_backend_fragment_write_stream_blocksize (esdm_backend_t *b, estream_write_t *state, void *cur_buf, size_t cur_offset, uint32_t cur_size) |
|
double | esdmI_backendOutputTime () |
|
double | esdmI_backendInputTime () |
|
void | esdmI_resetBackendIoTimes () |
|
void | esdmI_container_init (char const *name, esdm_container_t **out_container) |
|
esdm_status | esdm_container_open_md_load (esdm_container_t *c, char **out_md, int *out_size) |
|
esdm_status | esdm_container_open_md_parse (esdm_container_t *c, char *md, int size) |
|
void | esdmI_container_register_dataset (esdm_container_t *c, esdm_dataset_t *dset) |
|
esdm_status | esdmI_container_destroy (esdm_container_t *container) |
|
void | esdm_dataset_init (esdm_container_t *container, const char *name, esdm_dataspace_t *dataspace, esdm_dataset_t **out_dataset) |
|
esdm_status | esdm_dataset_open_md_load (esdm_dataset_t *dset, char **out_md, int *out_size) |
|
esdm_status | esdm_dataset_open_md_parse (esdm_dataset_t *d, char *md, int size) |
|
esdm_status | esdmI_dataset_fragmentsCoveringRegion (esdm_dataset_t *dataset, esdmI_hypercube_t *region, int64_t *out_count, esdm_fragment_t ***out_fragments, esdmI_hypercubeSet_t **out_uncovered, bool *out_fullyCovered) |
|
esdm_fragment_t * | esdmI_dataset_createFragment (esdm_dataset_t *dataset, esdm_dataspace_t *memspace, void *buf, bool *out_newFragment) |
|
esdm_fragment_t * | esdmI_dataset_lookupFragmentForShape (esdm_dataset_t *dataset, esdm_dataspace_t *shape) |
|
esdm_status | esdmI_dataset_destroy (esdm_dataset_t *dataset) |
|
esdm_status | esdmI_dataspace_createFromHypercube (esdmI_hypercube_t *extends, esdm_type_t type, esdm_dataspace_t **out_space) |
|
esdm_status | esdmI_dataspace_createFromJson (json_t *json, esdm_dataset_t *dataset, esdm_dataspace_t **out_dataspace) |
|
esdm_status | esdmI_dataspace_getExtends (esdm_dataspace_t *space, esdmI_hypercube_t **out_extends) |
|
esdm_status | esdmI_dataspace_setExtends (esdm_dataspace_t *space, esdmI_hypercube_t *extends) |
|
void | esdmI_fragments_construct (esdm_fragments_t *me) |
|
esdm_status | esdmI_fragments_add (esdm_fragments_t *me, esdm_fragment_t *fragment) __attribute__((warn_unused_result)) |
|
esdm_fragment_t * | esdmI_fragments_lookupForShape (esdm_fragments_t *me, esdmI_hypercube_t *shape) |
|
esdm_status | esdmI_fragments_deleteAll (esdm_fragments_t *me) |
|
esdm_fragment_t ** | esdmI_fragments_makeSetCoveringRegion (esdm_fragments_t *me, esdmI_hypercube_t *region, int64_t *out_fragmentCount) |
|
void | esdmI_fragments_metadata_create (esdm_fragments_t *me, smd_string_stream_t *s) |
|
void | esdmI_fragments_purge (esdm_fragments_t *me) |
|
esdm_status | esdmI_fragments_destruct (esdm_fragments_t *me) |
|
void | esdm_fragment_metadata_create (esdm_fragment_t *f, smd_string_stream_t *stream) |
|
esdm_status | esdmI_create_fragment_from_metadata (esdm_dataset_t *dset, json_t *json, esdm_fragment_t **out) |
|
esdm_status | esdmI_fragment_create (esdm_dataset_t *dataset, esdm_dataspace_t *memspace, void *buf, esdm_fragment_t **out_fragment) |
|
esdm_layout_t * | esdm_layout_init (esdm_instance_t *esdm) |
|
esdm_status | esdm_layout_finalize (esdm_instance_t *esdm) |
|
esdm_fragment_t * | esdm_layout_reconstruction (esdm_dataset_t *dataset, esdm_dataspace_t *subspace) |
|
esdm_status | esdm_layout_recommendation (esdm_instance_t *esdm, esdm_fragment_t *in, esdm_fragment_t *out) |
|
esdm_backend_t * | esdmI_init_backend (char const *name, esdm_config_backend_t *config) |
|
esdm_status | esdm_backend_t_estimate_performance (esdm_backend_t *backend, int fragment) |
|
void | print_stat (struct stat sb) |
|
int | mkdir_recursive (const char *path) |
|
int | posix_recursive_remove (const char *path) |
|
int | ea_read_file (char *filepath, char **buf) |
|
int | ea_read_check (int fd, char *buf, size_t len) |
|
int | ea_write_check (int fd, char *buf, size_t len) |
|
json_t * | load_json (const char *str) |
|
esdm_backend_t * | esdmI_get_backend (char const *plugin_id) |
|
void | ea_generate_id (char *str, size_t length) |
|
char * | ea_make_id (size_t length) |
|
void * | ea_checked_malloc (size_t size) __attribute__((alloc_size(1) |
|
void * | ea_checked_calloc (size_t nmemb, size_t size) __attribute__((alloc_size(1 |
|
void * | ea_checked_realloc (void *ptr, size_t size) __attribute__((alloc_size(2) |
|
char * | ea_checked_strdup (const char *string) |
|
char * | ea_checked_strndup (const char *string, size_t n) |
|
void * | ea_memdup (void *data, size_t size) |
|
int | ea_compute_hash_str (const char *str) |
|
bool | ea_is_valid_dataset_name (const char *str) |
|
void | ea_start_timer (timer *t1) |
|
double | ea_stop_timer (timer t1) |
|
double | ea_timer_subtract (timer number, timer subtract) |
|
ea_datatype_converter | ea_converter_for_types (esdm_type_t destType, esdm_type_t sourceType) |
|
esdmI_range_t | esdmI_range_intersection (esdmI_range_t a, esdmI_range_t b) |
|
void | esdmI_range_print (esdmI_range_t range, FILE *stream) |
|
esdmI_hypercube_t * | esdmI_hypercube_makeDefault (int64_t dimensions) |
|
esdmI_hypercube_t * | esdmI_hypercube_make (int64_t dimensions, int64_t *offset, int64_t *size) |
|
esdmI_hypercube_t * | esdmI_hypercube_makeCopy (esdmI_hypercube_t *original) |
|
esdmI_hypercube_t * | esdmI_hypercube_makeIntersection (esdmI_hypercube_t *a, esdmI_hypercube_t *b) |
|
bool | esdmI_hypercube_isEmpty (esdmI_hypercube_t *cube) |
|
uint32_t | esdmI_hypercube_hash (const esdmI_hypercube_t *me) |
|
uint32_t | esdmI_hypercube_hashOffsetSize (int64_t dimCount, const int64_t *offset, const int64_t *size) |
|
bool | esdmI_hypercube_doesIntersect (esdmI_hypercube_t *a, esdmI_hypercube_t *b) |
|
bool | esdmI_hypercube_touches (esdmI_hypercube_t *a, esdmI_hypercube_t *b) |
|
int64_t | esdmI_hypercube_overlap (esdmI_hypercube_t *a, esdmI_hypercube_t *b) |
|
bool | esdmI_hypercube_equal (const esdmI_hypercube_t *a, const esdmI_hypercube_t *b) |
|
double | esdmI_hypercube_shapeSimilarity (esdmI_hypercube_t *a, esdmI_hypercube_t *b) |
|
void | esdmI_hypercube_getOffsetAndSize (const esdmI_hypercube_t *cube, int64_t *out_offset, int64_t *out_size) |
|
int64_t | esdmI_hypercube_size (esdmI_hypercube_t *cube) |
|
void | esdmI_hypercube_print (esdmI_hypercube_t *cube, FILE *stream) |
|
void | esdmI_hypercube_destroy (esdmI_hypercube_t *cube) |
|
bool | esdmI_hypercubeList_doesIntersect (esdmI_hypercubeList_t *list, esdmI_hypercube_t *cube) |
|
bool | esdmI_hypercubeList_doesCoverFully (esdmI_hypercubeList_t *list, esdmI_hypercube_t *cube) |
|
void | esdmI_hypercubeList_nonredundantSubsets_internal (esdmI_hypercubeList_t *list, int64_t count, int64_t *inout_setCount, uint8_t(*out_subsets)[count]) |
|
void | esdmI_hypercubeList_print (esdmI_hypercubeList_t *list, FILE *stream) |
|
esdmI_hypercubeSet_t * | esdmI_hypercubeSet_make () |
|
void | esdmI_hypercubeSet_construct (esdmI_hypercubeSet_t *me) |
|
esdmI_hypercubeList_t * | esdmI_hypercubeSet_list (esdmI_hypercubeSet_t *me) |
|
bool | esdmI_hypercubeSet_isEmpty (esdmI_hypercubeSet_t *me) |
|
int64_t | esdmI_hypercubeSet_count (esdmI_hypercubeSet_t *me) |
|
void | esdmI_hypercubeSet_add (esdmI_hypercubeSet_t *me, esdmI_hypercube_t *cube) |
|
void | esdmI_hypercubeSet_subtract (esdmI_hypercubeSet_t *me, esdmI_hypercube_t *cube) |
|
void | esdmI_hypercubeSet_destruct (esdmI_hypercubeSet_t *me) |
|
void | esdmI_hypercubeSet_destroy (esdmI_hypercubeSet_t *me) |
|
esdmI_hypercubeNeighbourManager_t * | esdmI_hypercubeNeighbourManager_make (int64_t dimensions) |
|
esdmI_hypercubeList_t * | esdmI_hypercubeNeighbourManager_list (esdmI_hypercubeNeighbourManager_t *me) |
|
void | esdmI_hypercubeNeighbourManager_pushBack (esdmI_hypercubeNeighbourManager_t *me, esdmI_hypercube_t *cube) |
|
int64_t * | esdmI_hypercubeNeighbourManager_getNeighbours (esdmI_hypercubeNeighbourManager_t *me, int64_t index, int64_t *out_neighbourCount) |
|
void | esdmI_hypercubeNeighbourManager_destroy (esdmI_hypercubeNeighbourManager_t *me) |
|