mca_spml_ucx_ctx_default 83 oshmem/mca/spml/ucx/spml_ucx.c mca_spml_ucx_ctx_t mca_spml_ucx_ctx_default = { mca_spml_ucx_ctx_default 109 oshmem/mca/spml/ucx/spml_ucx.c if (!mca_spml_ucx_ctx_default.ucp_peers) { mca_spml_ucx_ctx_default 119 oshmem/mca/spml/ucx/spml_ucx.c del_procs[i].ep = mca_spml_ucx_ctx_default.ucp_peers[i].ucp_conn; mca_spml_ucx_ctx_default 123 oshmem/mca/spml/ucx/spml_ucx.c mca_spml_ucx_ctx_default.ucp_peers[i].ucp_conn = NULL; mca_spml_ucx_ctx_default 128 oshmem/mca/spml/ucx/spml_ucx.c mca_spml_ucx_ctx_default.ucp_worker); mca_spml_ucx_ctx_default 132 oshmem/mca/spml/ucx/spml_ucx.c free(mca_spml_ucx_ctx_default.ucp_peers); mca_spml_ucx_ctx_default 134 oshmem/mca/spml/ucx/spml_ucx.c mca_spml_ucx_ctx_default.ucp_peers = NULL; mca_spml_ucx_ctx_default 230 oshmem/mca/spml/ucx/spml_ucx.c mca_spml_ucx_ctx_default.ucp_peers = (ucp_peer_t *) calloc(nprocs, sizeof(*(mca_spml_ucx_ctx_default.ucp_peers))); mca_spml_ucx_ctx_default 231 oshmem/mca/spml/ucx/spml_ucx.c if (NULL == mca_spml_ucx_ctx_default.ucp_peers) { mca_spml_ucx_ctx_default 235 oshmem/mca/spml/ucx/spml_ucx.c err = ucp_worker_get_address(mca_spml_ucx_ctx_default.ucp_worker, &wk_local_addr, &wk_addr_len); mca_spml_ucx_ctx_default 260 oshmem/mca/spml/ucx/spml_ucx.c err = ucp_ep_create(mca_spml_ucx_ctx_default.ucp_worker, &ep_params, mca_spml_ucx_ctx_default 261 oshmem/mca/spml/ucx/spml_ucx.c &mca_spml_ucx_ctx_default.ucp_peers[i].ucp_conn); mca_spml_ucx_ctx_default 272 oshmem/mca/spml/ucx/spml_ucx.c mca_spml_ucx_ctx_default.ucp_peers[i].mkeys[j].key.rkey = NULL; mca_spml_ucx_ctx_default 280 oshmem/mca/spml/ucx/spml_ucx.c ucp_worker_release_address(mca_spml_ucx_ctx_default.ucp_worker, wk_local_addr); mca_spml_ucx_ctx_default 290 oshmem/mca/spml/ucx/spml_ucx.c if (mca_spml_ucx_ctx_default.ucp_peers[i].ucp_conn) { mca_spml_ucx_ctx_default 291 oshmem/mca/spml/ucx/spml_ucx.c ucp_ep_destroy(mca_spml_ucx_ctx_default.ucp_peers[i].ucp_conn); mca_spml_ucx_ctx_default 297 oshmem/mca/spml/ucx/spml_ucx.c if (mca_spml_ucx_ctx_default.ucp_peers) mca_spml_ucx_ctx_default 298 oshmem/mca/spml/ucx/spml_ucx.c free(mca_spml_ucx_ctx_default.ucp_peers); mca_spml_ucx_ctx_default 355 oshmem/mca/spml/ucx/spml_ucx.c if (ucx_ctx == &mca_spml_ucx_ctx_default) { mca_spml_ucx_ctx_default 378 oshmem/mca/spml/ucx/spml_ucx.c ucx_mkey = &mca_spml_ucx_ctx_default.ucp_peers[my_pe].mkeys[HEAP_SEG_INDEX].key; mca_spml_ucx_ctx_default 419 oshmem/mca/spml/ucx/spml_ucx.c ucx_mkey = &mca_spml_ucx_ctx_default.ucp_peers[my_pe].mkeys[segno].key; mca_spml_ucx_ctx_default 458 oshmem/mca/spml/ucx/spml_ucx.c status = ucp_ep_rkey_unpack(mca_spml_ucx_ctx_default.ucp_peers[oshmem_group_self->my_pe].ucp_conn, mca_spml_ucx_ctx_default 469 oshmem/mca/spml/ucx/spml_ucx.c mca_spml_ucx_cache_mkey(&mca_spml_ucx_ctx_default, &mkeys[0], segno, my_pe); mca_spml_ucx_ctx_default 75 oshmem/mca/spml/ucx/spml_ucx.h extern mca_spml_ucx_ctx_t mca_spml_ucx_ctx_default; mca_spml_ucx_ctx_default 147 oshmem/mca/spml/ucx/spml_ucx_component.c ucp_worker_progress(mca_spml_ucx_ctx_default.ucp_worker); mca_spml_ucx_ctx_default 255 oshmem/mca/spml/ucx/spml_ucx_component.c &mca_spml_ucx_ctx_default.ucp_worker); mca_spml_ucx_ctx_default 261 oshmem/mca/spml/ucx/spml_ucx_component.c err = ucp_worker_query(mca_spml_ucx_ctx_default.ucp_worker, &wkr_attr); mca_spml_ucx_ctx_default 284 oshmem/mca/spml/ucx/spml_ucx_component.c oshmem_ctx_default = (shmem_ctx_t) &mca_spml_ucx_ctx_default; mca_spml_ucx_ctx_default 382 oshmem/mca/spml/ucx/spml_ucx_component.c ucp_worker_progress(mca_spml_ucx_ctx_default.ucp_worker); mca_spml_ucx_ctx_default 400 oshmem/mca/spml/ucx/spml_ucx_component.c if (mca_spml_ucx_ctx_default.ucp_worker) { mca_spml_ucx_ctx_default 401 oshmem/mca/spml/ucx/spml_ucx_component.c ucp_worker_destroy(mca_spml_ucx_ctx_default.ucp_worker);