rcount 304 ompi/datatype/ompi_datatype.h void *rbuf, int32_t rcount, const ompi_datatype_t* rdtype); rcount 46 ompi/datatype/ompi_datatype_sndrcv.c void *rbuf, int32_t rcount, const ompi_datatype_t* rdtype) rcount 55 ompi/datatype/ompi_datatype_sndrcv.c if (0 == rcount || 0 == rdtype->super.size) { rcount 61 ompi/datatype/ompi_datatype_sndrcv.c int32_t count = ( scount < rcount ? scount : rcount ); rcount 63 ompi/datatype/ompi_datatype_sndrcv.c return ((scount > rcount) ? MPI_ERR_TRUNCATE : MPI_SUCCESS); rcount 76 ompi/datatype/ompi_datatype_sndrcv.c if( (int32_t)iov.iov_len > rcount ) iov.iov_len = rcount; rcount 80 ompi/datatype/ompi_datatype_sndrcv.c return ((max_data < (size_t)rcount) ? MPI_ERR_TRUNCATE : MPI_SUCCESS); rcount 87 ompi/datatype/ompi_datatype_sndrcv.c &(rdtype->super), rcount, rbuf, 0, rcount 92 ompi/datatype/ompi_datatype_sndrcv.c iov.iov_len = rcount * rdtype->super.size; rcount 109 ompi/datatype/ompi_datatype_sndrcv.c &(rdtype->super), rcount, rbuf, 0, rcount 124 ompi/datatype/ompi_datatype_sndrcv.c return ( (scount * sdtype->super.size) <= (rcount * rdtype->super.size) ? MPI_SUCCESS : MPI_ERR_TRUNCATE ); rcount 87 ompi/mca/coll/base/coll_base_allgather.c void* rbuf, int rcount, rcount 113 ompi/mca/coll/base/coll_base_allgather.c err = ompi_datatype_sndrcv(tmpsend, scount, sdtype, tmprecv, rcount, rdtype); rcount 117 ompi/mca/coll/base/coll_base_allgather.c tmpsend = ((char*)rbuf) + (ptrdiff_t)rank * (ptrdiff_t)rcount * rext; rcount 118 ompi/mca/coll/base/coll_base_allgather.c err = ompi_datatype_copy_content_same_ddt(rdtype, rcount, tmprecv, tmpsend); rcount 139 ompi/mca/coll/base/coll_base_allgather.c tmprecv = tmpsend + (ptrdiff_t)distance * (ptrdiff_t)rcount * rext; rcount 148 ompi/mca/coll/base/coll_base_allgather.c err = ompi_coll_base_sendrecv(tmpsend, blockcount * rcount, rdtype, rcount 150 ompi/mca/coll/base/coll_base_allgather.c tmprecv, blockcount * rcount, rdtype, rcount 170 ompi/mca/coll/base/coll_base_allgather.c span = opal_datatype_span(&rdtype->super, (int64_t)(size - rank) * rcount, &gap); rcount 179 ompi/mca/coll/base/coll_base_allgather.c err = ompi_datatype_copy_content_same_ddt(rdtype, ((ptrdiff_t)(size - rank) * (ptrdiff_t)rcount), rcount 184 ompi/mca/coll/base/coll_base_allgather.c tmpsend = (char*) rbuf + (ptrdiff_t)(size - rank) * (ptrdiff_t)rcount * rext; rcount 185 ompi/mca/coll/base/coll_base_allgather.c err = ompi_datatype_copy_content_same_ddt(rdtype, (ptrdiff_t)rank * (ptrdiff_t)rcount, rcount 190 ompi/mca/coll/base/coll_base_allgather.c tmprecv = (char*) rbuf + (ptrdiff_t)rank * (ptrdiff_t)rcount * rext; rcount 191 ompi/mca/coll/base/coll_base_allgather.c err = ompi_datatype_copy_content_same_ddt(rdtype, (ptrdiff_t)(size - rank) * (ptrdiff_t)rcount, rcount 255 ompi/mca/coll/base/coll_base_allgather.c void* rbuf, int rcount, rcount 281 ompi/mca/coll/base/coll_base_allgather.c rbuf, rcount, rdtype, rcount 298 ompi/mca/coll/base/coll_base_allgather.c tmprecv = (char*) rbuf + (ptrdiff_t)rank * (ptrdiff_t)rcount * rext; rcount 299 ompi/mca/coll/base/coll_base_allgather.c err = ompi_datatype_sndrcv(tmpsend, scount, sdtype, tmprecv, rcount, rdtype); rcount 314 ompi/mca/coll/base/coll_base_allgather.c tmpsend = (char*)rbuf + (ptrdiff_t)sendblocklocation * (ptrdiff_t)rcount * rext; rcount 315 ompi/mca/coll/base/coll_base_allgather.c tmprecv = (char*)rbuf + (ptrdiff_t)(sendblocklocation + distance) * (ptrdiff_t)rcount * rext; rcount 317 ompi/mca/coll/base/coll_base_allgather.c tmpsend = (char*)rbuf + (ptrdiff_t)sendblocklocation * (ptrdiff_t)rcount * rext; rcount 318 ompi/mca/coll/base/coll_base_allgather.c tmprecv = (char*)rbuf + (ptrdiff_t)(sendblocklocation - distance) * (ptrdiff_t)rcount * rext; rcount 323 ompi/mca/coll/base/coll_base_allgather.c err = ompi_coll_base_sendrecv(tmpsend, (ptrdiff_t)distance * (ptrdiff_t)rcount, rdtype, rcount 325 ompi/mca/coll/base/coll_base_allgather.c tmprecv, (ptrdiff_t)distance * (ptrdiff_t)rcount, rdtype, rcount 360 ompi/mca/coll/base/coll_base_allgather.c void* rbuf, int rcount, rcount 382 ompi/mca/coll/base/coll_base_allgather.c tmprecv = (char*) rbuf + (ptrdiff_t)rank * (ptrdiff_t)rcount * rext; rcount 385 ompi/mca/coll/base/coll_base_allgather.c err = ompi_datatype_sndrcv(tmpsend, scount, sdtype, tmprecv, rcount, rdtype); rcount 404 ompi/mca/coll/base/coll_base_allgather.c tmprecv = (char*)rbuf + (ptrdiff_t)recvdatafrom * (ptrdiff_t)rcount * rext; rcount 405 ompi/mca/coll/base/coll_base_allgather.c tmpsend = (char*)rbuf + (ptrdiff_t)senddatafrom * (ptrdiff_t)rcount * rext; rcount 408 ompi/mca/coll/base/coll_base_allgather.c err = ompi_coll_base_sendrecv(tmpsend, rcount, rdtype, sendto, rcount 410 ompi/mca/coll/base/coll_base_allgather.c tmprecv, rcount, rdtype, recvfrom, rcount 486 ompi/mca/coll/base/coll_base_allgather.c void* rbuf, int rcount, rcount 504 ompi/mca/coll/base/coll_base_allgather.c rbuf, rcount, rdtype, rcount 518 ompi/mca/coll/base/coll_base_allgather.c tmprecv = (char*) rbuf + (ptrdiff_t)rank *(ptrdiff_t) rcount * rext; rcount 521 ompi/mca/coll/base/coll_base_allgather.c err = ompi_datatype_sndrcv(tmpsend, scount, sdtype, tmprecv, rcount, rdtype); rcount 550 ompi/mca/coll/base/coll_base_allgather.c tmprecv = (char*)rbuf + (ptrdiff_t)neighbor[0] * (ptrdiff_t)rcount * rext; rcount 551 ompi/mca/coll/base/coll_base_allgather.c tmpsend = (char*)rbuf + (ptrdiff_t)rank * (ptrdiff_t)rcount * rext; rcount 553 ompi/mca/coll/base/coll_base_allgather.c err = ompi_coll_base_sendrecv(tmpsend, rcount, rdtype, neighbor[0], rcount 555 ompi/mca/coll/base/coll_base_allgather.c tmprecv, rcount, rdtype, neighbor[0], rcount 572 ompi/mca/coll/base/coll_base_allgather.c tmprecv = (char*)rbuf + (ptrdiff_t)recv_data_from[i_parity] * (ptrdiff_t)rcount * rext; rcount 573 ompi/mca/coll/base/coll_base_allgather.c tmpsend = (char*)rbuf + (ptrdiff_t)send_data_from * rcount * rext; rcount 576 ompi/mca/coll/base/coll_base_allgather.c err = ompi_coll_base_sendrecv(tmpsend, (ptrdiff_t)2 * (ptrdiff_t)rcount, rdtype, rcount 579 ompi/mca/coll/base/coll_base_allgather.c tmprecv, (ptrdiff_t)2 * (ptrdiff_t)rcount, rdtype, rcount 600 ompi/mca/coll/base/coll_base_allgather.c void* rbuf, int rcount, rcount 629 ompi/mca/coll/base/coll_base_allgather.c tmpsend = (char*)rbuf + (ptrdiff_t)rank * (ptrdiff_t)rcount * rext; rcount 630 ompi/mca/coll/base/coll_base_allgather.c scount = rcount; rcount 633 ompi/mca/coll/base/coll_base_allgather.c tmprecv = (char*)rbuf + (ptrdiff_t)remote * (ptrdiff_t)rcount * rext; rcount 637 ompi/mca/coll/base/coll_base_allgather.c tmprecv, rcount, rdtype, remote, rcount 645 ompi/mca/coll/base/coll_base_allgather.c (char*)rbuf + (ptrdiff_t)rank * (ptrdiff_t)rcount * rext, rcount, rdtype); rcount 684 ompi/mca/coll/base/coll_base_allgather.c int rcount, rcount 699 ompi/mca/coll/base/coll_base_allgather.c sbuf = ((char*) rbuf) + (ompi_comm_rank(comm) * extent * rcount); rcount 701 ompi/mca/coll/base/coll_base_allgather.c scount = rcount; rcount 707 ompi/mca/coll/base/coll_base_allgather.c rbuf, rcount, rdtype, rcount 710 ompi/mca/coll/base/coll_base_allgather.c size_t length = (ptrdiff_t)rcount * ompi_comm_size(comm); rcount 712 ompi/mca/coll/base/coll_base_allgather.c err = comm->c_coll->coll_bcast(rbuf, (ptrdiff_t)rcount * ompi_comm_size(comm), rdtype, rcount 718 ompi/mca/coll/base/coll_base_allgather.c err = comm->c_coll->coll_bcast(rbuf, rcount, temptype, rcount 975 ompi/mca/coll/base/coll_base_allreduce.c int *rindex = NULL, *rcount = NULL, *sindex = NULL, *scount = NULL; rcount 1111 ompi/mca/coll/base/coll_base_allreduce.c rcount = malloc(sizeof(*rcount) * nsteps); rcount 1113 ompi/mca/coll/base/coll_base_allreduce.c if (NULL == rindex || NULL == sindex || NULL == rcount || NULL == scount) { rcount 1138 ompi/mca/coll/base/coll_base_allreduce.c rcount[step] = wsize / 2; rcount 1139 ompi/mca/coll/base/coll_base_allreduce.c scount[step] = wsize - rcount[step]; rcount 1140 ompi/mca/coll/base/coll_base_allreduce.c sindex[step] = rindex[step] + rcount[step]; rcount 1148 ompi/mca/coll/base/coll_base_allreduce.c rcount[step] = wsize - scount[step]; rcount 1157 ompi/mca/coll/base/coll_base_allreduce.c rcount[step], dtype, dest, rcount 1165 ompi/mca/coll/base/coll_base_allreduce.c rcount[step], dtype); rcount 1171 ompi/mca/coll/base/coll_base_allreduce.c wsize = rcount[step]; rcount 1200 ompi/mca/coll/base/coll_base_allreduce.c rcount[step], dtype, dest, rcount 1238 ompi/mca/coll/base/coll_base_allreduce.c if (NULL != rcount) rcount 1239 ompi/mca/coll/base/coll_base_allreduce.c free(rcount); rcount 40 ompi/mca/coll/base/coll_base_alltoall.c mca_coll_base_alltoall_intra_basic_inplace(const void *rbuf, int rcount, rcount 63 ompi/mca/coll/base/coll_base_alltoall.c max_size = opal_datatype_span(&rdtype->super, rcount, &gap); rcount 71 ompi/mca/coll/base/coll_base_alltoall.c max_size = ext * rcount; rcount 78 ompi/mca/coll/base/coll_base_alltoall.c err = ompi_datatype_copy_content_same_ddt (rdtype, rcount, tmp_buffer, rcount 83 ompi/mca/coll/base/coll_base_alltoall.c err = MCA_PML_CALL(irecv ((char *) rbuf + max_size * j, rcount, rdtype, rcount 87 ompi/mca/coll/base/coll_base_alltoall.c err = MCA_PML_CALL(send ((char *) tmp_buffer, rcount, rdtype, rcount 93 ompi/mca/coll/base/coll_base_alltoall.c err = ompi_datatype_copy_content_same_ddt (rdtype, rcount, tmp_buffer, rcount 98 ompi/mca/coll/base/coll_base_alltoall.c err = MCA_PML_CALL(irecv ((char *) rbuf + max_size * i, rcount, rdtype, rcount 102 ompi/mca/coll/base/coll_base_alltoall.c err = MCA_PML_CALL(send ((char *) tmp_buffer, rcount, rdtype, rcount 134 ompi/mca/coll/base/coll_base_alltoall.c void* rbuf, int rcount, rcount 144 ompi/mca/coll/base/coll_base_alltoall.c return mca_coll_base_alltoall_intra_basic_inplace (rbuf, rcount, rdtype, rcount 169 ompi/mca/coll/base/coll_base_alltoall.c tmprecv = (char*)rbuf + (ptrdiff_t)recvfrom * rext * (ptrdiff_t)rcount; rcount 174 ompi/mca/coll/base/coll_base_alltoall.c tmprecv, rcount, rdtype, recvfrom, rcount 193 ompi/mca/coll/base/coll_base_alltoall.c void* rbuf, int rcount, rcount 205 ompi/mca/coll/base/coll_base_alltoall.c return mca_coll_base_alltoall_intra_basic_inplace (rbuf, rcount, rdtype, rcount 293 ompi/mca/coll/base/coll_base_alltoall.c err = ompi_datatype_copy_content_same_ddt (rdtype, (int32_t) rcount, rcount 294 ompi/mca/coll/base/coll_base_alltoall.c ((char*)rbuf) + ((ptrdiff_t)((rank - i + size) % size) * (ptrdiff_t)rcount * rext), rcount 295 ompi/mca/coll/base/coll_base_alltoall.c tmpbuf + (ptrdiff_t)i * (ptrdiff_t)rcount * rext); rcount 335 ompi/mca/coll/base/coll_base_alltoall.c void* rbuf, int rcount, rcount 349 ompi/mca/coll/base/coll_base_alltoall.c return mca_coll_base_alltoall_intra_basic_inplace (rbuf, rcount, rdtype, rcount 371 ompi/mca/coll/base/coll_base_alltoall.c rext *= rcount; rcount 378 ompi/mca/coll/base/coll_base_alltoall.c error = ompi_datatype_sndrcv(psnd, scount, sdtype, prcv, rcount, rdtype); rcount 407 ompi/mca/coll/base/coll_base_alltoall.c (prcv + (ptrdiff_t)ri * rext, rcount, rdtype, ri, rcount 446 ompi/mca/coll/base/coll_base_alltoall.c (prcv + (ptrdiff_t)ri * rext, rcount, rdtype, ri, rcount 492 ompi/mca/coll/base/coll_base_alltoall.c void* rbuf, int rcount, rcount 502 ompi/mca/coll/base/coll_base_alltoall.c return mca_coll_base_alltoall_intra_basic_inplace (rbuf, rcount, rdtype, rcount 525 ompi/mca/coll/base/coll_base_alltoall.c tmprecv = (char*)rbuf + (ptrdiff_t)remote * rext * (ptrdiff_t)rcount; rcount 530 ompi/mca/coll/base/coll_base_alltoall.c tmprecv, rcount, rdtype, remote, rcount 538 ompi/mca/coll/base/coll_base_alltoall.c (char*) rbuf + (ptrdiff_t)rank * rext * (ptrdiff_t)rcount, rcount 539 ompi/mca/coll/base/coll_base_alltoall.c (int32_t) rcount, rdtype); rcount 571 ompi/mca/coll/base/coll_base_alltoall.c void* rbuf, int rcount, rcount 585 ompi/mca/coll/base/coll_base_alltoall.c return mca_coll_base_alltoall_intra_basic_inplace (rbuf, rcount, rdtype, rcount 607 ompi/mca/coll/base/coll_base_alltoall.c rcvinc *= rcount; rcount 614 ompi/mca/coll/base/coll_base_alltoall.c err = ompi_datatype_sndrcv(psnd, scount, sdtype, prcv, rcount, rdtype); rcount 639 ompi/mca/coll/base/coll_base_alltoall.c (prcv + (ptrdiff_t)i * rcvinc, rcount, rdtype, i, rcount 217 ompi/mca/coll/base/coll_base_functions.h int mca_coll_base_alltoall_intra_basic_inplace(const void *rbuf, int rcount, rcount 43 ompi/mca/coll/base/coll_base_gather.c void *rbuf, int rcount, rcount 72 ompi/mca/coll/base/coll_base_gather.c rsize = opal_datatype_span(&rdtype->super, (int64_t)rcount * size, &rgap); rcount 78 ompi/mca/coll/base/coll_base_gather.c ptmp, rcount, rdtype); rcount 93 ompi/mca/coll/base/coll_base_gather.c ptmp, rcount, rdtype); rcount 97 ompi/mca/coll/base/coll_base_gather.c err = ompi_datatype_copy_content_same_ddt(rdtype, rcount, ptmp, rcount 98 ompi/mca/coll/base/coll_base_gather.c (char *)rbuf + (ptrdiff_t)rank * rextent * (ptrdiff_t)rcount); rcount 102 ompi/mca/coll/base/coll_base_gather.c total_recv = rcount; rcount 123 ompi/mca/coll/base/coll_base_gather.c rcount = scount; rcount 125 ompi/mca/coll/base/coll_base_gather.c total_recv = rcount; rcount 142 ompi/mca/coll/base/coll_base_gather.c mycount *= rcount; rcount 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, rcount 173 ompi/mca/coll/base/coll_base_gather.c err = ompi_datatype_copy_content_same_ddt(rdtype, (ptrdiff_t)rcount * (ptrdiff_t)(size - root), rcount 174 ompi/mca/coll/base/coll_base_gather.c (char *)rbuf + rextent * (ptrdiff_t)root * (ptrdiff_t)rcount, ptmp); rcount 178 ompi/mca/coll/base/coll_base_gather.c err = ompi_datatype_copy_content_same_ddt(rdtype, (ptrdiff_t)rcount * (ptrdiff_t)root, rcount 179 ompi/mca/coll/base/coll_base_gather.c (char *) rbuf, ptmp + rextent * (ptrdiff_t)rcount * (ptrdiff_t)(size-root)); rcount 210 ompi/mca/coll/base/coll_base_gather.c void *rbuf, int rcount, rcount 275 ompi/mca/coll/base/coll_base_gather.c first_segment_count = rcount; rcount 288 ompi/mca/coll/base/coll_base_gather.c ptmp = (char*)rbuf + (ptrdiff_t)i * (ptrdiff_t)rcount * extent; rcount 301 ompi/mca/coll/base/coll_base_gather.c ptmp = (char*)rbuf + ((ptrdiff_t)i * (ptrdiff_t)rcount + first_segment_count) * extent; rcount 302 ompi/mca/coll/base/coll_base_gather.c ret = MCA_PML_CALL(irecv(ptmp, (rcount - first_segment_count), rcount 315 ompi/mca/coll/base/coll_base_gather.c (char*)rbuf + (ptrdiff_t)rank * (ptrdiff_t)rcount * extent, rcount 316 ompi/mca/coll/base/coll_base_gather.c rcount, rdtype); rcount 370 ompi/mca/coll/base/coll_base_gather.c void *rbuf, int rcount, rcount 396 ompi/mca/coll/base/coll_base_gather.c incr = extent * (ptrdiff_t)rcount; rcount 401 ompi/mca/coll/base/coll_base_gather.c ptmp, rcount, rdtype); rcount 406 ompi/mca/coll/base/coll_base_gather.c err = MCA_PML_CALL(recv(ptmp, rcount, rdtype, i, rcount 817 ompi/mca/coll/base/coll_base_reduce.c int *rindex = NULL, *rcount = NULL, *sindex = NULL, *scount = NULL; rcount 944 ompi/mca/coll/base/coll_base_reduce.c rcount = malloc(sizeof(*rcount) * nsteps); rcount 946 ompi/mca/coll/base/coll_base_reduce.c if (NULL == rindex || NULL == sindex || NULL == rcount || NULL == scount) { rcount 971 ompi/mca/coll/base/coll_base_reduce.c rcount[step] = wsize / 2; rcount 972 ompi/mca/coll/base/coll_base_reduce.c scount[step] = wsize - rcount[step]; rcount 973 ompi/mca/coll/base/coll_base_reduce.c sindex[step] = rindex[step] + rcount[step]; rcount 981 ompi/mca/coll/base/coll_base_reduce.c rcount[step] = wsize - scount[step]; rcount 990 ompi/mca/coll/base/coll_base_reduce.c rcount[step], dtype, dest, rcount 998 ompi/mca/coll/base/coll_base_reduce.c rcount[step], dtype); rcount 1004 ompi/mca/coll/base/coll_base_reduce.c wsize = rcount[step]; rcount 1034 ompi/mca/coll/base/coll_base_reduce.c rcount[step] = wsize / 2; rcount 1035 ompi/mca/coll/base/coll_base_reduce.c scount[step] = wsize - rcount[step]; rcount 1037 ompi/mca/coll/base/coll_base_reduce.c sindex[step] = rcount[step]; rcount 1042 ompi/mca/coll/base/coll_base_reduce.c err = MCA_PML_CALL(recv(rbuf, rcount[nsteps - 1], dtype, 0, rcount 1050 ompi/mca/coll/base/coll_base_reduce.c err = MCA_PML_CALL(send(rbuf, rcount[nsteps - 1], dtype, root, rcount 1091 ompi/mca/coll/base/coll_base_reduce.c rcount[step], dtype, dest, rcount 1117 ompi/mca/coll/base/coll_base_reduce.c if (NULL != rcount) rcount 1118 ompi/mca/coll/base/coll_base_reduce.c free(rcount); rcount 55 ompi/mca/coll/base/coll_base_reduce_scatter_block.c ompi_coll_base_reduce_scatter_block_basic_linear(const void *sbuf, void *rbuf, int rcount, rcount 70 ompi/mca/coll/base/coll_base_reduce_scatter_block.c count = rcount * size; rcount 101 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = comm->c_coll->coll_scatter(recv_buf, rcount, dtype, rcount 102 ompi/mca/coll/base/coll_base_reduce_scatter_block.c rbuf, rcount, dtype, 0, rcount 129 ompi/mca/coll/base/coll_base_reduce_scatter_block.c const void *sbuf, void *rbuf, int rcount, struct ompi_datatype_t *dtype, rcount 144 ompi/mca/coll/base/coll_base_reduce_scatter_block.c if (rcount == 0) rcount 149 ompi/mca/coll/base/coll_base_reduce_scatter_block.c totalcount = comm_size * rcount; rcount 191 ompi/mca/coll/base/coll_base_reduce_scatter_block.c blocklens[0] = rcount * cur_tree_root; rcount 193 ompi/mca/coll/base/coll_base_reduce_scatter_block.c rcount * (comm_size - cur_tree_root - mask) : 0; rcount 195 ompi/mca/coll/base/coll_base_reduce_scatter_block.c displs[1] = comm_size * rcount - blocklens[1]; rcount 202 ompi/mca/coll/base/coll_base_reduce_scatter_block.c blocklens[0] = rcount * remote_tree_root; rcount 204 ompi/mca/coll/base/coll_base_reduce_scatter_block.c rcount * (comm_size - remote_tree_root - mask) : 0; rcount 206 ompi/mca/coll/base/coll_base_reduce_scatter_block.c displs[1] = comm_size * rcount - blocklens[1]; rcount 282 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = ompi_datatype_copy_content_same_ddt(dtype, rcount, rbuf, rcount 283 ompi/mca/coll/base/coll_base_reduce_scatter_block.c tmpbuf + (ptrdiff_t)rank * rcount * extent); rcount 327 ompi/mca/coll/base/coll_base_reduce_scatter_block.c const void *sbuf, void *rbuf, int rcount, struct ompi_datatype_t *dtype, rcount 340 ompi/mca/coll/base/coll_base_reduce_scatter_block.c if (rcount == 0 || comm_size < 2) rcount 347 ompi/mca/coll/base/coll_base_reduce_scatter_block.c return ompi_coll_base_reduce_scatter_block_basic_linear(sbuf, rbuf, rcount, dtype, rcount 350 ompi/mca/coll/base/coll_base_reduce_scatter_block.c totalcount = comm_size * rcount; rcount 438 ompi/mca/coll/base/coll_base_reduce_scatter_block.c send_count = rcount * ompi_range_sum(send_index, last_index - 1, nprocs_rem - 1); rcount 439 ompi/mca/coll/base/coll_base_reduce_scatter_block.c recv_count = rcount * ompi_range_sum(recv_index, send_index - 1, nprocs_rem - 1); rcount 443 ompi/mca/coll/base/coll_base_reduce_scatter_block.c send_count = rcount * ompi_range_sum(send_index, recv_index - 1, nprocs_rem - 1); rcount 444 ompi/mca/coll/base/coll_base_reduce_scatter_block.c recv_count = rcount * ompi_range_sum(recv_index, last_index - 1, nprocs_rem - 1); rcount 446 ompi/mca/coll/base/coll_base_reduce_scatter_block.c ptrdiff_t rdispl = rcount * ((recv_index <= nprocs_rem - 1) ? rcount 448 ompi/mca/coll/base/coll_base_reduce_scatter_block.c ptrdiff_t sdispl = rcount * ((send_index <= nprocs_rem - 1) ? rcount 474 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = ompi_datatype_copy_content_same_ddt(dtype, rcount, rbuf, rcount 475 ompi/mca/coll/base/coll_base_reduce_scatter_block.c tmpbuf + (ptrdiff_t)rank * rcount * extent); rcount 483 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = MCA_PML_CALL(recv(rbuf, rcount, dtype, rank + 1, rcount 489 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = MCA_PML_CALL(send(tmpbuf + (ptrdiff_t)(rank - 1) * rcount * extent, rcount 490 ompi/mca/coll/base/coll_base_reduce_scatter_block.c rcount, dtype, rank - 1, rcount 506 ompi/mca/coll/base/coll_base_reduce_scatter_block.c const void *sbuf, void *rbuf, int rcount, struct ompi_datatype_t *dtype, rcount 568 ompi/mca/coll/base/coll_base_reduce_scatter_block.c const void *sbuf, void *rbuf, int rcount, struct ompi_datatype_t *dtype, rcount 581 ompi/mca/coll/base/coll_base_reduce_scatter_block.c if (rcount == 0 || comm_size < 2) rcount 587 ompi/mca/coll/base/coll_base_reduce_scatter_block.c sbuf, rbuf, rcount, dtype, op, comm, module); rcount 590 ompi/mca/coll/base/coll_base_reduce_scatter_block.c totalcount = comm_size * rcount; rcount 680 ompi/mca/coll/base/coll_base_reduce_scatter_block.c int send_count = rcount * ompi_range_sum(send_index, rcount 682 ompi/mca/coll/base/coll_base_reduce_scatter_block.c int recv_count = rcount * ompi_range_sum(recv_index, rcount 684 ompi/mca/coll/base/coll_base_reduce_scatter_block.c ptrdiff_t sdispl = rcount * ((send_index <= nprocs_rem - 1) ? rcount 686 ompi/mca/coll/base/coll_base_reduce_scatter_block.c ptrdiff_t rdispl = rcount * ((recv_index <= nprocs_rem - 1) ? rcount 722 ompi/mca/coll/base/coll_base_reduce_scatter_block.c ptrdiff_t sdispl = rcount * ((send_index <= nprocs_rem - 1) ? rcount 725 ompi/mca/coll/base/coll_base_reduce_scatter_block.c rcount, dtype, peer - 1, rcount 732 ompi/mca/coll/base/coll_base_reduce_scatter_block.c ptrdiff_t sdispl = rcount * ((send_index <= nprocs_rem - 1) ? rcount 736 ompi/mca/coll/base/coll_base_reduce_scatter_block.c sdispl += rcount; rcount 738 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = ompi_coll_base_sendrecv(psend + (ptrdiff_t)sdispl * extent, rcount, rcount 740 ompi/mca/coll/base/coll_base_reduce_scatter_block.c rbuf, rcount, dtype, peer, rcount 745 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = ompi_datatype_copy_content_same_ddt(dtype, rcount, rbuf, rcount 754 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = MCA_PML_CALL(recv(rbuf, rcount, dtype, peer, rcount 811 ompi/mca/coll/base/coll_base_reduce_scatter_block.c const void *sbuf, void *rbuf, int rcount, struct ompi_datatype_t *dtype, rcount 821 ompi/mca/coll/base/coll_base_reduce_scatter_block.c if (rcount == 0 || comm_size < 2) rcount 824 ompi/mca/coll/base/coll_base_reduce_scatter_block.c totalcount = comm_size * rcount; rcount 840 ompi/mca/coll/base/coll_base_reduce_scatter_block.c char *src = pdata + (ptrdiff_t)i * extent * rcount; rcount 841 ompi/mca/coll/base/coll_base_reduce_scatter_block.c char *dst = psend + (ptrdiff_t)ompi_mirror_perm(i, log2_comm_size) * extent * rcount; rcount 842 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = ompi_datatype_copy_content_same_ddt(dtype, rcount, dst, src); rcount 882 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = ompi_datatype_copy_content_same_ddt(dtype, rcount, rbuf, rcount 64 ompi/mca/coll/base/coll_base_scatter.c void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 100 ompi/mca/coll/base/coll_base_scatter.c rbuf, rcount, rdtype); rcount 123 ompi/mca/coll/base/coll_base_scatter.c rbuf, rcount, rdtype); rcount 131 ompi/mca/coll/base/coll_base_scatter.c rsize = opal_datatype_span(&rdtype->super, (int64_t)rcount * size, &rgap); rcount 138 ompi/mca/coll/base/coll_base_scatter.c scount = rcount; rcount 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, rcount 157 ompi/mca/coll/base/coll_base_scatter.c rbuf, rcount, rdtype); rcount 179 ompi/mca/coll/base/coll_base_scatter.c err = MCA_PML_CALL(recv(ptmp, rcount, rdtype, bmtree->tree_prev, rcount 219 ompi/mca/coll/base/coll_base_scatter.c void *rbuf, int rcount, rcount 237 ompi/mca/coll/base/coll_base_scatter.c err = MCA_PML_CALL(recv(rbuf, rcount, rdtype, root, rcount 258 ompi/mca/coll/base/coll_base_scatter.c ompi_datatype_sndrcv(ptmp, scount, sdtype, rbuf, rcount, rcount 35 ompi/mca/coll/base/coll_base_util.c void* recvbuf, size_t rcount, rcount 49 ompi/mca/coll/base/coll_base_util.c err = MCA_PML_CALL(irecv( recvbuf, rcount, rdatatype, source, rtag, rcount 42 ompi/mca/coll/base/coll_base_util.h void* recvbuf, size_t rcount, rcount 58 ompi/mca/coll/base/coll_base_util.h void* recvbuf, size_t rcount, ompi_datatype_t* rdatatype, rcount 65 ompi/mca/coll/base/coll_base_util.h recvbuf, (int32_t) rcount, rdatatype); rcount 69 ompi/mca/coll/base/coll_base_util.h recvbuf, rcount, rdatatype, rcount 60 ompi/mca/coll/basic/coll_basic.h void *rbuf, int rcount, rcount 86 ompi/mca/coll/basic/coll_basic.h void *rbuf, int rcount, rcount 155 ompi/mca/coll/basic/coll_basic.h void *rbuf, int rcount, rcount 198 ompi/mca/coll/basic/coll_basic.h int rcount, rcount 205 ompi/mca/coll/basic/coll_basic.h int rcount, rcount 238 ompi/mca/coll/basic/coll_basic.h void *rbuf, int rcount, rcount 246 ompi/mca/coll/basic/coll_basic.h void *rbuf, int rcount, rcount 253 ompi/mca/coll/basic/coll_basic.h void *rbuf, int rcount, rcount 261 ompi/mca/coll/basic/coll_basic.h int rcount, struct ompi_datatype_t *rdtype, rcount 270 ompi/mca/coll/basic/coll_basic.h int rcount, struct ompi_datatype_t *rdtype, struct ompi_communicator_t *comm, rcount 46 ompi/mca/coll/basic/coll_basic_allgather.c void *rbuf, int rcount, rcount 92 ompi/mca/coll/basic/coll_basic_allgather.c err = MCA_PML_CALL(irecv(rbuf, rcount, rdtype, 0, rcount 97 ompi/mca/coll/basic/coll_basic_allgather.c incr = rextent * rcount; rcount 100 ompi/mca/coll/basic/coll_basic_allgather.c err = MCA_PML_CALL(irecv(ptmp, rcount, rdtype, i, rcount 115 ompi/mca/coll/basic/coll_basic_allgather.c err = MCA_PML_CALL(isend(rbuf, rsize * rcount, rdtype, 0, rcount 136 ompi/mca/coll/basic/coll_basic_allgather.c err = MCA_PML_CALL(recv(rbuf, rsize * rcount, rdtype, 0, rcount 46 ompi/mca/coll/basic/coll_basic_alltoall.c void *rbuf, int rcount, rcount 77 ompi/mca/coll/basic/coll_basic_alltoall.c rcvinc *= rcount; rcount 90 ompi/mca/coll/basic/coll_basic_alltoall.c err = MCA_PML_CALL(irecv(prcv + (i * rcvinc), rcount, rdtype, i, rcount 43 ompi/mca/coll/basic/coll_basic_gather.c void *rbuf, int rcount, rcount 73 ompi/mca/coll/basic/coll_basic_gather.c incr = extent * rcount; rcount 75 ompi/mca/coll/basic/coll_basic_gather.c err = MCA_PML_CALL(recv(ptmp, rcount, rdtype, i, rcount 42 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c int rcount, struct ompi_datatype_t *rdtype, rcount 72 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c rc = MCA_PML_CALL(irecv(rbuf, rcount, rdtype, srank, rcount 87 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c rbuf = (char *) rbuf + extent * rcount; rcount 91 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c rc = MCA_PML_CALL(irecv(rbuf, rcount, rdtype, drank, rcount 104 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c rbuf = (char *) rbuf + extent * rcount; rcount 122 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c int rcount, struct ompi_datatype_t *rdtype, rcount 147 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c rc = MCA_PML_CALL(irecv(rbuf, rcount, rdtype, edges[neighbor], MCA_COLL_BASE_TAG_ALLGATHER, rcount 150 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c rbuf = (char *) rbuf + extent * rcount; rcount 175 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c int rcount, struct ompi_datatype_t *rdtype, rcount 198 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c rc = MCA_PML_CALL(irecv(rbuf, rcount, rdtype, inedges[neighbor], rcount 202 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c rbuf = (char *) rbuf + extent * rcount; rcount 234 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c int rcount, struct ompi_datatype_t *rdtype, rcount 244 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c rcount, rdtype, comm, module); rcount 247 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c rcount, rdtype, comm, module); rcount 250 ompi/mca/coll/basic/coll_basic_neighbor_allgather.c rcount, rdtype, comm, module); rcount 41 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c int rcount, struct ompi_datatype_t *rdtype, struct ompi_communicator_t *comm, rcount 69 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c rc = MCA_PML_CALL(irecv(rbuf, rcount, rdtype, srank, rcount 75 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c rbuf = (char *) rbuf + rdextent * rcount; rcount 79 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c rc = MCA_PML_CALL(irecv(rbuf, rcount, rdtype, drank, rcount 85 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c rbuf = (char *) rbuf + rdextent * rcount; rcount 141 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c int rcount, struct ompi_datatype_t *rdtype, struct ompi_communicator_t *comm, rcount 166 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c rc = MCA_PML_CALL(irecv(rbuf, rcount, rdtype, edges[neighbor], MCA_COLL_BASE_TAG_ALLTOALL, rcount 169 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c rbuf = (char *) rbuf + rdextent * rcount; rcount 200 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c int rcount, struct ompi_datatype_t *rdtype, struct ompi_communicator_t *comm, rcount 224 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c rc = MCA_PML_CALL(irecv(rbuf, rcount, rdtype, inedges[neighbor], rcount 228 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c rbuf = (char *) rbuf + rdextent * rcount; rcount 258 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c int rcount, struct ompi_datatype_t *rdtype, struct ompi_communicator_t *comm, rcount 267 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c rcount, rdtype, comm, module); rcount 270 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c rcount, rdtype, comm, module); rcount 273 ompi/mca/coll/basic/coll_basic_neighbor_alltoall.c rcount, rdtype, comm, module); rcount 54 ompi/mca/coll/basic/coll_basic_reduce_scatter_block.c mca_coll_basic_reduce_scatter_block_intra(const void *sbuf, void *rbuf, int rcount, rcount 60 ompi/mca/coll/basic/coll_basic_reduce_scatter_block.c return ompi_coll_base_reduce_scatter_block_basic_linear(sbuf, rbuf, rcount, dtype, op, comm, module); rcount 71 ompi/mca/coll/basic/coll_basic_reduce_scatter_block.c mca_coll_basic_reduce_scatter_block_inter(const void *sbuf, void *rbuf, int rcount, rcount 88 ompi/mca/coll/basic/coll_basic_reduce_scatter_block.c totalcounts = lsize * rcount; rcount 165 ompi/mca/coll/basic/coll_basic_reduce_scatter_block.c err = comm->c_local_comm->c_coll->coll_scatter(lbuf, rcount, dtype, rcount 166 ompi/mca/coll/basic/coll_basic_reduce_scatter_block.c rbuf, rcount, dtype, 0, rcount 44 ompi/mca/coll/basic/coll_basic_scatter.c void *rbuf, int rcount, rcount 62 ompi/mca/coll/basic/coll_basic_scatter.c err = MCA_PML_CALL(recv(rbuf, rcount, rdtype, root, rcount 44 ompi/mca/coll/basic/coll_basic_scatterv.c void *rbuf, int rcount, rcount 62 ompi/mca/coll/basic/coll_basic_scatterv.c if (rcount > 0) { rcount 63 ompi/mca/coll/basic/coll_basic_scatterv.c return MCA_PML_CALL(recv(rbuf, rcount, rdtype, rcount 85 ompi/mca/coll/basic/coll_basic_scatterv.c err = ompi_datatype_sndrcv(ptmp, scounts[i], sdtype, rbuf, rcount, rcount 117 ompi/mca/coll/basic/coll_basic_scatterv.c void *rbuf, int rcount, rcount 138 ompi/mca/coll/basic/coll_basic_scatterv.c err = MCA_PML_CALL(recv(rbuf, rcount, rdtype, rcount 202 ompi/mca/coll/coll.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 213 ompi/mca/coll/coll.h void* rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 233 ompi/mca/coll/coll.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 246 ompi/mca/coll/coll.h (const void *sbuf, void *rbuf, int rcount, struct ompi_datatype_t *dtype, rcount 253 ompi/mca/coll/coll.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 257 ompi/mca/coll/coll.h void* rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 263 ompi/mca/coll/coll.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 277 ompi/mca/coll/coll.h void* rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 303 ompi/mca/coll/coll.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 320 ompi/mca/coll/coll.h (const void *sbuf, void *rbuf, int rcount, struct ompi_datatype_t *dtype, rcount 329 ompi/mca/coll/coll.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 334 ompi/mca/coll/coll.h void* rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 341 ompi/mca/coll/coll.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 355 ompi/mca/coll/coll.h void* rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 381 ompi/mca/coll/coll.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 398 ompi/mca/coll/coll.h (const void *sbuf, void *rbuf, int rcount, struct ompi_datatype_t *dtype, rcount 407 ompi/mca/coll/coll.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 412 ompi/mca/coll/coll.h void* rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 68 ompi/mca/coll/cuda/coll_cuda.h mca_coll_cuda_reduce_scatter_block(const void *sbuf, void *rbuf, int rcount, rcount 34 ompi/mca/coll/cuda/coll_cuda_reduce_scatter_block.c mca_coll_cuda_reduce_scatter_block(const void *sbuf, void *rbuf, int rcount, rcount 46 ompi/mca/coll/cuda/coll_cuda_reduce_scatter_block.c rbufsize = opal_datatype_span(&dtype->super, rcount, &gap); rcount 69 ompi/mca/coll/cuda/coll_cuda_reduce_scatter_block.c rc = s->c_coll.coll_reduce_scatter_block(sbuf, rbuf, rcount, dtype, op, comm, rcount 52 ompi/mca/coll/demo/coll_demo.h void *rbuf, int rcount, rcount 58 ompi/mca/coll/demo/coll_demo.h void *rbuf, int rcount, rcount 89 ompi/mca/coll/demo/coll_demo.h void* rbuf, int rcount, rcount 95 ompi/mca/coll/demo/coll_demo.h void* rbuf, int rcount, rcount 155 ompi/mca/coll/demo/coll_demo.h int rcount, struct ompi_datatype_t *rdtype, rcount 160 ompi/mca/coll/demo/coll_demo.h int rcount, struct ompi_datatype_t *rdtype, rcount 216 ompi/mca/coll/demo/coll_demo.h int rcount, struct ompi_datatype_t *rdtype, rcount 221 ompi/mca/coll/demo/coll_demo.h int rcount, struct ompi_datatype_t *rdtype, rcount 227 ompi/mca/coll/demo/coll_demo.h void* rbuf, int rcount, rcount 233 ompi/mca/coll/demo/coll_demo.h void* rbuf, int rcount, rcount 38 ompi/mca/coll/demo/coll_demo_allgather.c int rcount, struct ompi_datatype_t *rdtype, rcount 45 ompi/mca/coll/demo/coll_demo_allgather.c rcount, rdtype, comm, rcount 59 ompi/mca/coll/demo/coll_demo_allgather.c void *rbuf, int rcount, rcount 67 ompi/mca/coll/demo/coll_demo_allgather.c rcount, rdtype, comm, rcount 38 ompi/mca/coll/demo/coll_demo_alltoall.c void *rbuf, int rcount, rcount 46 ompi/mca/coll/demo/coll_demo_alltoall.c rbuf, rcount, rdtype, rcount 61 ompi/mca/coll/demo/coll_demo_alltoall.c void *rbuf, int rcount, rcount 69 ompi/mca/coll/demo/coll_demo_alltoall.c rbuf, rcount, rdtype, rcount 37 ompi/mca/coll/demo/coll_demo_gather.c void *rbuf, int rcount, rcount 45 ompi/mca/coll/demo/coll_demo_gather.c rbuf, rcount, rdtype, rcount 60 ompi/mca/coll/demo/coll_demo_gather.c void *rbuf, int rcount, rcount 68 ompi/mca/coll/demo/coll_demo_gather.c rbuf, rcount, rdtype, rcount 38 ompi/mca/coll/demo/coll_demo_scatter.c void *rbuf, int rcount, rcount 47 ompi/mca/coll/demo/coll_demo_scatter.c rbuf, rcount, rdtype, rcount 62 ompi/mca/coll/demo/coll_demo_scatter.c void *rbuf, int rcount, rcount 71 ompi/mca/coll/demo/coll_demo_scatter.c rbuf, rcount, rdtype, rcount 38 ompi/mca/coll/demo/coll_demo_scatterv.c void *rbuf, int rcount, rcount 46 ompi/mca/coll/demo/coll_demo_scatterv.c sdtype, rbuf, rcount, rcount 61 ompi/mca/coll/demo/coll_demo_scatterv.c void *rbuf, int rcount, rcount 69 ompi/mca/coll/demo/coll_demo_scatterv.c sdtype, rbuf, rcount, rcount 188 ompi/mca/coll/hcoll/coll_hcoll.h void *rbuf, int rcount, rcount 195 ompi/mca/coll/hcoll/coll_hcoll.h void *rbuf, const int *rcount, rcount 203 ompi/mca/coll/hcoll/coll_hcoll.h void *rbuf, int rcount, rcount 224 ompi/mca/coll/hcoll/coll_hcoll.h void* rbuf, int rcount, rcount 249 ompi/mca/coll/hcoll/coll_hcoll.h void* rbuf, int rcount, rcount 267 ompi/mca/coll/hcoll/coll_hcoll.h void *rbuf, int rcount, rcount 275 ompi/mca/coll/hcoll/coll_hcoll.h void *rbuf, const int *rcount, rcount 299 ompi/mca/coll/hcoll/coll_hcoll.h void* rbuf, int rcount, rcount 70 ompi/mca/coll/hcoll/coll_hcoll_ops.c void *rbuf, int rcount, rcount 93 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf,rcount,rdtype, rcount 98 ompi/mca/coll/hcoll/coll_hcoll_ops.c rc = hcoll_collectives.coll_allgather((void *)sbuf,scount,stype,rbuf,rcount,rtype,hcoll_module->hcoll_context); rcount 102 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf,rcount,rdtype, rcount 111 ompi/mca/coll/hcoll/coll_hcoll_ops.c void *rbuf, const int *rcount, rcount 132 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf,rcount, rcount 139 ompi/mca/coll/hcoll/coll_hcoll_ops.c rc = hcoll_collectives.coll_allgatherv((void *)sbuf,scount,stype,rbuf,rcount,displs,rtype,hcoll_module->hcoll_context); rcount 143 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf,rcount, rcount 154 ompi/mca/coll/hcoll/coll_hcoll_ops.c void *rbuf, int rcount, rcount 174 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf,rcount,rdtype,root, rcount 179 ompi/mca/coll/hcoll/coll_hcoll_ops.c rc = hcoll_collectives.coll_gather((void *)sbuf,scount,stype,rbuf,rcount,rtype,root,hcoll_module->hcoll_context); rcount 183 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf,rcount,rdtype,root, rcount 291 ompi/mca/coll/hcoll/coll_hcoll_ops.c void* rbuf, int rcount, rcount 311 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf,rcount,rdtype, rcount 316 ompi/mca/coll/hcoll/coll_hcoll_ops.c rc = hcoll_collectives.coll_alltoall((void *)sbuf,scount,stype,rbuf,rcount,rtype,hcoll_module->hcoll_context); rcount 320 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf,rcount,rdtype, rcount 402 ompi/mca/coll/hcoll/coll_hcoll_ops.c void* rbuf, int rcount, rcount 423 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf, rcount, rdtype, root, rcount 427 ompi/mca/coll/hcoll/coll_hcoll_ops.c rc = hcoll_collectives.coll_scatterv((void *)sbuf, (int *)scounts, (int *)displs, stype, rbuf, rcount, rtype, root, hcoll_module->hcoll_context); rcount 431 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf, rcount, rdtype, root, rcount 487 ompi/mca/coll/hcoll/coll_hcoll_ops.c void *rbuf, int rcount, rcount 510 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf,rcount,rdtype, rcount 516 ompi/mca/coll/hcoll/coll_hcoll_ops.c rc = hcoll_collectives.coll_iallgather((void *)sbuf, scount, stype, rbuf, rcount, rtype, hcoll_module->hcoll_context, rt_handle); rcount 520 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf,rcount,rdtype, rcount 530 ompi/mca/coll/hcoll/coll_hcoll_ops.c void *rbuf, const int *rcount, rcount 553 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf,rcount, rcount 561 ompi/mca/coll/hcoll/coll_hcoll_ops.c rc = hcoll_collectives.coll_iallgatherv((void *)sbuf,scount,stype,rbuf,rcount,displs,rtype, rcount 566 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf,rcount, rcount 58 ompi/mca/coll/inter/coll_inter.h void *rbuf, int rcount, rcount 80 ompi/mca/coll/inter/coll_inter.h void *rbuf, int rcount, rcount 100 ompi/mca/coll/inter/coll_inter.h int rcount, struct ompi_datatype_t *rdtype, rcount 105 ompi/mca/coll/inter/coll_inter.h void* rbuf, int rcount, rcount 46 ompi/mca/coll/inter/coll_inter_allgather.c void *rbuf, int rcount, rcount 81 ompi/mca/coll/inter/coll_inter_allgather.c rbuf, rcount*rsize, rdtype, 0, rcount 89 ompi/mca/coll/inter/coll_inter_allgather.c if ( rcount > 0 ) { rcount 90 ompi/mca/coll/inter/coll_inter_allgather.c err = comm->c_local_comm->c_coll->coll_bcast(rbuf, rcount*rsize, rdtype, rcount 43 ompi/mca/coll/inter/coll_inter_gather.c void *rbuf, int rcount, rcount 89 ompi/mca/coll/inter/coll_inter_gather.c err = MCA_PML_CALL(recv(rbuf, rcount*size, rdtype, 0, rcount 42 ompi/mca/coll/inter/coll_inter_scatter.c void *rbuf, int rcount, rcount 65 ompi/mca/coll/inter/coll_inter_scatter.c span = opal_datatype_span(&rdtype->super, (int64_t)rcount*(int64_t)size_local, &gap); rcount 72 ompi/mca/coll/inter/coll_inter_scatter.c err = MCA_PML_CALL(recv(ptmp, rcount*size_local, rdtype, rcount 80 ompi/mca/coll/inter/coll_inter_scatter.c err = comm->c_local_comm->c_coll->coll_scatter(ptmp, rcount, rdtype, rcount 81 ompi/mca/coll/inter/coll_inter_scatter.c rbuf, rcount, rdtype, rcount 43 ompi/mca/coll/inter/coll_inter_scatterv.c void *rbuf, int rcount, rcount 100 ompi/mca/coll/inter/coll_inter_scatterv.c rdtype, rbuf, rcount, rcount 206 ompi/mca/coll/libnbc/coll_libnbc.h int ompi_coll_libnbc_ireduce_scatter_block(const void *sbuf, void *rbuf, int rcount, struct ompi_datatype_t *dtype, rcount 261 ompi/mca/coll/libnbc/coll_libnbc.h int ompi_coll_libnbc_ireduce_scatter_block_inter(const void *sbuf, void *rbuf, int rcount, struct ompi_datatype_t *dtype, rcount 276 ompi/mca/coll/libnbc/coll_libnbc.h int rcount, MPI_Datatype rtype, struct ompi_communicator_t *comm, rcount 283 ompi/mca/coll/libnbc/coll_libnbc.h int rcount, MPI_Datatype rtype, struct ompi_communicator_t *comm, rcount 335 ompi/mca/coll/libnbc/coll_libnbc.h int ompi_coll_libnbc_reduce_scatter_block_init(const void *sbuf, void *rbuf, int rcount, struct ompi_datatype_t *dtype, rcount 388 ompi/mca/coll/libnbc/coll_libnbc.h int ompi_coll_libnbc_reduce_scatter_block_inter_init(const void *sbuf, void *rbuf, int rcount, struct ompi_datatype_t *dtype, rcount 402 ompi/mca/coll/libnbc/coll_libnbc.h int rcount, MPI_Datatype rtype, struct ompi_communicator_t *comm, rcount 409 ompi/mca/coll/libnbc/coll_libnbc.h int rcount, MPI_Datatype rtype, struct ompi_communicator_t *comm, MPI_Info info, rcount 25 ompi/mca/coll/libnbc/nbc_iallgather.c int scount, struct ompi_datatype_t *sdtype, void *recvbuf, int rcount, rcount 29 ompi/mca/coll/libnbc/nbc_iallgather.c int scount, struct ompi_datatype_t *sdtype, void *rbuf, int rcount, rcount 299 ompi/mca/coll/libnbc/nbc_iallgather.c int scount, struct ompi_datatype_t *sdtype, void *recvbuf, int rcount, rcount 306 ompi/mca/coll/libnbc/nbc_iallgather.c char *sbuf = (char *)recvbuf + rank * rcount * rext; rcount 311 ompi/mca/coll/libnbc/nbc_iallgather.c char *rbuf = (char *)recvbuf + remote * rcount * rext; rcount 312 ompi/mca/coll/libnbc/nbc_iallgather.c res = NBC_Sched_recv(rbuf, false, rcount, rdtype, remote, schedule, false); rcount 316 ompi/mca/coll/libnbc/nbc_iallgather.c res = NBC_Sched_send(sbuf, false, rcount, rdtype, remote, schedule, false); rcount 357 ompi/mca/coll/libnbc/nbc_iallgather.c int scount, struct ompi_datatype_t *sdtype, void *rbuf, int rcount, rcount 371 ompi/mca/coll/libnbc/nbc_iallgather.c tmpsend = (char *)rbuf + (ptrdiff_t)sendblocklocation * (ptrdiff_t)rcount * rext; rcount 373 ompi/mca/coll/libnbc/nbc_iallgather.c tmprecv = (char *)rbuf + (ptrdiff_t)(sendblocklocation + distance) * (ptrdiff_t)rcount * rext; rcount 375 ompi/mca/coll/libnbc/nbc_iallgather.c tmprecv = (char *)rbuf + (ptrdiff_t)(sendblocklocation - distance) * (ptrdiff_t)rcount * rext; rcount 379 ompi/mca/coll/libnbc/nbc_iallgather.c res = NBC_Sched_send(tmpsend, false, (ptrdiff_t)distance * (ptrdiff_t)rcount, rcount 383 ompi/mca/coll/libnbc/nbc_iallgather.c res = NBC_Sched_recv(tmprecv, false, (ptrdiff_t)distance * (ptrdiff_t)rcount, rcount 819 ompi/mca/coll/libnbc/nbc_iallreduce.c int *rindex = NULL, *rcount = NULL, *sindex = NULL, *scount = NULL; rcount 912 ompi/mca/coll/libnbc/nbc_iallreduce.c rcount = malloc(sizeof(*rcount) * nsteps); rcount 914 ompi/mca/coll/libnbc/nbc_iallreduce.c if (NULL == rindex || NULL == sindex || NULL == rcount || NULL == scount) { rcount 936 ompi/mca/coll/libnbc/nbc_iallreduce.c rcount[step] = wsize / 2; rcount 937 ompi/mca/coll/libnbc/nbc_iallreduce.c scount[step] = wsize - rcount[step]; rcount 938 ompi/mca/coll/libnbc/nbc_iallreduce.c sindex[step] = rindex[step] + rcount[step]; rcount 946 ompi/mca/coll/libnbc/nbc_iallreduce.c rcount[step] = wsize - scount[step]; rcount 954 ompi/mca/coll/libnbc/nbc_iallreduce.c false, rcount[step], datatype, dest, schedule, true); rcount 959 ompi/mca/coll/libnbc/nbc_iallreduce.c false, rcount[step], datatype, op, schedule, true); rcount 965 ompi/mca/coll/libnbc/nbc_iallreduce.c wsize = rcount[step]; rcount 990 ompi/mca/coll/libnbc/nbc_iallreduce.c false, rcount[step], datatype, dest, schedule, false); rcount 1017 ompi/mca/coll/libnbc/nbc_iallreduce.c if (NULL != rcount) rcount 1018 ompi/mca/coll/libnbc/nbc_iallreduce.c free(rcount); rcount 33 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c (a->rcount == b->rcount) && rcount 48 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c int rcount, MPI_Datatype rtype, struct ompi_communicator_t *comm, rcount 70 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c search.rcount = rcount; rcount 89 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c res = NBC_Sched_recv ((char *) rbuf + i * rcount * rcvext, true, rcount, rtype, srcs[i], schedule, false); rcount 134 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c args->rcount = rcount; rcount 167 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c int rcount, MPI_Datatype rtype, struct ompi_communicator_t *comm, rcount 169 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c int res = nbc_neighbor_allgather_init(sbuf, scount, stype, rbuf, rcount, rtype, rcount 186 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c int rcount, MPI_Datatype rtype, struct ompi_communicator_t *comm, rcount 188 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c int res = nbc_neighbor_allgather_init(sbuf, scount, stype, rbuf, rcount, rtype, rcount 33 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c (a->rcount == b->rcount) && rcount 70 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c search.rcount = rcount; rcount 134 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c args->rcount = rcount; rcount 33 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c (a->rcount == b->rcount) && rcount 45 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c int rcount, MPI_Datatype rtype, struct ompi_communicator_t *comm, rcount 73 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c search.rcount = rcount; rcount 92 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c res = NBC_Sched_recv ((char *) rbuf + i * rcount * rcvext, true, rcount, rtype, srcs[i], schedule, false); rcount 137 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c args->rcount = rcount; rcount 171 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c int rcount, MPI_Datatype rtype, struct ompi_communicator_t *comm, rcount 173 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c int res = nbc_neighbor_alltoall_init(sbuf, scount, stype, rbuf, rcount, rtype, rcount 189 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c int rcount, MPI_Datatype rtype, struct ompi_communicator_t *comm, MPI_Info info, rcount 191 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c int res = nbc_neighbor_alltoall_init(sbuf, scount, stype, rbuf, rcount, rtype, rcount 33 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c (a->rcount == b->rcount) && rcount 76 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c search.rcount = rcount; rcount 141 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c args->rcount = rcount; rcount 33 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c (a->rcount == b->rcount) && rcount 62 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c search.rcount = rcount; rcount 127 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c args->rcount = rcount; rcount 655 ompi/mca/coll/libnbc/nbc_ireduce.c int *rindex = NULL, *rcount = NULL, *sindex = NULL, *scount = NULL; rcount 770 ompi/mca/coll/libnbc/nbc_ireduce.c rcount = malloc(sizeof(*rcount) * nsteps); rcount 772 ompi/mca/coll/libnbc/nbc_ireduce.c if (NULL == rindex || NULL == sindex || NULL == rcount || NULL == scount) { rcount 797 ompi/mca/coll/libnbc/nbc_ireduce.c rcount[step] = wsize / 2; rcount 798 ompi/mca/coll/libnbc/nbc_ireduce.c scount[step] = wsize - rcount[step]; rcount 799 ompi/mca/coll/libnbc/nbc_ireduce.c sindex[step] = rindex[step] + rcount[step]; rcount 807 ompi/mca/coll/libnbc/nbc_ireduce.c rcount[step] = wsize - scount[step]; rcount 816 ompi/mca/coll/libnbc/nbc_ireduce.c false, rcount[step], datatype, dest, schedule, true); rcount 822 ompi/mca/coll/libnbc/nbc_ireduce.c tmpredbuf, rcount[step], datatype, op, schedule, true); rcount 829 ompi/mca/coll/libnbc/nbc_ireduce.c wsize = rcount[step]; rcount 859 ompi/mca/coll/libnbc/nbc_ireduce.c rcount[step] = wsize / 2; rcount 860 ompi/mca/coll/libnbc/nbc_ireduce.c scount[step] = wsize - rcount[step]; rcount 862 ompi/mca/coll/libnbc/nbc_ireduce.c sindex[step] = rcount[step]; rcount 867 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_recv(rbuf, tmpredbuf, rcount[nsteps - 1], datatype, rcount 874 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_send(rbuf, tmpredbuf, rcount[nsteps - 1], datatype, rcount 915 ompi/mca/coll/libnbc/nbc_ireduce.c tmpredbuf, rcount[step], datatype, dest, schedule, false); rcount 933 ompi/mca/coll/libnbc/nbc_ireduce.c if (NULL != rcount) rcount 934 ompi/mca/coll/libnbc/nbc_ireduce.c free(rcount); rcount 228 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c static int nbc_reduce_scatter_block_inter_init(const void *sendbuf, void *recvbuf, int rcount, struct ompi_datatype_t *dtype, rcount 248 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c count = rcount * lsize; rcount 305 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_copy (lbuf, true, rcount, dtype, recvbuf, false, rcount, rcount 313 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_local_send (lbuf + ext * rcount * peer, true, rcount, dtype, peer, schedule, false); rcount 322 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_local_recv(recvbuf, false, rcount, dtype, 0, schedule, false); rcount 51 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, int rcount, rcount 72 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, int rcount, rcount 112 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 139 ompi/mca/coll/monitoring/coll_monitoring.h int rcount, rcount 153 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, int rcount, rcount 161 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, int rcount, rcount 170 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, int rcount, rcount 194 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, int rcount, rcount 240 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 271 ompi/mca/coll/monitoring/coll_monitoring.h int rcount, rcount 287 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, int rcount, rcount 296 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, int rcount, rcount 306 ompi/mca/coll/monitoring/coll_monitoring.h int rcount, struct ompi_datatype_t *rdtype, rcount 319 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, int rcount, rcount 344 ompi/mca/coll/monitoring/coll_monitoring.h int rcount, struct ompi_datatype_t *rdtype, rcount 360 ompi/mca/coll/monitoring/coll_monitoring.h int rcount, struct ompi_datatype_t *rdtype, rcount 18 ompi/mca/coll/monitoring/coll_monitoring_allgather.c void *rbuf, int rcount, rcount 41 ompi/mca/coll/monitoring/coll_monitoring_allgather.c return monitoring_module->real.coll_allgather(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, monitoring_module->real.coll_allgather_module); rcount 46 ompi/mca/coll/monitoring/coll_monitoring_allgather.c void *rbuf, int rcount, rcount 70 ompi/mca/coll/monitoring/coll_monitoring_allgather.c return monitoring_module->real.coll_iallgather(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, request, monitoring_module->real.coll_iallgather_module); rcount 17 ompi/mca/coll/monitoring/coll_monitoring_alltoall.c void* rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 39 ompi/mca/coll/monitoring/coll_monitoring_alltoall.c return monitoring_module->real.coll_alltoall(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, monitoring_module->real.coll_alltoall_module); rcount 44 ompi/mca/coll/monitoring/coll_monitoring_alltoall.c void *rbuf, int rcount, rcount 68 ompi/mca/coll/monitoring/coll_monitoring_alltoall.c return monitoring_module->real.coll_ialltoall(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, request, monitoring_module->real.coll_ialltoall_module); rcount 18 ompi/mca/coll/monitoring/coll_monitoring_gather.c void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 28 ompi/mca/coll/monitoring/coll_monitoring_gather.c data_size = rcount * type_size; rcount 41 ompi/mca/coll/monitoring/coll_monitoring_gather.c return monitoring_module->real.coll_gather(sbuf, scount, sdtype, rbuf, rcount, rdtype, root, comm, monitoring_module->real.coll_gather_module); rcount 46 ompi/mca/coll/monitoring/coll_monitoring_gather.c void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 57 ompi/mca/coll/monitoring/coll_monitoring_gather.c data_size = rcount * type_size; rcount 70 ompi/mca/coll/monitoring/coll_monitoring_gather.c return monitoring_module->real.coll_igather(sbuf, scount, sdtype, rbuf, rcount, rdtype, root, comm, request, monitoring_module->real.coll_igather_module); rcount 19 ompi/mca/coll/monitoring/coll_monitoring_neighbor_allgather.c int rcount, struct ompi_datatype_t *rdtype, rcount 66 ompi/mca/coll/monitoring/coll_monitoring_neighbor_allgather.c return monitoring_module->real.coll_neighbor_allgather(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, monitoring_module->real.coll_neighbor_allgather_module); rcount 71 ompi/mca/coll/monitoring/coll_monitoring_neighbor_allgather.c int rcount, struct ompi_datatype_t *rdtype, rcount 119 ompi/mca/coll/monitoring/coll_monitoring_neighbor_allgather.c return monitoring_module->real.coll_ineighbor_allgather(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, request, monitoring_module->real.coll_ineighbor_allgather_module); rcount 19 ompi/mca/coll/monitoring/coll_monitoring_neighbor_alltoall.c void* rbuf, int rcount, rcount 67 ompi/mca/coll/monitoring/coll_monitoring_neighbor_alltoall.c return monitoring_module->real.coll_neighbor_alltoall(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, monitoring_module->real.coll_neighbor_alltoall_module); rcount 72 ompi/mca/coll/monitoring/coll_monitoring_neighbor_alltoall.c void *rbuf, int rcount, rcount 121 ompi/mca/coll/monitoring/coll_monitoring_neighbor_alltoall.c return monitoring_module->real.coll_ineighbor_alltoall(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, request, monitoring_module->real.coll_ineighbor_alltoall_module); rcount 18 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c int rcount, rcount 30 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c data_size = rcount * type_size; rcount 42 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c return monitoring_module->real.coll_reduce_scatter_block(sbuf, rbuf, rcount, dtype, op, comm, monitoring_module->real.coll_reduce_scatter_block_module); rcount 46 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c int rcount, rcount 59 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c data_size = rcount * type_size; rcount 71 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c return monitoring_module->real.coll_ireduce_scatter_block(sbuf, rbuf, rcount, dtype, op, comm, request, monitoring_module->real.coll_ireduce_scatter_block_module); rcount 18 ompi/mca/coll/monitoring/coll_monitoring_scatter.c void *rbuf, int rcount, rcount 44 ompi/mca/coll/monitoring/coll_monitoring_scatter.c return monitoring_module->real.coll_scatter(sbuf, scount, sdtype, rbuf, rcount, rdtype, root, comm, monitoring_module->real.coll_scatter_module); rcount 50 ompi/mca/coll/monitoring/coll_monitoring_scatter.c void *rbuf, int rcount, rcount 77 ompi/mca/coll/monitoring/coll_monitoring_scatter.c return monitoring_module->real.coll_iscatter(sbuf, scount, sdtype, rbuf, rcount, rdtype, root, comm, request, monitoring_module->real.coll_iscatter_module); rcount 18 ompi/mca/coll/monitoring/coll_monitoring_scatterv.c void* rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 42 ompi/mca/coll/monitoring/coll_monitoring_scatterv.c return monitoring_module->real.coll_scatterv(sbuf, scounts, disps, sdtype, rbuf, rcount, rdtype, root, comm, monitoring_module->real.coll_scatterv_module); rcount 47 ompi/mca/coll/monitoring/coll_monitoring_scatterv.c void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 72 ompi/mca/coll/monitoring/coll_monitoring_scatterv.c return monitoring_module->real.coll_iscatterv(sbuf, scounts, disps, sdtype, rbuf, rcount, rdtype, root, comm, request, monitoring_module->real.coll_iscatterv_module); rcount 226 ompi/mca/coll/portals4/coll_portals4.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 231 ompi/mca/coll/portals4/coll_portals4.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 239 ompi/mca/coll/portals4/coll_portals4.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 244 ompi/mca/coll/portals4/coll_portals4.h void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 509 ompi/mca/coll/portals4/coll_portals4_gather.c void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 552 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_count = rcount; rcount 567 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.unpack_dst_count = rcount; rcount 807 ompi/mca/coll/portals4/coll_portals4_gather.c void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 847 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_count = rcount; rcount 862 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.unpack_dst_count = rcount; rcount 1222 ompi/mca/coll/portals4/coll_portals4_gather.c void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 1251 ompi/mca/coll/portals4/coll_portals4_gather.c rbuf, rcount, rdtype, rcount 1262 ompi/mca/coll/portals4/coll_portals4_gather.c rbuf, rcount, rdtype, rcount 1294 ompi/mca/coll/portals4/coll_portals4_gather.c void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 1325 ompi/mca/coll/portals4/coll_portals4_gather.c rbuf, rcount, rdtype, rcount 1333 ompi/mca/coll/portals4/coll_portals4_gather.c rbuf, rcount, rdtype, rcount 310 ompi/mca/coll/portals4/coll_portals4_scatter.c void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 368 ompi/mca/coll/portals4/coll_portals4_scatter.c request->u.scatter.unpack_dst_count = rcount; rcount 650 ompi/mca/coll/portals4/coll_portals4_scatter.c void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 678 ompi/mca/coll/portals4/coll_portals4_scatter.c rbuf, rcount, rdtype, rcount 709 ompi/mca/coll/portals4/coll_portals4_scatter.c void *rbuf, int rcount, struct ompi_datatype_t *rdtype, rcount 739 ompi/mca/coll/portals4/coll_portals4_scatter.c rbuf, rcount, rdtype, rcount 58 ompi/mca/coll/self/coll_self.h void *rbuf, int rcount, rcount 75 ompi/mca/coll/self/coll_self.h void* rbuf, int rcount, rcount 105 ompi/mca/coll/self/coll_self.h int rcount, struct ompi_datatype_t *rdtype, rcount 133 ompi/mca/coll/self/coll_self.h int rcount, struct ompi_datatype_t *rdtype, rcount 138 ompi/mca/coll/self/coll_self.h void* rbuf, int rcount, rcount 37 ompi/mca/coll/self/coll_self_allgather.c int rcount, struct ompi_datatype_t *rdtype, rcount 45 ompi/mca/coll/self/coll_self_allgather.c rbuf, rcount, rdtype); rcount 38 ompi/mca/coll/self/coll_self_alltoall.c void *rbuf, int rcount, rcount 48 ompi/mca/coll/self/coll_self_alltoall.c rbuf, rcount, rdtype); rcount 37 ompi/mca/coll/self/coll_self_gather.c void *rbuf, int rcount, rcount 46 ompi/mca/coll/self/coll_self_gather.c rbuf, rcount, rdtype); rcount 37 ompi/mca/coll/self/coll_self_scatter.c void *rbuf, int rcount, rcount 47 ompi/mca/coll/self/coll_self_scatter.c rbuf, rcount, rdtype); rcount 37 ompi/mca/coll/self/coll_self_scatterv.c void *rbuf, int rcount, rcount 52 ompi/mca/coll/self/coll_self_scatterv.c sdtype, rbuf, rcount, rdtype); rcount 222 ompi/mca/coll/sm/coll_sm.h void *rbuf, int rcount, rcount 240 ompi/mca/coll/sm/coll_sm.h void* rbuf, int rcount, rcount 275 ompi/mca/coll/sm/coll_sm.h int rcount, struct ompi_datatype_t *rdtype, rcount 309 ompi/mca/coll/sm/coll_sm.h int rcount, struct ompi_datatype_t *rdtype, rcount 314 ompi/mca/coll/sm/coll_sm.h void* rbuf, int rcount, rcount 36 ompi/mca/coll/sm/coll_sm_allgather.c int rcount, struct ompi_datatype_t *rdtype, rcount 36 ompi/mca/coll/sm/coll_sm_alltoall.c int rcount, struct ompi_datatype_t *rdtype, rcount 36 ompi/mca/coll/sm/coll_sm_gather.c int rcount, struct ompi_datatype_t *rdtype, rcount 36 ompi/mca/coll/sm/coll_sm_scatter.c int rcount, struct ompi_datatype_t *rdtype, rcount 36 ompi/mca/coll/sm/coll_sm_scatterv.c void *rbuf, int rcount, rcount 66 ompi/mca/coll/sync/coll_sync.h void *rbuf, int rcount, rcount 102 ompi/mca/coll/sync/coll_sync.h void *rbuf, int rcount, rcount 110 ompi/mca/coll/sync/coll_sync.h void *rbuf, int rcount, rcount 34 ompi/mca/coll/sync/coll_sync_gather.c void *rbuf, int rcount, rcount 43 ompi/mca/coll/sync/coll_sync_gather.c rbuf, rcount, rdtype, root, comm, rcount 47 ompi/mca/coll/sync/coll_sync_gather.c rbuf, rcount, rdtype, root, comm, rcount 34 ompi/mca/coll/sync/coll_sync_scatter.c void *rbuf, int rcount, rcount 43 ompi/mca/coll/sync/coll_sync_scatter.c rbuf, rcount, rdtype, root, comm, rcount 47 ompi/mca/coll/sync/coll_sync_scatter.c rbuf, rcount, rdtype, root, comm, rcount 34 ompi/mca/coll/sync/coll_sync_scatterv.c void *rbuf, int rcount, rcount 43 ompi/mca/coll/sync/coll_sync_scatterv.c rbuf, rcount, rdtype, root, comm, rcount 47 ompi/mca/coll/sync/coll_sync_scatterv.c rbuf, rcount, rdtype, root, comm, rcount 125 ompi/mca/coll/tuned/coll_tuned_allgather_decision.c void* rbuf, int rcount, rcount 138 ompi/mca/coll/tuned/coll_tuned_allgather_decision.c rbuf, rcount, rdtype, rcount 142 ompi/mca/coll/tuned/coll_tuned_allgather_decision.c rbuf, rcount, rdtype, rcount 146 ompi/mca/coll/tuned/coll_tuned_allgather_decision.c rbuf, rcount, rdtype, rcount 150 ompi/mca/coll/tuned/coll_tuned_allgather_decision.c rbuf, rcount, rdtype, rcount 154 ompi/mca/coll/tuned/coll_tuned_allgather_decision.c rbuf, rcount, rdtype, rcount 158 ompi/mca/coll/tuned/coll_tuned_allgather_decision.c rbuf, rcount, rdtype, rcount 162 ompi/mca/coll/tuned/coll_tuned_allgather_decision.c rbuf, rcount, rdtype, rcount 144 ompi/mca/coll/tuned/coll_tuned_alltoall_decision.c void* rbuf, int rcount, rcount 156 ompi/mca/coll/tuned/coll_tuned_alltoall_decision.c return ompi_coll_tuned_alltoall_intra_dec_fixed(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, module); rcount 158 ompi/mca/coll/tuned/coll_tuned_alltoall_decision.c return ompi_coll_base_alltoall_intra_basic_linear(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, module); rcount 160 ompi/mca/coll/tuned/coll_tuned_alltoall_decision.c return ompi_coll_base_alltoall_intra_pairwise(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, module); rcount 162 ompi/mca/coll/tuned/coll_tuned_alltoall_decision.c return ompi_coll_base_alltoall_intra_bruck(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, module); rcount 164 ompi/mca/coll/tuned/coll_tuned_alltoall_decision.c return ompi_coll_base_alltoall_intra_linear_sync(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, module, max_requests); rcount 166 ompi/mca/coll/tuned/coll_tuned_alltoall_decision.c return ompi_coll_base_alltoall_intra_two_procs(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, module); rcount 103 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c void* rbuf, int rcount, rcount 129 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcount, rdtype, rcount 137 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcount, rdtype, rcount 145 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcount, rdtype, rcount 399 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c int rcount, rcount 417 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c dsize *= rcount * size; rcount 424 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c return ompi_coll_tuned_reduce_scatter_block_intra_do_this (sbuf, rbuf, rcount, dtype, rcount 431 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c return ompi_coll_tuned_reduce_scatter_block_intra_do_this(sbuf, rbuf, rcount, dtype, rcount 437 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c return ompi_coll_tuned_reduce_scatter_block_intra_dec_fixed (sbuf, rbuf, rcount, rcount 452 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c void* rbuf, int rcount, rcount 479 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcount, rdtype, rcount 489 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcount, rdtype, rcount 498 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcount, rdtype, rcount 569 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c void* rbuf, int rcount, rcount 597 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcount, rdtype, rcount 605 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcount, rdtype, rcount 613 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcount, rdtype, rcount 619 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c void* rbuf, int rcount, rcount 646 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcount, rdtype, rcount 654 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcount, rdtype, rcount 662 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcount, rdtype, rcount 98 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c void* rbuf, int rcount, rcount 114 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 132 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 137 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 142 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 156 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c return ompi_coll_base_alltoall_intra_bruck(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, module); rcount 159 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c return ompi_coll_base_alltoall_intra_basic_linear(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, module); rcount 161 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c return ompi_coll_base_alltoall_intra_pairwise(sbuf, scount, sdtype, rbuf, rcount, rdtype, comm, module); rcount 516 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c int rcount, rcount 523 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c return ompi_coll_base_reduce_scatter_block_basic_linear(sbuf, rbuf, rcount, rcount 538 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c void* rbuf, int rcount, rcount 551 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 580 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 584 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 590 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 594 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 611 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 615 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 619 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 700 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c void* rbuf, int rcount, rcount 728 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c block_size = dsize * (ptrdiff_t)rcount; rcount 736 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 742 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 750 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 755 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 770 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c void* rbuf, int rcount, rcount 791 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c block_size = dsize * (ptrdiff_t)rcount; rcount 797 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 801 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcount, rdtype, rcount 124 ompi/mca/coll/tuned/coll_tuned_gather_decision.c void* rbuf, int rcount, rcount 138 ompi/mca/coll/tuned/coll_tuned_gather_decision.c rbuf, rcount, rdtype, rcount 142 ompi/mca/coll/tuned/coll_tuned_gather_decision.c rbuf, rcount, rdtype, rcount 146 ompi/mca/coll/tuned/coll_tuned_gather_decision.c rbuf, rcount, rdtype, rcount 150 ompi/mca/coll/tuned/coll_tuned_gather_decision.c rbuf, rcount, rdtype, rcount 114 ompi/mca/coll/tuned/coll_tuned_reduce_scatter_block_decision.c int rcount, rcount 125 ompi/mca/coll/tuned/coll_tuned_reduce_scatter_block_decision.c case (0): return ompi_coll_tuned_reduce_scatter_block_intra_dec_fixed(sbuf, rbuf, rcount, rcount 127 ompi/mca/coll/tuned/coll_tuned_reduce_scatter_block_decision.c case (1): return ompi_coll_base_reduce_scatter_block_basic_linear(sbuf, rbuf, rcount, rcount 129 ompi/mca/coll/tuned/coll_tuned_reduce_scatter_block_decision.c case (2): return ompi_coll_base_reduce_scatter_block_intra_recursivedoubling(sbuf, rbuf, rcount, rcount 131 ompi/mca/coll/tuned/coll_tuned_reduce_scatter_block_decision.c case (3): return ompi_coll_base_reduce_scatter_block_intra_recursivehalving(sbuf, rbuf, rcount, rcount 133 ompi/mca/coll/tuned/coll_tuned_reduce_scatter_block_decision.c case (4): return ompi_coll_base_reduce_scatter_block_intra_butterfly(sbuf, rbuf, rcount, dtype, op, comm, rcount 123 ompi/mca/coll/tuned/coll_tuned_scatter_decision.c void* rbuf, int rcount, rcount 137 ompi/mca/coll/tuned/coll_tuned_scatter_decision.c rbuf, rcount, rdtype, rcount 141 ompi/mca/coll/tuned/coll_tuned_scatter_decision.c rbuf, rcount, rdtype, rcount 145 ompi/mca/coll/tuned/coll_tuned_scatter_decision.c rbuf, rcount, rdtype, rcount 215 ompi/mca/fcoll/base/fcoll_base_coll_array.c int rcount, rcount 231 ompi/mca/fcoll/base/fcoll_base_coll_array.c if (rcount > 0) { rcount 233 ompi/mca/fcoll/base/fcoll_base_coll_array.c rcount, rcount 261 ompi/mca/fcoll/base/fcoll_base_coll_array.c (0 < rcount)) { rcount 266 ompi/mca/fcoll/base/fcoll_base_coll_array.c rcount, rcount 304 ompi/mca/fcoll/base/fcoll_base_coll_array.c int rcount, rcount 322 ompi/mca/fcoll/base/fcoll_base_coll_array.c sbuf = ((char*) rbuf) + (rank * extent * rcount); rcount 324 ompi/mca/fcoll/base/fcoll_base_coll_array.c scount = rcount; rcount 332 ompi/mca/fcoll/base/fcoll_base_coll_array.c rcount, rcount 341 ompi/mca/fcoll/base/fcoll_base_coll_array.c rcount * procs_per_group, rcount 357 ompi/mca/fcoll/base/fcoll_base_coll_array.c int rcount, rcount 388 ompi/mca/fcoll/base/fcoll_base_coll_array.c incr = extent * rcount; rcount 404 ompi/mca/fcoll/base/fcoll_base_coll_array.c rcount, rcount 414 ompi/mca/fcoll/base/fcoll_base_coll_array.c rcount, rcount 61 ompi/mca/fcoll/base/fcoll_base_coll_array.h int rcount, rcount 71 ompi/mca/fcoll/base/fcoll_base_coll_array.h int rcount, rcount 93 ompi/mca/fcoll/base/fcoll_base_coll_array.h int rcount, rcount 482 ompi/mpi/java/java/Comm.java Object rbuf, boolean rdb, int roffset, int rcount, rcount 299 opal/datatype/opal_datatype.h int32_t rcount, const opal_datatype_t* rdtype); rcount 862 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size_t rcount = rank == PMIX_RANK_WILDCARD ? 0 : rank + 1; rcount 876 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (rcount == cur_elem->rank) { rcount 887 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c id = rcount/ds_ctx->max_meta_elems; rcount 888 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rel_offset = (rcount % ds_ctx->max_meta_elems) * sizeof(rank_meta_info) + sizeof(size_t); rcount 964 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c size_t rcount = rinfo->rank == PMIX_RANK_WILDCARD ? 0 : rinfo->rank + 1; rcount 965 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c id = rcount/ds_ctx->max_meta_elems; rcount 966 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rel_offset = (rcount % ds_ctx->max_meta_elems) * sizeof(rank_meta_info) + sizeof(size_t); rcount 192 test/datatype/to_self.c MPI_Datatype rdt, int rcount, void* rbuf ) rcount 202 test/datatype/to_self.c rlength *= rcount; rcount 210 test/datatype/to_self.c MPI_Recv( rbuf, rcount, rdt, myself, tag, MPI_COMM_WORLD, &status ); rcount 215 test/datatype/to_self.c ftmpi_mpi_recv( rbuf, rcount, rdt, myself, tag, MPI_COMM_WORLD, &status ); rcount 226 test/datatype/to_self.c MPI_Datatype rdt, int rcount, void* rbuf ) rcount 236 test/datatype/to_self.c rlength *= rcount; rcount 243 test/datatype/to_self.c MPI_Irecv( rbuf, rcount, rdt, myself, tag, MPI_COMM_WORLD, &req ); rcount 248 test/datatype/to_self.c ftmpi_mpi_irecv( rbuf, rcount, rdt, myself, tag, MPI_COMM_WORLD, &req ); rcount 260 test/datatype/to_self.c MPI_Datatype rdt, int rcount, void* rbuf ) rcount 270 test/datatype/to_self.c rlength *= rcount; rcount 278 test/datatype/to_self.c MPI_Irecv( rbuf, rcount, rdt, myself, tag, MPI_COMM_WORLD, &rreq ); rcount 285 test/datatype/to_self.c ftmpi_mpi_irecv( rbuf, rcount, rdt, myself, tag, MPI_COMM_WORLD, &rreq ); rcount 298 test/datatype/to_self.c MPI_Datatype rdt, int rcount, void* rbuf ) rcount 308 test/datatype/to_self.c rlength *= rcount; rcount 315 test/datatype/to_self.c MPI_Irecv( rbuf, rcount, rdt, myself, tag, MPI_COMM_WORLD, &rreq ); rcount 322 test/datatype/to_self.c ftmpi_mpi_irecv( rbuf, rcount, rdt, myself, tag, MPI_COMM_WORLD, &rreq );