ucp_peers 44 oshmem/mca/atomic/ucx/atomic_ucx_cswap.c status_ptr = ucp_atomic_fetch_nb(ucx_ctx->ucp_peers[pe].ucp_conn, ucp_peers 51 oshmem/mca/atomic/ucx/atomic_ucx_module.c status = ucp_atomic_post(ucx_ctx->ucp_peers[pe].ucp_conn, ucp_peers 74 oshmem/mca/atomic/ucx/atomic_ucx_module.c status_ptr = ucp_atomic_fetch_nb(ucx_ctx->ucp_peers[pe].ucp_conn, ucp_peers 85 oshmem/mca/spml/ucx/spml_ucx.c .ucp_peers = NULL, ucp_peers 109 oshmem/mca/spml/ucx/spml_ucx.c if (!mca_spml_ucx_ctx_default.ucp_peers) { ucp_peers 119 oshmem/mca/spml/ucx/spml_ucx.c del_procs[i].ep = mca_spml_ucx_ctx_default.ucp_peers[i].ucp_conn; ucp_peers 123 oshmem/mca/spml/ucx/spml_ucx.c mca_spml_ucx_ctx_default.ucp_peers[i].ucp_conn = NULL; ucp_peers 132 oshmem/mca/spml/ucx/spml_ucx.c free(mca_spml_ucx_ctx_default.ucp_peers); ucp_peers 134 oshmem/mca/spml/ucx/spml_ucx.c mca_spml_ucx_ctx_default.ucp_peers = NULL; ucp_peers 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))); ucp_peers 231 oshmem/mca/spml/ucx/spml_ucx.c if (NULL == mca_spml_ucx_ctx_default.ucp_peers) { ucp_peers 261 oshmem/mca/spml/ucx/spml_ucx.c &mca_spml_ucx_ctx_default.ucp_peers[i].ucp_conn); ucp_peers 272 oshmem/mca/spml/ucx/spml_ucx.c mca_spml_ucx_ctx_default.ucp_peers[i].mkeys[j].key.rkey = NULL; ucp_peers 290 oshmem/mca/spml/ucx/spml_ucx.c if (mca_spml_ucx_ctx_default.ucp_peers[i].ucp_conn) { ucp_peers 291 oshmem/mca/spml/ucx/spml_ucx.c ucp_ep_destroy(mca_spml_ucx_ctx_default.ucp_peers[i].ucp_conn); ucp_peers 297 oshmem/mca/spml/ucx/spml_ucx.c if (mca_spml_ucx_ctx_default.ucp_peers) ucp_peers 298 oshmem/mca/spml/ucx/spml_ucx.c free(mca_spml_ucx_ctx_default.ucp_peers); ucp_peers 345 oshmem/mca/spml/ucx/spml_ucx.c ucx_mkey = &ucx_ctx->ucp_peers[pe].mkeys[segno].key; ucp_peers 347 oshmem/mca/spml/ucx/spml_ucx.c err = ucp_ep_rkey_unpack(ucx_ctx->ucp_peers[pe].ucp_conn, ucp_peers 378 oshmem/mca/spml/ucx/spml_ucx.c ucx_mkey = &mca_spml_ucx_ctx_default.ucp_peers[my_pe].mkeys[HEAP_SEG_INDEX].key; ucp_peers 419 oshmem/mca/spml/ucx/spml_ucx.c ucx_mkey = &mca_spml_ucx_ctx_default.ucp_peers[my_pe].mkeys[segno].key; ucp_peers 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, ucp_peers 579 oshmem/mca/spml/ucx/spml_ucx.c ucx_ctx->ucp_peers = (ucp_peer_t *) calloc(nprocs, sizeof(*(ucx_ctx->ucp_peers))); ucp_peers 580 oshmem/mca/spml/ucx/spml_ucx.c if (NULL == ucx_ctx->ucp_peers) { ucp_peers 588 oshmem/mca/spml/ucx/spml_ucx.c &ucx_ctx->ucp_peers[i].ucp_conn); ucp_peers 597 oshmem/mca/spml/ucx/spml_ucx.c ucx_mkey = &ucx_ctx->ucp_peers[i].mkeys[j].key; ucp_peers 599 oshmem/mca/spml/ucx/spml_ucx.c err = ucp_ep_rkey_unpack(ucx_ctx->ucp_peers[i].ucp_conn, ucp_peers 617 oshmem/mca/spml/ucx/spml_ucx.c if (ucx_ctx->ucp_peers[i].ucp_conn) { ucp_peers 618 oshmem/mca/spml/ucx/spml_ucx.c ucp_ep_destroy(ucx_ctx->ucp_peers[i].ucp_conn); ucp_peers 622 oshmem/mca/spml/ucx/spml_ucx.c if (ucx_ctx->ucp_peers) ucp_peers 623 oshmem/mca/spml/ucx/spml_ucx.c free(ucx_ctx->ucp_peers); ucp_peers 687 oshmem/mca/spml/ucx/spml_ucx.c request = ucp_get_nb(ucx_ctx->ucp_peers[src].ucp_conn, dst_addr, size, ucp_peers 691 oshmem/mca/spml/ucx/spml_ucx.c status = ucp_get(ucx_ctx->ucp_peers[src].ucp_conn, dst_addr, size, ucp_peers 705 oshmem/mca/spml/ucx/spml_ucx.c status = ucp_get_nbi(ucx_ctx->ucp_peers[src].ucp_conn, dst_addr, size, ucp_peers 724 oshmem/mca/spml/ucx/spml_ucx.c request = ucp_put_nb(ucx_ctx->ucp_peers[dst].ucp_conn, src_addr, size, ucp_peers 728 oshmem/mca/spml/ucx/spml_ucx.c status = ucp_put(ucx_ctx->ucp_peers[dst].ucp_conn, src_addr, size, ucp_peers 742 oshmem/mca/spml/ucx/spml_ucx.c status = ucp_put_nbi(ucx_ctx->ucp_peers[dst].ucp_conn, src_addr, size, ucp_peers 70 oshmem/mca/spml/ucx/spml_ucx.h ucp_peer_t *ucp_peers; ucp_peers 192 oshmem/mca/spml/ucx/spml_ucx.h peer = &(ucx_ctx->ucp_peers[dst_pe]); ucp_peers 202 oshmem/mca/spml/ucx/spml_ucx.h mkey = ucx_ctx->ucp_peers[pe].mkeys; ucp_peers 318 oshmem/mca/spml/ucx/spml_ucx_component.c if (ctx->ucp_peers[i].mkeys[j].key.rkey != NULL) { ucp_peers 319 oshmem/mca/spml/ucx/spml_ucx_component.c ucp_rkey_destroy(ctx->ucp_peers[i].mkeys[j].key.rkey); ucp_peers 323 oshmem/mca/spml/ucx/spml_ucx_component.c del_procs[i].ep = ctx->ucp_peers[i].ucp_conn; ucp_peers 325 oshmem/mca/spml/ucx/spml_ucx_component.c ctx->ucp_peers[i].ucp_conn = NULL; ucp_peers 332 oshmem/mca/spml/ucx/spml_ucx_component.c free(ctx->ucp_peers);