rcounts 1731 ompi/communicator/comm.c int *rcounts; rcounts 1751 ompi/communicator/comm.c rcounts = (int *) calloc ( rsize, sizeof(int)); rcounts 1752 ompi/communicator/comm.c if ( NULL == rcounts ){ rcounts 1757 ompi/communicator/comm.c rcounts[0] = 1; rcounts 1763 ompi/communicator/comm.c &rhigh, rcounts, rdisps, rcounts 1769 ompi/communicator/comm.c if ( NULL != rcounts ) { rcounts 1770 ompi/communicator/comm.c free ( rcounts ); rcounts 95 ompi/mca/coll/base/coll_base_allgatherv.c void *rbuf, const int *rcounts, rcounts 124 ompi/mca/coll/base/coll_base_allgatherv.c tmprecv, rcounts[rank], rdtype); rcounts 164 ompi/mca/coll/base/coll_base_allgatherv.c new_scounts[i] = rcounts[tmp_srank]; rcounts 166 ompi/mca/coll/base/coll_base_allgatherv.c new_rcounts[i] = rcounts[tmp_rrank]; rcounts 223 ompi/mca/coll/base/coll_base_allgatherv.c void* rbuf, const int *rcounts, const int *rdisps, rcounts 249 ompi/mca/coll/base/coll_base_allgatherv.c tmprecv, rcounts[rank], rdtype); rcounts 272 ompi/mca/coll/base/coll_base_allgatherv.c err = ompi_coll_base_sendrecv(tmpsend, rcounts[senddatafrom], rdtype, rcounts 274 ompi/mca/coll/base/coll_base_allgatherv.c tmprecv, rcounts[recvdatafrom], rdtype, rcounts 350 ompi/mca/coll/base/coll_base_allgatherv.c void* rbuf, const int *rcounts, const int *rdispls, rcounts 370 ompi/mca/coll/base/coll_base_allgatherv.c rbuf, rcounts, rcounts 389 ompi/mca/coll/base/coll_base_allgatherv.c tmprecv, rcounts[rank], rdtype); rcounts 422 ompi/mca/coll/base/coll_base_allgatherv.c err = ompi_coll_base_sendrecv(tmpsend, rcounts[rank], rdtype, rcounts 424 ompi/mca/coll/base/coll_base_allgatherv.c tmprecv, rcounts[neighbor[0]], rdtype, rcounts 446 ompi/mca/coll/base/coll_base_allgatherv.c new_scounts[0] = rcounts[send_data_from]; rcounts 447 ompi/mca/coll/base/coll_base_allgatherv.c new_scounts[1] = rcounts[(send_data_from + 1)]; rcounts 456 ompi/mca/coll/base/coll_base_allgatherv.c new_rcounts[0] = rcounts[recv_data_from[i_parity]]; rcounts 457 ompi/mca/coll/base/coll_base_allgatherv.c new_rcounts[1] = rcounts[(recv_data_from[i_parity] + 1)]; rcounts 495 ompi/mca/coll/base/coll_base_allgatherv.c void* rbuf, const int *rcounts, rcounts 526 ompi/mca/coll/base/coll_base_allgatherv.c scount = rcounts[rank]; rcounts 533 ompi/mca/coll/base/coll_base_allgatherv.c tmprecv, rcounts[remote], rdtype, remote, rcounts 542 ompi/mca/coll/base/coll_base_allgatherv.c rcounts[rank], rdtype); rcounts 581 ompi/mca/coll/base/coll_base_allgatherv.c void *rbuf, const int *rcounts, rcounts 608 ompi/mca/coll/base/coll_base_allgatherv.c scount = rcounts[rank]; rcounts 616 ompi/mca/coll/base/coll_base_allgatherv.c rcounts, disps, rdtype, 0, rcounts 634 ompi/mca/coll/base/coll_base_allgatherv.c err = ompi_datatype_create_indexed(size,rcounts,disps,rdtype,&newtype); rcounts 41 ompi/mca/coll/base/coll_base_alltoallv.c mca_coll_base_alltoallv_intra_basic_inplace(const void *rbuf, const int *rcounts, const int *rdisps, rcounts 66 ompi/mca/coll/base/coll_base_alltoallv.c size_t size = opal_datatype_span(&rdtype->super, rcounts[i], &gap); rcounts 86 ompi/mca/coll/base/coll_base_alltoallv.c if (i == rank && 0 != rcounts[j]) { rcounts 88 ompi/mca/coll/base/coll_base_alltoallv.c err = ompi_datatype_copy_content_same_ddt (rdtype, rcounts[j], rcounts 93 ompi/mca/coll/base/coll_base_alltoallv.c err = ompi_coll_base_sendrecv_actual((void *) tmp_buffer, rcounts[j], rdtype, rcounts 95 ompi/mca/coll/base/coll_base_alltoallv.c (char *)rbuf + rdisps[j] * ext, rcounts[j], rdtype, rcounts 99 ompi/mca/coll/base/coll_base_alltoallv.c } else if (j == rank && 0 != rcounts[i]) { rcounts 101 ompi/mca/coll/base/coll_base_alltoallv.c err = ompi_datatype_copy_content_same_ddt (rdtype, rcounts[i], rcounts 106 ompi/mca/coll/base/coll_base_alltoallv.c err = ompi_coll_base_sendrecv_actual((void *) tmp_buffer, rcounts[i], rdtype, rcounts 108 ompi/mca/coll/base/coll_base_alltoallv.c (char *) rbuf + rdisps[i] * ext, rcounts[i], rdtype, rcounts 127 ompi/mca/coll/base/coll_base_alltoallv.c void* rbuf, const int *rcounts, const int *rdisps, rcounts 137 ompi/mca/coll/base/coll_base_alltoallv.c return mca_coll_base_alltoallv_intra_basic_inplace (rbuf, rcounts, rdisps, rcounts 164 ompi/mca/coll/base/coll_base_alltoallv.c prcv, rcounts[recvfrom], rdtype, recvfrom, rcounts 191 ompi/mca/coll/base/coll_base_alltoallv.c void *rbuf, const int *rcounts, const int *rdisps, rcounts 204 ompi/mca/coll/base/coll_base_alltoallv.c return mca_coll_base_alltoallv_intra_basic_inplace (rbuf, rcounts, rdisps, rcounts 222 ompi/mca/coll/base/coll_base_alltoallv.c prcv, rcounts[rank], rdtype); rcounts 246 ompi/mca/coll/base/coll_base_alltoallv.c err = MCA_PML_CALL(irecv_init(prcv, rcounts[i], rdtype, rcounts 225 ompi/mca/coll/base/coll_base_functions.h int mca_coll_base_alltoallv_intra_basic_inplace(const void *rbuf, const int *rcounts, const int *rdisps, rcounts 48 ompi/mca/coll/base/coll_base_reduce_scatter.c const int *rcounts, rcounts 63 ompi/mca/coll/base/coll_base_reduce_scatter.c for (i = 0, total_count = 0; i < size; i++) { total_count += rcounts[i]; } rcounts 97 ompi/mca/coll/base/coll_base_reduce_scatter.c displs[i] = displs[i-1] + rcounts[i-1]; rcounts 100 ompi/mca/coll/base/coll_base_reduce_scatter.c err = comm->c_coll->coll_scatterv (tmprbuf, rcounts, displs, dtype, rcounts 104 ompi/mca/coll/base/coll_base_reduce_scatter.c err = comm->c_coll->coll_scatterv (tmprbuf, rcounts, displs, dtype, rcounts 105 ompi/mca/coll/base/coll_base_reduce_scatter.c rbuf, rcounts[rank], dtype, rcounts 134 ompi/mca/coll/base/coll_base_reduce_scatter.c const int *rcounts, rcounts 158 ompi/mca/coll/base/coll_base_reduce_scatter.c disps[i + 1] = disps[i] + rcounts[i]; rcounts 160 ompi/mca/coll/base/coll_base_reduce_scatter.c count = disps[size - 1] + rcounts[size - 1]; rcounts 254 ompi/mca/coll/base/coll_base_reduce_scatter.c tmp_rcounts[i] = rcounts[i * 2 + 1] + rcounts[i * 2]; rcounts 256 ompi/mca/coll/base/coll_base_reduce_scatter.c tmp_rcounts[i] = rcounts[i + remain]; rcounts 348 ompi/mca/coll/base/coll_base_reduce_scatter.c if (0 != rcounts[rank]) { rcounts 350 ompi/mca/coll/base/coll_base_reduce_scatter.c rcounts[rank], dtype, rcounts 351 ompi/mca/coll/base/coll_base_reduce_scatter.c rbuf, rcounts[rank], dtype); rcounts 367 ompi/mca/coll/base/coll_base_reduce_scatter.c if (rcounts[rank]) { rcounts 368 ompi/mca/coll/base/coll_base_reduce_scatter.c err = MCA_PML_CALL(recv(rbuf, rcounts[rank], dtype, rank + 1, rcounts 374 ompi/mca/coll/base/coll_base_reduce_scatter.c if (rcounts[rank - 1]) { rcounts 376 ompi/mca/coll/base/coll_base_reduce_scatter.c rcounts[rank - 1], dtype, rank - 1, rcounts 456 ompi/mca/coll/base/coll_base_reduce_scatter.c ompi_coll_base_reduce_scatter_intra_ring( const void *sbuf, void *rbuf, const int *rcounts, rcounts 482 ompi/mca/coll/base/coll_base_reduce_scatter.c total_count = rcounts[0]; rcounts 483 ompi/mca/coll/base/coll_base_reduce_scatter.c max_block_count = rcounts[0]; rcounts 486 ompi/mca/coll/base/coll_base_reduce_scatter.c total_count += rcounts[i]; rcounts 487 ompi/mca/coll/base/coll_base_reduce_scatter.c if (max_block_count < rcounts[i]) max_block_count = rcounts[i]; rcounts 561 ompi/mca/coll/base/coll_base_reduce_scatter.c ret = MCA_PML_CALL(send(tmpsend, rcounts[recv_from], dtype, send_to, rcounts 585 ompi/mca/coll/base/coll_base_reduce_scatter.c ompi_op_reduce(op, inbuf[inbi ^ 0x1], tmprecv, rcounts[prevblock], dtype); rcounts 588 ompi/mca/coll/base/coll_base_reduce_scatter.c ret = MCA_PML_CALL(send(tmprecv, rcounts[prevblock], dtype, send_to, rcounts 601 ompi/mca/coll/base/coll_base_reduce_scatter.c ompi_op_reduce(op, inbuf[inbi], tmprecv, rcounts[rank], dtype); rcounts 604 ompi/mca/coll/base/coll_base_reduce_scatter.c ret = ompi_datatype_copy_content_same_ddt(dtype, rcounts[rank], (char *)rbuf, tmprecv); rcounts 692 ompi/mca/coll/base/coll_base_reduce_scatter.c const void *sbuf, void *rbuf, const int *rcounts, struct ompi_datatype_t *dtype, rcounts 716 ompi/mca/coll/base/coll_base_reduce_scatter.c displs[i] = displs[i - 1] + rcounts[i - 1]; rcounts 718 ompi/mca/coll/base/coll_base_reduce_scatter.c totalcount = displs[comm_size - 1] + rcounts[comm_size - 1]; rcounts 810 ompi/mca/coll/base/coll_base_reduce_scatter.c int send_count = ompi_sum_counts(rcounts, displs, nprocs_rem, rcounts 816 ompi/mca/coll/base/coll_base_reduce_scatter.c int recv_count = ompi_sum_counts(rcounts, displs, nprocs_rem, rcounts 856 ompi/mca/coll/base/coll_base_reduce_scatter.c rcounts[index], dtype, peer - 1, rcounts 867 ompi/mca/coll/base/coll_base_reduce_scatter.c rcounts[index], dtype, peer, rcounts 869 ompi/mca/coll/base/coll_base_reduce_scatter.c rbuf, rcounts[rank], dtype, peer, rcounts 874 ompi/mca/coll/base/coll_base_reduce_scatter.c err = ompi_datatype_copy_content_same_ddt(dtype, rcounts[rank], rbuf, rcounts 883 ompi/mca/coll/base/coll_base_reduce_scatter.c err = MCA_PML_CALL(recv(rbuf, rcounts[rank], dtype, peer, rcounts 67 ompi/mca/coll/basic/coll_basic.h void *rbuf, const int *rcounts, rcounts 94 ompi/mca/coll/basic/coll_basic.h void *rbuf, const int *rcounts, rcounts 103 ompi/mca/coll/basic/coll_basic.h void *rbuf, const int *rcounts, rcounts 111 ompi/mca/coll/basic/coll_basic.h void *rbuf, const int *rcounts, rcounts 163 ompi/mca/coll/basic/coll_basic.h void *rbuf, const int *rcounts, const int *disps, rcounts 171 ompi/mca/coll/basic/coll_basic.h void *rbuf, const int *rcounts, const int *disps, rcounts 212 ompi/mca/coll/basic/coll_basic.h const int *rcounts, rcounts 219 ompi/mca/coll/basic/coll_basic.h const int *rcounts, rcounts 266 ompi/mca/coll/basic/coll_basic.h void *rbuf, const int rcounts[], const int disps[], struct ompi_datatype_t *rdtype, rcounts 274 ompi/mca/coll/basic/coll_basic.h struct ompi_datatype_t *sdtype, void *rbuf, const int rcounts[], rcounts 279 ompi/mca/coll/basic/coll_basic.h struct ompi_datatype_t * const *sdtypes, void *rbuf, const int rcounts[], rcounts 43 ompi/mca/coll/basic/coll_basic_allgatherv.c void *rbuf, const int *rcounts, const int *disps, rcounts 65 ompi/mca/coll/basic/coll_basic_allgatherv.c rbuf, rcounts, disps, rdtype, comm, rcounts 47 ompi/mca/coll/basic/coll_basic_alltoallv.c const int *rcounts, const int *rdisps, rcounts 79 ompi/mca/coll/basic/coll_basic_alltoallv.c if (rcounts[i] > 0) { rcounts 80 ompi/mca/coll/basic/coll_basic_alltoallv.c err = MCA_PML_CALL(irecv(prcv, rcounts[i], rdtype, rcounts 40 ompi/mca/coll/basic/coll_basic_alltoallw.c mca_coll_basic_alltoallw_intra_inplace(const void *rbuf, const int *rcounts, const int *rdisps, rcounts 62 ompi/mca/coll/basic/coll_basic_alltoallw.c ext = opal_datatype_span(&rdtypes[i]->super, rcounts[i], &gap); rcounts 78 ompi/mca/coll/basic/coll_basic_alltoallw.c msg_size_i *= rcounts[i]; rcounts 82 ompi/mca/coll/basic/coll_basic_alltoallw.c msg_size_j *= rcounts[j]; rcounts 87 ompi/mca/coll/basic/coll_basic_alltoallw.c err = ompi_datatype_copy_content_same_ddt (rdtypes[j], rcounts[j], rcounts 92 ompi/mca/coll/basic/coll_basic_alltoallw.c err = MCA_PML_CALL(irecv ((char *) rbuf + rdisps[j], rcounts[j], rdtypes[j], rcounts 96 ompi/mca/coll/basic/coll_basic_alltoallw.c err = MCA_PML_CALL(send ((void *) tmp_buffer, rcounts[j], rdtypes[j], rcounts 102 ompi/mca/coll/basic/coll_basic_alltoallw.c err = ompi_datatype_copy_content_same_ddt (rdtypes[i], rcounts[i], rcounts 107 ompi/mca/coll/basic/coll_basic_alltoallw.c err = MCA_PML_CALL(irecv ((char *) rbuf + rdisps[i], rcounts[i], rdtypes[i], rcounts 111 ompi/mca/coll/basic/coll_basic_alltoallw.c err = MCA_PML_CALL(send ((void *) tmp_buffer, rcounts[i], rdtypes[i], rcounts 145 ompi/mca/coll/basic/coll_basic_alltoallw.c void *rbuf, const int *rcounts, const int *rdisps, rcounts 156 ompi/mca/coll/basic/coll_basic_alltoallw.c return mca_coll_basic_alltoallw_intra_inplace (rbuf, rcounts, rdisps, rcounts 169 ompi/mca/coll/basic/coll_basic_alltoallw.c prcv, rcounts[rank], rdtypes[rank]); rcounts 191 ompi/mca/coll/basic/coll_basic_alltoallw.c msg_size *= rcounts[i]; rcounts 197 ompi/mca/coll/basic/coll_basic_alltoallw.c err = MCA_PML_CALL(irecv_init(prcv, rcounts[i], rdtypes[i], rcounts 259 ompi/mca/coll/basic/coll_basic_alltoallw.c void *rbuf, const int *rcounts, const int *rdisps, rcounts 280 ompi/mca/coll/basic/coll_basic_alltoallw.c msg_size *= rcounts[i]; rcounts 286 ompi/mca/coll/basic/coll_basic_alltoallw.c err = MCA_PML_CALL(irecv_init(prcv, rcounts[i], rdtypes[i], rcounts 42 ompi/mca/coll/basic/coll_basic_gatherv.c void *rbuf, const int *rcounts, const int *disps, rcounts 81 ompi/mca/coll/basic/coll_basic_gatherv.c if (MPI_IN_PLACE != sbuf && (0 < scount) && (0 < rcounts[i])) { rcounts 83 ompi/mca/coll/basic/coll_basic_gatherv.c ptmp, rcounts[i], rdtype); rcounts 87 ompi/mca/coll/basic/coll_basic_gatherv.c if (rcounts[i] > 0) { rcounts 88 ompi/mca/coll/basic/coll_basic_gatherv.c err = MCA_PML_CALL(recv(ptmp, rcounts[i], rdtype, i, rcounts 115 ompi/mca/coll/basic/coll_basic_gatherv.c void *rbuf, const int *rcounts, const int *disps, rcounts 150 ompi/mca/coll/basic/coll_basic_gatherv.c err = MCA_PML_CALL(irecv(ptmp, rcounts[i], rdtype, i, rcounts 41 ompi/mca/coll/basic/coll_basic_neighbor_allgatherv.c void *rbuf, const int rcounts[], const int disps[], rcounts 71 ompi/mca/coll/basic/coll_basic_neighbor_allgatherv.c rc = MCA_PML_CALL(irecv((char *) rbuf + disps[i] * extent, rcounts[i], rdtype, srank, rcounts 85 ompi/mca/coll/basic/coll_basic_neighbor_allgatherv.c rc = MCA_PML_CALL(irecv((char *) rbuf + disps[i+1] * extent, rcounts[i+1], rdtype, drank, rcounts 110 ompi/mca/coll/basic/coll_basic_neighbor_allgatherv.c void *rbuf, const int rcounts[], const int disps[], rcounts 134 ompi/mca/coll/basic/coll_basic_neighbor_allgatherv.c rc = MCA_PML_CALL(irecv((char *) rbuf + disps[neighbor] * extent, rcounts[neighbor], rcounts 160 ompi/mca/coll/basic/coll_basic_neighbor_allgatherv.c void *rbuf, const int rcounts[], const int disps[], rcounts 183 ompi/mca/coll/basic/coll_basic_neighbor_allgatherv.c rc = MCA_PML_CALL(irecv((char *) rbuf + disps[neighbor] * extent, rcounts[neighbor], rdtype, rcounts 215 ompi/mca/coll/basic/coll_basic_neighbor_allgatherv.c void *rbuf, const int rcounts[], const int disps[], struct ompi_datatype_t *rdtype, rcounts 223 ompi/mca/coll/basic/coll_basic_neighbor_allgatherv.c return mca_coll_basic_neighbor_allgatherv_cart (sbuf, scount, sdtype, rbuf, rcounts, rcounts 226 ompi/mca/coll/basic/coll_basic_neighbor_allgatherv.c return mca_coll_basic_neighbor_allgatherv_graph (sbuf, scount, sdtype, rbuf, rcounts, rcounts 229 ompi/mca/coll/basic/coll_basic_neighbor_allgatherv.c return mca_coll_basic_neighbor_allgatherv_dist_graph (sbuf, scount, sdtype, rbuf, rcounts, rcounts 41 ompi/mca/coll/basic/coll_basic_neighbor_alltoallv.c struct ompi_datatype_t *sdtype, void *rbuf, const int rcounts[], rcounts 70 ompi/mca/coll/basic/coll_basic_neighbor_alltoallv.c rc = MCA_PML_CALL(irecv((char *) rbuf + rdisps[i] * rdextent, rcounts[i], rdtype, srank, rcounts 77 ompi/mca/coll/basic/coll_basic_neighbor_alltoallv.c rc = MCA_PML_CALL(irecv((char *) rbuf + rdisps[i+1] * rdextent, rcounts[i+1], rdtype, drank, rcounts 127 ompi/mca/coll/basic/coll_basic_neighbor_alltoallv.c struct ompi_datatype_t *sdtype, void *rbuf, const int rcounts[], rcounts 153 ompi/mca/coll/basic/coll_basic_neighbor_alltoallv.c rc = MCA_PML_CALL(irecv((char *) rbuf + rdisps[neighbor] * rdextent, rcounts[neighbor], rdtype, rcounts 185 ompi/mca/coll/basic/coll_basic_neighbor_alltoallv.c struct ompi_datatype_t *sdtype, void *rbuf, const int rcounts[], rcounts 210 ompi/mca/coll/basic/coll_basic_neighbor_alltoallv.c rc = MCA_PML_CALL(irecv((char *) rbuf + rdisps[neighbor] * rdextent, rcounts[neighbor], rdtype, rcounts 241 ompi/mca/coll/basic/coll_basic_neighbor_alltoallv.c struct ompi_datatype_t *sdtype, void *rbuf, const int rcounts[], rcounts 251 ompi/mca/coll/basic/coll_basic_neighbor_alltoallv.c rcounts, rdisps, rdtype, comm, module); rcounts 254 ompi/mca/coll/basic/coll_basic_neighbor_alltoallv.c rcounts, rdisps, rdtype, comm, module); rcounts 257 ompi/mca/coll/basic/coll_basic_neighbor_alltoallv.c rcounts, rdisps, rdtype, comm, module); rcounts 41 ompi/mca/coll/basic/coll_basic_neighbor_alltoallw.c struct ompi_datatype_t * const *sdtypes, void *rbuf, const int rcounts[], rcounts 67 ompi/mca/coll/basic/coll_basic_neighbor_alltoallw.c rc = MCA_PML_CALL(irecv((char *) rbuf + rdisps[i], rcounts[i], rdtypes[i], srank, rcounts 74 ompi/mca/coll/basic/coll_basic_neighbor_alltoallw.c rc = MCA_PML_CALL(irecv((char *) rbuf + rdisps[i+1], rcounts[i+1], rdtypes[i+1], drank, rcounts 124 ompi/mca/coll/basic/coll_basic_neighbor_alltoallw.c struct ompi_datatype_t * const sdtypes[], void *rbuf, const int rcounts[], rcounts 147 ompi/mca/coll/basic/coll_basic_neighbor_alltoallw.c rc = MCA_PML_CALL(irecv((char *) rbuf + rdisps[neighbor], rcounts[neighbor], rdtypes[neighbor], rcounts 179 ompi/mca/coll/basic/coll_basic_neighbor_alltoallw.c struct ompi_datatype_t * const *sdtypes, void *rbuf, const int rcounts[], rcounts 203 ompi/mca/coll/basic/coll_basic_neighbor_alltoallw.c rc = MCA_PML_CALL(irecv((char *) rbuf + rdisps[neighbor], rcounts[neighbor], rdtypes[neighbor], rcounts 234 ompi/mca/coll/basic/coll_basic_neighbor_alltoallw.c struct ompi_datatype_t * const *sdtypes, void *rbuf, const int rcounts[], rcounts 244 ompi/mca/coll/basic/coll_basic_neighbor_alltoallw.c rcounts, rdisps, rdtypes, comm, module); rcounts 247 ompi/mca/coll/basic/coll_basic_neighbor_alltoallw.c rcounts, rdisps, rdtypes, comm, module); rcounts 250 ompi/mca/coll/basic/coll_basic_neighbor_alltoallw.c rcounts, rdisps, rdtypes, comm, module); rcounts 67 ompi/mca/coll/basic/coll_basic_reduce_scatter.c mca_coll_basic_reduce_scatter_intra(const void *sbuf, void *rbuf, const int *rcounts, rcounts 88 ompi/mca/coll/basic/coll_basic_reduce_scatter.c disps[i + 1] = disps[i] + rcounts[i]; rcounts 90 ompi/mca/coll/basic/coll_basic_reduce_scatter.c count = disps[size - 1] + rcounts[size - 1]; rcounts 189 ompi/mca/coll/basic/coll_basic_reduce_scatter.c tmp_rcounts[i] = rcounts[i * 2 + 1] + rcounts[i * 2]; rcounts 191 ompi/mca/coll/basic/coll_basic_reduce_scatter.c tmp_rcounts[i] = rcounts[i + remain]; rcounts 283 ompi/mca/coll/basic/coll_basic_reduce_scatter.c if (0 != rcounts[rank]) { rcounts 285 ompi/mca/coll/basic/coll_basic_reduce_scatter.c rcounts[rank], dtype, rcounts 286 ompi/mca/coll/basic/coll_basic_reduce_scatter.c rbuf, rcounts[rank], dtype); rcounts 302 ompi/mca/coll/basic/coll_basic_reduce_scatter.c if (rcounts[rank]) { rcounts 303 ompi/mca/coll/basic/coll_basic_reduce_scatter.c err = MCA_PML_CALL(recv(rbuf, rcounts[rank], dtype, rank + 1, rcounts 309 ompi/mca/coll/basic/coll_basic_reduce_scatter.c if (rcounts[rank - 1]) { rcounts 311 ompi/mca/coll/basic/coll_basic_reduce_scatter.c rcounts[rank - 1], dtype, rank - 1, rcounts 339 ompi/mca/coll/basic/coll_basic_reduce_scatter.c err = comm->c_coll->coll_scatterv(recv_buf, rcounts, disps, dtype, rcounts 340 ompi/mca/coll/basic/coll_basic_reduce_scatter.c rbuf, rcounts[rank], dtype, 0, rcounts 362 ompi/mca/coll/basic/coll_basic_reduce_scatter.c mca_coll_basic_reduce_scatter_inter(const void *sbuf, void *rbuf, const int *rcounts, rcounts 380 ompi/mca/coll/basic/coll_basic_reduce_scatter.c totalcounts += rcounts[i]; rcounts 410 ompi/mca/coll/basic/coll_basic_reduce_scatter.c disps[i + 1] = disps[i] + rcounts[i]; rcounts 472 ompi/mca/coll/basic/coll_basic_reduce_scatter.c err = comm->c_local_comm->c_coll->coll_scatterv(lbuf, rcounts, disps, dtype, rcounts 473 ompi/mca/coll/basic/coll_basic_reduce_scatter.c rbuf, rcounts[rank], dtype, 0, rcounts 206 ompi/mca/coll/coll.h void * rbuf, const int *rcounts, const int *disps, struct ompi_datatype_t *rdtype, rcounts 217 ompi/mca/coll/coll.h void *rbuf, const int *rcounts, const int *rdisps, struct ompi_datatype_t *rdtype, rcounts 221 ompi/mca/coll/coll.h void *rbuf, const int *rcounts, const int *rdisps, struct ompi_datatype_t * const *rdtypes, rcounts 237 ompi/mca/coll/coll.h void *rbuf, const int *rcounts, const int *disps, struct ompi_datatype_t *rdtype, rcounts 243 ompi/mca/coll/coll.h (const void *sbuf, void *rbuf, const int *rcounts, struct ompi_datatype_t *dtype, rcounts 268 ompi/mca/coll/coll.h void * rbuf, const int *rcounts, const int *disps, struct ompi_datatype_t *rdtype, rcounts 282 ompi/mca/coll/coll.h void *rbuf, const int *rcounts, const int *rdisps, struct ompi_datatype_t *rdtype, rcounts 287 ompi/mca/coll/coll.h void *rbuf, const int *rcounts, const int *rdisps, struct ompi_datatype_t * const *rdtypes, rcounts 308 ompi/mca/coll/coll.h void *rbuf, const int *rcounts, const int *disps, struct ompi_datatype_t *rdtype, rcounts 316 ompi/mca/coll/coll.h (const void *sbuf, void *rbuf, const int *rcounts, struct ompi_datatype_t *dtype, rcounts 346 ompi/mca/coll/coll.h void * rbuf, const int *rcounts, const int *disps, struct ompi_datatype_t *rdtype, rcounts 360 ompi/mca/coll/coll.h void *rbuf, const int *rcounts, const int *rdisps, struct ompi_datatype_t *rdtype, rcounts 365 ompi/mca/coll/coll.h void *rbuf, const int *rcounts, const int *rdisps, struct ompi_datatype_t * const *rdtypes, rcounts 386 ompi/mca/coll/coll.h void *rbuf, const int *rcounts, const int *disps, struct ompi_datatype_t *rdtype, rcounts 394 ompi/mca/coll/coll.h (const void *sbuf, void *rbuf, const int *rcounts, struct ompi_datatype_t *dtype, rcounts 421 ompi/mca/coll/coll.h void *rbuf, const int *rcounts, const MPI_Aint *rdisps, struct ompi_datatype_t * const *rdtypes, rcounts 425 ompi/mca/coll/coll.h void *rbuf, const int *rcounts, const MPI_Aint *rdisps, struct ompi_datatype_t * const *rdtypes, rcounts 430 ompi/mca/coll/coll.h void *rbuf, const int *rcounts, const MPI_Aint *rdisps, struct ompi_datatype_t * const *rdtypes, rcounts 65 ompi/mca/coll/demo/coll_demo.h void * rbuf, int *rcounts, int *disps, rcounts 71 ompi/mca/coll/demo/coll_demo.h void * rbuf, int *rcounts, int *disps, rcounts 102 ompi/mca/coll/demo/coll_demo.h void *rbuf, int *rcounts, int *rdisps, rcounts 108 ompi/mca/coll/demo/coll_demo.h void *rbuf, int *rcounts, int *rdisps, rcounts 115 ompi/mca/coll/demo/coll_demo.h void *rbuf, int *rcounts, int *rdisps, rcounts 121 ompi/mca/coll/demo/coll_demo.h void *rbuf, int *rcounts, int *rdisps, rcounts 166 ompi/mca/coll/demo/coll_demo.h int *rcounts, int *disps, rcounts 172 ompi/mca/coll/demo/coll_demo.h int *rcounts, int *disps, rcounts 191 ompi/mca/coll/demo/coll_demo.h int *rcounts, rcounts 197 ompi/mca/coll/demo/coll_demo.h int *rcounts, rcounts 38 ompi/mca/coll/demo/coll_demo_allgatherv.c void * rbuf, int *rcounts, int *disps, rcounts 46 ompi/mca/coll/demo/coll_demo_allgatherv.c rbuf, rcounts, disps, rcounts 61 ompi/mca/coll/demo/coll_demo_allgatherv.c void * rbuf, int *rcounts, int *disps, rcounts 69 ompi/mca/coll/demo/coll_demo_allgatherv.c rbuf, rcounts, disps, rcounts 39 ompi/mca/coll/demo/coll_demo_alltoallv.c void *rbuf, int *rcounts, int *rdisps, rcounts 47 ompi/mca/coll/demo/coll_demo_alltoallv.c sdtype, rbuf, rcounts, rcounts 63 ompi/mca/coll/demo/coll_demo_alltoallv.c int *rcounts, int *rdisps, rcounts 71 ompi/mca/coll/demo/coll_demo_alltoallv.c sdtype, rbuf, rcounts, rcounts 38 ompi/mca/coll/demo/coll_demo_alltoallw.c void *rbuf, int *rcounts, int *rdisps, rcounts 46 ompi/mca/coll/demo/coll_demo_alltoallw.c sdtypes, rbuf, rcounts, rcounts 61 ompi/mca/coll/demo/coll_demo_alltoallw.c void *rbuf, int *rcounts, int *rdisps, rcounts 69 ompi/mca/coll/demo/coll_demo_alltoallw.c sdtypes, rbuf, rcounts, rcounts 38 ompi/mca/coll/demo/coll_demo_gatherv.c void *rbuf, int *rcounts, int *disps, rcounts 46 ompi/mca/coll/demo/coll_demo_gatherv.c rbuf, rcounts, disps, rcounts 61 ompi/mca/coll/demo/coll_demo_gatherv.c void *rbuf, int *rcounts, int *disps, rcounts 69 ompi/mca/coll/demo/coll_demo_gatherv.c rbuf, rcounts, disps, rcounts 36 ompi/mca/coll/demo/coll_demo_reduce_scatter.c int mca_coll_demo_reduce_scatter_intra(void *sbuf, void *rbuf, int *rcounts, rcounts 44 ompi/mca/coll/demo/coll_demo_reduce_scatter.c return demo_module->underlying.coll_reduce_scatter(sbuf, rbuf, rcounts, rcounts 57 ompi/mca/coll/demo/coll_demo_reduce_scatter.c int mca_coll_demo_reduce_scatter_inter(void *sbuf, void *rbuf, int *rcounts, rcounts 65 ompi/mca/coll/demo/coll_demo_reduce_scatter.c return demo_module->underlying.coll_reduce_scatter(sbuf, rbuf, rcounts, rcounts 232 ompi/mca/coll/hcoll/coll_hcoll.h void *rbuf, const int *rcounts, rcounts 240 ompi/mca/coll/hcoll/coll_hcoll.h void* rbuf, const int *rcounts, const int *displs, rcounts 309 ompi/mca/coll/hcoll/coll_hcoll.h void *rbuf, int *rcounts, rcounts 319 ompi/mca/coll/hcoll/coll_hcoll.h void* rbuf, const int *rcounts, const int *displs, rcounts 329 ompi/mca/coll/hcoll/coll_hcoll_ops.c void *rbuf, const int *rcounts, const int *rdisps, rcounts 346 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf, rcounts, rdisps, rdtype, rcounts 351 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf, (int *)rcounts, (int *)rdisps, rtype, rcounts 356 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf, rcounts, rdisps, rdtype, rcounts 364 ompi/mca/coll/hcoll/coll_hcoll_ops.c void* rbuf, const int *rcounts, const int *displs, rcounts 385 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf, rcounts, displs, rdtype,root, rcounts 389 ompi/mca/coll/hcoll/coll_hcoll_ops.c rc = hcoll_collectives.coll_gatherv((void *)sbuf, scount, stype, rbuf, (int *)rcounts, (int *)displs, rtype, root, hcoll_module->hcoll_context); rcounts 393 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf, rcounts, displs, rdtype,root, rcounts 684 ompi/mca/coll/hcoll/coll_hcoll_ops.c void* rbuf, const int *rcounts, const int *displs, rcounts 708 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf, rcounts, displs, rdtype,root, rcounts 713 ompi/mca/coll/hcoll/coll_hcoll_ops.c rc = hcoll_collectives.coll_igatherv((void *)sbuf, scount, stype, rbuf, (int *)rcounts, (int *)displs, rtype, root, hcoll_module->hcoll_context, rt_handle); rcounts 717 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf, rcounts, displs, rdtype,root, rcounts 729 ompi/mca/coll/hcoll/coll_hcoll_ops.c void *rbuf, int *rcounts, int *rdisps, rcounts 747 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf, rcounts, rdisps, rdtype, rcounts 752 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf, (int *)rcounts, (int *)rdisps, rtype, rcounts 757 ompi/mca/coll/hcoll/coll_hcoll_ops.c rbuf, rcounts, rdisps, rdtype, rcounts 64 ompi/mca/coll/inter/coll_inter.h void *rbuf, const int *rcounts, const int *disps, rcounts 87 ompi/mca/coll/inter/coll_inter.h void *rbuf, const int *rcounts, const int *disps, rcounts 45 ompi/mca/coll/inter/coll_inter_allgatherv.c void *rbuf, const int *rcounts, const int *disps, rcounts 103 ompi/mca/coll/inter/coll_inter_allgatherv.c ompi_datatype_create_indexed(size,rcounts,disps,rdtype,&ndtype); rcounts 42 ompi/mca/coll/inter/coll_inter_gatherv.c void *rbuf, const int *rcounts, const int *disps, rcounts 60 ompi/mca/coll/inter/coll_inter_gatherv.c ompi_datatype_create_indexed(size, rcounts, disps, rdtype, &ndtype); rcounts 182 ompi/mca/coll/libnbc/coll_libnbc.h void *rbuf, const int *rcounts, const int *rdisps, struct ompi_datatype_t * const *rdtypes, rcounts 240 ompi/mca/coll/libnbc/coll_libnbc.h void *rbuf, const int *rcounts, const int *rdisps, struct ompi_datatype_t * const *rdtypes, rcounts 279 ompi/mca/coll/libnbc/coll_libnbc.h const int *rcounts, const int *displs, MPI_Datatype rtype, rcounts 286 ompi/mca/coll/libnbc/coll_libnbc.h void *rbuf, const int *rcounts, const int *rdispls, MPI_Datatype rtype, rcounts 290 ompi/mca/coll/libnbc/coll_libnbc.h void *rbuf, const int *rcounts, const MPI_Aint *rdisps, struct ompi_datatype_t * const *rtypes, rcounts 311 ompi/mca/coll/libnbc/coll_libnbc.h void *rbuf, const int *rcounts, const int *rdisps, struct ompi_datatype_t * const *rdtypes, rcounts 367 ompi/mca/coll/libnbc/coll_libnbc.h void *rbuf, const int *rcounts, const int *rdisps, struct ompi_datatype_t * const *rdtypes, rcounts 405 ompi/mca/coll/libnbc/coll_libnbc.h const int *rcounts, const int *displs, MPI_Datatype rtype, rcounts 412 ompi/mca/coll/libnbc/coll_libnbc.h void *rbuf, const int *rcounts, const int *rdispls, MPI_Datatype rtype, rcounts 416 ompi/mca/coll/libnbc/coll_libnbc.h void *rbuf, const int *rcounts, const MPI_Aint *rdisps, struct ompi_datatype_t * const *rtypes, rcounts 48 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c const int *rcounts, const int *displs, MPI_Datatype rtype, rcounts 90 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c res = NBC_Sched_recv ((char *) rbuf + displs[i] * rcvext, false, rcounts[i], rtype, srcs[i], schedule, false); rcounts 168 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c const int *rcounts, const int *displs, MPI_Datatype rtype, rcounts 171 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c int res = nbc_neighbor_allgatherv_init(sbuf, scount, stype, rbuf, rcounts, displs, rtype, rcounts 187 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c const int *rcounts, const int *displs, MPI_Datatype rtype, rcounts 190 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c int res = nbc_neighbor_allgatherv_init(sbuf, scount, stype, rbuf, rcounts, displs, rtype, rcounts 48 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c void *rbuf, const int *rcounts, const int *rdispls, MPI_Datatype rtype, rcounts 96 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c res = NBC_Sched_recv ((char *) rbuf + rdispls[i] * rcvext, false, rcounts[i], rtype, srcs[i], schedule, false); rcounts 175 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c void *rbuf, const int *rcounts, const int *rdispls, MPI_Datatype rtype, rcounts 178 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c int res = nbc_neighbor_alltoallv_init(sbuf, scounts, sdispls, stype, rbuf, rcounts, rdispls, rtype, rcounts 194 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c void *rbuf, const int *rcounts, const int *rdispls, MPI_Datatype rtype, rcounts 197 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c int res = nbc_neighbor_alltoallv_init(sbuf, scounts, sdispls, stype, rbuf, rcounts, rdispls, rtype, rcounts 47 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c void *rbuf, const int *rcounts, const MPI_Aint *rdisps, struct ompi_datatype_t * const *rtypes, rcounts 82 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c res = NBC_Sched_recv ((char *) rbuf + rdisps[i], false, rcounts[i], rtypes[i], srcs[i], schedule, false); rcounts 160 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c void *rbuf, const int *rcounts, const MPI_Aint *rdisps, struct ompi_datatype_t * const *rtypes, rcounts 163 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c int res = nbc_neighbor_alltoallw_init(sbuf, scounts, sdisps, stypes, rbuf, rcounts, rdisps, rtypes, rcounts 179 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c void *rbuf, const int *rcounts, const MPI_Aint *rdisps, struct ompi_datatype_t * const *rtypes, rcounts 182 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c int res = nbc_neighbor_alltoallw_init(sbuf, scounts, sdisps, stypes, rbuf, rcounts, rdisps, rtypes, rcounts 58 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, const int *rcounts, rcounts 80 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, const int *rcounts, rcounts 89 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, const int *rcounts, rcounts 118 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, const int *rcounts, const int *disps, rcounts 132 ompi/mca/coll/monitoring/coll_monitoring.h const int *rcounts, rcounts 178 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, const int *rcounts, rcounts 203 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, const int *rcounts, rcounts 213 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, const int *rcounts, rcounts 247 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, const int *rcounts, const int *disps, rcounts 263 ompi/mca/coll/monitoring/coll_monitoring.h const int *rcounts, rcounts 312 ompi/mca/coll/monitoring/coll_monitoring.h const int *rcounts, const int *disps, rcounts 327 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, const int *rcounts, rcounts 336 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, const int *rcounts, rcounts 351 ompi/mca/coll/monitoring/coll_monitoring.h void * rbuf, const int *rcounts, rcounts 368 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, const int *rcounts, rcounts 378 ompi/mca/coll/monitoring/coll_monitoring.h void *rbuf, const int *rcounts, rcounts 18 ompi/mca/coll/monitoring/coll_monitoring_allgatherv.c void * rbuf, const int *rcounts, const int *disps, rcounts 41 ompi/mca/coll/monitoring/coll_monitoring_allgatherv.c return monitoring_module->real.coll_allgatherv(sbuf, scount, sdtype, rbuf, rcounts, disps, rdtype, comm, monitoring_module->real.coll_allgatherv_module); rcounts 46 ompi/mca/coll/monitoring/coll_monitoring_allgatherv.c void * rbuf, const int *rcounts, const int *disps, rcounts 70 ompi/mca/coll/monitoring/coll_monitoring_allgatherv.c return monitoring_module->real.coll_iallgatherv(sbuf, scount, sdtype, rbuf, rcounts, disps, rdtype, comm, request, monitoring_module->real.coll_iallgatherv_module); rcounts 18 ompi/mca/coll/monitoring/coll_monitoring_alltoallv.c void *rbuf, const int *rcounts, const int *rdisps, rcounts 42 ompi/mca/coll/monitoring/coll_monitoring_alltoallv.c return monitoring_module->real.coll_alltoallv(sbuf, scounts, sdisps, sdtype, rbuf, rcounts, rdisps, rdtype, comm, monitoring_module->real.coll_alltoallv_module); rcounts 48 ompi/mca/coll/monitoring/coll_monitoring_alltoallv.c void *rbuf, const int *rcounts, rcounts 74 ompi/mca/coll/monitoring/coll_monitoring_alltoallv.c return monitoring_module->real.coll_ialltoallv(sbuf, scounts, sdisps, sdtype, rbuf, rcounts, rdisps, rdtype, comm, request, monitoring_module->real.coll_ialltoallv_module); rcounts 19 ompi/mca/coll/monitoring/coll_monitoring_alltoallw.c void *rbuf, const int *rcounts, rcounts 44 ompi/mca/coll/monitoring/coll_monitoring_alltoallw.c return monitoring_module->real.coll_alltoallw(sbuf, scounts, sdisps, sdtypes, rbuf, rcounts, rdisps, rdtypes, comm, monitoring_module->real.coll_alltoallw_module); rcounts 50 ompi/mca/coll/monitoring/coll_monitoring_alltoallw.c void *rbuf, const int *rcounts, rcounts 76 ompi/mca/coll/monitoring/coll_monitoring_alltoallw.c return monitoring_module->real.coll_ialltoallw(sbuf, scounts, sdisps, sdtypes, rbuf, rcounts, rdisps, rdtypes, comm, request, monitoring_module->real.coll_ialltoallw_module); rcounts 18 ompi/mca/coll/monitoring/coll_monitoring_gatherv.c void *rbuf, const int *rcounts, const int *disps, rcounts 32 ompi/mca/coll/monitoring/coll_monitoring_gatherv.c data_size = rcounts[i] * type_size; rcounts 44 ompi/mca/coll/monitoring/coll_monitoring_gatherv.c return monitoring_module->real.coll_gatherv(sbuf, scount, sdtype, rbuf, rcounts, disps, rdtype, root, comm, monitoring_module->real.coll_gatherv_module); rcounts 49 ompi/mca/coll/monitoring/coll_monitoring_gatherv.c void *rbuf, const int *rcounts, const int *disps, rcounts 64 ompi/mca/coll/monitoring/coll_monitoring_gatherv.c data_size = rcounts[i] * type_size; rcounts 76 ompi/mca/coll/monitoring/coll_monitoring_gatherv.c return monitoring_module->real.coll_igatherv(sbuf, scount, sdtype, rbuf, rcounts, disps, rdtype, root, comm, request, monitoring_module->real.coll_igatherv_module); rcounts 21 ompi/mca/coll/monitoring/coll_monitoring_neighbor_allgatherv.c void * rbuf, const int *rcounts, const int *disps, rcounts 69 ompi/mca/coll/monitoring/coll_monitoring_neighbor_allgatherv.c return monitoring_module->real.coll_neighbor_allgatherv(sbuf, scount, sdtype, rbuf, rcounts, disps, rdtype, comm, monitoring_module->real.coll_neighbor_allgatherv_module); rcounts 74 ompi/mca/coll/monitoring/coll_monitoring_neighbor_allgatherv.c void * rbuf, const int *rcounts, const int *disps, rcounts 123 ompi/mca/coll/monitoring/coll_monitoring_neighbor_allgatherv.c return monitoring_module->real.coll_ineighbor_allgatherv(sbuf, scount, sdtype, rbuf, rcounts, disps, rdtype, comm, request, monitoring_module->real.coll_ineighbor_allgatherv_module); rcounts 19 ompi/mca/coll/monitoring/coll_monitoring_neighbor_alltoallv.c void *rbuf, const int *rcounts, const int *rdisps, rcounts 70 ompi/mca/coll/monitoring/coll_monitoring_neighbor_alltoallv.c return monitoring_module->real.coll_neighbor_alltoallv(sbuf, scounts, sdisps, sdtype, rbuf, rcounts, rdisps, rdtype, comm, monitoring_module->real.coll_neighbor_alltoallv_module); rcounts 76 ompi/mca/coll/monitoring/coll_monitoring_neighbor_alltoallv.c void *rbuf, const int *rcounts, rcounts 129 ompi/mca/coll/monitoring/coll_monitoring_neighbor_alltoallv.c return monitoring_module->real.coll_ineighbor_alltoallv(sbuf, scounts, sdisps, sdtype, rbuf, rcounts, rdisps, rdtype, comm, request, monitoring_module->real.coll_ineighbor_alltoallv_module); rcounts 20 ompi/mca/coll/monitoring/coll_monitoring_neighbor_alltoallw.c void *rbuf, const int *rcounts, rcounts 72 ompi/mca/coll/monitoring/coll_monitoring_neighbor_alltoallw.c return monitoring_module->real.coll_neighbor_alltoallw(sbuf, scounts, sdisps, sdtypes, rbuf, rcounts, rdisps, rdtypes, comm, monitoring_module->real.coll_neighbor_alltoallw_module); rcounts 78 ompi/mca/coll/monitoring/coll_monitoring_neighbor_alltoallw.c void *rbuf, const int *rcounts, rcounts 131 ompi/mca/coll/monitoring/coll_monitoring_neighbor_alltoallw.c return monitoring_module->real.coll_ineighbor_alltoallw(sbuf, scounts, sdisps, sdtypes, rbuf, rcounts, rdisps, rdtypes, comm, request, monitoring_module->real.coll_ineighbor_alltoallw_module); rcounts 18 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter.c const int *rcounts, rcounts 32 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter.c data_size = rcounts[i] * type_size; rcounts 43 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter.c return monitoring_module->real.coll_reduce_scatter(sbuf, rbuf, rcounts, dtype, op, comm, monitoring_module->real.coll_reduce_scatter_module); rcounts 47 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter.c const int *rcounts, rcounts 62 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter.c data_size = rcounts[i] * type_size; rcounts 73 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter.c return monitoring_module->real.coll_ireduce_scatter(sbuf, rbuf, rcounts, dtype, op, comm, request, monitoring_module->real.coll_ireduce_scatter_module); rcounts 64 ompi/mca/coll/self/coll_self.h void * rbuf, const int *rcounts, const int *disps, rcounts 81 ompi/mca/coll/self/coll_self.h void *rbuf, const int *rcounts, const int *rdisps, rcounts 87 ompi/mca/coll/self/coll_self.h void *rbuf, const int *rcounts, const int *rdisps, rcounts 110 ompi/mca/coll/self/coll_self.h const int *rcounts, const int *disps, rcounts 121 ompi/mca/coll/self/coll_self.h const int *rcounts, rcounts 37 ompi/mca/coll/self/coll_self_allgatherv.c void * rbuf, const int *rcounts, const int *disps, rcounts 52 ompi/mca/coll/self/coll_self_allgatherv.c ((char *) rbuf) + disps[0] * extent, rcounts[0], rdtype); rcounts 39 ompi/mca/coll/self/coll_self_alltoallv.c void *rbuf, const int *rcounts, const int *rdisps, rcounts 62 ompi/mca/coll/self/coll_self_alltoallv.c rcounts[0], rdtype); rcounts 38 ompi/mca/coll/self/coll_self_alltoallw.c void *rbuf, const int *rcounts, const int *rdisps, rcounts 62 ompi/mca/coll/self/coll_self_alltoallw.c rcounts[0], rdtypes[0]); rcounts 37 ompi/mca/coll/self/coll_self_gatherv.c void *rbuf, const int *rcounts, const int *disps, rcounts 53 ompi/mca/coll/self/coll_self_gatherv.c rcounts[0], rdtype); rcounts 35 ompi/mca/coll/self/coll_self_reduce_scatter.c int mca_coll_self_reduce_scatter_intra(const void *sbuf, void *rbuf, const int *rcounts, rcounts 44 ompi/mca/coll/self/coll_self_reduce_scatter.c return ompi_datatype_copy_content_same_ddt(dtype, rcounts[0], (char*)rbuf, (char*)sbuf); rcounts 229 ompi/mca/coll/sm/coll_sm.h void * rbuf, const int *rcounts, const int *disps, rcounts 246 ompi/mca/coll/sm/coll_sm.h void *rbuf, const int *rcounts, const int *rdisps, rcounts 252 ompi/mca/coll/sm/coll_sm.h void *rbuf, const int *rcounts, const int *rdisps, rcounts 280 ompi/mca/coll/sm/coll_sm.h int *rcounts, int *disps, rcounts 297 ompi/mca/coll/sm/coll_sm.h int *rcounts, rcounts 36 ompi/mca/coll/sm/coll_sm_allgatherv.c void * rbuf, const int *rcounts, const int *disps, rcounts 36 ompi/mca/coll/sm/coll_sm_alltoallv.c void *rbuf, const int *rcounts, const int *rdisps, rcounts 36 ompi/mca/coll/sm/coll_sm_alltoallw.c void *rbuf, const int *rcounts, const int *rdisps, rcounts 36 ompi/mca/coll/sm/coll_sm_gatherv.c void *rbuf, const int *rcounts, const int *disps, rcounts 34 ompi/mca/coll/sm/coll_sm_reduce_scatter.c int mca_coll_sm_reduce_scatter_intra(const void *sbuf, void *rbuf, const int *rcounts, rcounts 74 ompi/mca/coll/sync/coll_sync.h void *rbuf, const int *rcounts, const int *disps, rcounts 88 ompi/mca/coll/sync/coll_sync.h const int *rcounts, rcounts 34 ompi/mca/coll/sync/coll_sync_gatherv.c void *rbuf, const int *rcounts, const int *disps, rcounts 43 ompi/mca/coll/sync/coll_sync_gatherv.c rbuf, rcounts, disps, rdtype, root, comm, rcounts 47 ompi/mca/coll/sync/coll_sync_gatherv.c rbuf, rcounts, disps, rdtype, rcounts 33 ompi/mca/coll/sync/coll_sync_reduce_scatter.c int mca_coll_sync_reduce_scatter(const void *sbuf, void *rbuf, const int *rcounts, rcounts 42 ompi/mca/coll/sync/coll_sync_reduce_scatter.c return s->c_coll.coll_reduce_scatter(sbuf, rbuf, rcounts, rcounts 46 ompi/mca/coll/sync/coll_sync_reduce_scatter.c COLL_SYNC(s, s->c_coll.coll_reduce_scatter(sbuf, rbuf, rcounts, rcounts 124 ompi/mca/coll/tuned/coll_tuned_allgatherv_decision.c void *rbuf, const int *rcounts, rcounts 139 ompi/mca/coll/tuned/coll_tuned_allgatherv_decision.c rbuf, rcounts, rdispls, rdtype, rcounts 143 ompi/mca/coll/tuned/coll_tuned_allgatherv_decision.c rbuf, rcounts, rdispls, rdtype, rcounts 147 ompi/mca/coll/tuned/coll_tuned_allgatherv_decision.c rbuf, rcounts, rdispls, rdtype, rcounts 151 ompi/mca/coll/tuned/coll_tuned_allgatherv_decision.c rbuf, rcounts, rdispls, rdtype, rcounts 155 ompi/mca/coll/tuned/coll_tuned_allgatherv_decision.c rbuf, rcounts, rdispls, rdtype, rcounts 159 ompi/mca/coll/tuned/coll_tuned_allgatherv_decision.c rbuf, rcounts, rdispls, rdtype, rcounts 92 ompi/mca/coll/tuned/coll_tuned_alltoallv_decision.c void* rbuf, const int *rcounts, const int *rdisps, rcounts 105 ompi/mca/coll/tuned/coll_tuned_alltoallv_decision.c rbuf, rcounts, rdisps, rdtype, rcounts 109 ompi/mca/coll/tuned/coll_tuned_alltoallv_decision.c rbuf, rcounts, rdisps, rdtype, rcounts 113 ompi/mca/coll/tuned/coll_tuned_alltoallv_decision.c rbuf, rcounts, rdisps, rdtype, rcounts 157 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c void* rbuf, const int *rcounts, const int *rdisps, rcounts 181 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcounts, rdisps, rdtype, rcounts 189 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcounts, rdisps, rdtype, rcounts 194 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcounts, rdisps, rdtype, rcounts 346 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c const int *rcounts, rcounts 363 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c for (i = 0, count = 0; i < size; i++) { count += rcounts[i];} rcounts 372 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c return ompi_coll_tuned_reduce_scatter_intra_do_this (sbuf, rbuf, rcounts, dtype, rcounts 379 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c return ompi_coll_tuned_reduce_scatter_intra_do_this(sbuf, rbuf, rcounts, dtype, rcounts 385 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c return ompi_coll_tuned_reduce_scatter_intra_dec_fixed (sbuf, rbuf, rcounts, rcounts 513 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c void* rbuf, const int *rcounts, rcounts 534 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c for (i = 0; i < comsize; i++) { total_size += dsize * rcounts[i]; } rcounts 542 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcounts, rcounts 553 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcounts, rdispls, rdtype, rcounts 562 ompi/mca/coll/tuned/coll_tuned_decision_dynamic.c rbuf, rcounts, rcounts 172 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c void *rbuf, const int *rcounts, const int *rdisps, rcounts 179 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcounts, rdisps,rdtype, rcounts 460 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c const int *rcounts, rcounts 480 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c total_message_size += rcounts[i]; rcounts 484 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c return ompi_coll_base_reduce_scatter_intra_nonoverlapping(sbuf, rbuf, rcounts, rcounts 498 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c ompi_coll_base_reduce_scatter_intra_basic_recursivehalving(sbuf, rbuf, rcounts, rcounts 502 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c return ompi_coll_base_reduce_scatter_intra_ring(sbuf, rbuf, rcounts, rcounts 635 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c void* rbuf, const int *rcounts, rcounts 650 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcounts, rdispls, rdtype, rcounts 663 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c total_dsize += dsize * (ptrdiff_t)rcounts[i]; rcounts 674 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcounts, rdispls, rdtype, rcounts 679 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcounts, rdispls, rdtype, rcounts 683 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c rbuf, rcounts, rdispls, rdtype, rcounts 124 ompi/mca/coll/tuned/coll_tuned_reduce_scatter_decision.c const int *rcounts, rcounts 135 ompi/mca/coll/tuned/coll_tuned_reduce_scatter_decision.c case (0): return ompi_coll_tuned_reduce_scatter_intra_dec_fixed(sbuf, rbuf, rcounts, rcounts 137 ompi/mca/coll/tuned/coll_tuned_reduce_scatter_decision.c case (1): return ompi_coll_base_reduce_scatter_intra_nonoverlapping(sbuf, rbuf, rcounts, rcounts 139 ompi/mca/coll/tuned/coll_tuned_reduce_scatter_decision.c case (2): return ompi_coll_base_reduce_scatter_intra_basic_recursivehalving(sbuf, rbuf, rcounts, rcounts 141 ompi/mca/coll/tuned/coll_tuned_reduce_scatter_decision.c case (3): return ompi_coll_base_reduce_scatter_intra_ring(sbuf, rbuf, rcounts, rcounts 143 ompi/mca/coll/tuned/coll_tuned_reduce_scatter_decision.c case (4): return ompi_coll_base_reduce_scatter_intra_butterfly(sbuf, rbuf, rcounts, rcounts 42 ompi/mca/fcoll/base/fcoll_base_coll_array.c int *rcounts, rcounts 72 ompi/mca/fcoll/base/fcoll_base_coll_array.c send_buf += (rcounts[i] * extent); rcounts 81 ompi/mca/fcoll/base/fcoll_base_coll_array.c rcounts[j], rcounts 84 ompi/mca/fcoll/base/fcoll_base_coll_array.c rcounts, rcounts 96 ompi/mca/fcoll/base/fcoll_base_coll_array.c rcounts, rcounts 125 ompi/mca/fcoll/base/fcoll_base_coll_array.c int *rcounts, rcounts 171 ompi/mca/fcoll/base/fcoll_base_coll_array.c (0 < rcounts[i])) { rcounts 176 ompi/mca/fcoll/base/fcoll_base_coll_array.c rcounts[i], rcounts 183 ompi/mca/fcoll/base/fcoll_base_coll_array.c if (rcounts[i] > 0) { rcounts 185 ompi/mca/fcoll/base/fcoll_base_coll_array.c rcounts[i], rcounts 49 ompi/mca/fcoll/base/fcoll_base_coll_array.h int *rcounts, rcounts 82 ompi/mca/fcoll/base/fcoll_base_coll_array.h int *rcounts, rcounts 664 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c int *scounts, *sdispls, *rcounts, *rdispls; rcounts 693 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c rcounts = ADIOI_Malloc(nprocs*sizeof(int)); rcounts 746 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c rcounts[i] = count_others_req_per_proc[i]; rcounts 748 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c rcount_total += rcounts[i]; rcounts 770 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c rcounts, rdispls, ADIO_OFFSET, rcounts 776 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c rcounts[i] * sizeof(ADIO_Offset)); rcounts 794 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c rcounts, rdispls, ADIO_OFFSET, rcounts 800 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c rcounts[i] * sizeof(ADIO_Offset)); rcounts 809 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c ADIOI_Free (rcounts); rcounts 96 test/datatype/large_data.c int rcounts[2] = {per_process, per_process}; rcounts 125 test/datatype/large_data.c ompi_datatype_create_indexed(2, rcounts, rdispls, ddt, &rtype);