send_msg 185 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c p->send_msg = NULL; send_msg 211 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c if (NULL != p->send_msg) { send_msg 212 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c PMIX_RELEASE(p->send_msg); send_msg 254 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_ptl_send_t *send_msg; /**< current send in progress */ send_msg 389 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_ptl_send_t *msg = peer->send_msg; send_msg 407 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (PMIX_SUCCESS == (rc = send_msg(peer->sd, msg))) { send_msg 412 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c peer->send_msg = NULL; send_msg 431 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c peer->send_msg = NULL; send_msg 445 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c peer->send_msg = (pmix_ptl_send_t*) send_msg 450 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (NULL == peer->send_msg && peer->send_ev_active) { send_msg 666 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (NULL == (queue->peer)->send_msg) { send_msg 667 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c (queue->peer)->send_msg = snd; send_msg 743 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (NULL == ms->peer->send_msg) { send_msg 744 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c ms->peer->send_msg = snd; send_msg 285 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h if (NULL == (p)->send_msg) { \ send_msg 286 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h (p)->send_msg = snd; \ send_msg 555 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_ptl_send_t *msg = peer->send_msg; send_msg 590 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c peer->send_msg = NULL; send_msg 619 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c peer->send_msg = NULL; send_msg 636 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c peer->send_msg = NULL; send_msg 653 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c peer->send_msg = NULL; send_msg 669 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c peer->send_msg = (pmix_ptl_send_t*) send_msg 674 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (NULL == peer->send_msg && peer->send_ev_active) { send_msg 881 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (NULL == ms->peer->send_msg) { send_msg 882 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c ms->peer->send_msg = snd; send_msg 932 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (NULL == (queue->peer)->send_msg) { send_msg 933 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c (queue->peer)->send_msg = snd; send_msg 1338 orte/mca/oob/tcp/oob_tcp_component.c peer->send_msg = NULL; send_msg 341 orte/mca/oob/tcp/oob_tcp_connection.c if (NULL != peer->send_msg) { send_msg 974 orte/mca/oob/tcp/oob_tcp_connection.c if (NULL == peer->send_msg) { send_msg 975 orte/mca/oob/tcp/oob_tcp_connection.c peer->send_msg = (mca_oob_tcp_send_t*) send_msg 978 orte/mca/oob/tcp/oob_tcp_connection.c if (NULL != peer->send_msg && !peer->send_ev_active) { send_msg 63 orte/mca/oob/tcp/oob_tcp_peer.h mca_oob_tcp_send_t *send_msg; /**< current send in progress */ send_msg 92 orte/mca/oob/tcp/oob_tcp_sendrecv.c if (NULL == peer->send_msg) { send_msg 93 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->send_msg = snd; send_msg 208 orte/mca/oob/tcp/oob_tcp_sendrecv.c msg = peer->send_msg; send_msg 235 orte/mca/oob/tcp/oob_tcp_sendrecv.c (NULL == peer->send_msg) ? "NULL" : ORTE_NAME_PRINT(&peer->name)); send_msg 239 orte/mca/oob/tcp/oob_tcp_sendrecv.c if (ORTE_SUCCESS == (rc = send_msg(peer, msg))) { send_msg 249 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->send_msg = NULL; send_msg 260 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->send_msg = NULL; send_msg 273 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->send_msg = NULL; send_msg 295 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->send_msg = NULL; send_msg 312 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->send_msg = NULL; send_msg 323 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->send_msg = (mca_oob_tcp_send_t*) send_msg 328 orte/mca/oob/tcp/oob_tcp_sendrecv.c if (NULL == peer->send_msg && peer->send_ev_active) { send_msg 459 orte/mca/oob/tcp/oob_tcp_sendrecv.c if (NULL == peer->send_msg) { send_msg 460 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->send_msg = (mca_oob_tcp_send_t*)opal_list_remove_first(&peer->send_queue); send_msg 462 orte/mca/oob/tcp/oob_tcp_sendrecv.c if (NULL != peer->send_msg && !peer->send_ev_active) {