cq 105 ompi/mca/mtl/ofi/mtl_ofi.h ret = fi_cq_read(ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq, (void *)&wc, cq 129 ompi/mca/mtl/ofi/mtl_ofi.h ret = fi_cq_readerr(ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq, cq 1270 ompi/mca/mtl/ofi/mtl_ofi.h ret = fi_cq_open(ompi_mtl_ofi.domain, &cq_attr, &ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq, NULL); cq 1277 ompi/mca/mtl/ofi/mtl_ofi.h ret = fi_ep_bind(ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep, (fid_t)ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq, cq 1284 ompi/mca/mtl/ofi/mtl_ofi.h ret = fi_ep_bind(ompi_mtl_ofi.ofi_ctxt[ctxt_id].rx_ep, (fid_t)ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq, cq 1332 ompi/mca/mtl/ofi/mtl_ofi.h if (ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq) { cq 1333 ompi/mca/mtl/ofi/mtl_ofi.h (void) fi_close((fid_t)ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq); cq 1371 ompi/mca/mtl/ofi/mtl_ofi.h if ((ret = fi_close((fid_t)ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq))) { cq 600 ompi/mca/mtl/ofi/mtl_ofi_component.c ret = fi_cq_open(ompi_mtl_ofi.domain, &cq_attr, &ompi_mtl_ofi.ofi_ctxt[0].cq, NULL); cq 607 ompi/mca/mtl/ofi/mtl_ofi_component.c ret = fi_ep_bind(ompi_mtl_ofi.sep, (fid_t)ompi_mtl_ofi.ofi_ctxt[0].cq, cq 1025 ompi/mca/mtl/ofi/mtl_ofi_component.c ompi_mtl_ofi.ofi_ctxt[0].cq) { cq 1027 ompi/mca/mtl/ofi/mtl_ofi_component.c (void) fi_close((fid_t)ompi_mtl_ofi.ofi_ctxt[0].cq); cq 1068 ompi/mca/mtl/ofi/mtl_ofi_component.c if ((ret = fi_close((fid_t)ompi_mtl_ofi.ofi_ctxt[0].cq))) { cq 29 ompi/mca/mtl/ofi/mtl_ofi_types.h struct fid_cq *cq; cq 88 opal/mca/btl/ofi/btl_ofi.h struct fid_cq *cq; cq 123 opal/mca/btl/ofi/btl_ofi_context.c rc = fi_cq_open(domain, &cq_attr, &context->cq, NULL); cq 141 opal/mca/btl/ofi/btl_ofi_context.c rc = fi_ep_bind(ep, (fid_t)context->cq, cq_flags); cq 239 opal/mca/btl/ofi/btl_ofi_context.c rc = fi_cq_open(domain, &cq_attr, &contexts[i].cq, NULL); cq 249 opal/mca/btl/ofi/btl_ofi_context.c rc = fi_ep_bind(contexts[i].tx_ctx, (fid_t)contexts[i].cq, FI_TRANSMIT); cq 260 opal/mca/btl/ofi/btl_ofi_context.c rc = fi_ep_bind(contexts[i].rx_ctx, (fid_t)contexts[i].cq, FI_RECV); cq 324 opal/mca/btl/ofi/btl_ofi_context.c if( NULL != context->cq) { cq 325 opal/mca/btl/ofi/btl_ofi_context.c fi_close(&context->cq->fid); cq 383 opal/mca/btl/ofi/btl_ofi_context.c ret = fi_cq_read(context->cq, &cq_entry, mca_btl_ofi_component.num_cqe_read); cq 436 opal/mca/btl/ofi/btl_ofi_context.c ret = fi_cq_readerr(context->cq, &cqerr, 0); cq 251 opal/mca/btl/ugni/btl_ugni_add_procs.c gni_cq_handle_t cq = 0; cq 270 opal/mca/btl/ugni/btl_ugni_add_procs.c cq = ugni_module->smsg_remote_cq; cq 273 opal/mca/btl/ugni/btl_ugni_add_procs.c rc = mca_btl_ugni_reg_mem (ugni_module, base, size, (mca_btl_ugni_reg_t *) reg, cq, flags); cq 648 opal/mca/btl/ugni/btl_ugni_component.c mca_btl_ugni_cq_t *cq) cq 653 opal/mca/btl/ugni/btl_ugni_component.c rc = mca_btl_ugni_cq_get_completed_desc (device, cq, post_desc, MCA_BTL_UGNI_COMPLETIONS_PER_LOOP); cq 96 opal/mca/btl/ugni/btl_ugni_device.h mca_btl_ugni_cq_t *cq; cq 105 opal/mca/btl/ugni/btl_ugni_device.h rc = GNI_CqGetEvent (args->cq->gni_handle, args->event_data); cq 106 opal/mca/btl/ugni/btl_ugni_device.h args->cq->active_operations -= (GNI_RC_NOT_DONE != rc); cq 112 opal/mca/btl/ugni/btl_ugni_device.h gni_cq_handle_t cq = (gni_cq_handle_t) (intptr_t) arg; cq 117 opal/mca/btl/ugni/btl_ugni_device.h rc = GNI_CqGetEvent (cq, &event_data); cq 124 opal/mca/btl/ugni/btl_ugni_device.h gni_cq_handle_t cq; cq 132 opal/mca/btl/ugni/btl_ugni_device.h return GNI_CqGetEvent (args->cq, args->event_data); cq 136 opal/mca/btl/ugni/btl_ugni_device.h mca_btl_ugni_cq_t *cq; cq 156 opal/mca/btl/ugni/btl_ugni_device.h static inline intptr_t _mca_btl_ugni_cq_get_completed_desc_device (mca_btl_ugni_device_t *device, mca_btl_ugni_cq_t *cq, cq 165 opal/mca/btl/ugni/btl_ugni_device.h for (desc_index = 0 ; desc_index < count && cq->active_operations ; ) { cq 168 opal/mca/btl/ugni/btl_ugni_device.h rc = GNI_CqGetEvent (cq->gni_handle, &event_data); cq 179 opal/mca/btl/ugni/btl_ugni_device.h rc = GNI_GetCompleted (cq->gni_handle, event_data, &desc); cq 204 opal/mca/btl/ugni/btl_ugni_device.h --cq->active_operations; cq 214 opal/mca/btl/ugni/btl_ugni_device.h return _mca_btl_ugni_cq_get_completed_desc_device (device, args->cq, args->post_desc, args->count, false); cq 321 opal/mca/btl/ugni/btl_ugni_device.h rdma_desc->btl_ugni_desc.cq = mca_btl_ugni_component.progress_thread_enabled ? &device->dev_rdma_local_irq_cq : cq 334 opal/mca/btl/ugni/btl_ugni_device.h ++rdma_desc->btl_ugni_desc.cq->active_operations; cq 425 opal/mca/btl/ugni/btl_ugni_device.h gni_cq_handle_t cq; cq 434 opal/mca/btl/ugni/btl_ugni_device.h rc = GNI_MemRegister (device->dev_handle, (uint64_t) args->base, args->size, args->cq, cq 485 opal/mca/btl/ugni/btl_ugni_device.h static inline void mca_btl_ugni_cq_clear (mca_btl_ugni_device_t *device, gni_cq_handle_t cq) cq 487 opal/mca/btl/ugni/btl_ugni_device.h (void) mca_btl_ugni_device_serialize (device, (mca_btl_ugni_device_serialize_fn_t) mca_btl_ugni_cq_clear_device, (void *) (intptr_t) cq); cq 490 opal/mca/btl/ugni/btl_ugni_device.h static inline int mca_btl_ugni_cq_get_event (mca_btl_ugni_device_t *device, mca_btl_ugni_cq_t *cq, gni_cq_entry_t *event_data) cq 492 opal/mca/btl/ugni/btl_ugni_device.h mca_btl_ugni_cq_get_event_args_t args = {.cq = cq, .event_data = event_data}; cq 500 opal/mca/btl/ugni/btl_ugni_device.h static inline int mca_btl_ugni_gni_cq_get_event (mca_btl_ugni_device_t *device, gni_cq_handle_t cq, gni_cq_entry_t *event_data) cq 502 opal/mca/btl/ugni/btl_ugni_device.h mca_btl_ugni_gni_cq_get_event_args_t args = {.cq = cq, .event_data = event_data}; cq 544 opal/mca/btl/ugni/btl_ugni_device.h static inline int mca_btl_ugni_cq_get_completed_desc (mca_btl_ugni_device_t *device, mca_btl_ugni_cq_t *cq, cq 548 opal/mca/btl/ugni/btl_ugni_device.h mca_btl_ugni_cq_get_completed_desc_arg_t args = {.cq = cq, .post_desc = post_desc, .count = count}; cq 549 opal/mca/btl/ugni/btl_ugni_device.h if (0 == cq->active_operations) { cq 564 opal/mca/btl/ugni/btl_ugni_device.h gni_cq_handle_t cq, int flags) cq 567 opal/mca/btl/ugni/btl_ugni_device.h .ugni_reg = ugni_reg, .cq = cq, .flags = flags}; cq 374 opal/mca/btl/ugni/btl_ugni_endpoint.c int mca_btl_ugni_ep_handle_init (mca_btl_ugni_endpoint_t *ep, gni_cq_handle_t cq, cq 382 opal/mca/btl/ugni/btl_ugni_endpoint.c grc = GNI_EpCreate (device->dev_handle, cq, &ep_handle->gni_handle); cq 140 opal/mca/btl/ugni/btl_ugni_endpoint.h int mca_btl_ugni_ep_handle_init (mca_btl_ugni_endpoint_t *ep, gni_cq_handle_t cq, cq 43 opal/mca/btl/ugni/btl_ugni_frag.c desc->cq = NULL; cq 94 opal/mca/btl/ugni/btl_ugni_frag.h mca_btl_ugni_cq_t *cq; cq 109 opal/mca/btl/ugni/btl_ugni_rdma.h static inline int mca_btl_ugni_post_cqwrite (mca_btl_base_endpoint_t *endpoint, mca_btl_ugni_cq_t *cq, cq 120 opal/mca/btl/ugni/btl_ugni_rdma.h post_desc.gni_desc.src_cq_hndl = cq->gni_handle; cq 122 opal/mca/btl/ugni/btl_ugni_rdma.h post_desc.cq = cq; cq 1156 opal/mca/btl/usnic/btl_usnic_component.c int ret = fi_cq_read(channel->cq, &completion, 1); cq 1259 opal/mca/btl/usnic/btl_usnic_component.c rc = fi_cq_readerr(channel->cq, &err_entry, 0); cq 1330 opal/mca/btl/usnic/btl_usnic_component.c fi_cq_read(channel->cq, completions, cq 1630 opal/mca/btl/usnic/btl_usnic_module.c rc = fi_ep_bind(channel->ep, &channel->cq->fid, FI_SEND); cq 1641 opal/mca/btl/usnic/btl_usnic_module.c rc = fi_ep_bind(channel->ep, &channel->cq->fid, FI_RECV); cq 1732 opal/mca/btl/usnic/btl_usnic_module.c if (NULL != channel->cq) { cq 1733 opal/mca/btl/usnic/btl_usnic_module.c fi_close(&channel->cq->fid); cq 1734 opal/mca/btl/usnic/btl_usnic_module.c channel->cq = NULL; cq 1746 opal/mca/btl/usnic/btl_usnic_module.c assert(NULL == channel->ep && NULL == channel->cq); cq 1790 opal/mca/btl/usnic/btl_usnic_module.c rc = fi_cq_open(module->domain, &cq_attr, &channel->cq, NULL); cq 68 opal/mca/btl/usnic/btl_usnic_module.h struct fid_cq *cq;