mq 95 ompi/mca/mtl/psm/mtl_psm.c psm_mq_t mq; mq 167 ompi/mca/mtl/psm/mtl_psm.c &mq); mq 177 ompi/mca/mtl/psm/mtl_psm.c ompi_mtl_psm.mq = mq; mq 202 ompi/mca/mtl/psm/mtl_psm.c err = psm_mq_finalize(ompi_mtl_psm.mq); mq 422 ompi/mca/mtl/psm/mtl_psm.c err = psm_mq_ipeek(ompi_mtl_psm.mq, &req, NULL); mq 42 ompi/mca/mtl/psm/mtl_psm_probe.c err = psm_mq_iprobe(ompi_mtl_psm.mq, mqtag, tagsel, &mqstat); mq 69 ompi/mca/mtl/psm/mtl_psm_recv.c err = psm_mq_irecv(ompi_mtl_psm.mq, mq 76 ompi/mca/mtl/psm/mtl_psm_send.c err = psm_mq_send(ompi_mtl_psm.mq, mq 136 ompi/mca/mtl/psm/mtl_psm_send.c psm_error = psm_mq_isend(ompi_mtl_psm.mq, mq 59 ompi/mca/mtl/psm/mtl_psm_types.h psm_mq_t mq; mq 95 ompi/mca/mtl/psm2/mtl_psm2.c psm2_mq_t mq; mq 150 ompi/mca/mtl/psm2/mtl_psm2.c &mq); mq 160 ompi/mca/mtl/psm2/mtl_psm2.c ompi_mtl_psm2.mq = mq; mq 190 ompi/mca/mtl/psm2/mtl_psm2.c err = psm2_mq_finalize(ompi_mtl_psm2.mq); mq 410 ompi/mca/mtl/psm2/mtl_psm2.c err = psm2_mq_ipeek2(ompi_mtl_psm2.mq, &req, NULL); mq 44 ompi/mca/mtl/psm2/mtl_psm2_probe.c err = psm2_mq_iprobe2(ompi_mtl_psm2.mq, mq 93 ompi/mca/mtl/psm2/mtl_psm2_probe.c err = psm2_mq_improbe2(ompi_mtl_psm2.mq, mq 68 ompi/mca/mtl/psm2/mtl_psm2_recv.c err = psm2_mq_irecv2(ompi_mtl_psm2.mq, mq 124 ompi/mca/mtl/psm2/mtl_psm2_recv.c err = psm2_mq_imrecv(ompi_mtl_psm2.mq, 0, mq 74 ompi/mca/mtl/psm2/mtl_psm2_send.c err = psm2_mq_send2(ompi_mtl_psm2.mq, mq 133 ompi/mca/mtl/psm2/mtl_psm2_send.c psm2_error = psm2_mq_isend2(ompi_mtl_psm2.mq, mq 74 ompi/mca/mtl/psm2/mtl_psm2_stats.c psm2_mq_get_stats(ompi_mtl_psm2.mq, &stats); mq 50 ompi/mca/mtl/psm2/mtl_psm2_types.h psm2_mq_t mq; mq 302 ompi/mca/pml/yalla/pml_yalla.c mxm_mq_h mq; mq 304 ompi/mca/pml/yalla/pml_yalla.c error = mxm_mq_create(ompi_pml_yalla.mxm_context, comm->c_contextid, &mq); mq 309 ompi/mca/pml/yalla/pml_yalla.c comm->c_pml_comm = (void*)mq; mq 317 ompi/mca/pml/yalla/pml_yalla.c mxm_mq_h mq = (void*)comm->c_pml_comm; mq 326 ompi/mca/pml/yalla/pml_yalla.c mxm_mq_destroy(mq); mq 431 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.mq = mxm_sreq->base.mq; mq 118 ompi/mca/pml/yalla/pml_yalla_request.c mxm_req_base->mq = NULL; mq 77 ompi/mca/pml/yalla/pml_yalla_request.h (_req_base)->mq = (mxm_mq_h)(_comm)->c_pml_comm; \ mq 53 opal/mca/pmix/pmix4x/pmix/examples/alloc.c myquery_data_t *mq = (myquery_data_t*)cbdata; mq 62 opal/mca/pmix/pmix4x/pmix/examples/alloc.c PMIX_INFO_CREATE(mq->info, ninfo); mq 63 opal/mca/pmix/pmix4x/pmix/examples/alloc.c mq->ninfo = ninfo; mq 66 opal/mca/pmix/pmix4x/pmix/examples/alloc.c PMIX_INFO_XFER(&mq->info[n], &info[n]); mq 71 opal/mca/pmix/pmix4x/pmix/examples/alloc.c mq->lock.status = status; mq 80 opal/mca/pmix/pmix4x/pmix/examples/alloc.c DEBUG_WAKEUP_THREAD(&mq->lock); mq 103 opal/mca/pmix/pmix4x/pmix/examples/debugger.c myquery_data_t *mq = (myquery_data_t*)cbdata; mq 110 opal/mca/pmix/pmix4x/pmix/examples/debugger.c PMIX_INFO_CREATE(mq->info, ninfo); mq 111 opal/mca/pmix/pmix4x/pmix/examples/debugger.c mq->ninfo = ninfo; mq 114 opal/mca/pmix/pmix4x/pmix/examples/debugger.c PMIX_INFO_XFER(&mq->info[n], &info[n]); mq 125 opal/mca/pmix/pmix4x/pmix/examples/debugger.c DEBUG_WAKEUP_THREAD(&mq->lock); mq 64 opal/mca/pmix/pmix4x/pmix/examples/debuggerd.c myquery_data_t *mq = (myquery_data_t*)cbdata; mq 70 opal/mca/pmix/pmix4x/pmix/examples/debuggerd.c PMIX_INFO_CREATE(mq->info, ninfo); mq 71 opal/mca/pmix/pmix4x/pmix/examples/debuggerd.c mq->ninfo = ninfo; mq 74 opal/mca/pmix/pmix4x/pmix/examples/debuggerd.c PMIX_INFO_XFER(&mq->info[n], &info[n]); mq 84 opal/mca/pmix/pmix4x/pmix/examples/debuggerd.c mq->active = false; mq 40 opal/mca/pmix/pmix4x/pmix/examples/tool.c myquery_data_t *mq = (myquery_data_t*)cbdata; mq 43 opal/mca/pmix/pmix4x/pmix/examples/tool.c mq->lock.status = status; mq 48 opal/mca/pmix/pmix4x/pmix/examples/tool.c PMIX_INFO_CREATE(mq->info, ninfo); mq 49 opal/mca/pmix/pmix4x/pmix/examples/tool.c mq->ninfo = ninfo; mq 51 opal/mca/pmix/pmix4x/pmix/examples/tool.c PMIX_INFO_XFER(&mq->info[n], &info[n]); mq 61 opal/mca/pmix/pmix4x/pmix/examples/tool.c DEBUG_WAKEUP_THREAD(&mq->lock); mq 80 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c myquery_data_t *mq = (myquery_data_t*)cbdata; mq 83 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c mq->status = status; mq 88 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c PMIX_INFO_CREATE(mq->info, ninfo); mq 89 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c mq->ninfo = ninfo; mq 91 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c PMIX_INFO_XFER(&mq->info[n], &info[n]); mq 102 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c PMIX_WAKEUP_THREAD(&mq->lock); mq 275 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c myquery_data_t mq; mq 451 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c PMIX_CONSTRUCT_LOCK(&mq.lock); mq 452 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c rc = PMIx_Query_info_nb(&query, 1, cbfunc,(void*)&mq); mq 457 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c PMIX_WAIT_THREAD(&mq.lock); mq 458 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c PMIX_DESTRUCT_LOCK(&mq.lock); mq 459 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c if (PMIX_SUCCESS != mq.status) { mq 460 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c fprintf(stderr, "PMIx_Query returned: %s\n", PMIx_Error_string(mq.status)); mq 463 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c for (n=0; n < mq.ninfo; n++) { mq 464 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c if (PMIX_CHECK_KEY(&mq.info[n], PMIX_HOST_FUNCTIONS)) { mq 465 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c fns = pmix_argv_split(mq.info[n].value.data.string, ','); mq 473 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c if (PMIX_DATA_ARRAY == mq.info[n].value.type) { mq 474 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c info = (pmix_info_t*)mq.info[n].value.data.darray->array; mq 475 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c for (m=0; m < mq.info[n].value.data.darray->size; m++) { mq 480 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c reg = (pmix_regattr_t*)mq.info[n].value.data.ptr; mq 481 opal/mca/pmix/pmix4x/pmix/src/tools/pattrs/pattrs.c pmix_attributes_print_attrs(&ans, mq.info[n].key, reg, 1); mq 177 opal/mca/pmix/pmix4x/pmix/src/tools/pps/pps.c myquery_data_t *mq = (myquery_data_t*)cbdata; mq 184 opal/mca/pmix/pmix4x/pmix/src/tools/pps/pps.c PMIX_INFO_CREATE(mq->info, ninfo); mq 185 opal/mca/pmix/pmix4x/pmix/src/tools/pps/pps.c mq->ninfo = ninfo; mq 188 opal/mca/pmix/pmix4x/pmix/src/tools/pps/pps.c PMIX_INFO_XFER(&mq->info[n], &info[n]); mq 199 opal/mca/pmix/pmix4x/pmix/src/tools/pps/pps.c PMIX_WAKEUP_THREAD(&mq->lock.lock); mq 112 oshmem/mca/atomic/mxm/atomic_mxm.h sreq->base.mq = mca_atomic_mxm_spml_self->mxm_mq; mq 609 oshmem/mca/spml/ikrit/spml_ikrit.c sreq->base.mq = mca_spml_ikrit.mxm_mq; mq 749 oshmem/mca/spml/ikrit/spml_ikrit.c fence_req->mxm_req.base.mq = mca_spml_ikrit.mxm_mq; mq 842 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.base.mq = mca_spml_ikrit.mxm_mq; mq 927 oshmem/mca/spml/ikrit/spml_ikrit.c mxm_req.base.mq = mca_spml_ikrit.mxm_mq; mq 1048 oshmem/mca/spml/ikrit/spml_ikrit.c req.base.mq = mca_spml_ikrit.mxm_mq; mq 1089 oshmem/mca/spml/ikrit/spml_ikrit.c req.base.mq = mca_spml_ikrit.mxm_mq;