Blame test/mpi/coll/allgather_struct.c

Packit Service c5cf8c
/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */
Packit Service c5cf8c
/*
Packit Service c5cf8c
 *
Packit Service c5cf8c
 *  (C) 2015 by Argonne National Laboratory.
Packit Service c5cf8c
 *      See COPYRIGHT in top-level directory.
Packit Service c5cf8c
 */
Packit Service c5cf8c
Packit Service c5cf8c
#include <stdlib.h>
Packit Service c5cf8c
#include "mpi.h"
Packit Service c5cf8c
#include "mpitest.h"
Packit Service c5cf8c
Packit Service c5cf8c
/* Allgather a two-field struct datatype. This test
Packit Service c5cf8c
   may trigger bugs such as when the implementation
Packit Service c5cf8c
   does not handle well misaligned types.*/
Packit Service c5cf8c
Packit Service c5cf8c
typedef struct {
Packit Service c5cf8c
    int first;
Packit Service c5cf8c
    long second;
Packit Service c5cf8c
} int_long_t;
Packit Service c5cf8c
Packit Service c5cf8c
int main(int argc, char **argv)
Packit Service c5cf8c
{
Packit Service c5cf8c
    MPI_Comm comm;
Packit Service c5cf8c
    int minsize = 2;
Packit Service c5cf8c
    int i, errs = 0;
Packit Service c5cf8c
    int rank, size;
Packit Service c5cf8c
    int_long_t object;
Packit Service c5cf8c
    MPI_Datatype type;
Packit Service c5cf8c
    MPI_Aint begin;
Packit Service c5cf8c
    MPI_Aint displacements[2];
Packit Service c5cf8c
    MPI_Datatype types[] = { MPI_INT, MPI_LONG };
Packit Service c5cf8c
    int blocklength[2] = { 1, 1 };
Packit Service c5cf8c
    int_long_t *gathered_objects;
Packit Service c5cf8c
Packit Service c5cf8c
    MTest_Init(&argc, &argv);
Packit Service c5cf8c
Packit Service c5cf8c
    while (MTestGetIntracommGeneral(&comm, minsize, 1)) {
Packit Service c5cf8c
Packit Service c5cf8c
        if (comm == MPI_COMM_NULL)
Packit Service c5cf8c
            continue;
Packit Service c5cf8c
        /* Determine the sender and receiver */
Packit Service c5cf8c
        MPI_Comm_rank(comm, &rank;;
Packit Service c5cf8c
        MPI_Comm_size(comm, &size);
Packit Service c5cf8c
Packit Service c5cf8c
        gathered_objects = (int_long_t *) malloc(size * sizeof(int_long_t));
Packit Service c5cf8c
Packit Service c5cf8c
        /* Local object */
Packit Service c5cf8c
        object.first = rank;
Packit Service c5cf8c
        object.second = rank * 10;
Packit Service c5cf8c
Packit Service c5cf8c
        /* Datatype creation */
Packit Service c5cf8c
        MPI_Get_address(&object, &begin);
Packit Service c5cf8c
        MPI_Get_address(&object.first, &displacements[0]);
Packit Service c5cf8c
        MPI_Get_address(&object.second, &displacements[1]);
Packit Service c5cf8c
Packit Service c5cf8c
        for (i = 0; i != 2; ++i)
Packit Service c5cf8c
            displacements[i] -= begin;
Packit Service c5cf8c
Packit Service c5cf8c
        MPI_Type_create_struct(2, &blocklength[0], &displacements[0], &types[0], &type);
Packit Service c5cf8c
        MPI_Type_commit(&type);
Packit Service c5cf8c
Packit Service c5cf8c
        MPI_Allgather(&object, 1, type, gathered_objects, 1, type, comm);
Packit Service c5cf8c
Packit Service c5cf8c
        for (i = 0; i < size; i++) {
Packit Service c5cf8c
            if (gathered_objects[i].first != i || gathered_objects[i].second != i * 10)
Packit Service c5cf8c
                errs++;
Packit Service c5cf8c
        }
Packit Service c5cf8c
Packit Service c5cf8c
        MPI_Type_free(&type);
Packit Service c5cf8c
        MTestFreeComm(&comm);
Packit Service c5cf8c
        free(gathered_objects);
Packit Service c5cf8c
    }
Packit Service c5cf8c
Packit Service c5cf8c
    MTest_Finalize(errs);
Packit Service c5cf8c
    return MTestReturnValue(errs);
Packit Service c5cf8c
}