ParisBlock.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>

#include "Type.h" // For ParisBlock_param_t 

class ParisBlock : 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

  // hum
  ParisBlock_param_t _param;

public:
  // Constructors
  ParisBlock(Fabrique* f );

  ParisBlock(Fabrique* f, unsigned int blocksize );

  virtual ~ParisBlock();
  
  // 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);

  int   setConfig(void * config);
  void* getConfig();

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

  bool computeReceive(Abstrait* darray);

  Abstrait* getResult() const ;
};

class ParisBlock_fab : virtual public paco_individual_fabrique_lib
{

 public:
  ParisBlock_fab() {}
  ~ParisBlock_fab() {}
  
  DistributionLibrary * paco_create(Fabrique* f)
    {
      return new ParisBlock(f);
    }

};
#endif