#include <Controlled.h>

Inheritance diagram for Controlled:

Collaboration diagram for Controlled:

Public Member Functions
virtual void	clientFree ()

virtual PieceToSend *	computePiecesToSend (unsigned &size)

	Controlled ()

virtual bool	freeComId (long id)

virtual void *	getClientData (void *pid, int server_node, long &size, long &length, bool &end)

virtual void *	getDescr ()

virtual PaCO::PacoTopology_t	getDestTopology ()

long	getMaxLen ()

virtual long	getNodeRank ()

virtual void *	getServerData (long &length)

virtual PaCO::PacoTopology_t	getSourceTopology ()

virtual bool	insertData (void *rcptBuf, unsigned long element_nb)

void	readFromFile (char *filename)

virtual void	serverFree ()

virtual bool	setComId (long id)

virtual void	setCommunicator (void *group)

virtual void	setDataPtr (void *dataPtr)

virtual void	setDescr (void *descr)

virtual void	setDestTopology (PaCO::PacoTopology_t topo)

void	setEltSize (unsigned long size)

void	setMaxLocalLen (unsigned long elt_nb)

virtual void	setNodeRank (long Rank)

virtual void	setSourceTopology (PaCO::PacoTopology_t topo)

virtual	~Controlled ()

Protected Member Functions
void	_setDestTopology (unsigned long total)

void	_setLocalLen (unsigned long elt_nb)

void	_setSourceTopology (unsigned long total)

Private Attributes
char *	_clientBuffer

ControlledLib::ControlledDescr	_clientDescr

CommMatrix *	_cm

unsigned	_config

PaCO::PacoTopology_t	_dTopo

unsigned	_llen

unsigned	_maxllen

unsigned	_nodeRank

CommMatrix *	_remaining_cm

char *	_serverBuffer

ControlledLib::ControlledDescr *	_serverDescr

unsigned long	_serverToReceived

PaCO::PacoTopology_t	_sTopo

unsigned	_unitsize

Detailed Description

Definition at line 15 of file Controlled.h.

Constructor & Destructor Documentation

◆ Controlled()

Controlled::Controlled ( )

Definition at line 19 of file Controlled.cc.

References _clientBuffer, _clientDescr, _cm, _config, _dTopo, _maxllen, _nodeRank, _remaining_cm, _serverBuffer, _serverDescr, _sTopo, ControlledLib::ControlledDescr::lens, and PaCO::PacoTopology_s::total.

 {
 #ifdef DEBUG_INTERNAL
   std::cerr<<"[new] Controlled"<<std::endl;
 #endif  
 
   // Common
   _config = 0;
 
   // By default 1->1 :)
   _sTopo.total=1;
   _dTopo.total=1;
   _nodeRank=0;
   
   // Client side
   _clientBuffer=NULL;
   _cm = new CommMatrix(_sTopo.total,_dTopo.total);
   _maxllen=0;
   _remaining_cm = NULL;
   _clientDescr.lens.length(0);
 
   // Server side
   _serverDescr=NULL;
   _serverBuffer=NULL;
 
 #ifdef DEBUG_INTERNAL
   std::cerr<<"[new] Controlled done"<<std::endl;
 #endif  
 
 }

◆ ~Controlled()

Controlled::~Controlled ( )

virtual

Definition at line 50 of file Controlled.cc.

References _cm.

 {
 #ifdef DEBUG_INTERNAL
   std::cerr<<"[del] Controlled"<<std::endl;
 #endif  
   delete _cm;
 }

Member Function Documentation

◆ _setDestTopology()

void Controlled::_setDestTopology ( unsigned long total )

protected

Definition at line 93 of file Controlled.cc.

References setDestTopology(), and PaCO::PacoTopology_s::total.

Referenced by readFromFile().

 {
   PaCO::PacoTopology_t topo;
   topo.total = total;
   setDestTopology(topo);
 }

Here is the call graph for this function:

◆ _setLocalLen()

