/*
 * BP1Aggregator.h
 *
 *  Created on: Mar 1, 2017
 *      Author: wfg
 */

#ifndef BP1AGGREGATOR_H_
#define BP1AGGREGATOR_H_

#ifdef ADIOS_NOMPI
#include "mpidummy.h"
#else
#include <mpi.h>
#endif

namespace adios
{
namespace format
{

/**
 * Does all MPI related spatial aggregation tasks
 */
class BP1Aggregator
{

public:
  MPI_Comm m_MPIComm = MPI_COMM_SELF; ///< MPI communicator from Engine
  int m_RankMPI = 0;                  ///< current MPI rank process
  int m_SizeMPI = 1;                  ///< current MPI processes size

  /**
   * Unique constructor
   * @param mpiComm coming from engine
   */
  BP1Aggregator(MPI_Comm mpiComm, const bool debugMode = false);

  ~BP1Aggregator();

  /**
   * Function that aggregates and writes (from rank = 0) profiling.log in python
   * dictionary format
   * @param rankLog contain rank profiling info to be aggregated
   */
  void WriteProfilingLog(const std::string fileName,
                         const std::string &rankLog);

private:
  const bool m_DebugMode = false;
};

} // end namespace format
} // end namespace adios

#endif /* BP1AGGREGATOR_H_ */