comm_size 262 ompi/debuggers/mpihandles_interface.h int comm_size; comm_size 476 ompi/debuggers/ompi_mpihandles_dll.c (*info)->comm_rank = (*info)->comm_size = 0; comm_size 512 ompi/debuggers/ompi_mpihandles_dll.c (*info)->comm_size = (*info)->comm_num_local_procs; comm_size 526 ompi/debuggers/ompi_mpihandles_dll.c (*info)->comm_size = (*info)->comm_num_remote_procs; comm_size 598 ompi/debuggers/ompi_msgq_dll.c mqs_tword_t comm_size, lowest_free, number_free; comm_size 611 ompi/debuggers/ompi_msgq_dll.c comm_size = ompi_fetch_int( proc, comm_size 624 ompi/debuggers/ompi_msgq_dll.c (int)comm_size, (int)lowest_free, (int)number_free)); comm_size 643 ompi/debuggers/ompi_msgq_dll.c for( i = 0; (commcount < (comm_size - number_free)) && (i < comm_size); i++ ) { comm_size 977 ompi/mca/coll/base/coll_base_allreduce.c int comm_size = ompi_comm_size(comm); comm_size 981 ompi/mca/coll/base/coll_base_allreduce.c rank, comm_size)); comm_size 984 ompi/mca/coll/base/coll_base_allreduce.c int nsteps = opal_hibit(comm_size, comm->c_cube_dim + 1); /* ilog2(comm_size) */ comm_size 992 ompi/mca/coll/base/coll_base_allreduce.c rank, comm_size, count)); comm_size 1033 ompi/mca/coll/base/coll_base_allreduce.c int nprocs_rem = comm_size - nprocs_pof2; comm_size 779 ompi/mca/coll/base/coll_base_bcast.c int comm_size = ompi_comm_size(comm); comm_size 784 ompi/mca/coll/base/coll_base_bcast.c rank, comm_size)); comm_size 785 ompi/mca/coll/base/coll_base_bcast.c if (comm_size < 2 || datatype_size == 0) comm_size 788 ompi/mca/coll/base/coll_base_bcast.c if (count < comm_size) { comm_size 792 ompi/mca/coll/base/coll_base_bcast.c rank, comm_size, count)); comm_size 797 ompi/mca/coll/base/coll_base_bcast.c int vrank = (rank - root + comm_size) % comm_size; comm_size 799 ompi/mca/coll/base/coll_base_bcast.c int scatter_count = (count + comm_size - 1) / comm_size; /* ceil(count / comm_size) */ comm_size 804 ompi/mca/coll/base/coll_base_bcast.c while (mask < comm_size) { comm_size 806 ompi/mca/coll/base/coll_base_bcast.c int parent = (rank - mask + comm_size) % comm_size; comm_size 828 ompi/mca/coll/base/coll_base_bcast.c if (vrank + mask < comm_size) { comm_size 831 ompi/mca/coll/base/coll_base_bcast.c int child = (rank + mask) % comm_size; comm_size 853 ompi/mca/coll/base/coll_base_bcast.c while (mask < comm_size) { comm_size 855 ompi/mca/coll/base/coll_base_bcast.c int remote = (vremote + root) % comm_size; comm_size 860 ompi/mca/coll/base/coll_base_bcast.c if (vremote < comm_size) { comm_size 883 ompi/mca/coll/base/coll_base_bcast.c if (vremote_tree_root + mask > comm_size) { comm_size 884 ompi/mca/coll/base/coll_base_bcast.c int nprocs_alldata = comm_size - vrank_tree_root - mask; comm_size 888 ompi/mca/coll/base/coll_base_bcast.c remote = (vremote + root) % comm_size; comm_size 956 ompi/mca/coll/base/coll_base_bcast.c int comm_size = ompi_comm_size(comm); comm_size 961 ompi/mca/coll/base/coll_base_bcast.c rank, comm_size)); comm_size 962 ompi/mca/coll/base/coll_base_bcast.c if (comm_size < 2 || datatype_size == 0) comm_size 965 ompi/mca/coll/base/coll_base_bcast.c if (count < comm_size) { comm_size 969 ompi/mca/coll/base/coll_base_bcast.c rank, comm_size, count)); comm_size 974 ompi/mca/coll/base/coll_base_bcast.c int vrank = (rank - root + comm_size) % comm_size; comm_size 976 ompi/mca/coll/base/coll_base_bcast.c int scatter_count = (count + comm_size - 1) / comm_size; /* ceil(count / comm_size) */ comm_size 981 ompi/mca/coll/base/coll_base_bcast.c while (mask < comm_size) { comm_size 983 ompi/mca/coll/base/coll_base_bcast.c int parent = (rank - mask + comm_size) % comm_size; comm_size 1005 ompi/mca/coll/base/coll_base_bcast.c if (vrank + mask < comm_size) { comm_size 1008 ompi/mca/coll/base/coll_base_bcast.c int child = (rank + mask) % comm_size; comm_size 1021 ompi/mca/coll/base/coll_base_bcast.c int left = (rank - 1 + comm_size) % comm_size; comm_size 1022 ompi/mca/coll/base/coll_base_bcast.c int right = (rank + 1) % comm_size; comm_size 1024 ompi/mca/coll/base/coll_base_bcast.c int recv_block = (vrank - 1 + comm_size) % comm_size; comm_size 1026 ompi/mca/coll/base/coll_base_bcast.c for (int i = 1; i < comm_size; i++) { comm_size 1046 ompi/mca/coll/base/coll_base_bcast.c recv_block = (recv_block - 1 + comm_size) % comm_size; comm_size 149 ompi/mca/coll/base/coll_base_exscan.c int comm_size = ompi_comm_size(comm); comm_size 153 ompi/mca/coll/base/coll_base_exscan.c rank, comm_size)); comm_size 156 ompi/mca/coll/base/coll_base_exscan.c if (comm_size < 2) comm_size 179 ompi/mca/coll/base/coll_base_exscan.c for (int mask = 1; mask < comm_size; mask <<= 1) { comm_size 181 ompi/mca/coll/base/coll_base_exscan.c if (remote < comm_size) { comm_size 796 ompi/mca/coll/base/coll_base_reduce.c int comm_size = ompi_comm_size(comm); comm_size 801 ompi/mca/coll/base/coll_base_reduce.c rank, comm_size, root)); comm_size 804 ompi/mca/coll/base/coll_base_reduce.c int nsteps = opal_hibit(comm_size, comm->c_cube_dim + 1); /* ilog2(comm_size) */ comm_size 811 ompi/mca/coll/base/coll_base_reduce.c "switching to basic linear reduce", rank, comm_size, count)); comm_size 865 ompi/mca/coll/base/coll_base_reduce.c int nprocs_rem = comm_size - nprocs_pof2; comm_size 700 ompi/mca/coll/base/coll_base_reduce_scatter.c int comm_size = ompi_comm_size(comm); comm_size 705 ompi/mca/coll/base/coll_base_reduce_scatter.c rank, comm_size)); comm_size 706 ompi/mca/coll/base/coll_base_reduce_scatter.c if (comm_size < 2) comm_size 709 ompi/mca/coll/base/coll_base_reduce_scatter.c displs = malloc(sizeof(*displs) * comm_size); comm_size 715 ompi/mca/coll/base/coll_base_reduce_scatter.c for (int i = 1; i < comm_size; i++) { comm_size 718 ompi/mca/coll/base/coll_base_reduce_scatter.c totalcount = displs[comm_size - 1] + rcounts[comm_size - 1]; comm_size 753 ompi/mca/coll/base/coll_base_reduce_scatter.c int nprocs_pof2 = opal_next_poweroftwo(comm_size); comm_size 755 ompi/mca/coll/base/coll_base_reduce_scatter.c int nprocs_rem = comm_size - nprocs_pof2; comm_size 138 ompi/mca/coll/base/coll_base_reduce_scatter_block.c int comm_size = ompi_comm_size(comm); comm_size 143 ompi/mca/coll/base/coll_base_reduce_scatter_block.c rank, comm_size)); comm_size 146 ompi/mca/coll/base/coll_base_reduce_scatter_block.c if (comm_size < 2) comm_size 149 ompi/mca/coll/base/coll_base_reduce_scatter_block.c totalcount = comm_size * rcount; comm_size 172 ompi/mca/coll/base/coll_base_reduce_scatter_block.c for (int mask = 1; mask < comm_size; mask <<= 1) { comm_size 192 ompi/mca/coll/base/coll_base_reduce_scatter_block.c blocklens[1] = (comm_size >= cur_tree_root + mask) ? comm_size 193 ompi/mca/coll/base/coll_base_reduce_scatter_block.c rcount * (comm_size - cur_tree_root - mask) : 0; comm_size 195 ompi/mca/coll/base/coll_base_reduce_scatter_block.c displs[1] = comm_size * rcount - blocklens[1]; comm_size 203 ompi/mca/coll/base/coll_base_reduce_scatter_block.c blocklens[1] = (comm_size >= remote_tree_root + mask) ? comm_size 204 ompi/mca/coll/base/coll_base_reduce_scatter_block.c rcount * (comm_size - remote_tree_root - mask) : 0; comm_size 206 ompi/mca/coll/base/coll_base_reduce_scatter_block.c displs[1] = comm_size * rcount - blocklens[1]; comm_size 213 ompi/mca/coll/base/coll_base_reduce_scatter_block.c if (remote < comm_size) { comm_size 227 ompi/mca/coll/base/coll_base_reduce_scatter_block.c if (remote_tree_root + mask > comm_size) { comm_size 232 ompi/mca/coll/base/coll_base_reduce_scatter_block.c int nprocs_alldata = comm_size - cur_tree_root - mask; comm_size 334 ompi/mca/coll/base/coll_base_reduce_scatter_block.c int comm_size = ompi_comm_size(comm); comm_size 339 ompi/mca/coll/base/coll_base_reduce_scatter_block.c rank, comm_size)); comm_size 340 ompi/mca/coll/base/coll_base_reduce_scatter_block.c if (rcount == 0 || comm_size < 2) comm_size 346 ompi/mca/coll/base/coll_base_reduce_scatter_block.c "switching to basic reduce_scatter_block", rank, comm_size)); comm_size 350 ompi/mca/coll/base/coll_base_reduce_scatter_block.c totalcount = comm_size * rcount; comm_size 384 ompi/mca/coll/base/coll_base_reduce_scatter_block.c int nprocs_pof2 = opal_next_poweroftwo(comm_size); comm_size 386 ompi/mca/coll/base/coll_base_reduce_scatter_block.c int nprocs_rem = comm_size - nprocs_pof2; comm_size 575 ompi/mca/coll/base/coll_base_reduce_scatter_block.c int comm_size = ompi_comm_size(comm); comm_size 580 ompi/mca/coll/base/coll_base_reduce_scatter_block.c rank, comm_size)); comm_size 581 ompi/mca/coll/base/coll_base_reduce_scatter_block.c if (rcount == 0 || comm_size < 2) comm_size 584 ompi/mca/coll/base/coll_base_reduce_scatter_block.c if (!(comm_size & (comm_size - 1))) { comm_size 590 ompi/mca/coll/base/coll_base_reduce_scatter_block.c totalcount = comm_size * rcount; comm_size 624 ompi/mca/coll/base/coll_base_reduce_scatter_block.c int nprocs_pof2 = opal_next_poweroftwo(comm_size); comm_size 626 ompi/mca/coll/base/coll_base_reduce_scatter_block.c int nprocs_rem = comm_size - nprocs_pof2; comm_size 818 ompi/mca/coll/base/coll_base_reduce_scatter_block.c int comm_size = ompi_comm_size(comm); comm_size 821 ompi/mca/coll/base/coll_base_reduce_scatter_block.c if (rcount == 0 || comm_size < 2) comm_size 824 ompi/mca/coll/base/coll_base_reduce_scatter_block.c totalcount = comm_size * rcount; comm_size 837 ompi/mca/coll/base/coll_base_reduce_scatter_block.c int log2_comm_size = opal_cube_dim(comm_size); comm_size 839 ompi/mca/coll/base/coll_base_reduce_scatter_block.c for (int i = 0; i < comm_size; i++) { comm_size 847 ompi/mca/coll/base/coll_base_reduce_scatter_block.c for (int mask = 1; mask < comm_size; mask <<= 1) { comm_size 164 ompi/mca/coll/base/coll_base_scan.c int comm_size = ompi_comm_size(comm); comm_size 169 ompi/mca/coll/base/coll_base_scan.c rank, comm_size)); comm_size 177 ompi/mca/coll/base/coll_base_scan.c if (comm_size < 2) comm_size 194 ompi/mca/coll/base/coll_base_scan.c for (int mask = 1; mask < comm_size; mask <<= 1) { comm_size 196 ompi/mca/coll/base/coll_base_scan.c if (remote < comm_size) { comm_size 479 ompi/mca/coll/base/coll_base_topo.c int comm_size = ompi_comm_size(comm); comm_size 484 ompi/mca/coll/base/coll_base_topo.c for (int i = 1; i < comm_size; i *= radix) comm_size 488 ompi/mca/coll/base/coll_base_topo.c int vrank = (rank - root + comm_size) % comm_size; comm_size 503 ompi/mca/coll/base/coll_base_topo.c while (mask < comm_size) { comm_size 506 ompi/mca/coll/base/coll_base_topo.c kmtree->tree_prev = (kmtree->tree_prev + root) % comm_size; comm_size 518 ompi/mca/coll/base/coll_base_topo.c if (child < comm_size) { comm_size 519 ompi/mca/coll/base/coll_base_topo.c child = (child + root) % comm_size; comm_size 24 ompi/mca/coll/libnbc/nbc_iallgather.c int rank, int comm_size, NBC_Schedule *schedule, const void *sendbuf, comm_size 28 ompi/mca/coll/libnbc/nbc_iallgather.c int rank, int comm_size, NBC_Schedule *schedule, const void *sbuf, comm_size 298 ompi/mca/coll/libnbc/nbc_iallgather.c int rank, int comm_size, NBC_Schedule *schedule, const void *sendbuf, comm_size 308 ompi/mca/coll/libnbc/nbc_iallgather.c for (int remote = 0; remote < comm_size ; ++remote) { comm_size 356 ompi/mca/coll/libnbc/nbc_iallgather.c int rank, int comm_size, NBC_Schedule *schedule, const void *sbuf, comm_size 368 ompi/mca/coll/libnbc/nbc_iallgather.c for (int distance = 1; distance < comm_size; distance <<= 1) { comm_size 38 ompi/mca/coll/libnbc/nbc_iallreduce.c int rank, int comm_size, int count, MPI_Datatype datatype, ptrdiff_t gap, comm_size 814 ompi/mca/coll/libnbc/nbc_iallreduce.c int rank, int comm_size, int count, MPI_Datatype datatype, ptrdiff_t gap, comm_size 821 ompi/mca/coll/libnbc/nbc_iallreduce.c int nsteps = opal_hibit(comm_size, comm->c_cube_dim + 1); /* ilog2(comm_size) */ comm_size 848 ompi/mca/coll/libnbc/nbc_iallreduce.c int nprocs_rem = comm_size - nprocs_pof2; comm_size 29 ompi/mca/coll/libnbc/nbc_ibcast.c static inline int bcast_sched_knomial(int rank, int comm_size, int root, NBC_Schedule *schedule, void *buf, comm_size 374 ompi/mca/coll/libnbc/nbc_ibcast.c int rank, int comm_size, int root, NBC_Schedule *schedule, void *buf, comm_size 380 ompi/mca/coll/libnbc/nbc_ibcast.c int vrank = (rank - root + comm_size) % comm_size; comm_size 382 ompi/mca/coll/libnbc/nbc_ibcast.c while (mask < comm_size) { comm_size 385 ompi/mca/coll/libnbc/nbc_ibcast.c parent = (parent + root) % comm_size; comm_size 398 ompi/mca/coll/libnbc/nbc_ibcast.c if (child < comm_size) { comm_size 399 ompi/mca/coll/libnbc/nbc_ibcast.c child = (child + root) % comm_size; comm_size 27 ompi/mca/coll/libnbc/nbc_iexscan.c int rank, int comm_size, const void *sendbuf, void *recvbuf, int count, comm_size 31 ompi/mca/coll/libnbc/nbc_iexscan.c int rank, int comm_size, const void *sendbuf, void *recvbuf, comm_size 214 ompi/mca/coll/libnbc/nbc_iexscan.c int rank, int comm_size, const void *sendbuf, void *recvbuf, int count, comm_size 235 ompi/mca/coll/libnbc/nbc_iexscan.c if (rank < comm_size - 1) { comm_size 248 ompi/mca/coll/libnbc/nbc_iexscan.c } else if (comm_size > 1) { comm_size 296 ompi/mca/coll/libnbc/nbc_iexscan.c int rank, int comm_size, const void *sendbuf, void *recvbuf, int count, comm_size 316 ompi/mca/coll/libnbc/nbc_iexscan.c for (int mask = 1; mask < comm_size; mask <<= 1) { comm_size 318 ompi/mca/coll/libnbc/nbc_iexscan.c if (remote < comm_size) { comm_size 37 ompi/mca/coll/libnbc/nbc_ireduce.c int rank, int comm_size, int root, const void *sbuf, void *rbuf, comm_size 650 ompi/mca/coll/libnbc/nbc_ireduce.c int rank, int comm_size, int root, const void *sbuf, void *rbuf, comm_size 658 ompi/mca/coll/libnbc/nbc_ireduce.c int nsteps = opal_hibit(comm_size, comm->c_cube_dim + 1); /* ilog2(comm_size) */ comm_size 693 ompi/mca/coll/libnbc/nbc_ireduce.c int nprocs_rem = comm_size - nprocs_pof2; comm_size 27 ompi/mca/coll/libnbc/nbc_iscan.c int rank, int comm_size, const void *sendbuf, void *recvbuf, int count, comm_size 31 ompi/mca/coll/libnbc/nbc_iscan.c int rank, int comm_size, const void *sendbuf, void *recvbuf, comm_size 184 ompi/mca/coll/libnbc/nbc_iscan.c int rank, int comm_size, const void *sendbuf, void *recvbuf, int count, comm_size 211 ompi/mca/coll/libnbc/nbc_iscan.c if (rank != comm_size - 1) { comm_size 254 ompi/mca/coll/libnbc/nbc_iscan.c int rank, int comm_size, const void *sendbuf, void *recvbuf, int count, comm_size 265 ompi/mca/coll/libnbc/nbc_iscan.c if (comm_size < 2) comm_size 275 ompi/mca/coll/libnbc/nbc_iscan.c for (int mask = 1; mask < comm_size; mask <<= 1) { comm_size 277 ompi/mca/coll/libnbc/nbc_iscan.c if (remote < comm_size) { comm_size 25 ompi/mca/coll/monitoring/coll_monitoring_allgather.c const int comm_size = ompi_comm_size(comm); comm_size 30 ompi/mca/coll/monitoring/coll_monitoring_allgather.c mca_common_monitoring_coll_a2a(data_size * (comm_size - 1), monitoring_module->data); comm_size 31 ompi/mca/coll/monitoring/coll_monitoring_allgather.c for( i = 0; i < comm_size; ++i ) { comm_size 54 ompi/mca/coll/monitoring/coll_monitoring_allgather.c const int comm_size = ompi_comm_size(comm); comm_size 59 ompi/mca/coll/monitoring/coll_monitoring_allgather.c mca_common_monitoring_coll_a2a(data_size * (comm_size - 1), monitoring_module->data); comm_size 60 ompi/mca/coll/monitoring/coll_monitoring_allgather.c for( i = 0; i < comm_size; ++i ) { comm_size 25 ompi/mca/coll/monitoring/coll_monitoring_allgatherv.c const int comm_size = ompi_comm_size(comm); comm_size 30 ompi/mca/coll/monitoring/coll_monitoring_allgatherv.c mca_common_monitoring_coll_a2a(data_size * (comm_size - 1), monitoring_module->data); comm_size 31 ompi/mca/coll/monitoring/coll_monitoring_allgatherv.c for( i = 0; i < comm_size; ++i ) { comm_size 54 ompi/mca/coll/monitoring/coll_monitoring_allgatherv.c const int comm_size = ompi_comm_size(comm); comm_size 59 ompi/mca/coll/monitoring/coll_monitoring_allgatherv.c mca_common_monitoring_coll_a2a(data_size * (comm_size - 1), monitoring_module->data); comm_size 60 ompi/mca/coll/monitoring/coll_monitoring_allgatherv.c for( i = 0; i < comm_size; ++i ) { comm_size 25 ompi/mca/coll/monitoring/coll_monitoring_allreduce.c const int comm_size = ompi_comm_size(comm); comm_size 30 ompi/mca/coll/monitoring/coll_monitoring_allreduce.c mca_common_monitoring_coll_a2a(data_size * (comm_size - 1), monitoring_module->data); comm_size 31 ompi/mca/coll/monitoring/coll_monitoring_allreduce.c for( i = 0; i < comm_size; ++i ) { comm_size 53 ompi/mca/coll/monitoring/coll_monitoring_allreduce.c const int comm_size = ompi_comm_size(comm); comm_size 58 ompi/mca/coll/monitoring/coll_monitoring_allreduce.c mca_common_monitoring_coll_a2a(data_size * (comm_size - 1), monitoring_module->data); comm_size 59 ompi/mca/coll/monitoring/coll_monitoring_allreduce.c for( i = 0; i < comm_size; ++i ) { comm_size 23 ompi/mca/coll/monitoring/coll_monitoring_alltoall.c const int comm_size = ompi_comm_size(comm); comm_size 28 ompi/mca/coll/monitoring/coll_monitoring_alltoall.c mca_common_monitoring_coll_a2a(data_size * (comm_size - 1), monitoring_module->data); comm_size 29 ompi/mca/coll/monitoring/coll_monitoring_alltoall.c for( i = 0; i < comm_size; ++i ) { comm_size 52 ompi/mca/coll/monitoring/coll_monitoring_alltoall.c const int comm_size = ompi_comm_size(comm); comm_size 57 ompi/mca/coll/monitoring/coll_monitoring_alltoall.c mca_common_monitoring_coll_a2a(data_size * (comm_size - 1), monitoring_module->data); comm_size 58 ompi/mca/coll/monitoring/coll_monitoring_alltoall.c for( i = 0; i < comm_size; ++i ) { comm_size 25 ompi/mca/coll/monitoring/coll_monitoring_alltoallv.c const int comm_size = ompi_comm_size(comm); comm_size 29 ompi/mca/coll/monitoring/coll_monitoring_alltoallv.c for( i = 0; i < comm_size; ++i ) { comm_size 57 ompi/mca/coll/monitoring/coll_monitoring_alltoallv.c const int comm_size = ompi_comm_size(comm); comm_size 61 ompi/mca/coll/monitoring/coll_monitoring_alltoallv.c for( i = 0; i < comm_size; ++i ) { comm_size 27 ompi/mca/coll/monitoring/coll_monitoring_alltoallw.c const int comm_size = ompi_comm_size(comm); comm_size 30 ompi/mca/coll/monitoring/coll_monitoring_alltoallw.c for( i = 0; i < comm_size; ++i ) { comm_size 59 ompi/mca/coll/monitoring/coll_monitoring_alltoallw.c const int comm_size = ompi_comm_size(comm); comm_size 62 ompi/mca/coll/monitoring/coll_monitoring_alltoallw.c for( i = 0; i < comm_size; ++i ) { comm_size 20 ompi/mca/coll/monitoring/coll_monitoring_barrier.c const int comm_size = ompi_comm_size(comm); comm_size 22 ompi/mca/coll/monitoring/coll_monitoring_barrier.c for( i = 0; i < comm_size; ++i ) { comm_size 42 ompi/mca/coll/monitoring/coll_monitoring_barrier.c const int comm_size = ompi_comm_size(comm); comm_size 44 ompi/mca/coll/monitoring/coll_monitoring_barrier.c for( i = 0; i < comm_size; ++i ) { comm_size 26 ompi/mca/coll/monitoring/coll_monitoring_bcast.c const int comm_size = ompi_comm_size(comm); comm_size 31 ompi/mca/coll/monitoring/coll_monitoring_bcast.c mca_common_monitoring_coll_o2a(data_size * (comm_size - 1), monitoring_module->data); comm_size 32 ompi/mca/coll/monitoring/coll_monitoring_bcast.c for( i = 0; i < comm_size; ++i ) { comm_size 55 ompi/mca/coll/monitoring/coll_monitoring_bcast.c const int comm_size = ompi_comm_size(comm); comm_size 60 ompi/mca/coll/monitoring/coll_monitoring_bcast.c mca_common_monitoring_coll_o2a(data_size * (comm_size - 1), monitoring_module->data); comm_size 61 ompi/mca/coll/monitoring/coll_monitoring_bcast.c for( i = 0; i < comm_size; ++i ) { comm_size 25 ompi/mca/coll/monitoring/coll_monitoring_exscan.c const int comm_size = ompi_comm_size(comm); comm_size 30 ompi/mca/coll/monitoring/coll_monitoring_exscan.c mca_common_monitoring_coll_a2a(data_size * (comm_size - my_rank), monitoring_module->data); comm_size 31 ompi/mca/coll/monitoring/coll_monitoring_exscan.c for( i = my_rank + 1; i < comm_size; ++i ) { comm_size 52 ompi/mca/coll/monitoring/coll_monitoring_exscan.c const int comm_size = ompi_comm_size(comm); comm_size 57 ompi/mca/coll/monitoring/coll_monitoring_exscan.c mca_common_monitoring_coll_a2a(data_size * (comm_size - my_rank), monitoring_module->data); comm_size 58 ompi/mca/coll/monitoring/coll_monitoring_exscan.c for( i = my_rank + 1; i < comm_size; ++i ) { comm_size 26 ompi/mca/coll/monitoring/coll_monitoring_gather.c const int comm_size = ompi_comm_size(comm); comm_size 29 ompi/mca/coll/monitoring/coll_monitoring_gather.c for( i = 0; i < comm_size; ++i ) { comm_size 39 ompi/mca/coll/monitoring/coll_monitoring_gather.c mca_common_monitoring_coll_a2o(data_size * (comm_size - 1), monitoring_module->data); comm_size 55 ompi/mca/coll/monitoring/coll_monitoring_gather.c const int comm_size = ompi_comm_size(comm); comm_size 58 ompi/mca/coll/monitoring/coll_monitoring_gather.c for( i = 0; i < comm_size; ++i ) { comm_size 68 ompi/mca/coll/monitoring/coll_monitoring_gather.c mca_common_monitoring_coll_a2o(data_size * (comm_size - 1), monitoring_module->data); comm_size 28 ompi/mca/coll/monitoring/coll_monitoring_gatherv.c const int comm_size = ompi_comm_size(comm); comm_size 30 ompi/mca/coll/monitoring/coll_monitoring_gatherv.c for( i = 0; i < comm_size; ++i ) { comm_size 60 ompi/mca/coll/monitoring/coll_monitoring_gatherv.c const int comm_size = ompi_comm_size(comm); comm_size 62 ompi/mca/coll/monitoring/coll_monitoring_gatherv.c for( i = 0; i < comm_size; ++i ) { comm_size 28 ompi/mca/coll/monitoring/coll_monitoring_reduce.c const int comm_size = ompi_comm_size(comm); comm_size 31 ompi/mca/coll/monitoring/coll_monitoring_reduce.c for( i = 0; i < comm_size; ++i ) { comm_size 41 ompi/mca/coll/monitoring/coll_monitoring_reduce.c mca_common_monitoring_coll_a2o(data_size * (comm_size - 1), monitoring_module->data); comm_size 58 ompi/mca/coll/monitoring/coll_monitoring_reduce.c const int comm_size = ompi_comm_size(comm); comm_size 61 ompi/mca/coll/monitoring/coll_monitoring_reduce.c for( i = 0; i < comm_size; ++i ) { comm_size 71 ompi/mca/coll/monitoring/coll_monitoring_reduce.c mca_common_monitoring_coll_a2o(data_size * (comm_size - 1), monitoring_module->data); comm_size 26 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter.c const int comm_size = ompi_comm_size(comm); comm_size 30 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter.c for( i = 0; i < comm_size; ++i ) { comm_size 56 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter.c const int comm_size = ompi_comm_size(comm); comm_size 60 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter.c for( i = 0; i < comm_size; ++i ) { comm_size 26 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c const int comm_size = ompi_comm_size(comm); comm_size 31 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c for( i = 0; i < comm_size; ++i ) { comm_size 41 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c mca_common_monitoring_coll_a2a(data_size * (comm_size - 1), monitoring_module->data); comm_size 55 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c const int comm_size = ompi_comm_size(comm); comm_size 60 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c for( i = 0; i < comm_size; ++i ) { comm_size 70 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c mca_common_monitoring_coll_a2a(data_size * (comm_size - 1), monitoring_module->data); comm_size 25 ompi/mca/coll/monitoring/coll_monitoring_scan.c const int comm_size = ompi_comm_size(comm); comm_size 30 ompi/mca/coll/monitoring/coll_monitoring_scan.c mca_common_monitoring_coll_a2a(data_size * (comm_size - my_rank), monitoring_module->data); comm_size 31 ompi/mca/coll/monitoring/coll_monitoring_scan.c for( i = my_rank + 1; i < comm_size; ++i ) { comm_size 52 ompi/mca/coll/monitoring/coll_monitoring_scan.c const int comm_size = ompi_comm_size(comm); comm_size 57 ompi/mca/coll/monitoring/coll_monitoring_scan.c mca_common_monitoring_coll_a2a(data_size * (comm_size - my_rank), monitoring_module->data); comm_size 58 ompi/mca/coll/monitoring/coll_monitoring_scan.c for( i = my_rank + 1; i < comm_size; ++i ) { comm_size 28 ompi/mca/coll/monitoring/coll_monitoring_scatter.c const int comm_size = ompi_comm_size(comm); comm_size 32 ompi/mca/coll/monitoring/coll_monitoring_scatter.c for( i = 0; i < comm_size; ++i ) { comm_size 42 ompi/mca/coll/monitoring/coll_monitoring_scatter.c mca_common_monitoring_coll_o2a(data_size * (comm_size - 1), monitoring_module->data); comm_size 61 ompi/mca/coll/monitoring/coll_monitoring_scatter.c const int comm_size = ompi_comm_size(comm); comm_size 65 ompi/mca/coll/monitoring/coll_monitoring_scatter.c for( i = 0; i < comm_size; ++i ) { comm_size 75 ompi/mca/coll/monitoring/coll_monitoring_scatter.c mca_common_monitoring_coll_o2a(data_size * (comm_size - 1), monitoring_module->data); comm_size 26 ompi/mca/coll/monitoring/coll_monitoring_scatterv.c const int comm_size = ompi_comm_size(comm); comm_size 29 ompi/mca/coll/monitoring/coll_monitoring_scatterv.c for( i = 0; i < comm_size; ++i ) { comm_size 56 ompi/mca/coll/monitoring/coll_monitoring_scatterv.c const int comm_size = ompi_comm_size(comm); comm_size 59 ompi/mca/coll/monitoring/coll_monitoring_scatterv.c for( i = 0; i < comm_size; ++i ) { comm_size 500 ompi/mca/coll/sm/coll_sm_module.c int comm_size = ompi_comm_size(comm); comm_size 515 ompi/mca/coll/sm/coll_sm_module.c for (i = 1; i < comm_size; ++i) { comm_size 564 ompi/mca/coll/sm/coll_sm_module.c (num_segments * (comm_size * control_size * 2)) + comm_size 565 ompi/mca/coll/sm/coll_sm_module.c (num_segments * (comm_size * frag_size)); comm_size 51 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c int comm_size = ompi_comm_size(comm); comm_size 71 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c if( ompi_op_is_commute(op) && (count > comm_size) ) { comm_size 73 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c if (((size_t)comm_size * (size_t)segment_size >= block_dsize)) { comm_size 466 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c int comm_size, i, pow2; comm_size 475 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c comm_size = ompi_comm_size(comm); comm_size 479 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c for (i = 0; i < comm_size; i++) { comm_size 492 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c pow2 = opal_next_poweroftwo_inclusive (comm_size); comm_size 495 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c ((total_message_size <= large_message_size) && (pow2 == comm_size)) || comm_size 496 ompi/mca/coll/tuned/coll_tuned_decision_fixed.c (comm_size >= a * total_message_size + b)) { comm_size 531 ompi/mca/common/monitoring/common_monitoring.c int i, comm_size = ompi_comm_size (comm); comm_size 537 ompi/mca/common/monitoring/common_monitoring.c for (i = 0 ; i < comm_size ; ++i) { comm_size 549 ompi/mca/common/monitoring/common_monitoring.c int comm_size = ompi_comm_size (comm); comm_size 556 ompi/mca/common/monitoring/common_monitoring.c for (i = 0 ; i < comm_size ; ++i) { comm_size 582 ompi/mca/common/monitoring/common_monitoring.c int i, comm_size = ompi_comm_size (comm); comm_size 588 ompi/mca/common/monitoring/common_monitoring.c for (i = 0 ; i < comm_size ; ++i) { comm_size 600 ompi/mca/common/monitoring/common_monitoring.c int comm_size = ompi_comm_size (comm); comm_size 607 ompi/mca/common/monitoring/common_monitoring.c for (i = 0 ; i < comm_size ; ++i) { comm_size 619 ompi/mca/common/monitoring/common_monitoring.c int i, comm_size = ompi_comm_size (comm); comm_size 625 ompi/mca/common/monitoring/common_monitoring.c for (i = 0 ; i < comm_size ; ++i) { comm_size 637 ompi/mca/common/monitoring/common_monitoring.c int comm_size = ompi_comm_size (comm); comm_size 644 ompi/mca/common/monitoring/common_monitoring.c for (i = 0 ; i < comm_size ; ++i) { comm_size 664 ompi/mca/common/monitoring/common_monitoring.c int i, comm_size = ompi_comm_size (comm); comm_size 670 ompi/mca/common/monitoring/common_monitoring.c for (i = 0 ; i < comm_size ; ++i) { comm_size 682 ompi/mca/common/monitoring/common_monitoring.c int comm_size = ompi_comm_size (comm); comm_size 689 ompi/mca/common/monitoring/common_monitoring.c for (i = 0 ; i < comm_size ; ++i) { comm_size 293 ompi/mca/osc/portals4/osc_portals4_passive_target.c int i, comm_size; comm_size 296 ompi/mca/osc/portals4/osc_portals4_passive_target.c comm_size = ompi_comm_size(module->comm); comm_size 298 ompi/mca/osc/portals4/osc_portals4_passive_target.c for (i = 0 ; i < comm_size ; ++i) { comm_size 341 ompi/mca/osc/portals4/osc_portals4_passive_target.c int i, comm_size; comm_size 343 ompi/mca/osc/portals4/osc_portals4_passive_target.c comm_size = ompi_comm_size(module->comm); comm_size 345 ompi/mca/osc/portals4/osc_portals4_passive_target.c for (i = 0 ; i < comm_size ; ++i) { comm_size 787 ompi/mca/osc/rdma/osc_rdma_component.c int comm_size = ompi_comm_size (comm); comm_size 827 ompi/mca/osc/rdma/osc_rdma_component.c for (int i = 0 ; i < comm_size ; ++i) { comm_size 907 ompi/mca/osc/rdma/osc_rdma_component.c if (btl_count >= comm_size && possible_btls[i]->btl_latency < selected_latency) { comm_size 937 ompi/mca/osc/rdma/osc_rdma_component.c int comm_size = ompi_comm_size (module->comm); comm_size 941 ompi/mca/osc/rdma/osc_rdma_component.c temp = malloc (sizeof (*temp) * comm_size); comm_size 981 ompi/mca/osc/rdma/osc_rdma_component.c int base_rank = ompi_comm_rank (module->local_leaders) * ((comm_size + module->node_count - 1) / module->node_count); comm_size 986 ompi/mca/osc/rdma/osc_rdma_component.c if (save_rank >= comm_size) { comm_size 192 ompi/mca/osc/sm/osc_sm_component.c int comm_size = ompi_comm_size (comm); comm_size 224 ompi/mca/osc/sm/osc_sm_component.c if (1 == comm_size) { comm_size 247 ompi/mca/osc/sm/osc_sm_component.c size_t posts_size, post_size = (comm_size + 63) / 64; comm_size 255 ompi/mca/osc/sm/osc_sm_component.c rbuf = malloc(sizeof(unsigned long) * comm_size); comm_size 276 ompi/mca/osc/sm/osc_sm_component.c for (i = 0 ; i < comm_size ; ++i) { comm_size 281 ompi/mca/osc/sm/osc_sm_component.c state_size = sizeof(ompi_osc_sm_global_state_t) + sizeof(ompi_osc_sm_node_state_t) * comm_size; comm_size 283 ompi/mca/osc/sm/osc_sm_component.c posts_size = comm_size * post_size * sizeof (module->posts[0][0]); comm_size 325 ompi/mca/osc/sm/osc_sm_component.c module->sizes = malloc(sizeof(size_t) * comm_size); comm_size 327 ompi/mca/osc/sm/osc_sm_component.c module->bases = malloc(sizeof(void*) * comm_size); comm_size 329 ompi/mca/osc/sm/osc_sm_component.c module->posts = calloc (comm_size, sizeof (module->posts[0])); comm_size 334 ompi/mca/osc/sm/osc_sm_component.c module->global_state = (ompi_osc_sm_global_state_t *) (module->posts[0] + comm_size * post_size); comm_size 337 ompi/mca/osc/sm/osc_sm_component.c for (i = 0, total = state_size + posts_size ; i < comm_size ; ++i) { comm_size 363 ompi/mca/osc/sm/osc_sm_component.c module->disp_units = malloc(sizeof(int) * comm_size); comm_size 376 ompi/mca/osc/sm/osc_sm_component.c module->outstanding_locks = calloc(comm_size, sizeof(enum ompi_osc_sm_locktype_t)); comm_size 413 ompi/mca/osc/sm/osc_sm_component.c module->global_state->count = comm_size; comm_size 196 ompi/mca/osc/sm/osc_sm_passive_target.c int ret, i, comm_size; comm_size 198 ompi/mca/osc/sm/osc_sm_passive_target.c comm_size = ompi_comm_size(module->comm); comm_size 199 ompi/mca/osc/sm/osc_sm_passive_target.c for (i = 0 ; i < comm_size ; ++i) { comm_size 213 ompi/mca/osc/sm/osc_sm_passive_target.c int ret, i, comm_size; comm_size 215 ompi/mca/osc/sm/osc_sm_passive_target.c comm_size = ompi_comm_size(module->comm); comm_size 216 ompi/mca/osc/sm/osc_sm_passive_target.c for (i = 0 ; i < comm_size ; ++i) { comm_size 159 ompi/mca/osc/ucx/osc_ucx_component.c int comm_size = ompi_comm_size(comm); comm_size 160 ompi/mca/osc/ucx/osc_ucx_component.c int lens[comm_size]; comm_size 171 ompi/mca/osc/ucx/osc_ucx_component.c (*disps_ptr) = (int *)calloc(comm_size, sizeof(int)); comm_size 172 ompi/mca/osc/ucx/osc_ucx_component.c for (i = 0; i < comm_size; i++) { comm_size 210 ompi/mca/osc/ucx/osc_ucx_component.c int i, comm_size = ompi_comm_size(comm); comm_size 292 ompi/mca/osc/ucx/osc_ucx_component.c module->disp_units = calloc(comm_size, sizeof(int)); comm_size 307 ompi/mca/osc/ucx/osc_ucx_component.c ret = opal_common_ucx_wpctx_create(mca_osc_ucx_component.wpool, comm_size, comm_size 360 ompi/mca/osc/ucx/osc_ucx_component.c recv_buf = (char *)calloc(comm_size, 2 * sizeof(uint64_t)); comm_size 368 ompi/mca/osc/ucx/osc_ucx_component.c module->addrs = calloc(comm_size, sizeof(uint64_t)); comm_size 369 ompi/mca/osc/ucx/osc_ucx_component.c module->state_addrs = calloc(comm_size, sizeof(uint64_t)); comm_size 370 ompi/mca/osc/ucx/osc_ucx_component.c for (i = 0; i < comm_size; i++) { comm_size 398 ompi/mca/osc/ucx/osc_ucx_component.c ret = opal_hash_table_init(&module->outstanding_locks, comm_size); comm_size 199 ompi/mca/osc/ucx/osc_ucx_passive_target.c int i, comm_size; comm_size 201 ompi/mca/osc/ucx/osc_ucx_passive_target.c comm_size = ompi_comm_size(module->comm); comm_size 202 ompi/mca/osc/ucx/osc_ucx_passive_target.c for (i = 0; i < comm_size; i++) { comm_size 221 ompi/mca/osc/ucx/osc_ucx_passive_target.c int comm_size = ompi_comm_size(module->comm); comm_size 237 ompi/mca/osc/ucx/osc_ucx_passive_target.c for (i = 0; i < comm_size; i++) { comm_size 146 ompi/mca/pml/ob1/pml_ob1_component.c int comm_size = ompi_comm_size (comm); comm_size 151 ompi/mca/pml/ob1/pml_ob1_component.c for (i = 0 ; i < comm_size ; ++i) { comm_size 172 ompi/mca/pml/ob1/pml_ob1_component.c int comm_size = ompi_comm_size (comm); comm_size 177 ompi/mca/pml/ob1/pml_ob1_component.c for (i = 0 ; i < comm_size ; ++i) { comm_size 42 ompi/mpi/c/dist_graph_create.c int i, j, index, err, comm_size; comm_size 63 ompi/mpi/c/dist_graph_create.c comm_size = ompi_comm_size(comm_old); comm_size 65 ompi/mpi/c/dist_graph_create.c if (((sources[i] < 0) && (sources[i] != MPI_PROC_NULL)) || sources[i] >= comm_size) { comm_size 73 ompi/mpi/c/dist_graph_create.c if (((destinations[index] < 0) && (destinations[index] != MPI_PROC_NULL)) || destinations[index] >= comm_size) { comm_size 52 ompi/mpi/c/dist_graph_create_adjacent.c int i, comm_size, err; comm_size 75 ompi/mpi/c/dist_graph_create_adjacent.c comm_size = ompi_comm_size(comm_old); comm_size 77 ompi/mpi/c/dist_graph_create_adjacent.c if (((sources[i] < 0) && (sources[i] != MPI_PROC_NULL)) || sources[i] >= comm_size) { comm_size 86 ompi/mpi/c/dist_graph_create_adjacent.c if (((destinations[i] < 0) && (destinations[i] != MPI_PROC_NULL)) || destinations[i] >= comm_size) { comm_size 420 ompi/mpi/cxx/comm_inln.h const int comm_size = Get_size(); comm_size 421 ompi/mpi/cxx/comm_inln.h MPI_Datatype *const data_type_tbl = new MPI_Datatype [2*comm_size]; comm_size 425 ompi/mpi/cxx/comm_inln.h for (int i_rank=0; i_rank < comm_size; i_rank++) { comm_size 427 ompi/mpi/cxx/comm_inln.h data_type_tbl[i_rank + comm_size] = recvtypes[i_rank]; comm_size 436 ompi/mpi/cxx/comm_inln.h &data_type_tbl[comm_size], mpi_comm); comm_size 33 ompi/runtime/ompi_mpi_preconnect.c int comm_size = ompi_comm_size(MPI_COMM_WORLD); comm_size 58 ompi/runtime/ompi_mpi_preconnect.c for (i = 1 ; i <= comm_size / 2 ; ++i) { comm_size 59 ompi/runtime/ompi_mpi_preconnect.c next = (comm_rank + i) % comm_size; comm_size 60 ompi/runtime/ompi_mpi_preconnect.c prev = (comm_rank - i + comm_size) % comm_size; comm_size 63 opal/mca/common/ucx/common_ucx_wpool.c winfo->comm_size = 0; comm_size 88 opal/mca/common/ucx/common_ucx_wpool.c if(winfo->comm_size != 0) { comm_size 90 opal/mca/common/ucx/common_ucx_wpool.c for (i = 0; i < winfo->comm_size; i++) { comm_size 100 opal/mca/common/ucx/common_ucx_wpool.c winfo->comm_size = 0; comm_size 346 opal/mca/common/ucx/common_ucx_wpool.c _wpool_get_idle(opal_common_ucx_wpool_t *wpool, size_t comm_size) comm_size 358 opal/mca/common/ucx/common_ucx_wpool.c winfo->endpoints = calloc(comm_size, sizeof(ucp_ep_h)); comm_size 359 opal/mca/common/ucx/common_ucx_wpool.c winfo->inflight_ops = calloc(comm_size, sizeof(short)); comm_size 360 opal/mca/common/ucx/common_ucx_wpool.c winfo->comm_size = comm_size; comm_size 375 opal/mca/common/ucx/common_ucx_wpool.c opal_common_ucx_wpctx_create(opal_common_ucx_wpool_t *wpool, int comm_size, comm_size 388 opal/mca/common/ucx/common_ucx_wpool.c ctx->comm_size = comm_size; comm_size 895 opal/mca/common/ucx/common_ucx_wpool.c tls->ctx_tbl[free_idx]->winfo = _wpool_get_idle(tls->wpool, ctx->comm_size); comm_size 965 opal/mca/common/ucx/common_ucx_wpool.c for(i = 0; i < mem_rec->gmem->ctx->comm_size; i++) { comm_size 1035 opal/mca/common/ucx/common_ucx_wpool.c tls->mem_tbl[free_idx]->mem->rkeys = calloc(mem->ctx->comm_size, comm_size 1200 opal/mca/common/ucx/common_ucx_wpool.c memset(item->ptr->inflight_ops, 0, item->ptr->comm_size * sizeof(short)); comm_size 73 opal/mca/common/ucx/common_ucx_wpool.h size_t comm_size; comm_size 113 opal/mca/common/ucx/common_ucx_wpool.h size_t comm_size; comm_size 171 opal/mca/common/ucx/common_ucx_wpool.h OPAL_DECLSPEC int opal_common_ucx_wpctx_create(opal_common_ucx_wpool_t *wpool, int comm_size, comm_size 312 opal/mca/common/ucx/common_ucx_wpool.h memset(winfo->inflight_ops, 0, winfo->comm_size * sizeof(short)); comm_size 92 opal/mca/common/ucx/common_ucx_wpool_int.h size_t comm_size);