void Controlled::_setLocalLen ( unsigned long elt_nb )

protected

Definition at line 150 of file Controlled.cc.

References _llen.

Referenced by setDescr().

 {
 #ifdef DEBUG_INTERNAL
   std::cerr << "-- setLotalNbElt: " << elt_nb << std::endl;
 #endif
   _llen = elt_nb;
 }

◆ _setSourceTopology()

void Controlled::_setSourceTopology ( unsigned long total )

protected

Definition at line 60 of file Controlled.cc.

References setSourceTopology(), and PaCO::PacoTopology_s::total.

Referenced by readFromFile().

 {
   PaCO::PacoTopology_t topo;
   topo.total = total;
   setSourceTopology(topo);
 }

Here is the call graph for this function:

◆ clientFree()

void Controlled::clientFree ( )

virtual

Implements DistributionLibrary.

Definition at line 333 of file Controlled.cc.

References _remaining_cm.

 {
 
 #ifdef DEBUG_INTERNAL
   std::cerr << "-- clientFree\n";
 #endif
   delete _remaining_cm;
   _remaining_cm=NULL;
 }

◆ computePiecesToSend()

PieceToSend * Controlled::computePiecesToSend ( unsigned & size )

virtual

Implements DistributionLibrary.

Definition at line 236 of file Controlled.cc.

References _cm, _config, _nodeRank, _unitsize, CORRECT_CONFIG, PieceToSend::destNode, CommMatrix::get(), CommMatrix::getReceiverSize(), CommMatrix::getSenderSize(), PieceToSend::id, PieceToSend::size, and PieceToSend::sourceNode.

 {
 
   PieceToSend * sched;
 
 #ifdef DEBUG_INTERNAL
   std::cerr << "computePiecesToSend-------------------- in\n";
   std::cerr << " config = "<<_config<<endl;
   std::cerr << " #sender: "<<_cm->getSenderSize()<<std::endl;
   std::cerr << " #recv: "<<_cm->getReceiverSize()<<std::endl;  
 #endif
 
   if (_config != CORRECT_CONFIG) {
     std::cerr << "Controlled: incorrect configuration state "<< _config<<"/"<<CORRECT_CONFIG<<endl;
     abort();
   }
 
   sched = new PieceToSend[_cm->getSenderSize()*_cm->getReceiverSize()];
 
   unsigned count=0;
   for(unsigned j=0;j<_cm->getReceiverSize();j++) {  
     if (_cm->get(_nodeRank,j)>0) {
 #ifdef DEBUG_INTERNAL
       std::cerr << " "<<_nodeRank<<" -> "<<j<<" : "<<_cm->get(_nodeRank,j)<<std::endl;
 #endif
       sched[count].sourceNode = _nodeRank; 
       sched[count].destNode   = j;
       sched[count].size       = _cm->get(_nodeRank,j)*_unitsize;
       sched[count].id         = (void*) -1; /* not used */
       count++;
     }
   }
   
   size_out = count;
   
 #ifdef DEBUG_INTERNAL
   std::cerr << "computePiecesToSend-------------------- done\n";
 #endif
 
   return sched;
 }

Here is the call graph for this function:

◆ freeComId()

virtual bool DistributionLibrary::freeComId ( long id )

inlinevirtualinherited

Reimplemented in BasicBC, and GaBro.

Definition at line 41 of file DistributionLibrairie.h.

41 { return false;}

◆ getClientData()

void * Controlled::getClientData	(	void *	pid,
		int	server_node,
		long &	size,
		long &	length,
		bool &	end
	)

virtual

Implements DistributionLibrary.

Definition at line 288 of file Controlled.cc.

