ParisBasicExample.h

Go to the documentation of this file.

#ifndef PARIS_BASIC_EXAMPLE_H
#define PARIS_BASIC_EXAMPLE_H

#include "DistributionLibrairie.h"

using namespace std;

class ParisBasicExample : public DistributionLibrary
{
 public:
  ParisBasicExample();
  virtual ~ParisBasicExample();

  // Common
  virtual void setSourceTopology(PaCO::PacoTopology_t topo); 
  virtual PaCO::PacoTopology_t getSourceTopology(); 
  virtual void setDestTopology(PaCO::PacoTopology_t topo); 
  virtual PaCO::PacoTopology_t getDestTopology(); 
  virtual void setNodeRank(long Rank);
  virtual long getNodeRank(); 
  virtual void setCommunicator(void * group) {}

  // Data description API
  void setEltSize(long size);
  void setNbElt(long elt_nb);

  // Client Side
  virtual PieceToSend* computePiecesToSend();
  virtual void setDataPtr(void* dataPtr);
  virtual void* getClientData(int server_node, long & size, long & length, bool & end);
  virtual void clientFree();
  virtual void * getDescr();
  // Server Side
  virtual bool insertData(void* rcptBuf); 
  virtual void* getServerData(long & length);
  virtual void serverFree() {}
  virtual void setDescr(void * descr);
  // Internal
  virtual void clientFree(int server_node);

 private:

  PaCO::PacoTopology_t _srcTopo;
  PaCO::PacoTopology_t _destTopo;

  CORBA::Short _length;
  long _data_size;
  long _data_elt_nb;
  long _my_rank;
  long _server_nb_nodes;
  
  long * _data_rst;
  long * position;
  char * _user_data;
  char * temp_buffer;
};

class ParisBasicExample_fab : virtual public paco_individual_fabrique_lib
{

 public:
  ParisBasicExample_fab() {}
  ~ParisBasicExample_fab() {}
  
  DistributionLibrary * paco_create(Fabrique* f)
    {
      return new ParisBasicExample();
    }

};

#endif