recv 1044 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c retval = recv(sd, (char *)&guid, sizeof(guid), 0); recv 471 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c int retval = recv(btl_endpoint->endpoint_sd, (char *)ptr+cnt, size-cnt, 0); recv 52 examples/Ring.java MPI.COMM_WORLD.recv(message, 1, MPI.INT, prev, tag); recv 70 examples/Ring.java MPI.COMM_WORLD.recv(message, 1, MPI.INT, prev, tag); recv 194 ompi/mca/coll/base/coll_base_allreduce.c ret = MCA_PML_CALL(recv(tmprecv, count, dtype, (rank - 1), recv 246 ompi/mca/coll/base/coll_base_allreduce.c ret = MCA_PML_CALL(recv(rbuf, count, dtype, (rank + 1), recv 1085 ompi/mca/coll/base/coll_base_allreduce.c err = MCA_PML_CALL(recv((char *)rbuf + (ptrdiff_t)count_lhalf * extent, recv 1217 ompi/mca/coll/base/coll_base_allreduce.c err = MCA_PML_CALL(recv(rbuf, count, dtype, rank - 1, recv 116 ompi/mca/coll/base/coll_base_barrier.c err = MCA_PML_CALL(recv((void*)NULL, 0, MPI_BYTE, left, recv 130 ompi/mca/coll/base/coll_base_barrier.c err = MCA_PML_CALL(recv((void*)NULL, 0, MPI_BYTE, left, recv 138 ompi/mca/coll/base/coll_base_barrier.c err = MCA_PML_CALL(recv((void*)NULL, 0, MPI_BYTE, left, recv 152 ompi/mca/coll/base/coll_base_barrier.c err = MCA_PML_CALL(recv((void*)NULL, 0, MPI_BYTE, left, recv 202 ompi/mca/coll/base/coll_base_barrier.c err = MCA_PML_CALL(recv((void*)NULL, 0, MPI_BYTE, rank+adjsize, recv 348 ompi/mca/coll/base/coll_base_barrier.c err = MCA_PML_CALL(recv (NULL, 0, MPI_BYTE, 0, recv 424 ompi/mca/coll/base/coll_base_barrier.c err = MCA_PML_CALL(recv (NULL, 0, MPI_BYTE, partner, recv 450 ompi/mca/coll/base/coll_base_barrier.c err = MCA_PML_CALL(recv (NULL, 0, MPI_BYTE, partner, recv 531 ompi/mca/coll/base/coll_base_bcast.c err = MCA_PML_CALL(recv(tmpbuf[lr], sendcount[lr], datatype, recv 578 ompi/mca/coll/base/coll_base_bcast.c err = MCA_PML_CALL(recv(tmpbuf[1], counts[1], datatype, recv 642 ompi/mca/coll/base/coll_base_bcast.c return MCA_PML_CALL(recv(buff, count, datatype, root, recv 813 ompi/mca/coll/base/coll_base_bcast.c err = MCA_PML_CALL(recv((char *)buf + (ptrdiff_t)vrank * scatter_count * extent, recv 905 ompi/mca/coll/base/coll_base_bcast.c err = MCA_PML_CALL(recv((char *)buf + (ptrdiff_t)offset * extent, recv 990 ompi/mca/coll/base/coll_base_bcast.c err = MCA_PML_CALL(recv((char *)buf + (ptrdiff_t)vrank * scatter_count * extent, recv 66 ompi/mca/coll/base/coll_base_exscan.c return MCA_PML_CALL(recv(rbuf, count, dtype, rank - 1, recv 87 ompi/mca/coll/base/coll_base_exscan.c err = MCA_PML_CALL(recv(rbuf, count, dtype, rank - 1, recv 148 ompi/mca/coll/base/coll_base_gather.c err = MCA_PML_CALL(recv(ptmp + total_recv*rextent, (ptrdiff_t)rcount * size - total_recv, rdtype, recv 241 ompi/mca/coll/base/coll_base_gather.c ret = MCA_PML_CALL(recv(rbuf, 0, MPI_BYTE, root, recv 406 ompi/mca/coll/base/coll_base_gather.c err = MCA_PML_CALL(recv(ptmp, rcount, rdtype, i, recv 587 ompi/mca/coll/base/coll_base_reduce.c ret = MCA_PML_CALL(recv(recvbuf, count, datatype, io_root, recv 683 ompi/mca/coll/base/coll_base_reduce.c err = MCA_PML_CALL(recv(rbuf, count, dtype, size - 1, recv 700 ompi/mca/coll/base/coll_base_reduce.c err = MCA_PML_CALL(recv(pml_buffer, count, dtype, i, recv 917 ompi/mca/coll/base/coll_base_reduce.c err = MCA_PML_CALL(recv((char *)rbuf + (ptrdiff_t)count_lhalf * extent, recv 1042 ompi/mca/coll/base/coll_base_reduce.c err = MCA_PML_CALL(recv(rbuf, rcount[nsteps - 1], dtype, 0, recv 1098 ompi/mca/coll/base/coll_base_reduce.c err = MCA_PML_CALL(recv((char *)rbuf + (ptrdiff_t)sindex[step] * extent, recv 214 ompi/mca/coll/base/coll_base_reduce_scatter.c err = MCA_PML_CALL(recv(recv_buf, count, dtype, rank - 1, recv 368 ompi/mca/coll/base/coll_base_reduce_scatter.c err = MCA_PML_CALL(recv(rbuf, rcounts[rank], dtype, rank + 1, recv 770 ompi/mca/coll/base/coll_base_reduce_scatter.c err = MCA_PML_CALL(recv(precv, totalcount, dtype, rank - 1, recv 883 ompi/mca/coll/base/coll_base_reduce_scatter.c err = MCA_PML_CALL(recv(rbuf, rcounts[rank], dtype, peer, recv 250 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = MCA_PML_CALL(recv(tmprecv, 1, dtyperecv, remote, recv 400 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = MCA_PML_CALL(recv(tmprecv, totalcount, dtype, rank - 1, recv 483 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = MCA_PML_CALL(recv(rbuf, rcount, dtype, rank + 1, recv 641 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = MCA_PML_CALL(recv(precv, totalcount, dtype, rank - 1, recv 754 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = MCA_PML_CALL(recv(rbuf, rcount, dtype, peer, recv 90 ompi/mca/coll/base/coll_base_scan.c err = MCA_PML_CALL(recv(pml_buffer, count, dtype, recv 146 ompi/mca/coll/base/coll_base_scatter.c err = MCA_PML_CALL(recv(ptmp, (ptrdiff_t)rcount * (ptrdiff_t)size, rdtype, bmtree->tree_prev, recv 179 ompi/mca/coll/base/coll_base_scatter.c err = MCA_PML_CALL(recv(ptmp, rcount, rdtype, bmtree->tree_prev, recv 237 ompi/mca/coll/base/coll_base_scatter.c err = MCA_PML_CALL(recv(rbuf, rcount, rdtype, root, recv 120 ompi/mca/coll/basic/coll_basic_allgather.c err = MCA_PML_CALL(recv(tmpbuf, size * scount, sdtype, 0, recv 136 ompi/mca/coll/basic/coll_basic_allgather.c err = MCA_PML_CALL(recv(rbuf, rsize * rcount, rdtype, 0, recv 127 ompi/mca/coll/basic/coll_basic_allreduce.c err = MCA_PML_CALL(recv(pml_buffer, count, dtype, i, recv 178 ompi/mca/coll/basic/coll_basic_allreduce.c err = MCA_PML_CALL(recv(rbuf, count, dtype, root, recv 65 ompi/mca/coll/basic/coll_basic_barrier.c err = MCA_PML_CALL(recv(NULL, 0, MPI_BYTE, peer, recv 87 ompi/mca/coll/basic/coll_basic_barrier.c err = MCA_PML_CALL(recv(NULL, 0, MPI_BYTE, peer, recv 75 ompi/mca/coll/basic/coll_basic_bcast.c err = MCA_PML_CALL(recv(buff, count, datatype, peer, recv 156 ompi/mca/coll/basic/coll_basic_bcast.c err = MCA_PML_CALL(recv(buff, count, datatype, root, recv 75 ompi/mca/coll/basic/coll_basic_gather.c err = MCA_PML_CALL(recv(ptmp, rcount, rdtype, i, recv 88 ompi/mca/coll/basic/coll_basic_gatherv.c err = MCA_PML_CALL(recv(ptmp, rcounts[i], rdtype, i, recv 206 ompi/mca/coll/basic/coll_basic_reduce.c err = MCA_PML_CALL(recv(rcv_buffer, count, dtype, peer, recv 251 ompi/mca/coll/basic/coll_basic_reduce.c err = MCA_PML_CALL(recv(rcv_buffer, count, dtype, 0, recv 318 ompi/mca/coll/basic/coll_basic_reduce.c err = MCA_PML_CALL(recv(rbuf, count, dtype, 0, recv 330 ompi/mca/coll/basic/coll_basic_reduce.c err = MCA_PML_CALL(recv(pml_buffer, count, dtype, i, recv 148 ompi/mca/coll/basic/coll_basic_reduce_scatter.c err = MCA_PML_CALL(recv(recv_buf, count, dtype, rank - 1, recv 303 ompi/mca/coll/basic/coll_basic_reduce_scatter.c err = MCA_PML_CALL(recv(rbuf, rcounts[rank], dtype, rank + 1, recv 430 ompi/mca/coll/basic/coll_basic_reduce_scatter.c err = MCA_PML_CALL(recv(lbuf, totalcounts, dtype, 0, recv 449 ompi/mca/coll/basic/coll_basic_reduce_scatter.c err = MCA_PML_CALL(recv(buf, totalcounts, dtype, i, recv 123 ompi/mca/coll/basic/coll_basic_reduce_scatter_block.c err = MCA_PML_CALL(recv(lbuf, totalcounts, dtype, 0, recv 142 ompi/mca/coll/basic/coll_basic_reduce_scatter_block.c err = MCA_PML_CALL(recv(buf, totalcounts, dtype, i, recv 62 ompi/mca/coll/basic/coll_basic_scatter.c err = MCA_PML_CALL(recv(rbuf, rcount, rdtype, root, recv 63 ompi/mca/coll/basic/coll_basic_scatterv.c return MCA_PML_CALL(recv(rbuf, rcount, rdtype, recv 138 ompi/mca/coll/basic/coll_basic_scatterv.c err = MCA_PML_CALL(recv(rbuf, rcount, rdtype, recv 56 ompi/mca/coll/inter/coll_inter_bcast.c err = MCA_PML_CALL(recv(buff, count, datatype, root, recv 89 ompi/mca/coll/inter/coll_inter_gather.c err = MCA_PML_CALL(recv(rbuf, rcount*size, rdtype, 0, recv 63 ompi/mca/coll/inter/coll_inter_gatherv.c err = MCA_PML_CALL(recv(rbuf, 1, ndtype, 0, recv 89 ompi/mca/coll/inter/coll_inter_reduce.c err = MCA_PML_CALL(recv(rbuf, count, dtype, 0, recv 72 ompi/mca/coll/inter/coll_inter_scatter.c err = MCA_PML_CALL(recv(ptmp, rcount*size_local, rdtype, recv 66 ompi/mca/coll/inter/coll_inter_scatterv.c err = MCA_PML_CALL(recv(counts, size_local, MPI_INT, recv 85 ompi/mca/coll/inter/coll_inter_scatterv.c err = MCA_PML_CALL(recv(ptmp, total, rdtype, recv 585 ompi/mca/coll/sm/coll_sm_module.c MCA_PML_CALL(recv(&shmem_ds, sizeof (shmem_ds), MPI_BYTE, 0, MCA_COLL_BASE_TAG_BCAST, comm, MPI_STATUS_IGNORE)); recv 843 ompi/mca/common/ompio/common_ompio_aggregators.c ret = MCA_PML_CALL(recv(&fh->f_procs_per_group, recv 861 ompi/mca/common/ompio/common_ompio_aggregators.c ret = MCA_PML_CALL(recv(fh->f_procs_in_group, recv 232 ompi/mca/fcoll/base/fcoll_base_coll_array.c err = MCA_PML_CALL(recv(rbuf, recv 459 ompi/mca/fcoll/base/fcoll_base_coll_array.c err = MCA_PML_CALL(recv(buff, recv 131 ompi/mca/mtl/portals4/mtl_portals4_request.h ompi_mtl_portals4_recv_request_t recv; recv 163 ompi/mca/osc/pt2pt/osc_pt2pt_component.c ompi_osc_pt2pt_receive_t *recv = (ompi_osc_pt2pt_receive_t *) opal_list_remove_first (&mca_osc_pt2pt_component.pending_receives); recv 165 ompi/mca/osc/pt2pt/osc_pt2pt_component.c if (NULL == recv) { recv 169 ompi/mca/osc/pt2pt/osc_pt2pt_component.c (void) ompi_osc_pt2pt_process_receive (recv); recv 482 ompi/mca/osc/pt2pt/osc_pt2pt_component.c static void ompi_osc_pt2pt_receive_construct (ompi_osc_pt2pt_receive_t *recv) recv 484 ompi/mca/osc/pt2pt/osc_pt2pt_component.c recv->buffer = NULL; recv 485 ompi/mca/osc/pt2pt/osc_pt2pt_component.c recv->pml_request = NULL; recv 488 ompi/mca/osc/pt2pt/osc_pt2pt_component.c static void ompi_osc_pt2pt_receive_destruct (ompi_osc_pt2pt_receive_t *recv) recv 490 ompi/mca/osc/pt2pt/osc_pt2pt_component.c free (recv->buffer); recv 491 ompi/mca/osc/pt2pt/osc_pt2pt_component.c if (recv->pml_request && MPI_REQUEST_NULL != recv->pml_request) { recv 492 ompi/mca/osc/pt2pt/osc_pt2pt_component.c recv->pml_request->req_complete_cb = NULL; recv 493 ompi/mca/osc/pt2pt/osc_pt2pt_component.c ompi_request_cancel (recv->pml_request); recv 494 ompi/mca/osc/pt2pt/osc_pt2pt_component.c ompi_request_free (&recv->pml_request); recv 1614 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c ompi_osc_pt2pt_receive_t *recv = (ompi_osc_pt2pt_receive_t *) request->req_complete_cb_data; recv 1621 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c opal_list_append (&mca_osc_pt2pt_component.pending_receives, &recv->super); recv 1627 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c static int ompi_osc_pt2pt_receive_repost (ompi_osc_pt2pt_receive_t *recv) recv 1630 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c ompi_request_wait_completion (recv->pml_request); recv 1633 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c recv->pml_request->req_complete_cb = ompi_osc_pt2pt_callback; recv 1634 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c recv->pml_request->req_complete_cb_data = (void *) recv; recv 1636 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c return MCA_PML_CALL(start(1, &recv->pml_request)); recv 1639 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c int ompi_osc_pt2pt_process_receive (ompi_osc_pt2pt_receive_t *recv) recv 1641 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c ompi_osc_pt2pt_module_t *module = (ompi_osc_pt2pt_module_t *) recv->module; recv 1642 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c ompi_osc_pt2pt_header_t *base_header = (ompi_osc_pt2pt_header_t *) recv->buffer; recv 1643 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c size_t incoming_length = recv->pml_request->req_status._ucount; recv 1644 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c int source = recv->pml_request->req_status.MPI_SOURCE; recv 1689 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c rc = ompi_osc_pt2pt_receive_repost (recv); recv 157 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.h int ompi_osc_pt2pt_process_receive (ompi_osc_pt2pt_receive_t *recv); recv 545 ompi/mca/pml/ucx/pml_ucx.c PML_UCX_MAKE_RECV_TAG(req->tag, req->recv.tag_mask, tag, src, comm); recv 1027 ompi/mca/pml/ucx/pml_ucx.c preq->recv.tag_mask, recv 113 ompi/mca/pml/ucx/pml_ucx_request.h } recv; recv 378 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_INIT_MXM_RECV_REQ(&rreq, buf, count, datatype, src, tag, comm, recv); recv 667 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_INIT_MXM_RECV_REQ(&rreq, buf, count, datatype, -1, 0, (*message)->comm, recv); recv 209 ompi/mca/topo/base/topo_base_dist_graph_create.c MCA_PML_CALL(recv( &temp[count - left_over], left_over, (ompi_datatype_t*)&ompi_mpi_int, /* keep receiving in the same buffer */ recv 245 ompi/mca/topo/base/topo_base_dist_graph_create.c MCA_PML_CALL(recv( &temp[count - left_over], left_over, (ompi_datatype_t*)&ompi_mpi_int, /* keep receiving in the same buffer */ recv 30 ompi/mca/vprotocol/base/vprotocol_base_parasite.c if(mca_vprotocol.recv) recv 31 ompi/mca/vprotocol/base/vprotocol_base_parasite.c mca_pml.pml_recv = mca_vprotocol.recv; recv 68 ompi/mca/vprotocol/vprotocol.h mca_pml_base_module_recv_fn_t recv; recv 82 ompi/mpi/c/recv.c rc = MCA_PML_CALL(recv(buf, count, type, source, tag, comm, status)); recv 413 ompi/mpi/java/java/Comm.java recv(handle, buf, db, off, count, recv 101 ompi/patterns/comm/allgather.c rc=MCA_PML_CALL(recv(dest_buf_current, recv 263 ompi/patterns/comm/allgather.c rc=MCA_PML_CALL(recv(dest_buf, recv 117 ompi/patterns/comm/allreduce.c rc=MCA_PML_CALL(recv(scratch_bufers[recv_buffer], recv 204 ompi/patterns/comm/allreduce.c rc=MCA_PML_CALL(recv(scratch_bufers[recv_buffer], recv 68 ompi/patterns/comm/bcast.c rc=MCA_PML_CALL(recv(buffer, count,dtype,peer_rank, recv 546 opal/mca/btl/tcp/btl_tcp.c int retval = recv(sd, ((char *)ptr) + cnt, size - cnt, 0); recv 2171 opal/mca/event/libevent2022/libevent/buffer.c n = recv(fd, p, howmuch, 0); recv 2759 opal/mca/event/libevent2022/libevent/event.c while (recv(fd, (char*)buf, sizeof(buf), 0) > 0) recv 143 opal/mca/event/libevent2022/libevent/signal.c n = recv(fd, signals, sizeof(signals), 0); recv 75 opal/mca/event/libevent2022/libevent/test/bench.c count += recv(fd, (char*)&ch, sizeof(ch), 0); recv 72 opal/mca/event/libevent2022/libevent/test/bench_cascade.c recv(fd, &ch, sizeof(ch), 0); recv 98 opal/mca/event/libevent2022/libevent/test/regress.c #define read(fd,buf,len) recv((fd),(buf),(int)(len),0) recv 60 opal/mca/event/libevent2022/libevent/test/regress_et.c len = recv(fd, &buf, sizeof(buf), 0); recv 70 opal/mca/event/libevent2022/libevent/test/test-eof.c len = recv(fd, buf, sizeof(buf), 0); recv 133 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c int retval = recv(sd, (char *)data+cnt, size-cnt, MSG_WAITALL); recv 138 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h pmix_ptl_recv_fn_t recv; recv 165 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h (r) = (p)->nptr->compat.ptl->recv((struct pmix_peer_t*)(p), c, t) recv 1067 orte/mca/oob/tcp/oob_tcp_connection.c int retval = recv(sd, (char *)ptr+cnt, size-cnt, 0); recv 61 orte/mca/rml/base/rml_base_msg_handlers.c orte_rml_posted_recv_t *post, *recv; recv 83 orte/mca/rml/base/rml_base_msg_handlers.c OPAL_LIST_FOREACH(recv, &orte_rml_base.posted_recvs, orte_rml_posted_recv_t) { recv 84 orte/mca/rml/base/rml_base_msg_handlers.c if (OPAL_EQUAL == orte_util_compare_name_fields(mask, &post->peer, &recv->peer) && recv 85 orte/mca/rml/base/rml_base_msg_handlers.c post->tag == recv->tag) { recv 89 orte/mca/rml/base/rml_base_msg_handlers.c post->tag, ORTE_NAME_PRINT(&recv->peer)); recv 91 orte/mca/rml/base/rml_base_msg_handlers.c opal_list_remove_item(&orte_rml_base.posted_recvs, &recv->super); recv 92 orte/mca/rml/base/rml_base_msg_handlers.c OBJ_RELEASE(recv); recv 101 orte/mca/rml/base/rml_base_msg_handlers.c OPAL_LIST_FOREACH(recv, &orte_rml_base.posted_recvs, orte_rml_posted_recv_t) { recv 102 orte/mca/rml/base/rml_base_msg_handlers.c if (OPAL_EQUAL == orte_util_compare_name_fields(mask, &post->peer, &recv->peer) && recv 103 orte/mca/rml/base/rml_base_msg_handlers.c post->tag == recv->tag) { recv 516 oshmem/mca/scoll/basic/scoll_basic_barrier.c rc = MCA_SPML_CALL(recv(NULL, 0, PE_root)); recv 530 oshmem/mca/scoll/basic/scoll_basic_barrier.c rc = MCA_SPML_CALL(recv(NULL, 0, pe_cur)); recv 596 oshmem/mca/scoll/basic/scoll_basic_reduce.c rc = MCA_SPML_CALL(recv(target, nlong, peer_pe)); recv 613 oshmem/mca/scoll/basic/scoll_basic_reduce.c rc = MCA_SPML_CALL(recv(pml_buffer, nlong, peer_pe)); recv 752 oshmem/mca/scoll/basic/scoll_basic_reduce.c rc = MCA_SPML_CALL(recv(rcv_buffer, nlong, peer_pe)); recv 789 oshmem/mca/scoll/basic/scoll_basic_reduce.c rc = MCA_SPML_CALL(recv(rcv_buffer, nlong, root_pe)); recv 795 oshmem/mca/spml/ucx/spml_ucx.c rc = MCA_PML_CALL(recv(buf,