snd 629 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_ptl_send_t *snd; snd 656 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd = PMIX_NEW(pmix_ptl_send_t); snd 657 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->hdr.pindex = htonl(pmix_globals.pindex); snd 658 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->hdr.tag = htonl(queue->tag); snd 659 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->hdr.nbytes = htonl((queue->buf)->bytes_used); snd 660 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->data = (queue->buf); snd 662 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->sdptr = (char*)&snd->hdr; snd 663 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->sdbytes = sizeof(pmix_ptl_hdr_t); snd 667 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c (queue->peer)->send_msg = snd; snd 670 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_list_append(&(queue->peer)->send_queue, &snd->super); snd 679 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_POST_OBJECT(snd); snd 686 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_ptl_send_t *snd; snd 733 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd = PMIX_NEW(pmix_ptl_send_t); snd 734 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->hdr.pindex = htonl(pmix_globals.pindex); snd 735 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->hdr.tag = htonl(tag); snd 736 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->hdr.nbytes = htonl(ms->bfr->bytes_used); snd 737 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->data = ms->bfr; snd 739 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->sdptr = (char*)&snd->hdr; snd 740 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->sdbytes = sizeof(pmix_ptl_hdr_t); snd 744 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c ms->peer->send_msg = snd; snd 747 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_list_append(&ms->peer->send_queue, &snd->super); snd 752 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_POST_OBJECT(snd); snd 757 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_POST_OBJECT(snd); snd 254 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h (c)->snd = (s); \ snd 265 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h pmix_ptl_send_t *snd; \ snd 275 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h snd = PMIX_NEW(pmix_ptl_send_t); \ snd 276 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h snd->hdr.pindex = htonl(pmix_globals.pindex); \ snd 277 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h snd->hdr.tag = htonl(t); \ snd 279 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h snd->hdr.nbytes = htonl(nbytes); \ snd 280 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h snd->data = (b); \ snd 282 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h snd->sdptr = (char*)&snd->hdr; \ snd 283 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h snd->sdbytes = sizeof(pmix_ptl_hdr_t); \ snd 286 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h (p)->send_msg = snd; \ snd 289 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h pmix_list_append(&(p)->send_queue, &snd->super); \ snd 294 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h PMIX_POST_OBJECT(snd); \ snd 835 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_ptl_send_t *snd; snd 871 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd = PMIX_NEW(pmix_ptl_send_t); snd 872 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->hdr.pindex = pmix_globals.pindex; snd 873 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->hdr.tag = tag; snd 874 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->hdr.nbytes = ms->bfr->bytes_used; snd 875 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->data = ms->bfr; snd 877 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->sdptr = (char*)&snd->hdr; snd 878 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->sdbytes = sizeof(pmix_usock_hdr_t); snd 882 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c ms->peer->send_msg = snd; snd 885 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_list_append(&ms->peer->send_queue, &snd->super); snd 890 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c PMIX_POST_OBJECT(snd); snd 895 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c PMIX_POST_OBJECT(snd); snd 901 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_ptl_send_t *snd; snd 922 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd = PMIX_NEW(pmix_ptl_send_t); snd 923 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->hdr.pindex = htonl(pmix_globals.pindex); snd 924 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->hdr.tag = htonl(queue->tag); snd 925 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->hdr.nbytes = htonl((queue->buf)->bytes_used); snd 926 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->data = (queue->buf); snd 928 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->sdptr = (char*)&snd->hdr; snd 929 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->sdbytes = sizeof(pmix_ptl_hdr_t); snd 933 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c (queue->peer)->send_msg = snd; snd 936 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_list_append(&(queue->peer)->send_queue, &snd->super); snd 945 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c PMIX_POST_OBJECT(snd); snd 1121 orte/mca/oob/tcp/oob_tcp_component.c orte_rml_send_t *snd; snd 1150 orte/mca/oob/tcp/oob_tcp_component.c ORTE_NAME_PRINT(&mop->snd->hdr.dst), snd 1159 orte/mca/oob/tcp/oob_tcp_component.c memcpy(&ui64, (char*)&(mop->snd->hdr.dst), sizeof(uint64_t)); snd 1165 orte/mca/oob/tcp/oob_tcp_component.c ORTE_NAME_PRINT(&mop->snd->hdr.dst)); snd 1175 orte/mca/oob/tcp/oob_tcp_component.c MCA_OOB_TCP_HDR_NTOH(&mop->snd->hdr); snd 1176 orte/mca/oob/tcp/oob_tcp_component.c snd = OBJ_NEW(orte_rml_send_t); snd 1177 orte/mca/oob/tcp/oob_tcp_component.c snd->retries = mop->rmsg->retries + 1; snd 1178 orte/mca/oob/tcp/oob_tcp_component.c snd->dst = mop->snd->hdr.dst; snd 1179 orte/mca/oob/tcp/oob_tcp_component.c snd->origin = mop->snd->hdr.origin; snd 1180 orte/mca/oob/tcp/oob_tcp_component.c snd->tag = mop->snd->hdr.tag; snd 1181 orte/mca/oob/tcp/oob_tcp_component.c snd->seq_num = mop->snd->hdr.seq_num; snd 1182 orte/mca/oob/tcp/oob_tcp_component.c snd->data = mop->snd->data; snd 1183 orte/mca/oob/tcp/oob_tcp_component.c snd->count = mop->snd->hdr.nbytes; snd 1184 orte/mca/oob/tcp/oob_tcp_component.c snd->cbfunc.iov = NULL; snd 1185 orte/mca/oob/tcp/oob_tcp_component.c snd->cbdata = NULL; snd 1187 orte/mca/oob/tcp/oob_tcp_component.c ORTE_OOB_SEND(snd); snd 1189 orte/mca/oob/tcp/oob_tcp_component.c mop->snd->data = NULL; snd 167 orte/mca/oob/tcp/oob_tcp_connection.c mca_oob_tcp_send_t *snd; snd 343 orte/mca/oob/tcp/oob_tcp_connection.c while (NULL != (snd = (mca_oob_tcp_send_t*)opal_list_remove_first(&peer->send_queue))) { snd 85 orte/mca/oob/tcp/oob_tcp_sendrecv.c mca_oob_tcp_send_t *snd = (mca_oob_tcp_send_t*)cbdata; snd 88 orte/mca/oob/tcp/oob_tcp_sendrecv.c ORTE_ACQUIRE_OBJECT(snd); snd 89 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer = (mca_oob_tcp_peer_t*)snd->peer; snd 93 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->send_msg = snd; snd 96 orte/mca/oob/tcp/oob_tcp_sendrecv.c opal_list_append(&peer->send_queue, &snd->super); snd 98 orte/mca/oob/tcp/oob_tcp_sendrecv.c if (snd->activate) { snd 433 orte/mca/oob/tcp/oob_tcp_sendrecv.c orte_rml_send_t *snd; snd 582 orte/mca/oob/tcp/oob_tcp_sendrecv.c snd = OBJ_NEW(orte_rml_send_t); snd 583 orte/mca/oob/tcp/oob_tcp_sendrecv.c snd->dst = peer->recv_msg->hdr.dst; snd 584 orte/mca/oob/tcp/oob_tcp_sendrecv.c snd->origin = peer->recv_msg->hdr.origin; snd 585 orte/mca/oob/tcp/oob_tcp_sendrecv.c snd->tag = peer->recv_msg->hdr.tag; snd 586 orte/mca/oob/tcp/oob_tcp_sendrecv.c snd->data = peer->recv_msg->data; snd 587 orte/mca/oob/tcp/oob_tcp_sendrecv.c snd->seq_num = peer->recv_msg->hdr.seq_num; snd 588 orte/mca/oob/tcp/oob_tcp_sendrecv.c snd->count = peer->recv_msg->hdr.nbytes; snd 589 orte/mca/oob/tcp/oob_tcp_sendrecv.c snd->cbfunc.iov = NULL; snd 590 orte/mca/oob/tcp/oob_tcp_sendrecv.c snd->cbdata = NULL; snd 592 orte/mca/oob/tcp/oob_tcp_sendrecv.c ORTE_OOB_SEND(snd); snd 666 orte/mca/oob/tcp/oob_tcp_sendrecv.c ptr->snd = NULL; snd 239 orte/mca/oob/tcp/oob_tcp_sendrecv.h mca_oob_tcp_send_t *snd; snd 247 orte/mca/oob/tcp/oob_tcp_sendrecv.h mca_oob_tcp_send_t *snd; \ snd 256 orte/mca/oob/tcp/oob_tcp_sendrecv.h mop->snd = (s); \ snd 261 orte/mca/oob/tcp/oob_tcp_sendrecv.h snd = OBJ_NEW(mca_oob_tcp_send_t); \ snd 262 orte/mca/oob/tcp/oob_tcp_sendrecv.h mop->snd = snd; \ snd 264 orte/mca/oob/tcp/oob_tcp_sendrecv.h snd->hdr = proxy->hdr; \ snd 265 orte/mca/oob/tcp/oob_tcp_sendrecv.h MCA_OOB_TCP_HDR_HTON(&snd->hdr); \ snd 267 orte/mca/oob/tcp/oob_tcp_sendrecv.h snd->data = proxy->data; \ snd 269 orte/mca/oob/tcp/oob_tcp_sendrecv.h snd->sdptr = (char*)&snd->hdr; \ snd 270 orte/mca/oob/tcp/oob_tcp_sendrecv.h snd->sdbytes = sizeof(mca_oob_tcp_hdr_t); \ snd 81 orte/mca/rml/oob/rml_oob_send.c orte_rml_send_t *snd; snd 164 orte/mca/rml/oob/rml_oob_send.c snd = OBJ_NEW(orte_rml_send_t); snd 165 orte/mca/rml/oob/rml_oob_send.c snd->dst = *peer; snd 166 orte/mca/rml/oob/rml_oob_send.c snd->origin = *ORTE_PROC_MY_NAME; snd 167 orte/mca/rml/oob/rml_oob_send.c snd->tag = tag; snd 168 orte/mca/rml/oob/rml_oob_send.c snd->iov = iov; snd 169 orte/mca/rml/oob/rml_oob_send.c snd->count = count; snd 170 orte/mca/rml/oob/rml_oob_send.c snd->cbfunc.iov = cbfunc; snd 171 orte/mca/rml/oob/rml_oob_send.c snd->cbdata = cbdata; snd 174 orte/mca/rml/oob/rml_oob_send.c ORTE_OOB_SEND(snd); snd 186 orte/mca/rml/oob/rml_oob_send.c orte_rml_send_t *snd; snd 252 orte/mca/rml/oob/rml_oob_send.c snd = OBJ_NEW(orte_rml_send_t); snd 253 orte/mca/rml/oob/rml_oob_send.c snd->dst = *peer; snd 254 orte/mca/rml/oob/rml_oob_send.c snd->origin = *ORTE_PROC_MY_NAME; snd 255 orte/mca/rml/oob/rml_oob_send.c snd->tag = tag; snd 256 orte/mca/rml/oob/rml_oob_send.c snd->buffer = buffer; snd 257 orte/mca/rml/oob/rml_oob_send.c snd->cbfunc.buffer = cbfunc; snd 258 orte/mca/rml/oob/rml_oob_send.c snd->cbdata = cbdata; snd 261 orte/mca/rml/oob/rml_oob_send.c ORTE_OOB_SEND(snd);