recv_msg          186 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c     p->recv_msg = NULL;
recv_msg          214 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c     if (NULL != p->recv_msg) {
recv_msg          215 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c         PMIX_RELEASE(p->recv_msg);
recv_msg          255 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h     pmix_ptl_recv_t *recv_msg;      /**< current recv in progress */
recv_msg           83 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c     if (NULL != peer->recv_msg) {
recv_msg           84 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c         PMIX_RELEASE(peer->recv_msg);
recv_msg           85 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c         peer->recv_msg = NULL;
recv_msg          486 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c     if (NULL == peer->recv_msg) {
recv_msg          489 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c         peer->recv_msg = PMIX_NEW(pmix_ptl_recv_t);
recv_msg          490 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c         if (NULL == peer->recv_msg) {
recv_msg          495 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c         peer->recv_msg->peer = peer;  // provide a handle back to the peer object
recv_msg          497 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c         peer->recv_msg->rdptr = (char*)&peer->recv_msg->hdr;
recv_msg          498 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c         peer->recv_msg->rdbytes = sizeof(pmix_ptl_hdr_t);
recv_msg          500 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c     msg = peer->recv_msg;
recv_msg          510 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c             peer->recv_msg->hdr_recvd = true;
recv_msg          512 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c             peer->recv_msg->hdr.pindex = ntohl(hdr.pindex);
recv_msg          513 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c             peer->recv_msg->hdr.tag = ntohl(hdr.tag);
recv_msg          514 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c             peer->recv_msg->hdr.nbytes = ntohl(hdr.nbytes);
recv_msg          517 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                                 (int)peer->recv_msg->hdr.tag,
recv_msg          518 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                                 (int)peer->recv_msg->hdr.nbytes);
recv_msg          520 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c             if (0 == peer->recv_msg->hdr.nbytes) {
recv_msg          524 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                                     peer->recv_msg->hdr.tag);
recv_msg          525 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                 peer->recv_msg->data = NULL;  // make sure
recv_msg          526 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                 peer->recv_msg->rdptr = NULL;
recv_msg          527 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                 peer->recv_msg->rdbytes = 0;
recv_msg          529 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                 PMIX_ACTIVATE_POST_MSG(peer->recv_msg);
recv_msg          530 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                 peer->recv_msg = NULL;
recv_msg          536 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                                     (unsigned long)peer->recv_msg->hdr.nbytes);
recv_msg          538 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                 if (pmix_ptl_globals.max_msg_size < peer->recv_msg->hdr.nbytes) {
recv_msg          540 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                                    (unsigned long)peer->recv_msg->hdr.nbytes,
recv_msg          544 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                 peer->recv_msg->data = (char*)malloc(peer->recv_msg->hdr.nbytes);
recv_msg          545 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                 memset(peer->recv_msg->data, 0, peer->recv_msg->hdr.nbytes);
recv_msg          547 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                 peer->recv_msg->rdptr = peer->recv_msg->data;
recv_msg          548 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                 peer->recv_msg->rdbytes = peer->recv_msg->hdr.nbytes;
recv_msg          566 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c     if (peer->recv_msg->hdr_recvd) {
recv_msg          576 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                                 (int)peer->recv_msg->hdr.nbytes,
recv_msg          577 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c                                 peer->recv_msg->hdr.tag, peer->sd);
recv_msg          579 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c             PMIX_ACTIVATE_POST_MSG(peer->recv_msg);
recv_msg          580 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c             peer->recv_msg = NULL;
recv_msg          616 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c     if (NULL != peer->recv_msg) {
recv_msg          617 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c         PMIX_RELEASE(peer->recv_msg);
recv_msg          618 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c         peer->recv_msg = NULL;
recv_msg          707 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c     if (NULL == peer->recv_msg) {
recv_msg          710 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c         peer->recv_msg = PMIX_NEW(pmix_ptl_recv_t);
recv_msg          711 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c         if (NULL == peer->recv_msg) {
recv_msg          716 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c         peer->recv_msg->peer = peer;  // provide a handle back to the peer object
recv_msg          718 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c         peer->recv_msg->rdptr = (char*)&peer->recv_msg->hdr;
recv_msg          719 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c         peer->recv_msg->rdbytes = sizeof(pmix_usock_hdr_t);
recv_msg          721 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c     msg = peer->recv_msg;
recv_msg          729 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c             peer->recv_msg->hdr_recvd = true;
recv_msg          732 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                                 (int)peer->recv_msg->hdr.tag,
recv_msg          733 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                                 (int)peer->recv_msg->hdr.nbytes);
recv_msg          735 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c             if (0 == peer->recv_msg->hdr.nbytes) {
recv_msg          739 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                                     peer->recv_msg->hdr.tag);
recv_msg          740 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                 peer->recv_msg->data = NULL;  // make sure
recv_msg          741 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                 peer->recv_msg->rdptr = NULL;
recv_msg          742 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                 peer->recv_msg->rdbytes = 0;
recv_msg          744 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                 PMIX_ACTIVATE_POST_MSG(peer->recv_msg);
recv_msg          745 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                 peer->recv_msg = NULL;
recv_msg          751 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                                     (unsigned long)peer->recv_msg->hdr.nbytes);
recv_msg          753 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                 peer->recv_msg->data = (char*)malloc(peer->recv_msg->hdr.nbytes);
recv_msg          754 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                 memset(peer->recv_msg->data, 0, peer->recv_msg->hdr.nbytes);
recv_msg          756 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                 peer->recv_msg->rdptr = peer->recv_msg->data;
recv_msg          757 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                 peer->recv_msg->rdbytes = peer->recv_msg->hdr.nbytes;
recv_msg          774 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c     if (peer->recv_msg->hdr_recvd) {
recv_msg          783 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                                 (int)peer->recv_msg->hdr.nbytes,
recv_msg          784 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c                                 peer->recv_msg->hdr.tag, peer->sd);
recv_msg          786 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c             PMIX_ACTIVATE_POST_MSG(peer->recv_msg);
recv_msg          787 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c             peer->recv_msg = NULL;
recv_msg          821 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c     if (NULL != peer->recv_msg) {
recv_msg          822 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c         PMIX_RELEASE(peer->recv_msg);
recv_msg          823 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c         peer->recv_msg = NULL;
recv_msg         1339 orte/mca/oob/tcp/oob_tcp_component.c     peer->recv_msg = NULL;
recv_msg           64 orte/mca/oob/tcp/oob_tcp_peer.h     mca_oob_tcp_recv_t *recv_msg; /**< current recv in progress */
recv_msg          351 orte/mca/oob/tcp/oob_tcp_sendrecv.c     while (0 < peer->recv_msg->rdbytes) {
recv_msg          352 orte/mca/oob/tcp/oob_tcp_sendrecv.c         rc = read(peer->sd, peer->recv_msg->rdptr, peer->recv_msg->rdbytes);
recv_msg          405 orte/mca/oob/tcp/oob_tcp_sendrecv.c             if (NULL != peer->recv_msg) {
recv_msg          406 orte/mca/oob/tcp/oob_tcp_sendrecv.c                 OBJ_RELEASE(peer->recv_msg);
recv_msg          407 orte/mca/oob/tcp/oob_tcp_sendrecv.c                 peer->recv_msg = NULL;
recv_msg          416 orte/mca/oob/tcp/oob_tcp_sendrecv.c         peer->recv_msg->rdbytes -= rc;
recv_msg          417 orte/mca/oob/tcp/oob_tcp_sendrecv.c         peer->recv_msg->rdptr += rc;
recv_msg          487 orte/mca/oob/tcp/oob_tcp_sendrecv.c         if (NULL == peer->recv_msg) {
recv_msg          491 orte/mca/oob/tcp/oob_tcp_sendrecv.c             peer->recv_msg = OBJ_NEW(mca_oob_tcp_recv_t);
recv_msg          492 orte/mca/oob/tcp/oob_tcp_sendrecv.c             if (NULL == peer->recv_msg) {
recv_msg          499 orte/mca/oob/tcp/oob_tcp_sendrecv.c             peer->recv_msg->rdptr = (char*)&peer->recv_msg->hdr;
recv_msg          500 orte/mca/oob/tcp/oob_tcp_sendrecv.c             peer->recv_msg->rdbytes = sizeof(mca_oob_tcp_hdr_t);
recv_msg          503 orte/mca/oob/tcp/oob_tcp_sendrecv.c         if (!peer->recv_msg->hdr_recvd) {
recv_msg          509 orte/mca/oob/tcp/oob_tcp_sendrecv.c                 peer->recv_msg->hdr_recvd = true;
recv_msg          511 orte/mca/oob/tcp/oob_tcp_sendrecv.c                 MCA_OOB_TCP_HDR_NTOH(&peer->recv_msg->hdr);
recv_msg          513 orte/mca/oob/tcp/oob_tcp_sendrecv.c                 if (0 == peer->recv_msg->hdr.nbytes) {
recv_msg          517 orte/mca/oob/tcp/oob_tcp_sendrecv.c                                         ORTE_NAME_PRINT(&peer->name), peer->recv_msg->hdr.tag);
recv_msg          518 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     peer->recv_msg->data = NULL;  // make sure
recv_msg          522 orte/mca/oob/tcp/oob_tcp_sendrecv.c                                         ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), (unsigned long)peer->recv_msg->hdr.nbytes);
recv_msg          524 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     peer->recv_msg->data = (char*)malloc(peer->recv_msg->hdr.nbytes);
recv_msg          526 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     peer->recv_msg->rdptr = peer->recv_msg->data;
recv_msg          527 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     peer->recv_msg->rdbytes = peer->recv_msg->hdr.nbytes;
recv_msg          544 orte/mca/oob/tcp/oob_tcp_sendrecv.c         if (peer->recv_msg->hdr_recvd) {
recv_msg          555 orte/mca/oob/tcp/oob_tcp_sendrecv.c                                     ORTE_NAME_PRINT(&peer->recv_msg->hdr.origin),
recv_msg          556 orte/mca/oob/tcp/oob_tcp_sendrecv.c                                     (int)peer->recv_msg->hdr.nbytes,
recv_msg          557 orte/mca/oob/tcp/oob_tcp_sendrecv.c                                     ORTE_NAME_PRINT(&peer->recv_msg->hdr.dst),
recv_msg          558 orte/mca/oob/tcp/oob_tcp_sendrecv.c                                     peer->recv_msg->hdr.tag);
recv_msg          561 orte/mca/oob/tcp/oob_tcp_sendrecv.c                 if (peer->recv_msg->hdr.dst.jobid == ORTE_PROC_MY_NAME->jobid &&
recv_msg          562 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     peer->recv_msg->hdr.dst.vpid == ORTE_PROC_MY_NAME->vpid) {
recv_msg          567 orte/mca/oob/tcp/oob_tcp_sendrecv.c                                         peer->recv_msg->hdr.tag,
recv_msg          568 orte/mca/oob/tcp/oob_tcp_sendrecv.c                                         peer->recv_msg->hdr.seq_num);
recv_msg          569 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     ORTE_RML_POST_MESSAGE(&peer->recv_msg->hdr.origin,
recv_msg          570 orte/mca/oob/tcp/oob_tcp_sendrecv.c                                           peer->recv_msg->hdr.tag,
recv_msg          571 orte/mca/oob/tcp/oob_tcp_sendrecv.c                                           peer->recv_msg->hdr.seq_num,
recv_msg          572 orte/mca/oob/tcp/oob_tcp_sendrecv.c                                           peer->recv_msg->data,
recv_msg          573 orte/mca/oob/tcp/oob_tcp_sendrecv.c                                           peer->recv_msg->hdr.nbytes);
recv_msg          574 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     OBJ_RELEASE(peer->recv_msg);
recv_msg          581 orte/mca/oob/tcp/oob_tcp_sendrecv.c                                         ORTE_NAME_PRINT(&peer->recv_msg->hdr.dst));
recv_msg          583 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     snd->dst = peer->recv_msg->hdr.dst;
recv_msg          584 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     snd->origin = peer->recv_msg->hdr.origin;
recv_msg          585 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     snd->tag = peer->recv_msg->hdr.tag;
recv_msg          586 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     snd->data = peer->recv_msg->data;
recv_msg          587 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     snd->seq_num = peer->recv_msg->hdr.seq_num;
recv_msg          588 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     snd->count = peer->recv_msg->hdr.nbytes;
recv_msg          594 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     peer->recv_msg->data = NULL;
recv_msg          596 orte/mca/oob/tcp/oob_tcp_sendrecv.c                     OBJ_RELEASE(peer->recv_msg);
recv_msg          598 orte/mca/oob/tcp/oob_tcp_sendrecv.c                 peer->recv_msg = NULL;
recv_msg          783 orte/mca/ras/slurm/ras_slurm_module.c     char recv_msg[8192];
recv_msg          800 orte/mca/ras/slurm/ras_slurm_module.c     memset(recv_msg, 0, sizeof(recv_msg));
recv_msg          801 orte/mca/ras/slurm/ras_slurm_module.c     nbytes = read(fd, recv_msg, sizeof(recv_msg) - 1);
recv_msg          805 orte/mca/ras/slurm/ras_slurm_module.c                         ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), recv_msg);
recv_msg          808 orte/mca/ras/slurm/ras_slurm_module.c     if (0 == nbytes || 0 == strlen(recv_msg) || strstr(recv_msg, "failure") != NULL) {
recv_msg          813 orte/mca/ras/slurm/ras_slurm_module.c                        (0 == strlen(recv_msg)) ? "NO MSG" : recv_msg);
recv_msg          819 orte/mca/ras/slurm/ras_slurm_module.c     alloc = opal_argv_split(recv_msg, ':');