ds_ctx 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, ds_ctx 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); ds_ctx 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, ds_ctx 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, ds_ctx 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, ds_ctx 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, ds_ctx 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, ds_ctx 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, ds_ctx 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); ds_ctx 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); ds_ctx 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, ds_ctx 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, ds_ctx 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, ds_ctx 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); ds_ctx 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, ds_ctx 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); ds_ctx 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, ds_ctx 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); ds_ctx 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); ds_ctx 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); ds_ctx 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); ds_ctx 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); ds_ctx 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); ds_ctx 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, ds_ctx 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, ds_ctx 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, ds_ctx 161 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c #define _ESH_LOCK(ds_ctx, session_id, operation) \ ds_ctx 164 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = ds_ctx->lock_cbs->operation(_ESH_SESSION_lock(ds_ctx->session_array, \ ds_ctx 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) { ds_ctx 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) ds_ctx 255 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->ns_track_array = NULL; ds_ctx 256 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->session_array = NULL; ds_ctx 257 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->ns_map_array = NULL; ds_ctx 260 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (ds_ctx->ns_track_array = PMIX_NEW(pmix_value_array_t))) { ds_ctx 265 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_SUCCESS != (rc = pmix_value_array_init(ds_ctx->ns_track_array, sizeof(ns_track_elem_t)))){ ds_ctx 271 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (ds_ctx->session_array = PMIX_NEW(pmix_value_array_t))){ ds_ctx 276 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_SUCCESS != (rc = pmix_value_array_init(ds_ctx->session_array, sizeof(session_t)))) { ds_ctx 280 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_SUCCESS != (rc = pmix_value_array_set_size(ds_ctx->session_array, ESH_INIT_SESSION_TBL_SIZE))) { ds_ctx 285 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memset(pmix_value_array_get_item(ds_ctx->session_array, idx), 0, sizeof(session_t)); ds_ctx 289 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (ds_ctx->ns_map_array = PMIX_NEW(pmix_value_array_t))) { ds_ctx 294 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_SUCCESS != (rc = pmix_value_array_init(ds_ctx->ns_map_array, sizeof(ns_map_t)))) { ds_ctx 298 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_SUCCESS != (rc = pmix_value_array_set_size(ds_ctx->ns_map_array, ESH_INIT_NS_MAP_TBL_SIZE))) { ds_ctx 303 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _esh_session_map_clean(ds_ctx, pmix_value_array_get_item(ds_ctx->ns_map_array, idx)); ds_ctx 308 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL != ds_ctx->ns_track_array) { ds_ctx 309 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_RELEASE(ds_ctx->ns_track_array); ds_ctx 311 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL != ds_ctx->session_array) { ds_ctx 312 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_RELEASE(ds_ctx->session_array); ds_ctx 314 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL != ds_ctx->ns_map_array) { ds_ctx 315 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_RELEASE(ds_ctx->ns_map_array); ds_ctx 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) ds_ctx 326 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == ds_ctx->ns_map_array) { ds_ctx 330 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size = pmix_value_array_get_size(ds_ctx->ns_map_array); ds_ctx 331 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map = PMIX_VALUE_ARRAY_GET_BASE(ds_ctx->ns_map_array, ns_map_t); ds_ctx 335 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _esh_session_map_clean(ds_ctx, &ns_map[idx]); ds_ctx 339 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_RELEASE(ds_ctx->ns_map_array); ds_ctx 340 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->ns_map_array = NULL; ds_ctx 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) ds_ctx 349 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == ds_ctx->session_array) { ds_ctx 353 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size = pmix_value_array_get_size(ds_ctx->session_array); ds_ctx 354 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c s_tbl = PMIX_VALUE_ARRAY_GET_BASE(ds_ctx->session_array, session_t); ds_ctx 358 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _esh_session_release(ds_ctx, idx); ds_ctx 361 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_RELEASE(ds_ctx->session_array); ds_ctx 362 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->session_array = NULL; ds_ctx 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) ds_ctx 370 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == ds_ctx->ns_track_array) { ds_ctx 374 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size = pmix_value_array_get_size(ds_ctx->ns_track_array); ds_ctx 375 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_trk = PMIX_VALUE_ARRAY_GET_BASE(ds_ctx->ns_track_array, ns_track_elem_t); ds_ctx 384 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_RELEASE(ds_ctx->ns_track_array); ds_ctx 385 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->ns_track_array = NULL; ds_ctx 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, ds_ctx 393 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size_t size = pmix_value_array_get_size(ds_ctx->ns_map_array); ds_ctx 394 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_t *ns_map = PMIX_VALUE_ARRAY_GET_BASE(ds_ctx->ns_map_array, ns_map_t); ds_ctx 411 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (new_map = pmix_value_array_get_item(ds_ctx->ns_map_array, map_idx))) { ds_ctx 416 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _esh_session_map_clean(ds_ctx, new_map); ds_ctx 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, ds_ctx 430 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size = pmix_value_array_get_size(ds_ctx->session_array); ds_ctx 431 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c session_tbl = PMIX_VALUE_ARRAY_GET_BASE(ds_ctx->session_array, session_t); ds_ctx 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) ds_ctx 446 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size_t size = pmix_value_array_get_size(ds_ctx->session_array); ds_ctx 447 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c session_t *s_tbl = PMIX_VALUE_ARRAY_GET_BASE(ds_ctx->session_array, session_t); ds_ctx 457 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (new_sesion = pmix_value_array_get_item(ds_ctx->session_array, idx))) { ds_ctx 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, ds_ctx 473 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size_t idx, size = pmix_value_array_get_size(ds_ctx->ns_map_array); ds_ctx 474 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_t *ns_map = PMIX_VALUE_ARRAY_GET_BASE(ds_ctx->ns_map_array, ns_map_t); ds_ctx 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, ds_ctx 491 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size_t idx, size = pmix_value_array_get_size(ds_ctx->ns_map_array); ds_ctx 492 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_t *ns_map = PMIX_VALUE_ARRAY_GET_BASE(ds_ctx->ns_map_array, ns_map_t); ds_ctx 504 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c return _esh_session_map(ds_ctx, nspace, 0, 0); ds_ctx 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, ds_ctx 511 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c session_t *s = &(PMIX_VALUE_ARRAY_GET_ITEM(ds_ctx->session_array, session_t, idx)); ds_ctx 516 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c s->nspace_path = strdup(ds_ctx->base_path); ds_ctx 535 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c seg = pmix_common_dstor_create_new_segment(PMIX_DSTORE_INITIAL_SEGMENT, ds_ctx->base_path, ds_ctx 536 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c m->name, 0, ds_ctx->jobuid, ds_ctx->setjobuid); ds_ctx 544 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c seg = pmix_common_dstor_attach_new_segment(PMIX_DSTORE_INITIAL_SEGMENT, ds_ctx->base_path, m->name, 0); ds_ctx 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) ds_ctx 559 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c session_t *s = &(PMIX_VALUE_ARRAY_GET_ITEM(ds_ctx->session_array, session_t, idx)); ds_ctx 567 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->lock_cbs->finalize(&_ESH_SESSION_lock(ds_ctx->session_array, idx)); ds_ctx 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) ds_ctx 584 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->initial_segment_size = strtoul(str, NULL, 10); ds_ctx 585 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if ((size_t)page_size > ds_ctx->initial_segment_size) { ds_ctx 586 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->initial_segment_size = (size_t)page_size; ds_ctx 589 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (0 == ds_ctx->initial_segment_size) { ds_ctx 590 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->initial_segment_size = INITIAL_SEG_SIZE; ds_ctx 593 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->meta_segment_size = strtoul(str, NULL, 10); ds_ctx 594 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if ((size_t)page_size > ds_ctx->meta_segment_size) { ds_ctx 595 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->meta_segment_size = (size_t)page_size; ds_ctx 598 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (0 == ds_ctx->meta_segment_size) { ds_ctx 599 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->meta_segment_size = NS_META_SEG_SIZE; ds_ctx 602 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->data_segment_size = strtoul(str, NULL, 10); ds_ctx 603 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if ((size_t)page_size > ds_ctx->data_segment_size) { ds_ctx 604 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->data_segment_size = (size_t)page_size; ds_ctx 607 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (0 == ds_ctx->data_segment_size) { ds_ctx 608 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->data_segment_size = NS_DATA_SEG_SIZE; ds_ctx 612 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->direct_mode = 1; ds_ctx 616 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->lock_segment_size = page_size; ds_ctx 617 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->max_ns_num = (ds_ctx->initial_segment_size - sizeof(size_t) * 2) / sizeof(ns_seg_info_t); ds_ctx 618 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->max_meta_elems = (ds_ctx->meta_segment_size - sizeof(size_t)) / sizeof(rank_meta_info); ds_ctx 620 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_common_dstor_init_segment_info(ds_ctx->initial_segment_size, ds_ctx->meta_segment_size, ds_ctx 621 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->data_segment_size); ds_ctx 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, ds_ctx 638 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (ns_map = ds_ctx->session_map_search(ds_ctx, info->ns_map.name))) { ds_ctx 654 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c seg = pmix_common_dstor_create_new_segment(PMIX_DSTORE_NS_META_SEGMENT, ds_ctx->base_path, ds_ctx 655 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c info->ns_map.name, i, ds_ctx->jobuid, ds_ctx 656 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->setjobuid); ds_ctx 663 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c seg = pmix_common_dstor_attach_new_segment(PMIX_DSTORE_NS_META_SEGMENT, ds_ctx->base_path, info->ns_map.name, i); ds_ctx 689 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c seg = pmix_common_dstor_create_new_segment(PMIX_DSTORE_NS_DATA_SEGMENT, ds_ctx->base_path, ds_ctx 690 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c info->ns_map.name, i, ds_ctx->jobuid, ds_ctx 691 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->setjobuid); ds_ctx 700 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c seg = pmix_common_dstor_attach_new_segment(PMIX_DSTORE_NS_DATA_SEGMENT, ds_ctx->base_path, info->ns_map.name, i); ds_ctx 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, ds_ctx 726 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c num_elems = *((size_t*)(_ESH_SESSION_sm_seg_last(ds_ctx->session_array, ds_ctx 728 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_dstore_seg_desc_t *last_seg = _ESH_SESSION_sm_seg_last(ds_ctx->session_array, ns_map->tbl_idx); ds_ctx 734 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (ds_ctx->max_ns_num == num_elems) { ds_ctx 736 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (last_seg = pmix_common_dstor_extend_segment(last_seg, ds_ctx->base_path, ns_map->name, ds_ctx 737 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->jobuid, ds_ctx->setjobuid))) { ds_ctx 744 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memcpy((uint8_t*)(_ESH_SESSION_sm_seg_last(ds_ctx->session_array, ns_map->tbl_idx)->seg_info.seg_base_addr + ds_ctx 746 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _ESH_SESSION_sm_seg_last(ds_ctx->session_array, ns_map->tbl_idx) = last_seg; ds_ctx 747 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memset(_ESH_SESSION_sm_seg_last(ds_ctx->session_array, ns_map->tbl_idx)->seg_info.seg_base_addr, ds_ctx 748 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c 0, ds_ctx->initial_segment_size); ds_ctx 755 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memcpy((uint8_t*)(_ESH_SESSION_sm_seg_last(ds_ctx->session_array, ns_map->tbl_idx)->seg_info.seg_base_addr) + ds_ctx 758 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memcpy((uint8_t*)(_ESH_SESSION_sm_seg_last(ds_ctx->session_array, ns_map->tbl_idx)->seg_info.seg_base_addr), ds_ctx 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) ds_ctx 767 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c tmp = _ESH_SESSION_sm_seg_first(ds_ctx->session_array, ns_map->tbl_idx); ds_ctx 776 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c tmp->next = pmix_common_dstor_attach_new_segment(PMIX_DSTORE_INITIAL_SEGMENT, ds_ctx->base_path, ds_ctx 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, ds_ctx 798 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c tmp = _ESH_SESSION_sm_seg_first(ds_ctx->session_array, ns_map->tbl_idx); ds_ctx 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, ds_ctx 824 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size_t size = pmix_value_array_get_size(ds_ctx->ns_track_array); ds_ctx 837 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c return pmix_value_array_get_item(ds_ctx->ns_track_array, ns_map->track_idx); ds_ctx 842 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (new_elem = pmix_value_array_get_item(ds_ctx->ns_track_array, size))) { ds_ctx 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) ds_ctx 868 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (1 == ds_ctx->direct_mode) { ds_ctx 887 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c id = rcount/ds_ctx->max_meta_elems; ds_ctx 888 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rel_offset = (rcount % ds_ctx->max_meta_elems) * sizeof(rank_meta_info) + sizeof(size_t); ds_ctx 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) ds_ctx 927 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (1 == ds_ctx->direct_mode) { ds_ctx 933 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (ds_ctx->max_meta_elems <= num_elems) { ds_ctx 938 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c tmp = pmix_common_dstor_extend_segment(tmp, ds_ctx->base_path, ns_info->ns_map.name, ds_ctx 939 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->jobuid, ds_ctx->setjobuid); ds_ctx 947 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_seg_info_t *elem = _get_ns_info_from_initial_segment(ds_ctx, &ns_info->ns_map); ds_ctx 965 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c id = rcount/ds_ctx->max_meta_elems; ds_ctx 966 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rel_offset = (rcount % ds_ctx->max_meta_elems) * sizeof(rank_meta_info) + sizeof(size_t); ds_ctx 978 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c tmp = pmix_common_dstor_extend_segment(tmp, ds_ctx->base_path, ns_info->ns_map.name, ds_ctx 979 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->jobuid, ds_ctx->setjobuid); ds_ctx 988 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_seg_info_t *elem = _get_ns_info_from_initial_segment(ds_ctx, &ns_info->ns_map); ds_ctx 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) ds_ctx 1016 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (rel_offset >= ds_ctx->data_segment_size) { ds_ctx 1017 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rel_offset -= ds_ctx->data_segment_size; ds_ctx 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) ds_ctx 1043 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c return (id * ds_ctx->data_segment_size + offset); ds_ctx 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) ds_ctx 1052 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c global_offset = get_free_offset(ds_ctx, dataseg); ds_ctx 1053 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rel_offset = global_offset % ds_ctx->data_segment_size; ds_ctx 1054 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (rel_offset + PMIX_DS_SLOT_SIZE(ds_ctx) > ds_ctx->data_segment_size) { ds_ctx 1058 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c addr = _get_data_region_by_offset(ds_ctx, dataseg, global_offset); ds_ctx 1059 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DS_PUT_KEY(rc, ds_ctx, addr, ESH_REGION_EXTENSION, (void*)&val, sizeof(size_t)); ds_ctx 1065 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c data_ended = rel_offset + PMIX_DS_SLOT_SIZE(ds_ctx); ds_ctx 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, ds_ctx 1089 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c global_offset = get_free_offset(ds_ctx, dataseg); ds_ctx 1090 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c offset = global_offset % ds_ctx->data_segment_size; ds_ctx 1094 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if ((sizeof(size_t) + PMIX_DS_KEY_SIZE(ds_ctx, key, size) + PMIX_DS_SLOT_SIZE(ds_ctx)) > ds_ctx 1095 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->data_segment_size) { ds_ctx 1101 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size + PMIX_DS_SLOT_SIZE(ds_ctx))); ds_ctx 1112 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if ( (0 == offset) || ( (offset + PMIX_DS_KEY_SIZE(ds_ctx, key, size) + ds_ctx 1113 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DS_SLOT_SIZE(ds_ctx)) > ds_ctx->data_segment_size) ) { ds_ctx 1116 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c tmp = pmix_common_dstor_extend_segment(tmp, ds_ctx->base_path, ns_info->ns_map.name, ds_ctx 1117 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->jobuid, ds_ctx->setjobuid); ds_ctx 1125 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_seg_info_t *elem = _get_ns_info_from_initial_segment(ds_ctx, &ns_info->ns_map); ds_ctx 1134 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c global_offset = offset + id * ds_ctx->data_segment_size; ds_ctx 1136 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DS_PUT_KEY(rc, ds_ctx, addr, key, buffer, size); ds_ctx 1143 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c data_ended = offset + PMIX_DS_KEY_SIZE(ds_ctx, key, size); ds_ctx 1151 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c (unsigned long)(id * ds_ctx->data_segment_size), ds_ctx 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, ds_ctx 1172 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_BFROPS_PACK(rc, _client_peer(ds_ctx), &buffer, kval->value, 1, PMIX_VALUE); ds_ctx 1182 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c free_offset = get_free_offset(ds_ctx, datadesc); ds_ctx 1183 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c offset = put_data_to_the_end(ds_ctx, ns_info, datadesc, kval->key, buffer.base_ptr, size); ds_ctx 1200 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c addr = _get_data_region_by_offset(ds_ctx, datadesc, free_offset); ds_ctx 1201 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DS_PUT_KEY(rc, ds_ctx, addr, ESH_REGION_EXTENSION, (void*)&offset, sizeof(size_t)); ds_ctx 1216 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c addr = _get_data_region_by_offset(ds_ctx, datadesc, (*rinfo)->offset); ds_ctx 1238 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if(PMIX_DS_KEY_IS_EXTSLOT(ds_ctx, addr)) { ds_ctx 1239 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memcpy(&offset, PMIX_DS_DATA_PTR(ds_ctx, addr), sizeof(size_t)); ds_ctx 1247 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c addr = _get_data_region_by_offset(ds_ctx, datadesc, offset); ds_ctx 1256 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c } else if (0 == strncmp(PMIX_DS_KNAME_PTR(ds_ctx, addr), kval->key, ds_ctx 1257 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DS_KNAME_LEN(ds_ctx, kval->key))) { ds_ctx 1262 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_DS_DATA_SIZE(ds_ctx, addr, PMIX_DS_DATA_PTR(ds_ctx, addr)) != size) { ds_ctx 1265 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DS_KEY_SET_INVALID(ds_ctx, addr); ds_ctx 1270 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c addr += PMIX_DS_KV_SIZE(ds_ctx, addr); ds_ctx 1279 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memset(PMIX_DS_DATA_PTR(ds_ctx, addr), 0, ds_ctx 1280 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DS_DATA_SIZE(ds_ctx, addr, PMIX_DS_DATA_PTR(ds_ctx, addr))); ds_ctx 1281 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memcpy(PMIX_DS_DATA_PTR(ds_ctx, addr), buffer.base_ptr, size); ds_ctx 1282 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c addr += PMIX_DS_KV_SIZE(ds_ctx, addr); ds_ctx 1290 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DS_KNAME_PTR(ds_ctx, addr), kval->key)); ds_ctx 1292 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (!PMIX_DS_KEY_IS_INVALID(ds_ctx, addr)) { ds_ctx 1297 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c addr += PMIX_DS_KV_SIZE(ds_ctx, addr); ds_ctx 1306 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c free_offset = get_free_offset(ds_ctx, datadesc); ds_ctx 1332 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_DS_KEY_IS_EXTSLOT(ds_ctx, addr)){ ds_ctx 1343 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c offs_cur_segment = free_offset % ds_ctx->data_segment_size; ds_ctx 1345 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c offs_past_extslot = (addr + PMIX_DS_KV_SIZE(ds_ctx, addr)) - segstart; ds_ctx 1362 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c free_offset = get_free_offset(ds_ctx, datadesc); ds_ctx 1367 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c offset = put_data_to_the_end(ds_ctx, ns_info, datadesc, kval->key, buffer.base_ptr, size); ds_ctx 1378 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_DS_KEY_IS_EXTSLOT(ds_ctx, addr)) { ds_ctx 1382 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memcpy(PMIX_DS_DATA_PTR(ds_ctx, addr), &offset, sizeof(size_t)); ds_ctx 1392 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DS_PUT_KEY(rc, ds_ctx, addr, ESH_REGION_EXTENSION, (void*)&offset, sizeof(size_t)); ds_ctx 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, ds_ctx 1438 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (0 < num_elems || 0 == ds_ctx->direct_mode) { ds_ctx 1440 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rinfo = _get_rank_meta_info(ds_ctx, rank, metadesc); ds_ctx 1449 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c free_offset = get_free_offset(ds_ctx, datadesc); ds_ctx 1456 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_SUCCESS != (rc = pmix_sm_store(ds_ctx, ns_info, rank, kp, &rinfo, data_exist))) { ds_ctx 1483 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c new_free_offset = get_free_offset(ds_ctx, datadesc); ds_ctx 1491 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = put_empty_ext_slot(ds_ctx, ns_info->data_seg); ds_ctx 1504 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c set_rank_meta_info(ds_ctx, ns_info, rinfo); ds_ctx 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) ds_ctx 1519 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _dstore_fetch(ds_ctx, nspace, PMIX_RANK_WILDCARD, PMIX_UNIV_SIZE, &val); ds_ctx 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, ds_ctx 1551 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_common_dstore_ctx_t *ds_ctx = NULL; ds_ctx 1556 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx = (pmix_common_dstore_ctx_t*) malloc(sizeof(*ds_ctx)); ds_ctx 1557 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == ds_ctx) { ds_ctx 1561 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memset(ds_ctx, 0, sizeof(*ds_ctx)); ds_ctx 1564 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->lock_cbs = lock_cb; ds_ctx 1565 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->file_cbs = file_cb; ds_ctx 1577 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->jobuid = getuid(); ds_ctx 1578 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->setjobuid = 0; ds_ctx 1580 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_SUCCESS != (rc = _esh_tbls_init(ds_ctx))) { ds_ctx 1591 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _set_constants_from_env(ds_ctx); ds_ctx 1592 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->ds_name = strdup(ds_name); ds_ctx 1596 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->session_map_search = (session_map_search_fn_t)_esh_session_map_search_server; ds_ctx 1602 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->jobuid = info[n].value.data.uint32; ds_ctx 1603 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->setjobuid = 1; ds_ctx 1649 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = asprintf(&ds_ctx->base_path, "%s/pmix_dstor_%s_%d", dstor_tmpdir, ds_ctx 1650 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->ds_name, getpid()); ds_ctx 1651 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if ((0 > rc) || (NULL == ds_ctx->base_path)) { ds_ctx 1657 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (0 != mkdir(ds_ctx->base_path, 0770)) { ds_ctx 1664 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (ds_ctx->setjobuid > 0) { ds_ctx 1665 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (chown(ds_ctx->base_path, (uid_t) ds_ctx->jobuid, (gid_t) -1) < 0){ ds_ctx 1671 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->session_map_search = _esh_session_map_search_server; ds_ctx 1672 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c return ds_ctx; ds_ctx 1679 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c sscanf(ds_ctx->ds_name, "ds%d", &ds_ver); ds_ctx 1700 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (ds_ctx->base_path = strdup(dstor_tmpdir))) { ds_ctx 1705 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->session_map_search = _esh_session_map_search_client; ds_ctx 1707 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (0 != pthread_mutex_init(&ds_ctx->lock, NULL)) { ds_ctx 1714 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _esh_session_tbl_add(ds_ctx, &tbl_idx); ds_ctx 1728 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = ds_ctx->lock_cbs->init(&_ESH_SESSION_lock(ds_ctx->session_array, tbl_idx), ds_ctx->base_path, nspace, 1, ds_ctx->jobuid, ds_ctx->setjobuid); ds_ctx 1732 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map = _esh_session_map(ds_ctx, nspace, 0, tbl_idx); ds_ctx 1739 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_SUCCESS != (rc =_esh_session_init(ds_ctx, tbl_idx, ns_map, 1, ds_ctx 1740 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->jobuid, ds_ctx->setjobuid))) { ds_ctx 1745 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c return ds_ctx; ds_ctx 1747 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_common_dstor_finalize(ds_ctx); ds_ctx 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) ds_ctx 1759 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _esh_sessions_cleanup(ds_ctx); ds_ctx 1760 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _esh_ns_map_cleanup(ds_ctx); ds_ctx 1761 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _esh_ns_track_cleanup(ds_ctx); ds_ctx 1765 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL != ds_ctx->base_path){ ds_ctx 1767 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (lstat(ds_ctx->base_path, &st) >= 0){ ds_ctx 1768 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_SUCCESS != (rc = _esh_dir_del(ds_ctx->base_path))) { ds_ctx 1773 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c free(ds_ctx->base_path); ds_ctx 1774 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->base_path = NULL; ds_ctx 1776 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL != ds_ctx->clients_peer) { ds_ctx 1777 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_RELEASE(ds_ctx->clients_peer->nptr); ds_ctx 1778 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_RELEASE(ds_ctx->clients_peer); ds_ctx 1784 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c free(ds_ctx->ds_name); ds_ctx 1785 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c free(ds_ctx->base_path); ds_ctx 1786 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c free(ds_ctx); ds_ctx 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, ds_ctx 1817 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c elem = _get_track_elem_for_namespace(ds_ctx, ns_map); ds_ctx 1832 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _update_ns_elem(ds_ctx, elem, &ns_info); ds_ctx 1839 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memset(elem->meta_seg->seg_info.seg_base_addr, 0, ds_ctx->meta_segment_size); ds_ctx 1840 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memset(elem->data_seg->seg_info.seg_base_addr, 0, ds_ctx->data_segment_size); ds_ctx 1843 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _put_ns_info_to_initial_segment(ds_ctx, ns_map, &elem->meta_seg->seg_info, &elem->data_seg->seg_info); ds_ctx 1855 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _store_data_for_rank(ds_ctx, elem, rank, &xfer); ds_ctx 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, ds_ctx 1897 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (ns_map = ds_ctx->session_map_search(ds_ctx, proc->nspace))) { ds_ctx 1904 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _ESH_LOCK(ds_ctx, ns_map->tbl_idx, wr_lock); ds_ctx 1910 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _dstore_store_nolock(ds_ctx, ns_map, proc->rank, kv2); ds_ctx 1917 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _ESH_LOCK(ds_ctx, ns_map->tbl_idx, wr_unlock); ds_ctx 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, ds_ctx 1970 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (0 != (rc = pthread_mutex_lock(&ds_ctx->lock))) { ds_ctx 1976 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (ns_map = ds_ctx->session_map_search(ds_ctx, nspace))) { ds_ctx 1990 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ssize_t _nprocs = _get_univ_size(ds_ctx, ns_map->name); ds_ctx 2002 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c lock_rc = _ESH_LOCK(ds_ctx, ns_map->tbl_idx, rd_lock); ds_ctx 2022 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _update_initial_segment_info(ds_ctx, ns_map); ds_ctx 2024 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_info = _get_ns_info_from_initial_segment(ds_ctx, ns_map); ds_ctx 2035 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c elem = _get_track_elem_for_namespace(ds_ctx, ns_map); ds_ctx 2046 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _update_ns_elem(ds_ctx, elem, ns_info); ds_ctx 2057 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c keyhash = PMIX_DS_KEY_HASH(ds_ctx, key); ds_ctx 2063 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (0 != (rc = pthread_mutex_unlock(&ds_ctx->lock))) { ds_ctx 2070 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rinfo = _get_rank_meta_info(ds_ctx, cur_rank, meta_seg); ds_ctx 2078 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c addr = _get_data_region_by_offset(ds_ctx, data_seg, rinfo->offset); ds_ctx 2130 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_DS_KEY_IS_INVALID(ds_ctx, addr)) { ds_ctx 2136 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c addr += PMIX_DS_KV_SIZE(ds_ctx, addr); ds_ctx 2137 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c } else if (PMIX_DS_KEY_IS_EXTSLOT(ds_ctx, addr)) { ds_ctx 2139 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memcpy(&offset, PMIX_DS_DATA_PTR(ds_ctx, addr), sizeof(size_t)); ds_ctx 2145 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c addr = _get_data_region_by_offset(ds_ctx, data_seg, offset); ds_ctx 2162 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c __FILE__, __LINE__, __func__, nspace, cur_rank, PMIX_DS_KNAME_PTR(ds_ctx, addr))); ds_ctx 2164 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c uint8_t *data_ptr = PMIX_DS_DATA_PTR(ds_ctx, addr); ds_ctx 2165 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size_t data_size = PMIX_DS_DATA_SIZE(ds_ctx, addr, data_ptr); ds_ctx 2167 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_LOAD_BUFFER(_client_peer(ds_ctx), &buffer, data_ptr, data_size); ds_ctx 2171 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_BFROPS_UNPACK(rc, _client_peer(ds_ctx), &buffer, &val, &cnt, PMIX_VALUE); ds_ctx 2176 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_strncpy(info[kval_cnt - 1].key, PMIX_DS_KNAME_PTR(ds_ctx, addr), ds_ctx 2177 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DS_KNAME_LEN(ds_ctx, addr)); ds_ctx 2186 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c addr += PMIX_DS_KV_SIZE(ds_ctx, addr); ds_ctx 2187 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c } else if (PMIX_DS_KEY_MATCH(ds_ctx, addr, key, keyhash)) { ds_ctx 2192 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c uint8_t *data_ptr = PMIX_DS_DATA_PTR(ds_ctx, addr); ds_ctx 2193 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size_t data_size = PMIX_DS_DATA_SIZE(ds_ctx, addr, data_ptr); ds_ctx 2195 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_LOAD_BUFFER(_client_peer(ds_ctx), &buffer, data_ptr, data_size); ds_ctx 2199 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_BFROPS_UNPACK(rc, _client_peer(ds_ctx), &buffer, (void*)*kvs, &cnt, PMIX_VALUE); ds_ctx 2213 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DS_KNAME_PTR(ds_ctx, addr), key)); ds_ctx 2215 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c addr += PMIX_DS_KV_SIZE(ds_ctx, addr); ds_ctx 2227 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c lock_rc = _ESH_LOCK(ds_ctx, ns_map->tbl_idx, rd_unlock); ds_ctx 2234 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pthread_mutex_unlock(&ds_ctx->lock); ds_ctx 2266 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pthread_mutex_unlock(&ds_ctx->lock); ds_ctx 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, ds_ctx 2286 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _dstore_fetch(ds_ctx, proc->nspace, proc->rank, key, &val); ds_ctx 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, ds_ctx 2343 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == ds_ctx->session_map_search) { ds_ctx 2349 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (ns_map = ds_ctx->session_map_search(ds_ctx, peer->nspace))) { ds_ctx 2355 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if ((NULL == ds_ctx->base_path) || (strlen(ds_ctx->base_path) == 0)){ ds_ctx 2362 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _ESH_SESSION_path(ds_ctx->session_array, ns_map->tbl_idx), ds_ctx 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, ds_ctx 2375 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c uid_t jobuid = ds_ctx->jobuid; ds_ctx 2376 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c char setjobuid = ds_ctx->setjobuid; ds_ctx 2398 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_SUCCESS != _esh_jobuid_tbl_search(ds_ctx, jobuid, &tbl_idx)) { ds_ctx 2400 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _esh_session_tbl_add(ds_ctx, &tbl_idx); ds_ctx 2405 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map = _esh_session_map(ds_ctx, nspace, local_size, tbl_idx); ds_ctx 2412 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_SUCCESS != (rc =_esh_session_init(ds_ctx, tbl_idx, ns_map, ds_ctx 2420 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map = _esh_session_map(ds_ctx, nspace, local_size, tbl_idx); ds_ctx 2429 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->lock_cbs->init(&_ESH_SESSION_lock(ds_ctx->session_array, tbl_idx), ds_ctx 2430 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->base_path, nspace, local_size, ds_ctx->jobuid, ds_ctx 2431 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->setjobuid); ds_ctx 2432 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == _ESH_SESSION_lock(ds_ctx->session_array, tbl_idx)) { ds_ctx 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) ds_ctx 2455 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (ns_map_data = ds_ctx->session_map_search(ds_ctx, nspace))) { ds_ctx 2461 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size = pmix_value_array_get_size(ds_ctx->ns_map_array); ds_ctx 2462 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map = PMIX_VALUE_ARRAY_GET_BASE(ds_ctx->ns_map_array, ns_map_t); ds_ctx 2468 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _esh_session_map_clean(ds_ctx, &ns_map[map_idx]); ds_ctx 2478 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c session_tbl = PMIX_VALUE_ARRAY_GET_BASE(ds_ctx->session_array, session_t); ds_ctx 2482 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size = pmix_value_array_get_size(ds_ctx->ns_track_array); ds_ctx 2489 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c trk = pmix_value_array_get_item(ds_ctx->ns_track_array, dstor_track_idx); ds_ctx 2492 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_value_array_remove_item(ds_ctx->ns_track_array, dstor_track_idx); ds_ctx 2495 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _esh_session_release(ds_ctx, session_tbl_idx); ds_ctx 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, ds_ctx 2533 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (ns_map = ds_ctx->session_map_search(ds_ctx, ns->nspace))) { ds_ctx 2540 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _ESH_LOCK(ds_ctx, ns_map->tbl_idx, wr_lock); ds_ctx 2546 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = pmix_gds_base_store_modex(nspace, buf, ds_ctx, ds_ctx 2554 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc1 = _ESH_LOCK(ds_ctx, ns_map->tbl_idx, wr_unlock); ds_ctx 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, ds_ctx 2643 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (ns_map = ds_ctx->session_map_search(ds_ctx, proc->nspace))) { ds_ctx 2650 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _dstore_store_nolock(ds_ctx, ns_map, proc->rank, kv); ds_ctx 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, ds_ctx 2691 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if ((PMIX_PROC_IS_V1(_client_peer(ds_ctx)) || PMIX_PROC_IS_V20(_client_peer(ds_ctx))) && ds_ctx 2728 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (PMIX_SUCCESS != (rc = _dstore_store_nolock(ds_ctx, ns_map, proc->rank, kvp))) { ds_ctx 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, ds_ctx 2759 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _client_compat_save(ds_ctx, peer); ds_ctx 2762 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == (ns_map = ds_ctx->session_map_search(ds_ctx, proc.nspace))) { ds_ctx 2769 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _ESH_LOCK(ds_ctx, ns_map->tbl_idx, wr_lock); ds_ctx 2775 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _store_job_info(ds_ctx, ns_map, &proc); ds_ctx 2783 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _store_job_info(ds_ctx, ns_map, &proc); ds_ctx 2790 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _ESH_LOCK(ds_ctx, ns_map->tbl_idx, wr_unlock); ds_ctx 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, ds_ctx 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) ds_ctx 2831 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == ds_ctx->clients_peer) { ds_ctx 2832 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->clients_peer = PMIX_NEW(pmix_peer_t); ds_ctx 2834 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->clients_peer->nptr = nptr; ds_ctx 2836 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->clients_peer->nptr->compat = peer->nptr->compat; ds_ctx 2837 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->clients_peer->proc_type = peer->proc_type; ds_ctx 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) ds_ctx 2842 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == ds_ctx->clients_peer) { ds_ctx 2845 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c return ds_ctx->clients_peer; ds_ctx 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, ds_ctx 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); ds_ctx 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, ds_ctx 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); ds_ctx 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, ds_ctx 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, ds_ctx 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, ds_ctx 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, ds_ctx 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, ds_ctx 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, ds_ctx 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,