Blame test/mpi/comm/comm_group_rand.c

Packit Service c5cf8c
/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */
Packit Service c5cf8c
/*
Packit Service c5cf8c
 *  (C) 2003 by Argonne National Laboratory.
Packit Service c5cf8c
 *      See COPYRIGHT in top-level directory.
Packit Service c5cf8c
 */
Packit Service c5cf8c
Packit Service c5cf8c
#include <stdio.h>
Packit Service c5cf8c
#include <stdlib.h>
Packit Service c5cf8c
#include <mpi.h>
Packit Service c5cf8c
#include "mpitestconf.h"
Packit Service c5cf8c
#include "mpitest.h"
Packit Service c5cf8c
Packit Service c5cf8c
#define LOOPS 100
Packit Service c5cf8c
Packit Service c5cf8c
int main(int argc, char **argv)
Packit Service c5cf8c
{
Packit Service c5cf8c
    int rank, size, i, j, count;
Packit Service c5cf8c
    MPI_Group full_group, sub_group;
Packit Service c5cf8c
    int *included, *ranks;
Packit Service c5cf8c
    MPI_Comm comm;
Packit Service c5cf8c
Packit Service c5cf8c
    MTest_Init(&argc, &argv);
Packit Service c5cf8c
    MPI_Comm_rank(MPI_COMM_WORLD, &rank;;
Packit Service c5cf8c
    MPI_Comm_size(MPI_COMM_WORLD, &size);
Packit Service c5cf8c
Packit Service c5cf8c
    ranks = malloc(size * sizeof(int));
Packit Service c5cf8c
    included = malloc(size * sizeof(int));
Packit Service c5cf8c
    MPI_Comm_group(MPI_COMM_WORLD, &full_group);
Packit Service c5cf8c
Packit Service c5cf8c
    for (j = 0; j < LOOPS; j++) {
Packit Service c5cf8c
        srand(j);       /* Deterministic seed */
Packit Service c5cf8c
Packit Service c5cf8c
        count = 0;
Packit Service c5cf8c
        for (i = 0; i < size; i++) {
Packit Service c5cf8c
            if (rand() % 2) {   /* randomly include a rank */
Packit Service c5cf8c
                included[i] = 1;
Packit Service c5cf8c
                ranks[count++] = i;
Packit Service c5cf8c
            } else
Packit Service c5cf8c
                included[i] = 0;
Packit Service c5cf8c
        }
Packit Service c5cf8c
Packit Service c5cf8c
        MPI_Group_incl(full_group, count, ranks, &sub_group);
Packit Service c5cf8c
Packit Service c5cf8c
        if (included[rank]) {
Packit Service c5cf8c
            MPI_Comm_create_group(MPI_COMM_WORLD, sub_group, 0, &comm);
Packit Service c5cf8c
            MPI_Barrier(comm);
Packit Service c5cf8c
            MPI_Comm_free(&comm);
Packit Service c5cf8c
        }
Packit Service c5cf8c
Packit Service c5cf8c
        MPI_Group_free(&sub_group);
Packit Service c5cf8c
    }
Packit Service c5cf8c
Packit Service c5cf8c
    MPI_Group_free(&full_group);
Packit Service c5cf8c
Packit Service c5cf8c
    free(ranks);
Packit Service c5cf8c
    free(included);
Packit Service c5cf8c
    MTest_Finalize(0);
Packit Service c5cf8c
Packit Service c5cf8c
    return 0;
Packit Service c5cf8c
}