pmix_common_dstore_ctx_t 68 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static int _store_data_for_rank(pmix_common_dstore_ctx_t *ds_ctx, ns_track_elem_t *ns_info, pmix_common_dstore_ctx_t 70 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static int _update_ns_elem(pmix_common_dstore_ctx_t *ds_ctx, ns_track_elem_t *ns_elem, ns_seg_info_t *info); pmix_common_dstore_ctx_t 71 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static int _put_ns_info_to_initial_segment(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 74 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static ns_seg_info_t *_get_ns_info_from_initial_segment(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 76 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static ns_track_elem_t *_get_track_elem_for_namespace(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 78 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static rank_meta_info *_get_rank_meta_info(pmix_common_dstore_ctx_t *ds_ctx, pmix_rank_t rank, pmix_common_dstore_ctx_t 80 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static uint8_t *_get_data_region_by_offset(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 82 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static void _update_initial_segment_info(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 84 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static void _set_constants_from_env(pmix_common_dstore_ctx_t *ds_ctx); pmix_common_dstore_ctx_t 85 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline ssize_t _get_univ_size(pmix_common_dstore_ctx_t *ds_ctx, const char *nspace); pmix_common_dstore_ctx_t 87 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline ns_map_data_t * _esh_session_map_search_server(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 89 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline ns_map_data_t * _esh_session_map_search_client(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 91 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline ns_map_data_t * _esh_session_map(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 94 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline void _esh_session_map_clean(pmix_common_dstore_ctx_t *ds_ctx, ns_map_t *m); pmix_common_dstore_ctx_t 95 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline int _esh_jobuid_tbl_search(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 97 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline int _esh_session_tbl_add(pmix_common_dstore_ctx_t *ds_ctx, size_t *tbl_idx); pmix_common_dstore_ctx_t 98 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static int _esh_session_init(pmix_common_dstore_ctx_t *ds_ctx, size_t idx, ns_map_data_t *m, pmix_common_dstore_ctx_t 100 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static void _esh_session_release(pmix_common_dstore_ctx_t *ds_ctx, size_t idx); pmix_common_dstore_ctx_t 101 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline void _esh_ns_track_cleanup(pmix_common_dstore_ctx_t *ds_ctx); pmix_common_dstore_ctx_t 102 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline void _esh_sessions_cleanup(pmix_common_dstore_ctx_t *ds_ctx); pmix_common_dstore_ctx_t 103 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline void _esh_ns_map_cleanup(pmix_common_dstore_ctx_t *ds_ctx); pmix_common_dstore_ctx_t 105 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline void _client_compat_save(pmix_common_dstore_ctx_t *ds_ctx, pmix_peer_t *peer); pmix_common_dstore_ctx_t 106 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline pmix_peer_t * _client_peer(pmix_common_dstore_ctx_t *ds_ctx); pmix_common_dstore_ctx_t 110 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static pmix_status_t _dstor_store_modex_cb(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 116 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static pmix_status_t _dstore_store_nolock(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 121 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static pmix_status_t _dstore_fetch(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 189 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline void _esh_session_map_clean(pmix_common_dstore_ctx_t *ds_ctx, ns_map_t *m) { pmix_common_dstore_ctx_t 249 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline int _esh_tbls_init(pmix_common_dstore_ctx_t *ds_ctx) pmix_common_dstore_ctx_t 320 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline void _esh_ns_map_cleanup(pmix_common_dstore_ctx_t *ds_ctx) pmix_common_dstore_ctx_t 343 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline void _esh_sessions_cleanup(pmix_common_dstore_ctx_t *ds_ctx) pmix_common_dstore_ctx_t 365 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline void _esh_ns_track_cleanup(pmix_common_dstore_ctx_t *ds_ctx) pmix_common_dstore_ctx_t 388 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline ns_map_data_t * _esh_session_map(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 424 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline int _esh_jobuid_tbl_search(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 443 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline int _esh_session_tbl_add(pmix_common_dstore_ctx_t *ds_ctx, size_t *tbl_idx) pmix_common_dstore_ctx_t 470 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline ns_map_data_t * _esh_session_map_search_server(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 488 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline ns_map_data_t * _esh_session_map_search_client(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 507 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static int _esh_session_init(pmix_common_dstore_ctx_t *ds_ctx, size_t idx, ns_map_data_t *m, pmix_common_dstore_ctx_t 557 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static void _esh_session_release(pmix_common_dstore_ctx_t *ds_ctx, size_t idx) pmix_common_dstore_ctx_t 578 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static void _set_constants_from_env(pmix_common_dstore_ctx_t *ds_ctx) pmix_common_dstore_ctx_t 626 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static int _update_ns_elem(pmix_common_dstore_ctx_t *ds_ctx, ns_track_elem_t *ns_elem, pmix_common_dstore_ctx_t 720 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static int _put_ns_info_to_initial_segment(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 764 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static void _update_initial_segment_info(pmix_common_dstore_ctx_t *ds_ctx, const ns_map_data_t *ns_map) pmix_common_dstore_ctx_t 785 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static ns_seg_info_t *_get_ns_info_from_initial_segment(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 820 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static ns_track_elem_t *_get_track_elem_for_namespace(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 853 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static rank_meta_info *_get_rank_meta_info(pmix_common_dstore_ctx_t *ds_ctx, pmix_rank_t rank, pmix_dstore_seg_desc_t *segdesc) pmix_common_dstore_ctx_t 907 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static int set_rank_meta_info(pmix_common_dstore_ctx_t *ds_ctx, ns_track_elem_t *ns_info, rank_meta_info *rinfo) pmix_common_dstore_ctx_t 1004 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static uint8_t *_get_data_region_by_offset(pmix_common_dstore_ctx_t *ds_ctx, pmix_dstore_seg_desc_t *segdesc, size_t offset) pmix_common_dstore_ctx_t 1027 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static size_t get_free_offset(pmix_common_dstore_ctx_t *ds_ctx, pmix_dstore_seg_desc_t *data_seg) pmix_common_dstore_ctx_t 1046 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static int put_empty_ext_slot(pmix_common_dstore_ctx_t *ds_ctx, pmix_dstore_seg_desc_t *dataseg) pmix_common_dstore_ctx_t 1071 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static size_t put_data_to_the_end(pmix_common_dstore_ctx_t *ds_ctx, ns_track_elem_t *ns_info, pmix_common_dstore_ctx_t 1156 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static int pmix_sm_store(pmix_common_dstore_ctx_t *ds_ctx, ns_track_elem_t *ns_info, pmix_common_dstore_ctx_t 1409 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static int _store_data_for_rank(pmix_common_dstore_ctx_t *ds_ctx, ns_track_elem_t *ns_info, pmix_common_dstore_ctx_t 1513 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline ssize_t _get_univ_size(pmix_common_dstore_ctx_t *ds_ctx, const char *nspace) pmix_common_dstore_ctx_t 1534 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_EXPORT pmix_status_t pmix_common_dstor_cache_job_info(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 1542 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_common_dstore_ctx_t *pmix_common_dstor_init(const char *ds_name, pmix_info_t info[], size_t ninfo, pmix_common_dstore_ctx_t 1551 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_common_dstore_ctx_t *ds_ctx = NULL; pmix_common_dstore_ctx_t 1556 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx = (pmix_common_dstore_ctx_t*) malloc(sizeof(*ds_ctx)); pmix_common_dstore_ctx_t 1751 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_EXPORT void pmix_common_dstor_finalize(pmix_common_dstore_ctx_t *ds_ctx) pmix_common_dstore_ctx_t 1789 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static pmix_status_t _dstore_store_nolock(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 1868 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_EXPORT pmix_status_t pmix_common_dstor_store(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 1930 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static pmix_status_t _dstore_fetch(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 2272 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_EXPORT pmix_status_t pmix_common_dstor_fetch(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 2334 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_EXPORT pmix_status_t pmix_common_dstor_setup_fork(pmix_common_dstore_ctx_t *ds_ctx, const char *base_path_env, pmix_common_dstore_ctx_t 2370 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_EXPORT pmix_status_t pmix_common_dstor_add_nspace(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 2440 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_EXPORT pmix_status_t pmix_common_dstor_del_nspace(pmix_common_dstore_ctx_t *ds_ctx, const char* nspace) pmix_common_dstore_ctx_t 2523 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_EXPORT pmix_status_t pmix_common_dstor_store_modex(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 2565 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static pmix_status_t _dstor_store_modex_cb(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 2662 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static pmix_status_t _store_job_info(pmix_common_dstore_ctx_t *ds_ctx, ns_map_data_t *ns_map, pmix_common_dstore_ctx_t 2740 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_EXPORT pmix_status_t pmix_common_dstor_register_job_info(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 2808 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_EXPORT pmix_status_t pmix_common_dstor_store_job_info(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 2827 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static void _client_compat_save(pmix_common_dstore_ctx_t *ds_ctx, pmix_peer_t *peer) pmix_common_dstore_ctx_t 2840 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline pmix_peer_t * _client_peer(pmix_common_dstore_ctx_t *ds_ctx) pmix_common_dstore_ctx_t 40 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.h typedef ns_map_data_t * (*session_map_search_fn_t)(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 48 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_common.h PMIX_EXPORT pmix_common_dstore_ctx_t *pmix_common_dstor_init(const char *ds_name, pmix_info_t info[], size_t ninfo, pmix_common_dstore_ctx_t 51 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_common.h PMIX_EXPORT void pmix_common_dstor_finalize(pmix_common_dstore_ctx_t *ds_ctx); pmix_common_dstore_ctx_t 52 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_common.h PMIX_EXPORT pmix_status_t pmix_common_dstor_add_nspace(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 54 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_common.h PMIX_EXPORT pmix_status_t pmix_common_dstor_del_nspace(pmix_common_dstore_ctx_t *ds_ctx, const char* nspace); pmix_common_dstore_ctx_t 55 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_common.h PMIX_EXPORT pmix_status_t pmix_common_dstor_setup_fork(pmix_common_dstore_ctx_t *ds_ctx, const char *base_path_env, pmix_common_dstore_ctx_t 57 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_common.h PMIX_EXPORT pmix_status_t pmix_common_dstor_cache_job_info(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 60 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_common.h PMIX_EXPORT pmix_status_t pmix_common_dstor_register_job_info(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 63 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_common.h PMIX_EXPORT pmix_status_t pmix_common_dstor_store_job_info(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 66 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_common.h PMIX_EXPORT pmix_status_t pmix_common_dstor_store(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 70 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_common.h PMIX_EXPORT pmix_status_t pmix_common_dstor_fetch(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 76 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_common.h PMIX_EXPORT pmix_status_t pmix_common_dstor_store_modex(pmix_common_dstore_ctx_t *ds_ctx, pmix_common_dstore_ctx_t 29 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_base.c static pmix_common_dstore_ctx_t *ds12_ctx; pmix_common_dstore_ctx_t 29 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_base.c static pmix_common_dstore_ctx_t *ds21_ctx;