References _clientBuffer, _clientDescr, _cm, _nodeRank, _remaining_cm, _unitsize, CommMatrix::get(), CommMatrix::getSenderSize(), ControlledLib::ControlledDescr::lens, ControlledLib::ControlledDescr::llen, and CommMatrix::sub().

 {
   if (!_remaining_cm)
     _remaining_cm = new CommMatrix(_cm);
 
   long rgsz = _remaining_cm->get(_nodeRank, dnode)*_unitsize;
   unsigned rglen;
 
   if (rgsz > remaining_size_octet) {
     rglen = remaining_size_octet/_unitsize;
     end=false;
   } else {
     rglen = _remaining_cm->get(_nodeRank, dnode);
     end=true;
   }    
 
   if (rglen>0) {
 
     returned_length_element=rglen;
     remaining_size_octet-=(returned_length_element*_unitsize);
     _remaining_cm->sub(_nodeRank, dnode, rglen);
   
     unsigned descr_len  = _clientDescr.lens.length();
     _clientDescr.lens.length(descr_len+1);
     _clientDescr.lens[descr_len]=rglen;
 
     unsigned total=0;
     for(unsigned i=0;i<_cm->getSenderSize();i++) {
       total+=_cm->get(i, dnode);
     }
     _clientDescr.llen = total;
 
   }
 #ifdef DEBUG_INTERNAL
   std::cerr << __FUNCTION__ << ": getClientData returns #elt: "<<rglen<<endl;
 #endif
 
   //  int dummy;
   //  fscanf(stdin, "%d", &dummy);  
 
 
   return _clientBuffer;
 }

Here is the call graph for this function:

◆ getDescr()

void * Controlled::getDescr ( )

virtual

Implements DistributionLibrary.

Definition at line 344 of file Controlled.cc.

References _clientDescr, ControlledLib::ControlledDescr::lens, and ControlledLib::ControlledDescr::llen.

 {
 #ifdef DEBUG_INTERNAL
   std::cerr << "-- descr:llen: "<<_clientDescr.llen<<std::endl;
 #endif
 
   _clientDescr.lens.length(0);
 
   return &_clientDescr;
 }

◆ getDestTopology()

PaCO::PacoTopology_t Controlled::getDestTopology ( )

virtual

Implements DistributionLibrary.

Definition at line 117 of file Controlled.cc.

References _dTopo.

 {
   std::cerr << "****** Why is the method " << __FUNCTION__ << "called?\n";
   abort();
   return _dTopo;
 }

◆ getMaxLen()

long Controlled::getMaxLen ( )

Definition at line 169 of file Controlled.cc.

References _maxllen.

 {
   return _maxllen;
 }

◆ getNodeRank()

long Controlled::getNodeRank ( )

virtual

Implements DistributionLibrary.

Definition at line 134 of file Controlled.cc.

References _nodeRank.

 {
   return _nodeRank;
 }

◆ getServerData()

void * Controlled::getServerData ( long & length )

virtual

Implements DistributionLibrary.

Definition at line 377 of file Controlled.cc.

References _llen, and _serverBuffer.

 {
   length= _llen;
 #ifdef DEBUG_INTERNAL
   std::cerr << "-- getServerData: ptr : "<<(void*)_serverBuffer<<" #element:"<<length<<std::endl;
 #endif  
   return (void*) _serverBuffer;
 }

◆ getSourceTopology()

PaCO::PacoTopology_t Controlled::getSourceTopology ( )

virtual

Implements DistributionLibrary.

Definition at line 84 of file Controlled.cc.

References _sTopo.

 {
   std::cerr << "****** Why is the method " << __FUNCTION__ << "called?\n";
   abort();
   return _sTopo;
 }

◆ insertData()

bool Controlled::insertData	(	void *	rcptBuf,
		unsigned long	element_nb
	)

virtual

Implements DistributionLibrary.

Definition at line 356 of file Controlled.cc.

References _serverBuffer, _serverToReceived, and _unitsize.

 {
   // cp from recpBuf to _serverBuffer
 #ifdef DEBUG_INTERNAL
   std::cerr << "-- insertData:"<<element_nb<<std::endl;
 #endif
   
   unsigned long llen = element_nb*_unitsize;
   _serverToReceived -= llen;
 
   memcpy(_serverBuffer+_serverToReceived, rcptBuf, llen);
 
 #ifdef DEBUG_INTERNAL
   std::cerr << "-- insertData: "<<_serverToReceived<<" octects"<<std::endl;
 #endif
   
 
   return (_serverToReceived==0);
 }

