pnd 956 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_pending_connection_t *pnd = (pmix_pending_connection_t*)cbdata; pnd 977 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_ACQUIRE_OBJECT(pnd); pnd 981 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->sd); pnd 984 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_ptl_base_set_blocking(pnd->sd); pnd 990 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_recv_blocking(pnd->sd, (char*)&hdr, sizeof(pmix_ptl_hdr_t)))) { pnd 991 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 992 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1000 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1001 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1005 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1006 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1009 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_recv_blocking(pnd->sd, msg, hdr.nbytes))) { pnd 1013 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->sd); pnd 1015 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1016 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1050 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->len = ntohl(len); pnd 1053 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (0 < pnd->len) { pnd 1054 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->cred = (char*)malloc(pnd->len); pnd 1055 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (NULL == pnd->cred) { pnd 1058 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1059 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1062 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c memcpy(pnd->cred, mg, pnd->len); pnd 1063 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c mg += pnd->len; pnd 1064 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c cnt -= pnd->len; pnd 1069 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c memcpy(&pnd->flag, mg, 1); pnd 1079 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (0 == pnd->flag) { pnd 1106 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c } else if (1 == pnd->flag) { pnd 1114 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->uid = ntohl(u32); pnd 1125 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->gid = ntohl(u32); pnd 1132 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c } else if (2 == pnd->flag) { pnd 1140 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->uid = ntohl(u32); pnd 1151 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->gid = ntohl(u32); pnd 1158 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c } else if (3 == pnd->flag || 6 == pnd->flag) { pnd 1160 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (3 == pnd->flag) { pnd 1170 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->uid = ntohl(u32); pnd 1181 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->gid = ntohl(u32); pnd 1189 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->need_id = true; pnd 1190 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c } else if (4 == pnd->flag || 5 == pnd->flag || 7 == pnd->flag || 8 == pnd->flag) { pnd 1192 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (4 == pnd->flag || 5 == pnd->flag) { pnd 1202 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->uid = ntohl(u32); pnd 1213 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->gid = ntohl(u32); pnd 1328 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (0 != pnd->flag) { pnd 1333 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1334 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1337 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->peer = peer; pnd 1341 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (5 == pnd->flag || 8 == pnd->flag) { pnd 1384 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c info->uid = pnd->uid; pnd 1385 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c info->gid = pnd->gid; pnd 1395 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1396 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1406 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1407 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1419 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_BFROPS_UNPACK(rc, peer, &buf, &pnd->ninfo, &foo, PMIX_SIZE); pnd 1420 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c foo = (int32_t)pnd->ninfo; pnd 1422 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (!pnd->need_id) { pnd 1423 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->ninfo += 5; pnd 1425 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->ninfo += 3; pnd 1427 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_INFO_CREATE(pnd->info, pnd->ninfo); pnd 1428 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_BFROPS_UNPACK(rc, peer, &buf, pnd->info, &foo, PMIX_INFO); pnd 1431 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (!pnd->need_id) { pnd 1432 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->ninfo = 5; pnd 1434 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->ninfo = 3; pnd 1436 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_INFO_CREATE(pnd->info, pnd->ninfo); pnd 1440 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->proc_type = proc_type; pnd 1443 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->psec = strdup(sec); pnd 1445 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->gds = strdup(gds); pnd 1450 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (pnd->need_id) { pnd 1462 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c cnct_cbfunc(PMIX_SUCCESS, &proc, (void*)pnd); pnd 1472 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_INFO_LOAD(&pnd->info[n], PMIX_VERSION_INFO, version, PMIX_STRING); pnd 1475 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_INFO_LOAD(&pnd->info[n], PMIX_USERID, &pnd->uid, PMIX_UINT32); pnd 1478 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_INFO_LOAD(&pnd->info[n], PMIX_GRPID, &pnd->gid, PMIX_UINT32); pnd 1481 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (!pnd->need_id) { pnd 1482 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_INFO_LOAD(&pnd->info[n], PMIX_NSPACE, nspace, PMIX_STRING); pnd 1484 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_INFO_LOAD(&pnd->info[n], PMIX_RANK, &rank, PMIX_PROC_RANK); pnd 1491 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_host_server.tool_connected(pnd->info, pnd->ninfo, cnct_cbfunc, pnd); pnd 1535 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1536 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1542 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c peer->protocol = pnd->protocol; pnd 1555 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c peer->sd = pnd->sd; pnd 1561 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1562 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1623 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c cred.bytes = pnd->cred; pnd 1624 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c cred.size = pnd->len; pnd 1641 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, (char*)&u32, sizeof(uint32_t)))) { pnd 1646 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1647 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1652 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, (char*)&u32, sizeof(uint32_t)))) { pnd 1678 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_ptl_base_set_nonblocking(pnd->sd); pnd 1681 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_event_assign(&peer->recv_event, pmix_globals.evbase, pnd->sd, pnd 1685 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_event_assign(&peer->send_event, pmix_globals.evbase, pnd->sd, pnd 1690 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1696 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, (char*)&u32, sizeof(int)))) { pnd 1698 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1700 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1708 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_pending_connection_t *pnd = (pmix_pending_connection_t*)cd->cbdata; pnd 1723 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, (char*)&u32, sizeof(uint32_t)))) { pnd 1725 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1726 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd->peer); pnd 1727 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1734 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd->peer); pnd 1735 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1741 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (pnd->need_id) { pnd 1743 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, cd->proc.nspace, PMIX_MAX_NSLEN+1))) { pnd 1745 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1746 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd->peer); pnd 1747 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1754 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, (char*)&u32, sizeof(uint32_t)))) { pnd 1756 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1757 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd->peer); pnd 1758 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1765 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, pmix_globals.myid.nspace, PMIX_MAX_NSLEN+1))) { pnd 1767 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1768 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd->peer); pnd 1769 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1776 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, (char*)&u32, sizeof(uint32_t)))) { pnd 1778 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1779 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd->peer); pnd 1780 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1786 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c peer = (pmix_peer_t*)pnd->peer; pnd 1791 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (5 != pnd->flag && 8 != pnd->flag) { pnd 1798 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c info->uid = pnd->uid; pnd 1799 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c info->gid = pnd->gid; pnd 1806 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c peer->proc_type = pnd->proc_type; pnd 1808 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c peer->protocol = pnd->protocol; pnd 1815 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c peer->sd = pnd->sd; pnd 1819 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c peer->nptr->compat.psec = pmix_psec_base_assign_module(pnd->psec); pnd 1824 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1832 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_INFO_LOAD(&ginfo, PMIX_GDS_MODULE, pnd->gds, PMIX_STRING); pnd 1839 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1858 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1869 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c cred.bytes = pnd->cred; pnd 1870 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c cred.size = pnd->len; pnd 1879 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 1884 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_ptl_base_set_nonblocking(pnd->sd); pnd 1887 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 1909 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(pnd); pnd 340 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_pending_connection_t *pnd = (pmix_pending_connection_t*)cbdata; pnd 359 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_ACQUIRE_OBJECT(pnd); pnd 362 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c "USOCK CONNECTION FROM PEER ON SOCKET %d", pnd->sd); pnd 368 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_recv_blocking(pnd->sd, (char*)&hdr, sizeof(pmix_usock_hdr_t)))) { pnd 369 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 370 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 378 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 379 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 383 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 384 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 387 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (PMIX_SUCCESS != pmix_ptl_base_recv_blocking(pnd->sd, msg, hdr.nbytes)) { pnd 390 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c "unable to complete recv of connect-ack with client ON SOCKET %d", pnd->sd); pnd 392 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 393 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 407 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 408 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 420 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 421 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 433 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 434 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 449 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 450 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 465 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 466 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 477 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 478 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 500 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 501 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 513 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 514 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 525 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 526 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 538 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 539 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 545 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c nspace, rank, version, pnd->sd); pnd 603 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 604 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 608 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c psave->protocol = pnd->protocol; pnd 620 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c psave->sd = pnd->sd; pnd 627 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 628 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 704 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 705 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 710 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, (char*)&psave->index, sizeof(int)))) { pnd 716 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 717 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 735 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 740 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_event_assign(&psave->recv_event, pmix_globals.evbase, pnd->sd, pnd 744 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_event_assign(&psave->send_event, pmix_globals.evbase, pnd->sd, pnd 750 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd); pnd 755 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (PMIX_SUCCESS != pmix_ptl_base_send_blocking(pnd->sd, (char*)&rc, sizeof(int))) { pnd 758 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); pnd 759 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(pnd);