mca_osc_ucx_component 39 ompi/mca/osc/ucx/osc_ucx.h OMPI_DECLSPEC extern ompi_osc_ucx_component_t mca_osc_ucx_component; mca_osc_ucx_component 146 ompi/mca/osc/ucx/osc_ucx_active_target.c opal_common_ucx_wpool_progress(mca_osc_ucx_component.wpool); mca_osc_ucx_component 275 ompi/mca/osc/ucx/osc_ucx_active_target.c ucp_worker_progress(mca_osc_ucx_component.wpool->dflt_worker); mca_osc_ucx_component 302 ompi/mca/osc/ucx/osc_ucx_active_target.c opal_common_ucx_wpool_progress(mca_osc_ucx_component.wpool); mca_osc_ucx_component 256 ompi/mca/osc/ucx/osc_ucx_comm.c ucp_worker_progress(mca_osc_ucx_component.wpool->dflt_worker); mca_osc_ucx_component 814 ompi/mca/osc/ucx/osc_ucx_comm.c mca_osc_ucx_component.num_incomplete_req_ops++; mca_osc_ucx_component 865 ompi/mca/osc/ucx/osc_ucx_comm.c mca_osc_ucx_component.num_incomplete_req_ops++; mca_osc_ucx_component 38 ompi/mca/osc/ucx/osc_ucx_component.c ompi_osc_ucx_component_t mca_osc_ucx_component = { mca_osc_ucx_component 114 ompi/mca/osc/ucx/osc_ucx_component.c mca_osc_ucx_component.priority = UCX_VERSION(major, minor, release_number) >= UCX_VERSION(1, 5, 0) ? 60 : 0; mca_osc_ucx_component 117 ompi/mca/osc/ucx/osc_ucx_component.c mca_osc_ucx_component.priority); mca_osc_ucx_component 118 ompi/mca/osc/ucx/osc_ucx_component.c (void) mca_base_component_var_register(&mca_osc_ucx_component.super.osc_version, "priority", description_str, mca_osc_ucx_component 120 ompi/mca/osc/ucx/osc_ucx_component.c MCA_BASE_VAR_SCOPE_GROUP, &mca_osc_ucx_component.priority); mca_osc_ucx_component 123 ompi/mca/osc/ucx/osc_ucx_component.c opal_common_ucx_mca_var_register(&mca_osc_ucx_component.super.osc_version); mca_osc_ucx_component 129 ompi/mca/osc/ucx/osc_ucx_component.c if (mca_osc_ucx_component.wpool != NULL) { mca_osc_ucx_component 130 ompi/mca/osc/ucx/osc_ucx_component.c opal_common_ucx_wpool_progress(mca_osc_ucx_component.wpool); mca_osc_ucx_component 136 ompi/mca/osc/ucx/osc_ucx_component.c mca_osc_ucx_component.enable_mpi_threads = enable_mpi_threads; mca_osc_ucx_component 137 ompi/mca/osc/ucx/osc_ucx_component.c mca_osc_ucx_component.wpool = opal_common_ucx_wpool_allocate(); mca_osc_ucx_component 144 ompi/mca/osc/ucx/osc_ucx_component.c opal_common_ucx_wpool_free(mca_osc_ucx_component.wpool); mca_osc_ucx_component 151 ompi/mca/osc/ucx/osc_ucx_component.c return mca_osc_ucx_component.priority; mca_osc_ucx_component 192 ompi/mca/osc/ucx/osc_ucx_component.c mca_osc_ucx_component.num_modules--; mca_osc_ucx_component 193 ompi/mca/osc/ucx/osc_ucx_component.c OSC_UCX_ASSERT(mca_osc_ucx_component.num_modules >= 0); mca_osc_ucx_component 194 ompi/mca/osc/ucx/osc_ucx_component.c if (0 == mca_osc_ucx_component.num_modules) { mca_osc_ucx_component 226 ompi/mca/osc/ucx/osc_ucx_component.c if (mca_osc_ucx_component.env_initialized == false) { mca_osc_ucx_component 228 ompi/mca/osc/ucx/osc_ucx_component.c OBJ_CONSTRUCT(&mca_osc_ucx_component.requests, opal_free_list_t); mca_osc_ucx_component 229 ompi/mca/osc/ucx/osc_ucx_component.c ret = opal_free_list_init (&mca_osc_ucx_component.requests, mca_osc_ucx_component 239 ompi/mca/osc/ucx/osc_ucx_component.c ret = opal_common_ucx_wpool_init(mca_osc_ucx_component.wpool, mca_osc_ucx_component 241 ompi/mca/osc/ucx/osc_ucx_component.c mca_osc_ucx_component.enable_mpi_threads); mca_osc_ucx_component 247 ompi/mca/osc/ucx/osc_ucx_component.c mca_osc_ucx_component.env_initialized = true; mca_osc_ucx_component 258 ompi/mca/osc/ucx/osc_ucx_component.c mca_osc_ucx_component.num_modules++; mca_osc_ucx_component 307 ompi/mca/osc/ucx/osc_ucx_component.c ret = opal_common_ucx_wpctx_create(mca_osc_ucx_component.wpool, comm_size, mca_osc_ucx_component 413 ompi/mca/osc/ucx/osc_ucx_component.c OSC_UCX_ASSERT(mca_osc_ucx_component.num_modules > 0); mca_osc_ucx_component 414 ompi/mca/osc/ucx/osc_ucx_component.c if (1 == mca_osc_ucx_component.num_modules) { mca_osc_ucx_component 433 ompi/mca/osc/ucx/osc_ucx_component.c opal_common_ucx_wpool_finalize(mca_osc_ucx_component.wpool); mca_osc_ucx_component 434 ompi/mca/osc/ucx/osc_ucx_component.c OBJ_DESTRUCT(&mca_osc_ucx_component.requests); mca_osc_ucx_component 435 ompi/mca/osc/ucx/osc_ucx_component.c mca_osc_ucx_component.env_initialized = false; mca_osc_ucx_component 579 ompi/mca/osc/ucx/osc_ucx_component.c opal_common_ucx_wpool_finalize(mca_osc_ucx_component.wpool); mca_osc_ucx_component 45 ompi/mca/osc/ucx/osc_ucx_passive_target.c ucp_worker_progress(mca_osc_ucx_component.wpool->dflt_worker); mca_osc_ucx_component 74 ompi/mca/osc/ucx/osc_ucx_passive_target.c ucp_worker_progress(mca_osc_ucx_component.wpool->dflt_worker); mca_osc_ucx_component 51 ompi/mca/osc/ucx/osc_ucx_request.c mca_osc_ucx_component.num_incomplete_req_ops--; mca_osc_ucx_component 52 ompi/mca/osc/ucx/osc_ucx_request.c assert(mca_osc_ucx_component.num_incomplete_req_ops >= 0); mca_osc_ucx_component 29 ompi/mca/osc/ucx/osc_ucx_request.h item = opal_free_list_get(&mca_osc_ucx_component.requests); \ mca_osc_ucx_component 31 ompi/mca/osc/ucx/osc_ucx_request.h if (mca_osc_ucx_component.num_incomplete_req_ops > 0) { \ mca_osc_ucx_component 32 ompi/mca/osc/ucx/osc_ucx_request.h opal_common_ucx_wpool_progress(mca_osc_ucx_component.wpool); \ mca_osc_ucx_component 47 ompi/mca/osc/ucx/osc_ucx_request.h opal_free_list_return (&mca_osc_ucx_component.requests, \