mpi/unstable/ex2.html

#include <mpi/mpi.hpp>

#include <mpi/monitor.hpp>

#include <iostream>


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

  // initialize MPI environment

  mpi::environment env(argc, argv);

  mpi::communicator world;


  // initialize monitor

  mpi::monitor monitor(world);


  // in case an event has occurred, print some info and return true

  auto stop = [&monitor, world](int i) {

    bool res = false;

    if (monitor.event_on_any_rank()) {

      std::cerr << "Processor " << world.rank() << ": After " << i << " steps an event has been communicated.\n";

      res = true;

    }

    return res;

  };


  // loop as long as no event has occurred

  int event_rank = 3;

  for (int i = 0; i < 1000000; ++i) {

    // report a local event on the event_rank

    if (world.rank() == event_rank) {

      std::cerr << "Processor " << event_rank << ": Local event reported.\n";

      monitor.report_local_event();

    }


    // should we stop the loop?

    if (stop(i)) break;

  }


  // check if all processes finished the loop

  if (world.rank() == 0) {

    if (monitor.event_on_any_rank()) {

      std::cout << "Oh no! An event occurred somewhere and the loop has not been finished on all processes.\n";

    } else {

      std::cout << "No worries, all processes have finished the loop.\n";

    }

  }

}

mpi::communicator
C++ wrapper around MPI_Comm providing various convenience functions.
Definition communicator.hpp:43

mpi::communicator::rank
int rank() const
Get the rank of the calling process in the communicator.
Definition communicator.hpp:64

mpi::monitor
Constructed on top of an MPI communicator, this class helps to monitor and communicate events across ...
Definition monitor.hpp:53

monitor.hpp
Provides a class for monitoring and communicating events across multiple processes.

mpi.hpp
Includes all relevant mpi headers.

mpi::environment
RAII class to initialize and finalize MPI.
Definition environment.hpp:70