world_size 66 ompi/mca/common/monitoring/common_monitoring_coll.c int i, pos = 0, size, world_size = -1, max_length, world_rank; world_size 69 ompi/mca/common/monitoring/common_monitoring_coll.c world_size = ompi_comm_size((ompi_communicator_t*)&ompi_mpi_comm_world) - 1; world_size 72 ompi/mca/common/monitoring/common_monitoring_coll.c max_length = snprintf(NULL, 0, "%d,", world_size - 1) + 1; world_size 1111 ompi/mca/osc/rdma/osc_rdma_component.c int world_size = ompi_comm_size (comm); world_size 1153 ompi/mca/osc/rdma/osc_rdma_component.c if (world_size > init_limit) { world_size 1160 ompi/mca/osc/rdma/osc_rdma_component.c module->outstanding_lock_array = calloc (world_size, sizeof (module->outstanding_lock_array[0])); world_size 1178 ompi/mca/osc/rdma/osc_rdma_component.c if (world_size > init_limit) { world_size 1182 ompi/mca/osc/rdma/osc_rdma_component.c module->peer_array = calloc (world_size, sizeof (ompi_osc_rdma_peer_t *)); world_size 1320 ompi/mca/osc/rdma/osc_rdma_component.c int world_size = ompi_comm_size (module->comm); world_size 1321 ompi/mca/osc/rdma/osc_rdma_component.c int init_limit = world_size > 256 ? 256 : world_size; world_size 353 ompi/runtime/ompi_spc.c int i, j, world_size, offset; world_size 357 ompi/runtime/ompi_spc.c world_size = ompi_comm_size(ompi_spc_comm); world_size 377 ompi/runtime/ompi_spc.c recv_buffer = (long long*)malloc(world_size * OMPI_SPC_NUM_COUNTERS * sizeof(long long)); world_size 393 ompi/runtime/ompi_spc.c for(j = 0; j < world_size; j++) { world_size 146 test/monitoring/check_monitoring.c static inline void pvar_all_init(MPI_T_pvar_session*session, int world_size) world_size 159 test/monitoring/check_monitoring.c old_cvalues = malloc(2 * world_size * sizeof(size_t)); world_size 160 test/monitoring/check_monitoring.c old_svalues = old_cvalues + world_size; world_size 189 test/monitoring/check_monitoring.c static inline int pvar_pml_check(MPI_T_pvar_session session, int world_size, int world_rank) world_size 193 test/monitoring/check_monitoring.c cvalues = malloc(2 * world_size * sizeof(size_t)); world_size 194 test/monitoring/check_monitoring.c svalues = cvalues + world_size; world_size 197 test/monitoring/check_monitoring.c for( i = 0; i < world_size && MPI_SUCCESS == ret; ++i ) { world_size 203 test/monitoring/check_monitoring.c } else if ( i != world_rank && (cvalues[i] - old_cvalues[i]) < (size_t) world_size ) { world_size 205 test/monitoring/check_monitoring.c __func__, i, cvalues[i] - old_cvalues[i], (size_t) world_size); world_size 213 test/monitoring/check_monitoring.c } else if ( i != world_rank && (svalues[i] - old_svalues[i]) < (size_t) (world_size * 13 * sizeof(char)) ) { world_size 215 test/monitoring/check_monitoring.c __func__, i, svalues[i] - old_svalues[i], (size_t) (world_size * 13 * sizeof(char))); world_size 225 test/monitoring/check_monitoring.c memcpy(old_cvalues, cvalues, 2 * world_size * sizeof(size_t)); world_size 231 test/monitoring/check_monitoring.c static inline int pvar_osc_check(MPI_T_pvar_session session, int world_size, int world_rank) world_size 235 test/monitoring/check_monitoring.c cvalues = malloc(2 * world_size * sizeof(size_t)); world_size 236 test/monitoring/check_monitoring.c svalues = cvalues + world_size; world_size 238 test/monitoring/check_monitoring.c memset(cvalues, 0, 2 * world_size * sizeof(size_t)); world_size 241 test/monitoring/check_monitoring.c for( i = 0; i < world_size && MPI_SUCCESS == ret; ++i ) { world_size 243 test/monitoring/check_monitoring.c if( cvalues[i] < (size_t) world_size ) { world_size 245 test/monitoring/check_monitoring.c __func__, i, cvalues[i], (size_t) world_size); world_size 249 test/monitoring/check_monitoring.c if( svalues[i] < (size_t) (world_size * 13 * sizeof(char)) ) { world_size 251 test/monitoring/check_monitoring.c __func__, i, svalues[i], (size_t) (world_size * 13 * sizeof(char))); world_size 257 test/monitoring/check_monitoring.c for( i = 0; i < world_size && MPI_SUCCESS == ret; ++i ) { world_size 259 test/monitoring/check_monitoring.c if( cvalues[i] < (size_t) world_size ) { world_size 261 test/monitoring/check_monitoring.c __func__, i, cvalues[i], (size_t) world_size); world_size 265 test/monitoring/check_monitoring.c if( svalues[i] < (size_t) (world_size * 13 * sizeof(char)) ) { world_size 267 test/monitoring/check_monitoring.c __func__, i, svalues[i], (size_t) (world_size * 13 * sizeof(char))); world_size 277 test/monitoring/check_monitoring.c memcpy(old_cvalues, cvalues, 2 * world_size * sizeof(size_t)); world_size 283 test/monitoring/check_monitoring.c static inline int pvar_coll_check(MPI_T_pvar_session session, int world_size, int world_rank) { world_size 287 test/monitoring/check_monitoring.c cvalues = malloc(2 * world_size * sizeof(size_t)); world_size 288 test/monitoring/check_monitoring.c svalues = cvalues + world_size; world_size 291 test/monitoring/check_monitoring.c for( i = 0; i < world_size && MPI_SUCCESS == ret; ++i ) { world_size 297 test/monitoring/check_monitoring.c } else if ( i != world_rank && cvalues[i] < (size_t) (world_size + 1) * 4 ) { world_size 299 test/monitoring/check_monitoring.c __func__, i, cvalues[i], (size_t) (world_size + 1) * 4); world_size 307 test/monitoring/check_monitoring.c } else if ( i != world_rank && svalues[i] < (size_t) (world_size * (2 * 13 * sizeof(char) + sizeof(int)) + 13 * 3 * sizeof(char) + sizeof(int)) ) { world_size 309 test/monitoring/check_monitoring.c __func__, i, svalues[i], (size_t) (world_size * (2 * 13 * sizeof(char) + sizeof(int)) + 13 * 3 * sizeof(char) + sizeof(int))); world_size 320 test/monitoring/check_monitoring.c if( size < (size_t) ((world_size - 1) * 13 * 2 * sizeof(char)) ) { world_size 322 test/monitoring/check_monitoring.c __func__, size, (size_t) ((world_size - 1) * 13 * 2 * sizeof(char))); world_size 332 test/monitoring/check_monitoring.c if( size < (size_t) ((world_size - 1) * (13 * sizeof(char) + sizeof(int))) ) { world_size 335 test/monitoring/check_monitoring.c (size_t) ((world_size - 1) * (13 * sizeof(char) + sizeof(int)))); world_size 340 test/monitoring/check_monitoring.c if( count < (size_t) (world_size * 4) ) { world_size 342 test/monitoring/check_monitoring.c __func__, count, (size_t) (world_size * 4)); world_size 345 test/monitoring/check_monitoring.c if( size < (size_t) (world_size * (world_size - 1) * (2 * 13 * sizeof(char) + sizeof(int))) ) { world_size 348 test/monitoring/check_monitoring.c (size_t) (world_size * (world_size - 1) * (2 * 13 * sizeof(char) + sizeof(int)))); world_size 53 test/monitoring/test_pvar_access.c static int world_rank, world_size; world_size 80 test/monitoring/test_pvar_access.c world_size = size; world_size 193 test/monitoring/test_pvar_access.c print_vars(world_rank, world_size, msg_count_p1, msg_size_p1); world_size 194 test/monitoring/test_pvar_access.c MPI_Send(NULL, 0, MPI_BYTE, (world_rank + 1) % world_size, 300, MPI_COMM_WORLD); world_size 195 test/monitoring/test_pvar_access.c MPI_Recv(NULL, 0, MPI_BYTE, (world_rank - 1) % world_size, 300, MPI_COMM_WORLD, &status); world_size 197 test/monitoring/test_pvar_access.c MPI_Recv(NULL, 0, MPI_BYTE, (world_rank - 1) % world_size, 300, MPI_COMM_WORLD, &status); world_size 198 test/monitoring/test_pvar_access.c print_vars(world_rank, world_size, msg_count_p1, msg_size_p1); world_size 199 test/monitoring/test_pvar_access.c MPI_Send(NULL, 0, MPI_BYTE, (world_rank + 1) % world_size, 300, MPI_COMM_WORLD); world_size 289 test/monitoring/test_pvar_access.c print_vars(world_rank, world_size, msg_count_p2, msg_size_p2); world_size 290 test/monitoring/test_pvar_access.c MPI_Send(NULL, 0, MPI_BYTE, (world_rank + 1) % world_size, 300, MPI_COMM_WORLD); world_size 291 test/monitoring/test_pvar_access.c MPI_Recv(NULL, 0, MPI_BYTE, (world_rank - 1) % world_size, 300, MPI_COMM_WORLD, &status); world_size 293 test/monitoring/test_pvar_access.c MPI_Recv(NULL, 0, MPI_BYTE, (world_rank - 1) % world_size, 300, MPI_COMM_WORLD, &status); world_size 294 test/monitoring/test_pvar_access.c print_vars(world_rank, world_size, msg_count_p2, msg_size_p2); world_size 295 test/monitoring/test_pvar_access.c MPI_Send(NULL, 0, MPI_BYTE, (world_rank + 1) % world_size, 300, MPI_COMM_WORLD);