ace_qmpi.h

#ifndef ACE_QMPI_H
#define ACE_QMPI_H
#include <QObject>
#include <QVector>
#include <mpi.h>
//



namespace Ace
{
   class QMPI : public QObject
   {
      Q_OBJECT
   public:
      static QMPI& instance();
      static void shutdown();
      bool isMaster() const;
      int size() const;
      int rank() const;
      int localSize() const;
      int localRank() const;
      void start();
      void stop();
   signals:
      void dataReceived(const QByteArray& data, int fromRank);
      void localDataReceived(const QByteArray& data, int fromRank);
   public slots:
      void sendData(int toRank, const QByteArray& data);
      void sendLocalData(int toRank, const QByteArray& data);
   protected:
      virtual void timerEvent(QTimerEvent* event) override final;
   private:
      explicit QMPI();
      ~QMPI();
      void probe(MPI_Comm comm, int rank);
      void sendData(MPI_Comm comm, int toRank, const QByteArray& data);
      void setupWorld();
      void setupLocal();
      constexpr static int _timerPeriod {50};
      static bool _hasShutdown;
      static QMPI* _instance;
      int _size;
      int _rank;
      MPI_Comm _local;
      int _localSize;
      int _localRank;
      bool _failed {false};
      bool _ignore {true};
   };
}



#endif