|
Packit |
0848f5 |
/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */
|
|
Packit |
0848f5 |
/*
|
|
Packit |
0848f5 |
* (C) 2001 by Argonne National Laboratory.
|
|
Packit |
0848f5 |
* See COPYRIGHT in top-level directory.
|
|
Packit |
0848f5 |
*/
|
|
Packit |
0848f5 |
#include "mpi.h"
|
|
Packit |
0848f5 |
#include <stdio.h>
|
|
Packit |
0848f5 |
/* stdlib.h Needed for malloc declaration */
|
|
Packit |
0848f5 |
#include <stdlib.h>
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
int main(int argc, char **argv)
|
|
Packit |
0848f5 |
{
|
|
Packit |
0848f5 |
int i, n, n_goal = 2048, n_all, rc, n_ranks, *ranks, rank, size, len;
|
|
Packit |
0848f5 |
int group_size;
|
|
Packit |
0848f5 |
MPI_Group *group_array, world_group;
|
|
Packit |
0848f5 |
char msg[MPI_MAX_ERROR_STRING];
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
MPI_Init(&argc, &argv);
|
|
Packit |
0848f5 |
MPI_Comm_size(MPI_COMM_WORLD, &size);
|
|
Packit |
0848f5 |
MPI_Comm_rank(MPI_COMM_WORLD, &rank;;
|
|
Packit |
0848f5 |
n = n_goal;
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
group_array = (MPI_Group *) malloc(n * sizeof(MPI_Group));
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
MPI_Comm_group(MPI_COMM_WORLD, &world_group);
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
n_ranks = size;
|
|
Packit |
0848f5 |
ranks = (int *) malloc(size * sizeof(int));
|
|
Packit |
0848f5 |
for (i = 0; i < size; i++)
|
|
Packit |
0848f5 |
ranks[i] = i;
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
MPI_Errhandler_set(MPI_COMM_WORLD, MPI_ERRORS_RETURN);
|
|
Packit |
0848f5 |
for (i = 0; i < n; i++) {
|
|
Packit |
0848f5 |
rc = MPI_Group_incl(world_group, n_ranks, ranks, group_array + i);
|
|
Packit |
0848f5 |
if (rc) {
|
|
Packit |
0848f5 |
fprintf(stderr, "Error when creating group number %d\n", i);
|
|
Packit |
0848f5 |
MPI_Error_string(rc, msg, &len;;
|
|
Packit |
0848f5 |
fprintf(stderr, "%s\n", msg);
|
|
Packit |
0848f5 |
n = i + 1;
|
|
Packit |
0848f5 |
break;
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
else {
|
|
Packit |
0848f5 |
/* Check that the group was created (and that any errors were
|
|
Packit |
0848f5 |
* caught) */
|
|
Packit |
0848f5 |
rc = MPI_Group_size(group_array[i], &group_size);
|
|
Packit |
0848f5 |
if (group_size != size) {
|
|
Packit |
0848f5 |
fprintf(stderr, "Group number %d not correct (size = %d)\n", i, size);
|
|
Packit |
0848f5 |
n = i + 1;
|
|
Packit |
0848f5 |
break;
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
for (i = 0; i < n; i++) {
|
|
Packit |
0848f5 |
rc = MPI_Group_free(group_array + i);
|
|
Packit |
0848f5 |
if (rc) {
|
|
Packit |
0848f5 |
fprintf(stderr, "Error when freeing group number %d\n", i);
|
|
Packit |
0848f5 |
MPI_Error_string(rc, msg, &len;;
|
|
Packit |
0848f5 |
fprintf(stderr, "%s\n", msg);
|
|
Packit |
0848f5 |
break;
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
MPI_Errhandler_set(MPI_COMM_WORLD, MPI_ERRORS_ARE_FATAL);
|
|
Packit |
0848f5 |
MPI_Group_free(&world_group);
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
MPI_Reduce(&n, &n_all, 1, MPI_INT, MPI_MIN, 0, MPI_COMM_WORLD);
|
|
Packit |
0848f5 |
if (rank == 0) {
|
|
Packit |
0848f5 |
/* printf("Completed test of %d type creations\n", n_all); */
|
|
Packit |
0848f5 |
if (n_all != n_goal) {
|
|
Packit |
0848f5 |
printf("This MPI implementation limits the number of groups that can be created\n\
|
|
Packit |
0848f5 |
This is allowed by the standard and is not a bug, but is a limit on the\n\
|
|
Packit |
0848f5 |
implementation\n");
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
else {
|
|
Packit |
0848f5 |
printf(" No Errors\n");
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
free(group_array);
|
|
Packit |
0848f5 |
free(ranks);
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
MPI_Finalize();
|
|
Packit |
0848f5 |
return 0;
|
|
Packit |
0848f5 |
}
|