ParisBlockMPC.h

Go to the documentation of this file.

#ifndef BASIC_DISTRIBUTION_LIBRARY_IS_DEFINED
#define BASIC_DISTRIBUTION_LIBRARY_IS_DEFINED

#include <DistributionLibrairie.h>
#include <stdio.h>

class ParisBlockMPC : public DistributionLibrary
{
private:
  PaCO::distLoc_t _mode; // ClientSide, ServerSide, CommSide
  PaCO::PacoTopology_t   _clttopo;
  PaCO::PacoTopology_t   _srvtopo;
  PaCO::PacoGlobalData_t _gd;

  // We are waiting for native type to be supported ;(
  LocalData_t  _ld;

  void* _comm; // communicator

  Fabrique*  _fab;
  Abstrait*  _darray;
  vAbstrait* _vdarray;
  int        _remaining; // number of messages to yet to be received
public:
  // Constructors
  ParisBlockMPC(Fabrique* f );

  virtual ~ParisBlockMPC();
  
  // Comm management
  void setCommunicator(void* comm) {_comm = comm;}

  // Fabric managment
  void setFabric(Fabrique* f);

  // Reset
  void reset();

  // Methods
  const PaCO::distLoc_t& getMode() const;

  bool setMode(const PaCO::distLoc_t mode); // true if ok

  bool setServerConfiguration(const PaCO::PacoTopology_t & stopo);
  bool setClientConfiguration(const PaCO::PacoTopology_t & ctopo);

  bool setGlobalDataConfiguration(const PaCO::PacoGlobalData_t& gd);
  bool setLocalDataConfiguration (const PaCO::PacoLocalData_t&  ld);

  void computeSend(const void* data, vAbstrait& vdarray, vector<unsigned>& destid);

  bool computeReceive(Abstrait* darray);

  Abstrait* getResult() const ;
};

class ParisBlockMPC_fab : virtual public paco_individual_fabrique_lib
{
 public:
  ParisBlockMPC_fab() {}
  ~ParisBlockMPC_fab() {}
  
  DistributionLibrary * paco_create(Fabrique* f)
    {
      return new ParisBlockMPC(f);
    }
};
#endif