21 #include "orte_config.h"
22 #include "orte/constants.h"
27 #include "opal/mca/base/base.h"
38 #define SSTORE_METADATA_LOCAL_CRS_COMP 0
40 #define SSTORE_METADATA_LOCAL_COMPRESS_COMP 1
42 #define SSTORE_METADATA_LOCAL_COMPRESS_POSTFIX 2
44 #define SSTORE_METADATA_LOCAL_PID 3
46 #define SSTORE_METADATA_LOCAL_CONTEXT 4
48 #define SSTORE_METADATA_LOCAL_MKDIR 5
50 #define SSTORE_METADATA_LOCAL_TOUCH 6
53 #define SSTORE_METADATA_LOCAL_SNAP_REF 7
55 #define SSTORE_METADATA_LOCAL_SNAP_REF_FMT 8
57 #define SSTORE_METADATA_LOCAL_SNAP_LOC 9
59 #define SSTORE_METADATA_LOCAL_SNAP_REF_LOC_FMT 10
61 #define SSTORE_METADATA_LOCAL_SNAP_META 11
64 #define SSTORE_METADATA_GLOBAL_SNAP_REF 12
66 #define SSTORE_METADATA_GLOBAL_SNAP_LOC 13
68 #define SSTORE_METADATA_GLOBAL_SNAP_LOC_ABS 14
70 #define SSTORE_METADATA_GLOBAL_SNAP_META 15
72 #define SSTORE_METADATA_GLOBAL_SNAP_SEQ 16
74 #define SSTORE_METADATA_GLOBAL_AMCA_PARAM 17
77 #define SSTORE_METADATA_GLOBAL_SNAP_NUM_SEQ 18
79 #define SSTORE_METADATA_GLOBAL_SNAP_ALL_SEQ 19
82 #define SSTORE_METADATA_BASE_LOC 20
87 #define SSTORE_METADATA_LOCAL_SKIP_CKPT 21
92 #define SSTORE_METADATA_GLOBAL_MIGRATING 22
95 #define SSTORE_METADATA_MAX 23
100 #define ORTE_SSTORE_HANDLE OPAL_UINT32
101 typedef uint32_t orte_sstore_base_handle_t;
102 ORTE_DECLSPEC
extern orte_sstore_base_handle_t orte_sstore_handle_current;
103 ORTE_DECLSPEC
extern orte_sstore_base_handle_t orte_sstore_handle_last_stable;
104 #define ORTE_SSTORE_HANDLE_INVALID 0
167 char *metadata_filename;
213 (orte_sstore_base_handle_t *handle,
214 char *basedir,
char *ref,
int seq,
227 (orte_sstore_base_handle_t *handle,
239 (orte_sstore_base_handle_t handle);
276 (orte_sstore_base_handle_t handle);
287 (orte_sstore_base_handle_t handle);
397 #define ORTE_SSTORE_BASE_VERSION_2_0_0 \
398 MCA_BASE_VERSION_2_0_0, \
int(* orte_sstore_base_register_handle_fn_t)(orte_sstore_base_handle_t handle)
Register access to a handle.
Definition: sstore.h:239
Information about a specific application to be launched in the RTE.
Definition: orte_globals.h:196
int(* orte_sstore_base_pack_fn_t)(orte_process_name_t *peer, opal_buffer_t *buffer, orte_sstore_base_handle_t handle)
Pack a handle into a buffer Only called between the HNP and ORTED (or Global and Local SnapC coordina...
Definition: sstore.h:301
Common type for all MCA components.
Definition: mca.h:250
int(* orte_sstore_base_remove_fn_t)(orte_sstore_base_handle_t handle)
Remove data associated with the handle.
Definition: sstore.h:287
orte_sstore_base_sync_fn_t sync
Sync.
Definition: sstore.h:376
opal_list_t local_snapshots
A list of orte_sstore_base_local_snapshot_info_t's.
Definition: sstore.h:143
int(* orte_sstore_base_wait_all_deps_fn_t)(void)
Wait for all application context dependencies to be fetched.
Definition: sstore.h:335
int(* orte_sstore_base_set_attribute_fn_t)(orte_sstore_base_handle_t handle, orte_sstore_base_key_t key, char *value)
Set attribute on the storage handle.
Definition: sstore.h:265
orte_sstore_base_module_finalize_fn_t sstore_finalize
Finalization Function.
Definition: sstore.h:363
uint32_t orte_jobid_t
Set the allowed range for ids in each space.
Definition: types.h:76
int priority
Default Priority.
Definition: sstore.h:351
char * end_time
End Timestamp.
Definition: sstore.h:152
orte_sstore_base_handle_t ss_handle
Stable Storage Handle.
Definition: sstore.h:115
orte_sstore_base_module_init_fn_t sstore_init
Initialization Function.
Definition: sstore.h:361
orte_process_name_t process_name
ORTE Process name.
Definition: sstore.h:118
Structure for SSTORE modules.
Definition: sstore.h:359
char * amca_param
AMCA parameter used.
Definition: sstore.h:161
Structure for SSTORE components.
Definition: sstore.h:340
Top-level interface for all MCA components.
Definition: opal_list.h:98
int(* orte_sstore_base_get_attribute_fn_t)(orte_sstore_base_handle_t handle, orte_sstore_base_key_t key, char **value)
Get attribute on the storage handle.
Definition: sstore.h:252
orte_sstore_base_pack_fn_t pack_handle
Pack/Unpack Handle.
Definition: sstore.h:382
int output_handle
Output Handle for opal_output.
Definition: sstore.h:349
char * start_time
Start/End Timestamps.
Definition: sstore.h:130
orte_sstore_base_request_checkpoint_handle_fn_t request_checkpoint_handle
Request handle.
Definition: sstore.h:366
char * crs_comp
CRS Component.
Definition: sstore.h:121
opal_list_item_t super
List super object.
Definition: sstore.h:112
char * compress_comp
Compress Component.
Definition: sstore.h:124
orte_sstore_base_fetch_app_deps_fn_t fetch_app_deps
Launch Helpers.
Definition: sstore.h:386
int num_seqs
Internal use only: Cache some information on the structure.
Definition: sstore.h:164
orte_sstore_base_get_attribute_fn_t get_attr
Get/Set Attributes.
Definition: sstore.h:372
char * compress_postfix
Compress Component Postfix.
Definition: sstore.h:127
int(* orte_sstore_base_request_restart_handle_fn_t)(orte_sstore_base_handle_t *handle, char *basedir, char *ref, int seq, orte_sstore_base_global_snapshot_info_t *snapshot)
Request a restart storage handle from stable storage This function will fail if the key cannot be mat...
Definition: sstore.h:213
int(* orte_sstore_base_fetch_app_deps_fn_t)(orte_app_context_t *app)
Fetch application context dependencies before local launch.
Definition: sstore.h:326
char * start_time
Start Timestamp.
Definition: sstore.h:149
BEGIN_C_DECLS typedef uint32_t orte_sstore_base_key_t
Keys accepted as metadata.
Definition: sstore.h:36
Local and Global snapshot information structure Primarily used by orte-restart as an abstract way to ...
Definition: sstore.h:110
mca_base_component_t base_version
MCA base component.
Definition: sstore.h:342
Meta data for MCA v2.0.0 components.
Definition: mca.h:309
Definition: opal_list.h:147
Global params for OpenRTE.
char * reference
Reference.
Definition: sstore.h:158
int(* orte_sstore_base_module_finalize_fn_t)(void)
Module finalization function.
Definition: sstore.h:186
int(* orte_sstore_base_request_checkpoint_handle_fn_t)(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid)
Request a checkpoint storage handle from stable storage.
Definition: sstore.h:199
int verbose
Verbosity Level.
Definition: sstore.h:347
int(* orte_sstore_base_unpack_fn_t)(orte_process_name_t *peer, opal_buffer_t *buffer, orte_sstore_base_handle_t *handle)
Unack a handle from a buffer Only called between the HNP and ORTED (or Global and Local SnapC coordin...
Definition: sstore.h:315
Structure for holding a buffer to be used with the RML or OOB subsystems.
Definition: dss_types.h:159
opal_list_item_t super
List super object.
Definition: sstore.h:140
int(* orte_sstore_base_request_global_snapshot_data_fn_t)(orte_sstore_base_handle_t *handle, orte_sstore_base_global_snapshot_info_t *snapshot)
Request snapshot info from a given handle.
Definition: sstore.h:227
A simple C-language object-oriented system with single inheritance and ownership-based memory managem...
int seq_num
Sequence number.
Definition: sstore.h:155
orte_sstore_base_handle_t ss_handle
Stable Storage Handle.
Definition: sstore.h:146
#define OBJ_CLASS_DECLARATION(NAME)
Declaration for class descriptor.
Definition: opal_object.h:236
int(* orte_sstore_base_sync_fn_t)(orte_sstore_base_handle_t handle)
Synchronize the handle.
Definition: sstore.h:276
mca_base_component_data_t base_data
MCA base data.
Definition: sstore.h:344
int(* orte_sstore_base_module_init_fn_t)(void)
Module initialization function.
Definition: sstore.h:179