◆ readFromFile()

void Controlled::readFromFile ( char * filename )

Definition at line 175 of file Controlled.cc.

References _cm, _maxllen, _setDestTopology(), _setSourceTopology(), CommMatrix::dump(), CommMatrix::set(), and setMaxLocalLen().

 {
 #ifdef DEBUG_INTERNAL
   std::cerr << "readFromFile-------------------- done\n";
 #endif
 
   //open comms file
   FILE *comms_file = fopen(filename, "r");
   if (comms_file == NULL) {
     perror("unable to open comms file");
     throw -1;
   }
 
   unsigned int senders, receivers;
   fscanf(comms_file, "%dx%d\n", &senders, &receivers);
 
   std::cerr<<" #s: "<<senders<<"  #r:"<<receivers<<std::endl;
 
   _setSourceTopology(senders);
   _setDestTopology(receivers);
    
   unsigned maxs[senders];
   for(unsigned int i = 0 ; i < senders ; i++)
     maxs[i]=0;
 
   //read edges in file, and add edges
   for(unsigned int i = 0 ; i < senders * receivers ; i++) {
     unsigned int value;
     fscanf(comms_file, "%d", &value); 
     unsigned int node2 = i % receivers;
     unsigned int node1 = (i - node2) / receivers;
     if (value != 0) {
       _cm->set(node1, node2, value);
 #ifdef DEBUG_INTERNAL
       std::cerr << " "<<node1<<" -> "<<node2<<" : "<<value<<endl;
 #endif
 
       maxs[node1]+=value;
     }
   }  
     
   fclose(comms_file);
   
   unsigned long max=0;
   for(unsigned int i = 0 ; i < senders ; i++)
     if (maxs[i]>max)
       max=maxs[i];
 
   if (_maxllen && (max>_maxllen))
     {
       std::cerr << "MaxLocalLen was set to small: "<<_maxllen<<" vs "<<max<<" (0: not set)"<<std::endl;
       abort();
     }
 
   setMaxLocalLen(max);
 
   _cm->dump();
 
 }  

Here is the call graph for this function:

◆ serverFree()

void Controlled::serverFree ( )

virtual

Implements DistributionLibrary.

Definition at line 415 of file Controlled.cc.

References _serverBuffer.

 { 
 #ifdef DEBUG_INTERNAL
   std::cerr << "-- serverFree: "<<(void*)_serverBuffer<<endl;
 #endif
   free(_serverBuffer);
   _serverBuffer=NULL; // the orb (or the user) need to free the memory!
 }

◆ setComId()

virtual bool DistributionLibrary::setComId ( long id )

inlinevirtualinherited

Reimplemented in BasicBC, and GaBro.

Definition at line 40 of file DistributionLibrairie.h.

Referenced by PaCO_operation::useCommunicationMemoryId().

40 { return false;}

◆ setCommunicator()

virtual void Controlled::setCommunicator ( void * group )

inlinevirtual

Implements DistributionLibrary.

Definition at line 61 of file Controlled.h.

61 {}

◆ setDataPtr()

void Controlled::setDataPtr ( void * dataPtr )

virtual

Implements DistributionLibrary.

Definition at line 279 of file Controlled.cc.

References _clientBuffer.

 {
   _clientBuffer = (char *) dataPtr;
 #ifdef DEBUG_INTERNAL
   cerr << "-- _clientBuffer set to "<<dataPtr<<endl;
 #endif
 }

◆ setDescr()

void Controlled::setDescr ( void * descr )

virtual

Implements DistributionLibrary.

Definition at line 387 of file Controlled.cc.

