comm_world_size 71 ompi/mca/common/monitoring/monitoring_prof.c static int comm_world_size; comm_world_size 110 ompi/mca/common/monitoring/monitoring_prof.c PMPI_Comm_size(MPI_COMM_WORLD, &comm_world_size); comm_world_size 176 ompi/mca/common/monitoring/monitoring_prof.c exchange_count_matrix_1 = (size_t *) calloc(comm_world_size * comm_world_size, sizeof(size_t)); comm_world_size 177 ompi/mca/common/monitoring/monitoring_prof.c exchange_size_matrix_1 = (size_t *) calloc(comm_world_size * comm_world_size, sizeof(size_t)); comm_world_size 178 ompi/mca/common/monitoring/monitoring_prof.c exchange_count_matrix_2 = (size_t *) calloc(comm_world_size * comm_world_size, sizeof(size_t)); comm_world_size 179 ompi/mca/common/monitoring/monitoring_prof.c exchange_size_matrix_2 = (size_t *) calloc(comm_world_size * comm_world_size, sizeof(size_t)); comm_world_size 180 ompi/mca/common/monitoring/monitoring_prof.c exchange_all_size_matrix = (size_t *) calloc(comm_world_size * comm_world_size, sizeof(size_t)); comm_world_size 181 ompi/mca/common/monitoring/monitoring_prof.c exchange_all_count_matrix = (size_t *) calloc(comm_world_size * comm_world_size, sizeof(size_t)); comm_world_size 182 ompi/mca/common/monitoring/monitoring_prof.c exchange_all_avg_matrix = (size_t *) calloc(comm_world_size * comm_world_size, sizeof(size_t)); comm_world_size 186 ompi/mca/common/monitoring/monitoring_prof.c PMPI_Gather(pml_counts.vector, comm_world_size, MPI_UNSIGNED_LONG, exchange_count_matrix_1, comm_world_size, MPI_UNSIGNED_LONG, 0, MPI_COMM_WORLD); comm_world_size 187 ompi/mca/common/monitoring/monitoring_prof.c PMPI_Gather(pml_sizes.vector, comm_world_size, MPI_UNSIGNED_LONG, exchange_size_matrix_1, comm_world_size, MPI_UNSIGNED_LONG, 0, MPI_COMM_WORLD); comm_world_size 188 ompi/mca/common/monitoring/monitoring_prof.c PMPI_Gather(coll_counts.vector, comm_world_size, MPI_UNSIGNED_LONG, exchange_count_matrix_2, comm_world_size, MPI_UNSIGNED_LONG, 0, MPI_COMM_WORLD); comm_world_size 189 ompi/mca/common/monitoring/monitoring_prof.c PMPI_Gather(coll_sizes.vector, comm_world_size, MPI_UNSIGNED_LONG, exchange_size_matrix_2, comm_world_size, MPI_UNSIGNED_LONG, 0, MPI_COMM_WORLD); comm_world_size 194 ompi/mca/common/monitoring/monitoring_prof.c for (i = 0; i < comm_world_size; ++i) { comm_world_size 195 ompi/mca/common/monitoring/monitoring_prof.c for (j = i + 1; j < comm_world_size; ++j) { comm_world_size 197 ompi/mca/common/monitoring/monitoring_prof.c exchange_count_matrix_1[i * comm_world_size + j] = exchange_count_matrix_1[j * comm_world_size + i] = (exchange_count_matrix_1[i * comm_world_size + j] + exchange_count_matrix_1[j * comm_world_size + i]) / 2; comm_world_size 198 ompi/mca/common/monitoring/monitoring_prof.c exchange_size_matrix_1[i * comm_world_size + j] = exchange_size_matrix_1[j * comm_world_size + i] = (exchange_size_matrix_1[i * comm_world_size + j] + exchange_size_matrix_1[j * comm_world_size + i]) / 2; comm_world_size 199 ompi/mca/common/monitoring/monitoring_prof.c if (exchange_count_matrix_1[i * comm_world_size + j] != 0) comm_world_size 200 ompi/mca/common/monitoring/monitoring_prof.c exchange_all_size_matrix[i * comm_world_size + j] = exchange_all_size_matrix[j * comm_world_size + i] = exchange_size_matrix_1[i * comm_world_size + j] / exchange_count_matrix_1[i * comm_world_size + j]; comm_world_size 203 ompi/mca/common/monitoring/monitoring_prof.c exchange_count_matrix_2[i * comm_world_size + j] = exchange_count_matrix_2[j * comm_world_size + i] = (exchange_count_matrix_2[i * comm_world_size + j] + exchange_count_matrix_2[j * comm_world_size + i]) / 2; comm_world_size 204 ompi/mca/common/monitoring/monitoring_prof.c exchange_size_matrix_2[i * comm_world_size + j] = exchange_size_matrix_2[j * comm_world_size + i] = (exchange_size_matrix_2[i * comm_world_size + j] + exchange_size_matrix_2[j * comm_world_size + i]) / 2; comm_world_size 205 ompi/mca/common/monitoring/monitoring_prof.c if (exchange_count_matrix_2[i * comm_world_size + j] != 0) comm_world_size 206 ompi/mca/common/monitoring/monitoring_prof.c exchange_all_count_matrix[i * comm_world_size + j] = exchange_all_count_matrix[j * comm_world_size + i] = exchange_size_matrix_2[i * comm_world_size + j] / exchange_count_matrix_2[i * comm_world_size + j]; comm_world_size 211 ompi/mca/common/monitoring/monitoring_prof.c write_mat("monitoring_pml_msg.mat", exchange_count_matrix_1, comm_world_size); comm_world_size 212 ompi/mca/common/monitoring/monitoring_prof.c write_mat("monitoring_pml_size.mat", exchange_size_matrix_1, comm_world_size); comm_world_size 213 ompi/mca/common/monitoring/monitoring_prof.c write_mat("monitoring_pml_avg.mat", exchange_all_size_matrix, comm_world_size); comm_world_size 216 ompi/mca/common/monitoring/monitoring_prof.c write_mat("monitoring_coll_msg.mat", exchange_count_matrix_2, comm_world_size); comm_world_size 217 ompi/mca/common/monitoring/monitoring_prof.c write_mat("monitoring_coll_size.mat", exchange_size_matrix_2, comm_world_size); comm_world_size 218 ompi/mca/common/monitoring/monitoring_prof.c write_mat("monitoring_coll_avg.mat", exchange_all_count_matrix, comm_world_size); comm_world_size 221 ompi/mca/common/monitoring/monitoring_prof.c for (i = 0; i < comm_world_size; ++i) { comm_world_size 222 ompi/mca/common/monitoring/monitoring_prof.c for (j = i + 1; j < comm_world_size; ++j) { comm_world_size 223 ompi/mca/common/monitoring/monitoring_prof.c exchange_all_size_matrix[i * comm_world_size + j] = exchange_all_size_matrix[j * comm_world_size + i] = exchange_size_matrix_1[i * comm_world_size + j] + exchange_size_matrix_2[i * comm_world_size + j]; comm_world_size 224 ompi/mca/common/monitoring/monitoring_prof.c exchange_all_count_matrix[i * comm_world_size + j] = exchange_all_count_matrix[j * comm_world_size + i] = exchange_count_matrix_1[i * comm_world_size + j] + exchange_count_matrix_2[i * comm_world_size + j]; comm_world_size 230 ompi/mca/common/monitoring/monitoring_prof.c PMPI_Gather(osc_scounts.vector, comm_world_size, MPI_UNSIGNED_LONG, exchange_count_matrix_1, comm_world_size, MPI_UNSIGNED_LONG, 0, MPI_COMM_WORLD); comm_world_size 231 ompi/mca/common/monitoring/monitoring_prof.c PMPI_Gather(osc_ssizes.vector, comm_world_size, MPI_UNSIGNED_LONG, exchange_size_matrix_1, comm_world_size, MPI_UNSIGNED_LONG, 0, MPI_COMM_WORLD); comm_world_size 232 ompi/mca/common/monitoring/monitoring_prof.c PMPI_Gather(osc_rcounts.vector, comm_world_size, MPI_UNSIGNED_LONG, exchange_count_matrix_2, comm_world_size, MPI_UNSIGNED_LONG, 0, MPI_COMM_WORLD); comm_world_size 233 ompi/mca/common/monitoring/monitoring_prof.c PMPI_Gather(osc_rsizes.vector, comm_world_size, MPI_UNSIGNED_LONG, exchange_size_matrix_2, comm_world_size, MPI_UNSIGNED_LONG, 0, MPI_COMM_WORLD); comm_world_size 238 ompi/mca/common/monitoring/monitoring_prof.c for (i = 0; i < comm_world_size; ++i) { comm_world_size 239 ompi/mca/common/monitoring/monitoring_prof.c for (j = i + 1; j < comm_world_size; ++j) { comm_world_size 241 ompi/mca/common/monitoring/monitoring_prof.c exchange_count_matrix_1[i * comm_world_size + j] = exchange_count_matrix_1[j * comm_world_size + i] = (exchange_count_matrix_1[i * comm_world_size + j] + exchange_count_matrix_1[j * comm_world_size + i] + exchange_count_matrix_2[i * comm_world_size + j] + exchange_count_matrix_2[j * comm_world_size + i]) / 2; comm_world_size 242 ompi/mca/common/monitoring/monitoring_prof.c exchange_size_matrix_1[i * comm_world_size + j] = exchange_size_matrix_1[j * comm_world_size + i] = (exchange_size_matrix_1[i * comm_world_size + j] + exchange_size_matrix_1[j * comm_world_size + i] + exchange_size_matrix_2[i * comm_world_size + j] + exchange_size_matrix_2[j * comm_world_size + i]) / 2; comm_world_size 243 ompi/mca/common/monitoring/monitoring_prof.c if (exchange_count_matrix_1[i * comm_world_size + j] != 0) comm_world_size 244 ompi/mca/common/monitoring/monitoring_prof.c exchange_all_avg_matrix[i * comm_world_size + j] = exchange_all_avg_matrix[j * comm_world_size + i] = exchange_size_matrix_1[i * comm_world_size + j] / exchange_count_matrix_1[i * comm_world_size + j]; comm_world_size 249 ompi/mca/common/monitoring/monitoring_prof.c write_mat("monitoring_osc_msg.mat", exchange_count_matrix_1, comm_world_size); comm_world_size 250 ompi/mca/common/monitoring/monitoring_prof.c write_mat("monitoring_osc_size.mat", exchange_size_matrix_1, comm_world_size); comm_world_size 251 ompi/mca/common/monitoring/monitoring_prof.c write_mat("monitoring_osc_avg.mat", exchange_all_avg_matrix, comm_world_size); comm_world_size 254 ompi/mca/common/monitoring/monitoring_prof.c for (i = 0; i < comm_world_size; ++i) { comm_world_size 255 ompi/mca/common/monitoring/monitoring_prof.c for (j = i + 1; j < comm_world_size; ++j) { comm_world_size 256 ompi/mca/common/monitoring/monitoring_prof.c exchange_all_size_matrix[i * comm_world_size + j] = exchange_all_size_matrix[j * comm_world_size + i] += exchange_size_matrix_1[i * comm_world_size + j]; comm_world_size 257 ompi/mca/common/monitoring/monitoring_prof.c exchange_all_count_matrix[i * comm_world_size + j] = exchange_all_count_matrix[j * comm_world_size + i] += exchange_count_matrix_1[i * comm_world_size + j]; comm_world_size 258 ompi/mca/common/monitoring/monitoring_prof.c if (exchange_all_count_matrix[i * comm_world_size + j] != 0) comm_world_size 259 ompi/mca/common/monitoring/monitoring_prof.c exchange_all_avg_matrix[i * comm_world_size + j] = exchange_all_avg_matrix[j * comm_world_size + i] = exchange_all_size_matrix[i * comm_world_size + j] / exchange_all_count_matrix[i * comm_world_size + j]; comm_world_size 264 ompi/mca/common/monitoring/monitoring_prof.c write_mat("monitoring_all_msg.mat", exchange_all_count_matrix, comm_world_size); comm_world_size 265 ompi/mca/common/monitoring/monitoring_prof.c write_mat("monitoring_all_size.mat", exchange_all_size_matrix, comm_world_size); comm_world_size 266 ompi/mca/common/monitoring/monitoring_prof.c write_mat("monitoring_all_avg.mat", exchange_all_avg_matrix, comm_world_size); comm_world_size 322 ompi/mca/common/monitoring/monitoring_prof.c if (count != comm_world_size) { comm_world_size 323 ompi/mca/common/monitoring/monitoring_prof.c fprintf(stderr, "ERROR : COMM_WORLD has %d ranks \"%s\" pvar contains %d values, check that you have monitoring pml\n", comm_world_size, pvar_name, count); comm_world_size 327 ompi/mca/common/monitoring/monitoring_prof.c res->vector = (size_t *) malloc(comm_world_size * sizeof(size_t)); comm_world_size 390 ompi/mca/common/monitoring/monitoring_prof.c for (i = 0; i < comm_world_size; ++i) { comm_world_size 391 ompi/mca/common/monitoring/monitoring_prof.c for (j = 0; j < comm_world_size; ++j) { comm_world_size 392 ompi/mca/common/monitoring/monitoring_prof.c fprintf(matrix_file, "%zu ", mat[i * comm_world_size + j]);