ace_analytic_mpislave.h

#ifndef ACE_ANALYTIC_MPISLAVE_H
#define ACE_ANALYTIC_MPISLAVE_H
#include "ace_analytic_abstractmpi.h"
#include "ace_analytic_abstractinput.h"
#include "ace_analytic.h"
//



namespace Ace
{
   namespace Analytic
   {
      class MPISlave : public AbstractMPI, public AbstractInput
      {
         Q_OBJECT
      public:
         virtual bool isFinished() const override final;
      public:
         explicit MPISlave(quint16 type);
         virtual ~MPISlave() override final;
      protected:
         virtual void mpiStart(Type type, int platform, int device) override final;
         virtual QFile* addOutputFile(const QString& path) override final;
         virtual Ace::DataObject* addOutputData(const QString& path, quint16 type, const EMetadata& system) override final;
         virtual void saveResult(std::unique_ptr<EAbstractAnalytic::Block>&& result) override final;
      private slots:
         void dataReceived(const QByteArray& data, int fromRank);
      private:
         void processCode(int code);
         void process(const QByteArray& data);
         bool setupOpenCL(int platform, int device);
         void setupSerial();
         QMPI& _mpi;
         AbstractRun* _runner {nullptr};
         int _workSize {0};
         bool _finished {false};
      };
   }
}



#endif