context_id 597 ompi/debuggers/ompi_msgq_dll.c int i, commcount = 0, context_id; context_id 656 ompi/debuggers/ompi_msgq_dll.c context_id = ompi_fetch_int( proc, context_id 660 ompi/debuggers/ompi_msgq_dll.c old = find_communicator(p_info, context_id); context_id 669 ompi/debuggers/ompi_msgq_dll.c old->comm_info.unique_id = context_id; context_id 676 ompi/debuggers/ompi_msgq_dll.c (long)old, context_id, local_rank)); context_id 81 opal/mca/btl/ofi/btl_ofi.h int32_t context_id; context_id 195 opal/mca/btl/ofi/btl_ofi.h int context_id; context_id 157 opal/mca/btl/ofi/btl_ofi_context.c context->context_id = 0; context_id 296 opal/mca/btl/ofi/btl_ofi_context.c contexts[i].context_id = i; context_id 283 opal/mca/btl/uct/btl_uct_am.c static inline size_t mca_btl_uct_max_sendi (mca_btl_uct_module_t *uct_btl, int context_id) context_id 285 opal/mca/btl/uct/btl_uct_am.c return MCA_BTL_UCT_TL_ATTR(uct_btl->am_tl, context_id).cap.am.max_bcopy; context_id 303 opal/mca/btl/uct/btl_uct_am.c if (OPAL_UNLIKELY(OPAL_SUCCESS != rc || msg_size > mca_btl_uct_max_sendi (uct_btl, context->context_id))) { context_id 316 opal/mca/btl/uct/btl_uct_am.c } else if (msg_size < (size_t) MCA_BTL_UCT_TL_ATTR(uct_btl->am_tl, context->context_id).cap.am.max_short) { context_id 26 opal/mca/btl/uct/btl_uct_device_context.h mca_btl_uct_device_context_t *mca_btl_uct_context_create (mca_btl_uct_module_t *module, mca_btl_uct_tl_t *tl, int context_id, bool enable_progress); context_id 63 opal/mca/btl/uct/btl_uct_device_context.h int context_id; context_id 69 opal/mca/btl/uct/btl_uct_device_context.h context_id = uct_index; context_id 70 opal/mca/btl/uct/btl_uct_device_context.h if (OPAL_UNLIKELY(-1 == context_id)) { context_id 71 opal/mca/btl/uct/btl_uct_device_context.h context_id = uct_index = opal_atomic_fetch_add_32 ((opal_atomic_int32_t *) &next_uct_index, 1) % context_id 78 opal/mca/btl/uct/btl_uct_device_context.h context_id = next_uct_index++ % mca_btl_uct_component.num_contexts_per_module; context_id 83 opal/mca/btl/uct/btl_uct_device_context.h return context_id; context_id 87 opal/mca/btl/uct/btl_uct_device_context.h mca_btl_uct_module_get_tl_context_specific (mca_btl_uct_module_t *module, mca_btl_uct_tl_t *tl, int context_id) context_id 89 opal/mca/btl/uct/btl_uct_device_context.h mca_btl_uct_device_context_t *context = tl->uct_dev_contexts[context_id]; context_id 93 opal/mca/btl/uct/btl_uct_device_context.h context = tl->uct_dev_contexts[context_id]; context_id 95 opal/mca/btl/uct/btl_uct_device_context.h context = tl->uct_dev_contexts[context_id] = mca_btl_uct_context_create (module, tl, context_id, true); context_id 108 opal/mca/btl/uct/btl_uct_device_context.h static inline mca_btl_uct_device_context_t *mca_btl_uct_module_get_rdma_context_specific (mca_btl_uct_module_t *module, int context_id) context_id 110 opal/mca/btl/uct/btl_uct_device_context.h return mca_btl_uct_module_get_tl_context_specific (module, module->rdma_tl, context_id); context_id 137 opal/mca/btl/uct/btl_uct_endpoint.c device_addr = (uct_device_addr_t *) ((uintptr_t) iface_addr + MCA_BTL_UCT_TL_ATTR(tl, tl_context->context_id).iface_addr_len); context_id 188 opal/mca/btl/uct/btl_uct_endpoint.c request->context_id, request->type, request_length)); context_id 238 opal/mca/btl/uct/btl_uct_endpoint.c size_t request_length = sizeof (mca_btl_uct_conn_req_t) + MCA_BTL_UCT_TL_ATTR(tl, tl_context->context_id).ep_addr_len; context_id 280 opal/mca/btl/uct/btl_uct_endpoint.c request->context_id = tl_context->context_id; context_id 299 opal/mca/btl/uct/btl_uct_endpoint.c tl->uct_tl_name, tl_context->context_id, ep_addr)); context_id 331 opal/mca/btl/uct/btl_uct_endpoint.c int mca_btl_uct_endpoint_connect (mca_btl_uct_module_t *uct_btl, mca_btl_uct_endpoint_t *endpoint, int context_id, context_id 334 opal/mca/btl/uct/btl_uct_endpoint.c mca_btl_uct_tl_endpoint_t *tl_endpoint = endpoint->uct_eps[context_id] + tl_index; context_id 337 opal/mca/btl/uct/btl_uct_endpoint.c mca_btl_uct_device_context_t *tl_context = mca_btl_uct_module_get_tl_context_specific (uct_btl, tl, context_id); context_id 352 opal/mca/btl/uct/btl_uct_endpoint.c BTL_VERBOSE(("checking endpoint %p with context id %d. cached uct ep: %p, ready: %d", (void *) endpoint, context_id, context_id 38 opal/mca/btl/uct/btl_uct_endpoint.h int ep_index = context->context_id; context_id 65 opal/mca/btl/uct/btl_uct_endpoint.h int ep_index = context->context_id; context_id 101 opal/mca/btl/uct/btl_uct_rdma.c if (size <= MCA_BTL_UCT_TL_ATTR(uct_btl->rdma_tl, context->context_id).cap.get.max_bcopy) { context_id 190 opal/mca/btl/uct/btl_uct_rdma.c use_short = size <= MCA_BTL_UCT_TL_ATTR(uct_btl->rdma_tl, context->context_id).cap.put.max_short; context_id 267 opal/mca/btl/uct/btl_uct_rdma.c if (NULL != endpoint && endpoint->uct_eps[context->context_id][tl_index].uct_ep) { context_id 268 opal/mca/btl/uct/btl_uct_rdma.c ucs_status = uct_ep_flush (endpoint->uct_eps[context->context_id][tl_index].uct_ep, 0, NULL); context_id 284 opal/mca/btl/uct/btl_uct_rdma.c const int context_id = mca_btl_uct_get_context_index (); context_id 285 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_device_context_t *context = uct_btl->rdma_tl->uct_dev_contexts[context_id]; context_id 150 opal/mca/btl/uct/btl_uct_tl.c for (int context_id = 0 ; context_id < MCA_BTL_UCT_MAX_WORKERS ; ++context_id) { context_id 151 opal/mca/btl/uct/btl_uct_tl.c if (NULL != tl->uct_dev_contexts[context_id]) { context_id 152 opal/mca/btl/uct/btl_uct_tl.c mca_btl_uct_context_destroy (tl->uct_dev_contexts[context_id]); context_id 193 opal/mca/btl/uct/btl_uct_tl.c mca_btl_uct_tl_endpoint_t *tl_endpoint = endpoint->uct_eps[req->context_id] + req->tl_index; context_id 198 opal/mca/btl/uct/btl_uct_tl.c (void *) endpoint, req->type, req->context_id)); context_id 211 opal/mca/btl/uct/btl_uct_tl.c rc = mca_btl_uct_endpoint_connect (module, endpoint, req->context_id, req->ep_addr, req->tl_index); context_id 232 opal/mca/btl/uct/btl_uct_tl.c if (frag->context->context_id == req->context_id && endpoint == frag->endpoint) { context_id 272 opal/mca/btl/uct/btl_uct_tl.c mca_btl_uct_device_context_t *mca_btl_uct_context_create (mca_btl_uct_module_t *module, mca_btl_uct_tl_t *tl, int context_id, bool enable_progress) context_id 295 opal/mca/btl/uct/btl_uct_tl.c context->context_id = context_id; context_id 337 opal/mca/btl/uct/btl_uct_tl.c if (context_id > 0 && tl == module->am_tl) { context_id 338 opal/mca/btl/uct/btl_uct_tl.c BTL_VERBOSE(("installing AM handler for tl %p context id %d", (void *) tl, context_id)); context_id 344 opal/mca/btl/uct/btl_uct_tl.c BTL_VERBOSE(("enabling progress for tl %p context id %d", (void *) tl, context_id)); context_id 84 opal/mca/btl/uct/btl_uct_types.h int context_id; context_id 133 opal/mca/btl/uct/btl_uct_types.h int context_id; context_id 333 opal/mca/btl/uct/btl_uct_types.h #define MCA_BTL_UCT_TL_ATTR(tl, context_id) (tl)->uct_dev_contexts[(context_id)]->uct_iface_attr