/* -*- Mode: C++; c-basic-offset:4 ; -*- */

/*

 *  (C) 2003 by Argonne National Laboratory.

 *      See COPYRIGHT in top-level directory.

 */

#include "mpi.h"

#include <iostream>

#include "mpitestconf.h"

#include "mpitestcxx.h"

static char MTEST_Descrip[] = "Simple intercomm barrier test";

/* This only checks that the Barrier operation accepts intercommunicators.

   It does not check for the semantics of a intercomm barrier (all processes

   in the local group can exit when (but not before) all processes in the

   remote group enter the barrier */

int main(int argc, char *argv[])

{

    int errs = 0;

    int leftGroup;

    MPI::Intercomm comm;

    MPI::Datatype datatype;

    MTest_Init();

    datatype = MPI::INT;

    while (MTestGetIntercomm(comm, leftGroup, 4)) {

        if (comm == MPI::COMM_NULL)

            continue;

        /* Get an intercommunicator */

        if (leftGroup) {

            try {

                comm.Barrier();

            }

            catch(MPI::Exception e) {

                errs++;

                MTestPrintError(e.Get_error_code());

            }

        } else {

            /* In the right group */

            try {

                comm.Barrier();

            }

            catch(MPI::Exception e) {

                errs++;

                MTestPrintError(e.Get_error_code());

            }

        }

        MTestFreeComm(comm);

    }

    MTest_Finalize(errs);

    return 0;

}