ucp_worker         79 ompi/mca/pml/ucx/pml_ucx.c     .ucp_worker            = NULL
ucp_worker         96 ompi/mca/pml/ucx/pml_ucx.c     status = ucp_worker_query(ompi_pml_ucx.ucp_worker, &attrs);
ucp_worker        105 ompi/mca/pml/ucx/pml_ucx.c     ucp_worker_release_address(ompi_pml_ucx.ucp_worker, attrs.address);
ucp_worker        128 ompi/mca/pml/ucx/pml_ucx.c     status = ucp_worker_get_address(ompi_pml_ucx.ucp_worker, &address, &addrlen);
ucp_worker        139 ompi/mca/pml/ucx/pml_ucx.c     ucp_worker_release_address(ompi_pml_ucx.ucp_worker, address);
ucp_worker        266 ompi/mca/pml/ucx/pml_ucx.c                                &ompi_pml_ucx.ucp_worker);
ucp_worker        274 ompi/mca/pml/ucx/pml_ucx.c     status = ucp_worker_query(ompi_pml_ucx.ucp_worker, &attr);
ucp_worker        312 ompi/mca/pml/ucx/pml_ucx.c                     (void *)ompi_pml_ucx.ucp_worker);
ucp_worker        316 ompi/mca/pml/ucx/pml_ucx.c     ucp_worker_destroy(ompi_pml_ucx.ucp_worker);
ucp_worker        317 ompi/mca/pml/ucx/pml_ucx.c     ompi_pml_ucx.ucp_worker = NULL;
ucp_worker        348 ompi/mca/pml/ucx/pml_ucx.c     if (ompi_pml_ucx.ucp_worker) {
ucp_worker        349 ompi/mca/pml/ucx/pml_ucx.c         ucp_worker_destroy(ompi_pml_ucx.ucp_worker);
ucp_worker        350 ompi/mca/pml/ucx/pml_ucx.c         ompi_pml_ucx.ucp_worker = NULL;
ucp_worker        375 ompi/mca/pml/ucx/pml_ucx.c     status = ucp_ep_create(ompi_pml_ucx.ucp_worker, &ep_params, &ep);
ucp_worker        475 ompi/mca/pml/ucx/pml_ucx.c                                     ompi_pml_ucx.num_disconnect, ompi_pml_ucx.ucp_worker);
ucp_worker        510 ompi/mca/pml/ucx/pml_ucx.c     ucp_worker_progress(ompi_pml_ucx.ucp_worker);
ucp_worker        562 ompi/mca/pml/ucx/pml_ucx.c     req = (ompi_request_t*)ucp_tag_recv_nb(ompi_pml_ucx.ucp_worker, buf, count,
ucp_worker        591 ompi/mca/pml/ucx/pml_ucx.c     status = ucp_tag_recv_nbr(ompi_pml_ucx.ucp_worker, buf, count,
ucp_worker        595 ompi/mca/pml/ucx/pml_ucx.c     MCA_COMMON_UCX_PROGRESS_LOOP(ompi_pml_ucx.ucp_worker) {
ucp_worker        795 ompi/mca/pml/ucx/pml_ucx.c         MCA_COMMON_UCX_WAIT_LOOP(req, ompi_pml_ucx.ucp_worker, "ucx send", ompi_request_free(&req));
ucp_worker        818 ompi/mca/pml/ucx/pml_ucx.c     MCA_COMMON_UCX_WAIT_LOOP(req, ompi_pml_ucx.ucp_worker, "ucx send", (void)0);
ucp_worker        863 ompi/mca/pml/ucx/pml_ucx.c     ucp_msg = ucp_tag_probe_nb(ompi_pml_ucx.ucp_worker, ucp_tag, ucp_tag_mask,
ucp_worker        870 ompi/mca/pml/ucx/pml_ucx.c             (void)ucp_worker_progress(ompi_pml_ucx.ucp_worker) : opal_progress();
ucp_worker        887 ompi/mca/pml/ucx/pml_ucx.c     MCA_COMMON_UCX_PROGRESS_LOOP(ompi_pml_ucx.ucp_worker) {
ucp_worker        888 ompi/mca/pml/ucx/pml_ucx.c         ucp_msg = ucp_tag_probe_nb(ompi_pml_ucx.ucp_worker, ucp_tag,
ucp_worker        910 ompi/mca/pml/ucx/pml_ucx.c     ucp_msg = ucp_tag_probe_nb(ompi_pml_ucx.ucp_worker, ucp_tag, ucp_tag_mask,
ucp_worker        919 ompi/mca/pml/ucx/pml_ucx.c             (void)ucp_worker_progress(ompi_pml_ucx.ucp_worker) : opal_progress();
ucp_worker        936 ompi/mca/pml/ucx/pml_ucx.c     MCA_COMMON_UCX_PROGRESS_LOOP(ompi_pml_ucx.ucp_worker) {
ucp_worker        937 ompi/mca/pml/ucx/pml_ucx.c         ucp_msg = ucp_tag_probe_nb(ompi_pml_ucx.ucp_worker, ucp_tag, ucp_tag_mask,
ucp_worker        956 ompi/mca/pml/ucx/pml_ucx.c     req = (ompi_request_t*)ucp_tag_msg_recv_nb(ompi_pml_ucx.ucp_worker, buf, count,
ucp_worker        979 ompi/mca/pml/ucx/pml_ucx.c     req = (ompi_request_t*)ucp_tag_msg_recv_nb(ompi_pml_ucx.ucp_worker, buf, count,
ucp_worker       1023 ompi/mca/pml/ucx/pml_ucx.c             tmp_req = (ompi_request_t*)ucp_tag_recv_nb(ompi_pml_ucx.ucp_worker,
ucp_worker         44 ompi/mca/pml/ucx/pml_ucx.h     ucp_worker_h              ucp_worker;
ucp_worker         33 ompi/mca/pml/ucx/pml_ucx_request.c     ucp_request_cancel(ompi_pml_ucx.ucp_worker, req);
ucp_worker        191 ompi/mca/pml/ucx/pml_ucx_request.c         ucp_request_cancel(ompi_pml_ucx.ucp_worker, preq->tmp_req);
ucp_worker         48 oshmem/mca/atomic/ucx/atomic_ucx_cswap.c     return opal_common_ucx_wait_request(status_ptr, ucx_ctx->ucp_worker,
ucp_worker         78 oshmem/mca/atomic/ucx/atomic_ucx_module.c     return opal_common_ucx_wait_request(status_ptr, ucx_ctx->ucp_worker,
ucp_worker         84 oshmem/mca/spml/ucx/spml_ucx.c     .ucp_worker = NULL,
ucp_worker        128 oshmem/mca/spml/ucx/spml_ucx.c                                     mca_spml_ucx_ctx_default.ucp_worker);
ucp_worker        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);
ucp_worker        260 oshmem/mca/spml/ucx/spml_ucx.c         err = ucp_ep_create(mca_spml_ucx_ctx_default.ucp_worker, &ep_params,
ucp_worker        280 oshmem/mca/spml/ucx/spml_ucx.c     ucp_worker_release_address(mca_spml_ucx_ctx_default.ucp_worker, wk_local_addr);
ucp_worker        573 oshmem/mca/spml/ucx/spml_ucx.c                             &ucx_ctx->ucp_worker);
ucp_worker        587 oshmem/mca/spml/ucx/spml_ucx.c         err = ucp_ep_create(ucx_ctx->ucp_worker, &ep_params,
ucp_worker        626 oshmem/mca/spml/ucx/spml_ucx.c     ucp_worker_destroy(ucx_ctx->ucp_worker);
ucp_worker        689 oshmem/mca/spml/ucx/spml_ucx.c     return opal_common_ucx_wait_request(request, ucx_ctx->ucp_worker, "ucp_get_nb");
ucp_worker        726 oshmem/mca/spml/ucx/spml_ucx.c     return opal_common_ucx_wait_request(request, ucx_ctx->ucp_worker, "ucp_put_nb");
ucp_worker        757 oshmem/mca/spml/ucx/spml_ucx.c     err = ucp_worker_fence(ucx_ctx->ucp_worker);
ucp_worker        773 oshmem/mca/spml/ucx/spml_ucx.c     ret = opal_common_ucx_worker_flush(ucx_ctx->ucp_worker);
ucp_worker        912 oshmem/mca/spml/ucx/spml_ucx.c     request = ucp_worker_flush_nb(((mca_spml_ucx_ctx_t*)ctx)->ucp_worker, 0,
ucp_worker         69 oshmem/mca/spml/ucx/spml_ucx.h     ucp_worker_h             ucp_worker;
ucp_worker        140 oshmem/mca/spml/ucx/spml_ucx_component.c         ucp_worker_progress(mca_spml_ucx.active_array.ctxs[i]->ucp_worker);
ucp_worker        147 oshmem/mca/spml/ucx/spml_ucx_component.c     ucp_worker_progress(mca_spml_ucx_ctx_default.ucp_worker);
ucp_worker        163 oshmem/mca/spml/ucx/spml_ucx_component.c     count = ucp_worker_progress(mca_spml_ucx.aux_ctx->ucp_worker);
ucp_worker        178 oshmem/mca/spml/ucx/spml_ucx_component.c         count = ucp_worker_progress(mca_spml_ucx.aux_ctx->ucp_worker);
ucp_worker        255 oshmem/mca/spml/ucx/spml_ucx_component.c                             &mca_spml_ucx_ctx_default.ucp_worker);
ucp_worker        261 oshmem/mca/spml/ucx/spml_ucx_component.c     err = ucp_worker_query(mca_spml_ucx_ctx_default.ucp_worker, &wkr_attr);
ucp_worker        330 oshmem/mca/spml/ucx/spml_ucx_component.c                                       ctx->ucp_worker);
ucp_worker        375 oshmem/mca/spml/ucx/spml_ucx_component.c             ucp_worker_progress(mca_spml_ucx.active_array.ctxs[i]->ucp_worker);
ucp_worker        379 oshmem/mca/spml/ucx/spml_ucx_component.c             ucp_worker_progress(mca_spml_ucx.idle_array.ctxs[i]->ucp_worker);
ucp_worker        382 oshmem/mca/spml/ucx/spml_ucx_component.c         ucp_worker_progress(mca_spml_ucx_ctx_default.ucp_worker);
ucp_worker        385 oshmem/mca/spml/ucx/spml_ucx_component.c             ucp_worker_progress(mca_spml_ucx.aux_ctx->ucp_worker);
ucp_worker        391 oshmem/mca/spml/ucx/spml_ucx_component.c         ucp_worker_destroy(mca_spml_ucx.active_array.ctxs[i]->ucp_worker);
ucp_worker        396 oshmem/mca/spml/ucx/spml_ucx_component.c         ucp_worker_destroy(mca_spml_ucx.idle_array.ctxs[i]->ucp_worker);
ucp_worker        400 oshmem/mca/spml/ucx/spml_ucx_component.c     if (mca_spml_ucx_ctx_default.ucp_worker) {
ucp_worker        401 oshmem/mca/spml/ucx/spml_ucx_component.c         ucp_worker_destroy(mca_spml_ucx_ctx_default.ucp_worker);
ucp_worker        405 oshmem/mca/spml/ucx/spml_ucx_component.c         ucp_worker_destroy(mca_spml_ucx.aux_ctx->ucp_worker);