rcv 434 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_ptl_posted_recv_t *rcv; rcv 476 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c rcv = PMIX_NEW(pmix_ptl_posted_recv_t); rcv 477 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c rcv->tag = PMIX_PTL_TAG_IOF; rcv 478 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c rcv->cbfunc = client_iof_handler; rcv 480 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_list_append(&pmix_ptl_globals.posted_recvs, &rcv->super); rcv 173 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_ptl_posted_recv_t *rcv; rcv 211 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c rcv = PMIX_NEW(pmix_ptl_posted_recv_t); rcv 212 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c rcv->tag = PMIX_PTL_TAG_HEARTBEAT; rcv 213 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c rcv->cbfunc = pmix_psensor_heartbeat_recv_beats; rcv 215 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_list_prepend(&pmix_ptl_globals.posted_recvs, &rcv->super); rcv 68 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_ptl_posted_recv_t *rcv; rcv 242 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_LIST_FOREACH(rcv, &pmix_ptl_globals.posted_recvs, pmix_ptl_posted_recv_t) { rcv 243 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (UINT_MAX != rcv->tag && NULL != rcv->cbfunc) { rcv 245 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c hdr.tag = rcv->tag; rcv 246 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c rcv->cbfunc(pmix_globals.mypeer, &hdr, &buf, rcv->cbdata); rcv 763 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_ptl_posted_recv_t *rcv; rcv 775 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_LIST_FOREACH(rcv, &pmix_ptl_globals.posted_recvs, pmix_ptl_posted_recv_t) { rcv 778 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c msg->hdr.tag, rcv->tag); rcv 780 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (msg->hdr.tag == rcv->tag || UINT_MAX == rcv->tag) { rcv 781 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (NULL != rcv->cbfunc) { rcv 796 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c rcv->cbfunc(msg->peer, &msg->hdr, &buf, rcv->cbdata); rcv 803 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (PMIX_PTL_TAG_DYNAMIC <= rcv->tag && UINT_MAX != rcv->tag) { rcv 804 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_list_remove_item(&pmix_ptl_globals.posted_recvs, &rcv->super); rcv 805 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_RELEASE(rcv); rcv 183 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_ptl_posted_recv_t *rcv; rcv 185 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c PMIX_LIST_FOREACH(rcv, &pmix_ptl_globals.posted_recvs, pmix_ptl_posted_recv_t) { rcv 186 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c if (rcv->tag == req->tag) { rcv 187 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_list_remove_item(&pmix_ptl_globals.posted_recvs, &rcv->super); rcv 188 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c PMIX_RELEASE(rcv); rcv 270 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_ptl_posted_recv_t *rcv; rcv 443 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c rcv = PMIX_NEW(pmix_ptl_posted_recv_t); rcv 444 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c rcv->tag = PMIX_PTL_TAG_IOF; rcv 445 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c rcv->cbfunc = tool_iof_handler; rcv 447 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_list_append(&pmix_ptl_globals.posted_recvs, &rcv->super); rcv 613 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c rcv = PMIX_NEW(pmix_ptl_posted_recv_t); rcv 614 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c rcv->tag = UINT32_MAX; rcv 615 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c rcv->cbfunc = pmix_server_message_handler; rcv 617 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_list_append(&pmix_ptl_globals.posted_recvs, &rcv->super); rcv 55 orte/mca/rml/base/rml_base_msg_handlers.c static void msg_match_recv(orte_rml_posted_recv_t *rcv, bool get_all); rcv 126 orte/mca/rml/base/rml_base_msg_handlers.c static void msg_match_recv(orte_rml_posted_recv_t *rcv, bool get_all) rcv 143 orte/mca/rml/base/rml_base_msg_handlers.c ORTE_NAME_PRINT(&rcv->peer), rcv 149 orte/mca/rml/base/rml_base_msg_handlers.c if (OPAL_EQUAL == orte_util_compare_name_fields(mask, &msg->sender, &rcv->peer) && rcv 150 orte/mca/rml/base/rml_base_msg_handlers.c msg->tag == rcv->tag) { rcv 80 orte/mca/rml/oob/rml_oob_send.c orte_rml_recv_t *rcv; rcv 138 orte/mca/rml/oob/rml_oob_send.c rcv = OBJ_NEW(orte_rml_recv_t); rcv 139 orte/mca/rml/oob/rml_oob_send.c rcv->sender = *peer; rcv 140 orte/mca/rml/oob/rml_oob_send.c rcv->tag = tag; rcv 148 orte/mca/rml/oob/rml_oob_send.c rcv->iov.iov_base = (IOVBASE_TYPE*)malloc(bytes); rcv 149 orte/mca/rml/oob/rml_oob_send.c rcv->iov.iov_len = bytes; rcv 151 orte/mca/rml/oob/rml_oob_send.c ptr = (char*)rcv->iov.iov_base; rcv 160 orte/mca/rml/oob/rml_oob_send.c ORTE_RML_ACTIVATE_MESSAGE(rcv); rcv 185 orte/mca/rml/oob/rml_oob_send.c orte_rml_recv_t *rcv; rcv 239 orte/mca/rml/oob/rml_oob_send.c rcv = OBJ_NEW(orte_rml_recv_t); rcv 240 orte/mca/rml/oob/rml_oob_send.c rcv->sender = *peer; rcv 241 orte/mca/rml/oob/rml_oob_send.c rcv->tag = tag; rcv 242 orte/mca/rml/oob/rml_oob_send.c rcv->iov.iov_base = (IOVBASE_TYPE*)malloc(buffer->bytes_used); rcv 243 orte/mca/rml/oob/rml_oob_send.c memcpy(rcv->iov.iov_base, buffer->base_ptr, buffer->bytes_used); rcv 244 orte/mca/rml/oob/rml_oob_send.c rcv->iov.iov_len = buffer->bytes_used; rcv 248 orte/mca/rml/oob/rml_oob_send.c ORTE_RML_ACTIVATE_MESSAGE(rcv);