18 #ifndef MCA_SSTORE_STAGE_EXPORT_H
19 #define MCA_SSTORE_STAGE_EXPORT_H
21 #include "orte_config.h"
29 typedef uint8_t orte_sstore_stage_cmd_flag_t;
30 #define ORTE_SSTORE_STAGE_CMD OPAL_UINT8
31 #define ORTE_SSTORE_STAGE_PULL 1
32 #define ORTE_SSTORE_STAGE_PUSH 2
33 #define ORTE_SSTORE_STAGE_REMOVE 3
34 #define ORTE_SSTORE_STAGE_DONE 4
36 #define ORTE_SSTORE_LOCAL_SNAPSHOT_DIR_NAME ("openmpi-local-snapshot")
37 #define ORTE_SSTORE_LOCAL_SNAPSHOT_STAGE_DIR_NAME ("stage")
38 #define ORTE_SSTORE_LOCAL_SNAPSHOT_RESTART_DIR_NAME ("restart")
39 #define ORTE_SSTORE_LOCAL_SNAPSHOT_CACHE_DIR_NAME ("cache")
51 extern char * orte_sstore_stage_local_snapshot_dir;
52 extern bool orte_sstore_stage_global_is_shared;
53 extern bool orte_sstore_stage_skip_filem;
54 extern bool orte_sstore_stage_enabled_caching;
55 extern bool orte_sstore_stage_enabled_compression;
56 extern int orte_sstore_stage_compress_delay;
57 extern int orte_sstore_stage_progress_meter;
64 int orte_sstore_stage_module_init(
void);
65 int orte_sstore_stage_module_finalize(
void);
67 int orte_sstore_stage_request_checkpoint_handle(orte_sstore_base_handle_t *handle,
int seq,
orte_jobid_t jobid);
68 int orte_sstore_stage_request_restart_handle(orte_sstore_base_handle_t *handle,
char *basedir,
char *ref,
int seq,
70 int orte_sstore_stage_request_global_snapshot_data(orte_sstore_base_handle_t *handle,
72 int orte_sstore_stage_register(orte_sstore_base_handle_t handle);
74 int orte_sstore_stage_get_attr(orte_sstore_base_handle_t handle,
orte_sstore_base_key_t key,
char **value);
77 int orte_sstore_stage_sync(orte_sstore_base_handle_t handle);
78 int orte_sstore_stage_remove(orte_sstore_base_handle_t handle);
84 int orte_sstore_stage_wait_all_deps(
void);
89 int orte_sstore_stage_global_module_init(
void);
90 int orte_sstore_stage_global_module_finalize(
void);
91 int orte_sstore_stage_global_request_checkpoint_handle(orte_sstore_base_handle_t *handle,
int seq,
orte_jobid_t jobid);
92 int orte_sstore_stage_global_request_global_snapshot_data(orte_sstore_base_handle_t *handle,
94 int orte_sstore_stage_global_register(orte_sstore_base_handle_t handle);
95 int orte_sstore_stage_global_get_attr(orte_sstore_base_handle_t handle,
orte_sstore_base_key_t key,
char **value);
96 int orte_sstore_stage_global_set_attr(orte_sstore_base_handle_t handle,
orte_sstore_base_key_t key,
char *value);
97 int orte_sstore_stage_global_sync(orte_sstore_base_handle_t handle);
98 int orte_sstore_stage_global_remove(orte_sstore_base_handle_t handle);
105 int orte_sstore_stage_local_module_init(
void);
106 int orte_sstore_stage_local_module_finalize(
void);
107 int orte_sstore_stage_local_request_checkpoint_handle(orte_sstore_base_handle_t *handle,
int seq,
orte_jobid_t jobid);
108 int orte_sstore_stage_local_register(orte_sstore_base_handle_t handle);
109 int orte_sstore_stage_local_get_attr(orte_sstore_base_handle_t handle,
orte_sstore_base_key_t key,
char **value);
110 int orte_sstore_stage_local_set_attr(orte_sstore_base_handle_t handle,
orte_sstore_base_key_t key,
char *value);
111 int orte_sstore_stage_local_sync(orte_sstore_base_handle_t handle);
112 int orte_sstore_stage_local_remove(orte_sstore_base_handle_t handle);
116 int orte_sstore_stage_local_wait_all_deps(
void);
118 void orte_sstore_stage_local_process_cmd(
int fd,
122 orte_sstore_stage_cmd_flag_t command,
123 orte_sstore_base_handle_t loc_id,
128 int orte_sstore_stage_app_module_init(
void);
129 int orte_sstore_stage_app_module_finalize(
void);
130 int orte_sstore_stage_app_request_checkpoint_handle(orte_sstore_base_handle_t *handle,
int seq,
orte_jobid_t jobid);
131 int orte_sstore_stage_app_register(orte_sstore_base_handle_t handle);
132 int orte_sstore_stage_app_get_attr(orte_sstore_base_handle_t handle,
orte_sstore_base_key_t key,
char **value);
133 int orte_sstore_stage_app_set_attr(orte_sstore_base_handle_t handle,
orte_sstore_base_key_t key,
char *value);
134 int orte_sstore_stage_app_sync(orte_sstore_base_handle_t handle);
135 int orte_sstore_stage_app_remove(orte_sstore_base_handle_t handle);
Information about a specific application to be launched in the RTE.
Definition: orte_globals.h:196
Common type for all MCA modules.
Definition: mca.h:100
uint32_t orte_jobid_t
Set the allowed range for ids in each space.
Definition: types.h:76
Structure to represent a single event.
Definition: event_struct.h:87
Distributed Stable Storage (SStore) Interface.
Structure for SSTORE components.
Definition: sstore.h:340
Top-level interface for all MCA components.
orte_sstore_base_component_t super
Base SSTORE component.
Definition: sstore_stage.h:46
BEGIN_C_DECLS typedef uint32_t orte_sstore_base_key_t
Keys accepted as metadata.
Definition: sstore.h:36
Structure for holding a buffer to be used with the RML or OOB subsystems.
Definition: dss_types.h:159
Definition: sstore_stage.h:44