References _dTopo, _llen, _serverBuffer, _serverDescr, _serverToReceived, _setLocalLen(), _sTopo, _unitsize, ControlledLib::ControlledDescr::llen, and PaCO::PacoTopology_s::total.

 {
   std::cerr << "-- setDescr "<<endl;
 
   _serverDescr = (ControlledLib::ControlledDescr*) descr;
 
   // Descr already received
 
   if ( _serverBuffer == NULL)
     {
       // 1st time -> allocate memory & init
       //this->setEltSize(_descr->usz); BUG: usz can be different in client and server (32bit vs 64bit)
       unsigned long len = _serverDescr->llen*_unitsize;
       this->_setLocalLen(_serverDescr->llen);
       
 #ifdef DEBUG_INTERNAL
       fprintf(stderr, "-- setDescr: stopo: %ld\tdtopo: %ld\n",_sTopo.total, _dTopo.total);
       fprintf(stderr, "   setDescr: local len: %ld\n", _serverDescr->llen);
 #endif  
       _serverBuffer = (char*) malloc(len*_unitsize);
 #ifdef DEBUG_INTERNAL
       std::cerr << "-- serverMalloc: "<<(void*)_serverBuffer<<" - "<<_llen<<endl;
 #endif
       _serverToReceived = len;
     }
 }

Here is the call graph for this function:

◆ setDestTopology()

void Controlled::setDestTopology ( PaCO::PacoTopology_t topo )

virtual

Implements DistributionLibrary.

Definition at line 101 of file Controlled.cc.

References _cm, _config, _dTopo, _sTopo, DST_TOPOLOGY, and PaCO::PacoTopology_s::total.

Referenced by _setDestTopology().

 {
 #ifdef DEBUG_INTERNAL
   std::cerr << "-- setDestTopology: " << topo.total << std::endl;
 #endif
   _config |= DST_TOPOLOGY;
 
   if (_dTopo.total != topo.total) {
     _dTopo = topo;
     delete _cm;
     _cm = new CommMatrix(_sTopo.total,_dTopo.total);
   }
 
 }

◆ setEltSize()

void Controlled::setEltSize ( unsigned long size )

Definition at line 140 of file Controlled.cc.

References _config, _unitsize, and ELEMENT_SIZE.

 {
 #ifdef DEBUG_INTERNAL
   std::cerr << "-- setEltSize: " << size << std::endl;
 #endif
   _config |= ELEMENT_SIZE;
   _unitsize = size;
 }

◆ setMaxLocalLen()

void Controlled::setMaxLocalLen ( unsigned long elt_nb )

Definition at line 159 of file Controlled.cc.

References _config, _maxllen, and LOCAL_SIZE.

Referenced by readFromFile().

 {
 #ifdef DEBUG_INTERNAL
   std::cerr << "-- setMaxLocalNbElt: " << elt_nb << std::endl;
 #endif
   _config |= LOCAL_SIZE;
   _maxllen = elt_nb;
 }

◆ setNodeRank()

void Controlled::setNodeRank ( long Rank )

virtual

Implements DistributionLibrary.

Definition at line 125 of file Controlled.cc.

References _nodeRank.

 {
 #ifdef DEBUG_INTERNAL
   std::cerr << "-- setNodeRank: " << Rank << std::endl;
 #endif
   _nodeRank = Rank;
 }

◆ setSourceTopology()

void Controlled::setSourceTopology ( PaCO::PacoTopology_t topo )

virtual

Implements DistributionLibrary.

Definition at line 68 of file Controlled.cc.

References _cm, _config, _dTopo, _sTopo, SRC_TOPOLOGY, and PaCO::PacoTopology_s::total.

Referenced by _setSourceTopology().

 {
 #ifdef DEBUG_INTERNAL
   std::cerr << "-- setSourceTopology: " << topo.total << std::endl;
 #endif
   _config |= SRC_TOPOLOGY;
 
   if (_sTopo.total != topo.total) {
     _sTopo = topo;
     delete _cm;
     _cm = new CommMatrix(_sTopo.total,_dTopo.total);
 
   }
 }