BasicDistributionLibrary.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 BasicDistributionLibrary : 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
  BasicDistributionLibrary(Fabrique* f);
  BasicDistributionLibrary(Fabrique* f, void* comm);

  virtual ~BasicDistributionLibrary();

  // Comm management
  void setCommunicator(void* 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 ;
};


#endif