ompi_pml_ucx 52 ompi/mca/pml/ucx/pml_ucx.c mca_pml_ucx_module_t ompi_pml_ucx = { ompi_pml_ucx 83 ompi/mca/pml/ucx/pml_ucx.c ((char *)alloca(ompi_pml_ucx.request_size) + ompi_pml_ucx.request_size); ompi_pml_ucx 96 ompi/mca/pml/ucx/pml_ucx.c status = ucp_worker_query(ompi_pml_ucx.ucp_worker, &attrs); ompi_pml_ucx 105 ompi/mca/pml/ucx/pml_ucx.c ucp_worker_release_address(ompi_pml_ucx.ucp_worker, attrs.address); ompi_pml_ucx 128 ompi/mca/pml/ucx/pml_ucx.c status = ucp_worker_get_address(ompi_pml_ucx.ucp_worker, &address, &addrlen); ompi_pml_ucx 139 ompi/mca/pml/ucx/pml_ucx.c ucp_worker_release_address(ompi_pml_ucx.ucp_worker, address); ompi_pml_ucx 216 ompi/mca/pml/ucx/pml_ucx.c status = ucp_init(¶ms, config, &ompi_pml_ucx.ucp_context); ompi_pml_ucx 225 ompi/mca/pml/ucx/pml_ucx.c status = ucp_context_query(ompi_pml_ucx.ucp_context, &attr); ompi_pml_ucx 227 ompi/mca/pml/ucx/pml_ucx.c ucp_cleanup(ompi_pml_ucx.ucp_context); ompi_pml_ucx 228 ompi/mca/pml/ucx/pml_ucx.c ompi_pml_ucx.ucp_context = NULL; ompi_pml_ucx 232 ompi/mca/pml/ucx/pml_ucx.c ompi_pml_ucx.request_size = attr.request_size; ompi_pml_ucx 241 ompi/mca/pml/ucx/pml_ucx.c if (ompi_pml_ucx.ucp_context != NULL) { ompi_pml_ucx 242 ompi/mca/pml/ucx/pml_ucx.c ucp_cleanup(ompi_pml_ucx.ucp_context); ompi_pml_ucx 243 ompi/mca/pml/ucx/pml_ucx.c ompi_pml_ucx.ucp_context = NULL; ompi_pml_ucx 265 ompi/mca/pml/ucx/pml_ucx.c status = ucp_worker_create(ompi_pml_ucx.ucp_context, ¶ms, ompi_pml_ucx 266 ompi/mca/pml/ucx/pml_ucx.c &ompi_pml_ucx.ucp_worker); ompi_pml_ucx 274 ompi/mca/pml/ucx/pml_ucx.c status = ucp_worker_query(ompi_pml_ucx.ucp_worker, &attr); ompi_pml_ucx 295 ompi/mca/pml/ucx/pml_ucx.c ompi_pml_ucx.datatype_attr_keyval = MPI_KEYVAL_INVALID; ompi_pml_ucx 297 ompi/mca/pml/ucx/pml_ucx.c ompi_pml_ucx.predefined_types[i] = PML_UCX_DATATYPE_INVALID; ompi_pml_ucx 301 ompi/mca/pml/ucx/pml_ucx.c OBJ_CONSTRUCT(&ompi_pml_ucx.persistent_reqs, mca_pml_ucx_freelist_t); ompi_pml_ucx 302 ompi/mca/pml/ucx/pml_ucx.c OBJ_CONSTRUCT(&ompi_pml_ucx.convs, mca_pml_ucx_freelist_t); ompi_pml_ucx 305 ompi/mca/pml/ucx/pml_ucx.c OBJ_CONSTRUCT(&ompi_pml_ucx.completed_send_req, ompi_request_t); ompi_pml_ucx 306 ompi/mca/pml/ucx/pml_ucx.c mca_pml_ucx_completed_request_init(&ompi_pml_ucx.completed_send_req); ompi_pml_ucx 311 ompi/mca/pml/ucx/pml_ucx.c (void *)ompi_pml_ucx.ucp_context, ompi_pml_ucx 312 ompi/mca/pml/ucx/pml_ucx.c (void *)ompi_pml_ucx.ucp_worker); ompi_pml_ucx 316 ompi/mca/pml/ucx/pml_ucx.c ucp_worker_destroy(ompi_pml_ucx.ucp_worker); ompi_pml_ucx 317 ompi/mca/pml/ucx/pml_ucx.c ompi_pml_ucx.ucp_worker = NULL; ompi_pml_ucx 330 ompi/mca/pml/ucx/pml_ucx.c if (ompi_pml_ucx.datatype_attr_keyval != MPI_KEYVAL_INVALID) { ompi_pml_ucx 331 ompi/mca/pml/ucx/pml_ucx.c ompi_attr_free_keyval(TYPE_ATTR, &ompi_pml_ucx.datatype_attr_keyval, false); ompi_pml_ucx 335 ompi/mca/pml/ucx/pml_ucx.c if (ompi_pml_ucx.predefined_types[i] != PML_UCX_DATATYPE_INVALID) { ompi_pml_ucx 336 ompi/mca/pml/ucx/pml_ucx.c ucp_dt_destroy(ompi_pml_ucx.predefined_types[i]); ompi_pml_ucx 337 ompi/mca/pml/ucx/pml_ucx.c ompi_pml_ucx.predefined_types[i] = PML_UCX_DATATYPE_INVALID; ompi_pml_ucx 341 ompi/mca/pml/ucx/pml_ucx.c ompi_pml_ucx.completed_send_req.req_state = OMPI_REQUEST_INVALID; ompi_pml_ucx 342 ompi/mca/pml/ucx/pml_ucx.c OMPI_REQUEST_FINI(&ompi_pml_ucx.completed_send_req); ompi_pml_ucx 343 ompi/mca/pml/ucx/pml_ucx.c OBJ_DESTRUCT(&ompi_pml_ucx.completed_send_req); ompi_pml_ucx 345 ompi/mca/pml/ucx/pml_ucx.c OBJ_DESTRUCT(&ompi_pml_ucx.convs); ompi_pml_ucx 346 ompi/mca/pml/ucx/pml_ucx.c OBJ_DESTRUCT(&ompi_pml_ucx.persistent_reqs); ompi_pml_ucx 348 ompi/mca/pml/ucx/pml_ucx.c if (ompi_pml_ucx.ucp_worker) { ompi_pml_ucx 349 ompi/mca/pml/ucx/pml_ucx.c ucp_worker_destroy(ompi_pml_ucx.ucp_worker); ompi_pml_ucx 350 ompi/mca/pml/ucx/pml_ucx.c ompi_pml_ucx.ucp_worker = NULL; ompi_pml_ucx 375 ompi/mca/pml/ucx/pml_ucx.c status = ucp_ep_create(ompi_pml_ucx.ucp_worker, &ep_params, &ep); ompi_pml_ucx 475 ompi/mca/pml/ucx/pml_ucx.c ompi_pml_ucx.num_disconnect, ompi_pml_ucx.ucp_worker); ompi_pml_ucx 492 ompi/mca/pml/ucx/pml_ucx.c &ompi_pml_ucx.datatype_attr_keyval, NULL, 0, ompi_pml_ucx 499 ompi/mca/pml/ucx/pml_ucx.c PML_UCX_FREELIST_INIT(&ompi_pml_ucx.persistent_reqs, ompi_pml_ucx 502 ompi/mca/pml/ucx/pml_ucx.c PML_UCX_FREELIST_INIT(&ompi_pml_ucx.convs, ompi_pml_ucx 510 ompi/mca/pml/ucx/pml_ucx.c ucp_worker_progress(ompi_pml_ucx.ucp_worker); ompi_pml_ucx 530 ompi/mca/pml/ucx/pml_ucx.c req = (mca_pml_ucx_persistent_request_t *)PML_UCX_FREELIST_GET(&ompi_pml_ucx.persistent_reqs); ompi_pml_ucx 562 ompi/mca/pml/ucx/pml_ucx.c req = (ompi_request_t*)ucp_tag_recv_nb(ompi_pml_ucx.ucp_worker, buf, count, ompi_pml_ucx 591 ompi/mca/pml/ucx/pml_ucx.c status = ucp_tag_recv_nbr(ompi_pml_ucx.ucp_worker, buf, count, ompi_pml_ucx 595 ompi/mca/pml/ucx/pml_ucx.c MCA_COMMON_UCX_PROGRESS_LOOP(ompi_pml_ucx.ucp_worker) { ompi_pml_ucx 632 ompi/mca/pml/ucx/pml_ucx.c req = (mca_pml_ucx_persistent_request_t *)PML_UCX_FREELIST_GET(&ompi_pml_ucx.persistent_reqs); ompi_pml_ucx 767 ompi/mca/pml/ucx/pml_ucx.c *request = &ompi_pml_ucx.completed_send_req; ompi_pml_ucx 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)); ompi_pml_ucx 818 ompi/mca/pml/ucx/pml_ucx.c MCA_COMMON_UCX_WAIT_LOOP(req, ompi_pml_ucx.ucp_worker, "ucx send", (void)0); ompi_pml_ucx 863 ompi/mca/pml/ucx/pml_ucx.c ucp_msg = ucp_tag_probe_nb(ompi_pml_ucx.ucp_worker, ucp_tag, ucp_tag_mask, ompi_pml_ucx 870 ompi/mca/pml/ucx/pml_ucx.c (void)ucp_worker_progress(ompi_pml_ucx.ucp_worker) : opal_progress(); ompi_pml_ucx 887 ompi/mca/pml/ucx/pml_ucx.c MCA_COMMON_UCX_PROGRESS_LOOP(ompi_pml_ucx.ucp_worker) { ompi_pml_ucx 888 ompi/mca/pml/ucx/pml_ucx.c ucp_msg = ucp_tag_probe_nb(ompi_pml_ucx.ucp_worker, ucp_tag, ompi_pml_ucx 910 ompi/mca/pml/ucx/pml_ucx.c ucp_msg = ucp_tag_probe_nb(ompi_pml_ucx.ucp_worker, ucp_tag, ucp_tag_mask, ompi_pml_ucx 919 ompi/mca/pml/ucx/pml_ucx.c (void)ucp_worker_progress(ompi_pml_ucx.ucp_worker) : opal_progress(); ompi_pml_ucx 936 ompi/mca/pml/ucx/pml_ucx.c MCA_COMMON_UCX_PROGRESS_LOOP(ompi_pml_ucx.ucp_worker) { ompi_pml_ucx 937 ompi/mca/pml/ucx/pml_ucx.c ucp_msg = ucp_tag_probe_nb(ompi_pml_ucx.ucp_worker, ucp_tag, ucp_tag_mask, ompi_pml_ucx 956 ompi/mca/pml/ucx/pml_ucx.c req = (ompi_request_t*)ucp_tag_msg_recv_nb(ompi_pml_ucx.ucp_worker, buf, count, ompi_pml_ucx 979 ompi/mca/pml/ucx/pml_ucx.c req = (ompi_request_t*)ucp_tag_msg_recv_nb(ompi_pml_ucx.ucp_worker, buf, count, ompi_pml_ucx 1023 ompi/mca/pml/ucx/pml_ucx.c tmp_req = (ompi_request_t*)ucp_tag_recv_nb(ompi_pml_ucx.ucp_worker, ompi_pml_ucx 63 ompi/mca/pml/ucx/pml_ucx.h extern mca_pml_ucx_module_t ompi_pml_ucx; ompi_pml_ucx 52 ompi/mca/pml/ucx/pml_ucx_component.c ompi_pml_ucx.priority = 51; ompi_pml_ucx 58 ompi/mca/pml/ucx/pml_ucx_component.c &ompi_pml_ucx.priority); ompi_pml_ucx 60 ompi/mca/pml/ucx/pml_ucx_component.c ompi_pml_ucx.num_disconnect = 1; ompi_pml_ucx 66 ompi/mca/pml/ucx/pml_ucx_component.c &ompi_pml_ucx.num_disconnect); ompi_pml_ucx 101 ompi/mca/pml/ucx/pml_ucx_component.c *priority = ompi_pml_ucx.priority; ompi_pml_ucx 102 ompi/mca/pml/ucx/pml_ucx_component.c return &ompi_pml_ucx.super; ompi_pml_ucx 24 ompi/mca/pml/ucx/pml_ucx_datatype.c convertor = (mca_pml_ucx_convertor_t *)PML_UCX_FREELIST_GET(&ompi_pml_ucx.convs); ompi_pml_ucx 40 ompi/mca/pml/ucx/pml_ucx_datatype.c convertor = (mca_pml_ucx_convertor_t *)PML_UCX_FREELIST_GET(&ompi_pml_ucx.convs); ompi_pml_ucx 119 ompi/mca/pml/ucx/pml_ucx_datatype.c PML_UCX_FREELIST_RETURN(&ompi_pml_ucx.convs, &convertor->super); ompi_pml_ucx 177 ompi/mca/pml/ucx/pml_ucx_datatype.c ompi_pml_ucx.predefined_types[datatype->id] = ucp_datatype; ompi_pml_ucx 180 ompi/mca/pml/ucx/pml_ucx_datatype.c ompi_pml_ucx.datatype_attr_keyval, ompi_pml_ucx 33 ompi/mca/pml/ucx/pml_ucx_request.c ucp_request_cancel(ompi_pml_ucx.ucp_worker, req); ompi_pml_ucx 181 ompi/mca/pml/ucx/pml_ucx_request.c PML_UCX_FREELIST_RETURN(&ompi_pml_ucx.persistent_reqs, &preq->ompi.super); ompi_pml_ucx 191 ompi/mca/pml/ucx/pml_ucx_request.c ucp_request_cancel(ompi_pml_ucx.ucp_worker, preq->tmp_req);