ns_map 72 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c const ns_map_data_t *ns_map, pmix_pshmem_seg_t *metaseg, ns_map 75 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c const ns_map_data_t *ns_map); ns_map 77 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_data_t *ns_map); ns_map 83 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c const ns_map_data_t *ns_map); ns_map 117 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_data_t *ns_map, ns_map 170 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memset(&p->ns_map, 0, sizeof(p->ns_map)); ns_map 181 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memset(&p->ns_map, 0, sizeof(p->ns_map)); ns_map 324 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_t *ns_map; ns_map 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); ns_map 334 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if(ns_map[idx].in_use) { ns_map 335 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _esh_session_map_clean(ds_ctx, &ns_map[idx]); ns_map 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); ns_map 403 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (!ns_map[map_idx].in_use) { ns_map 404 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map[map_idx].in_use = true; ns_map 405 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_strncpy(ns_map[map_idx].data.name, nspace, sizeof(ns_map[map_idx].data.name)-1); ns_map 406 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map[map_idx].data.tbl_idx = tbl_idx; ns_map 407 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c return &ns_map[map_idx].data; ns_map 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); ns_map 480 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (ns_map[idx].in_use && ns_map 481 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c (0 == strcmp(ns_map[idx].data.name, nspace))) { ns_map 482 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c return &ns_map[idx].data; ns_map 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); ns_map 499 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (ns_map[idx].in_use && ns_map 500 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c (0 == strcmp(ns_map[idx].data.name, nspace))) { ns_map 501 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c return &ns_map[idx].data; ns_map 631 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_data_t *ns_map = NULL; ns_map 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))) { ns_map 655 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c info->ns_map.name, i, ds_ctx->jobuid, ns_map 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); ns_map 690 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c info->ns_map.name, i, ds_ctx->jobuid, ns_map 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); ns_map 721 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c const ns_map_data_t *ns_map, pmix_pshmem_seg_t *metaseg, ns_map 727 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map->tbl_idx)->seg_info.seg_base_addr)); ns_map 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); ns_map 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, ns_map 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 + ns_map 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; ns_map 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, ns_map 750 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memset(&elem.ns_map, 0, sizeof(elem.ns_map)); ns_map 751 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_strncpy(elem.ns_map.name, ns_map->name, sizeof(elem.ns_map.name)-1); ns_map 752 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c elem.ns_map.tbl_idx = ns_map->tbl_idx; ns_map 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) + ns_map 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), ns_map 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) ns_map 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); ns_map 777 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map->name, tmp->id+1); ns_map 786 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c const ns_map_data_t *ns_map) ns_map 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); ns_map 806 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (0 == (rc = strncmp(cur_elem->ns_map.name, ns_map->name, strlen(ns_map->name)+1))) { ns_map 821 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_data_t *ns_map) ns_map 828 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c __FILE__, __LINE__, __func__, ns_map->name)); ns_map 831 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (ns_map->track_idx >= 0) { ns_map 832 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if ((ns_map->track_idx + 1) > (int)size) { ns_map 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); ns_map 846 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_strncpy(new_elem->ns_map.name, ns_map->name, sizeof(new_elem->ns_map.name)-1); ns_map 848 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map->track_idx = size; ns_map 923 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_info->ns_map.name, (unsigned long)rinfo->rank, ns_map 936 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c __FILE__, __LINE__, __func__, ns_info->ns_map.name)); ns_map 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, ns_map 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); ns_map 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, ns_map 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); ns_map 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, ns_map 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); ns_map 1550 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_data_t *ns_map = NULL; ns_map 1732 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map = _esh_session_map(ds_ctx, nspace, 0, tbl_idx); ns_map 1733 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == ns_map) { ns_map 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, ns_map 1790 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_data_t *ns_map, ns_map 1805 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c __FILE__, __LINE__, __func__, ns_map->name, rank)); ns_map 1817 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c elem = _get_track_elem_for_namespace(ds_ctx, ns_map); ns_map 1827 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c memset(&ns_info.ns_map, 0, sizeof(ns_info.ns_map)); ns_map 1828 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_strncpy(ns_info.ns_map.name, ns_map->name, sizeof(ns_info.ns_map.name)-1); ns_map 1829 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_info.ns_map.tbl_idx = ns_map->tbl_idx; ns_map 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); ns_map 1874 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_data_t *ns_map; ns_map 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))) { ns_map 1904 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _ESH_LOCK(ds_ctx, ns_map->tbl_idx, wr_lock); ns_map 1910 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _dstore_store_nolock(ds_ctx, ns_map, proc->rank, kv2); ns_map 1917 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _ESH_LOCK(ds_ctx, ns_map->tbl_idx, wr_unlock); ns_map 1945 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_data_t *ns_map = NULL; ns_map 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))) { ns_map 1990 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ssize_t _nprocs = _get_univ_size(ds_ctx, ns_map->name); ns_map 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); ns_map 2022 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _update_initial_segment_info(ds_ctx, ns_map); ns_map 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); ns_map 2029 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c __FILE__, __LINE__, __func__, ns_map->name)); ns_map 2035 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c elem = _get_track_elem_for_namespace(ds_ctx, ns_map); ns_map 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); ns_map 2338 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_data_t *ns_map = NULL; ns_map 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))) { ns_map 2362 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _ESH_SESSION_path(ds_ctx->session_array, ns_map->tbl_idx), ns_map 2378 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_data_t *ns_map = NULL; ns_map 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); ns_map 2406 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == ns_map) { ns_map 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, ns_map 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); ns_map 2421 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL == ns_map) { ns_map 2446 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_t *ns_map; ns_map 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); ns_map 2465 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (ns_map[map_idx].in_use && ns_map 2466 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c (ns_map[map_idx].data.tbl_idx == ns_map_data->tbl_idx)) { ns_map 2467 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (0 == strcmp(ns_map[map_idx].data.name, nspace)) { ns_map 2468 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c _esh_session_map_clean(ds_ctx, &ns_map[map_idx]); ns_map 2531 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_data_t *ns_map; ns_map 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))) { ns_map 2540 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _ESH_LOCK(ds_ctx, ns_map->tbl_idx, wr_lock); ns_map 2554 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc1 = _ESH_LOCK(ds_ctx, ns_map->tbl_idx, wr_unlock); ns_map 2573 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_data_t *ns_map; ns_map 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))) { ns_map 2650 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _dstore_store_nolock(ds_ctx, ns_map, proc->rank, kv); ns_map 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, ns_map 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))) { ns_map 2757 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_map_data_t *ns_map; ns_map 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))) { ns_map 2769 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _ESH_LOCK(ds_ctx, ns_map->tbl_idx, wr_lock); ns_map 2775 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _store_job_info(ds_ctx, ns_map, &proc); ns_map 2783 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _store_job_info(ds_ctx, ns_map, &proc); ns_map 2790 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _ESH_LOCK(ds_ctx, ns_map->tbl_idx, wr_unlock); ns_map 106 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.h ns_map_data_t ns_map; ns_map 124 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.h ns_map_data_t ns_map;