ParisBlockMPC Class Reference

#include <ParisBlockMPC.h>

Inheritance diagram for ParisBlockMPC:

Collaboration diagram for ParisBlockMPC:

Public Member Functions
virtual void	clientFree ()=0
virtual PieceToSend *	computePiecesToSend (unsigned &size)=0
bool	computeReceive (Abstrait *darray)
	Compute communication schedule on the server side. More...
void	computeSend (const void *data, vAbstrait &vdarray, vector< unsigned > &destid)
	Compute communication schedule on the client side. More...
virtual bool	freeComId (long id)
virtual void *	getClientData (void *pid, int server_node, long &size, long &length, bool &end)=0
virtual void *	getDescr ()=0
virtual PaCO::PacoTopology_t	getDestTopology ()=0
const PaCO::distLoc_t &	getMode () const
virtual long	getNodeRank ()=0
Abstrait *	getResult () const
	If computeReceive returns ok, get the data. More...
virtual void *	getServerData (long &length)=0
virtual PaCO::PacoTopology_t	getSourceTopology ()=0
virtual bool	insertData (void *rcptBuf, unsigned long element_nb)=0
	ParisBlockMPC (Fabrique *f)
void	reset ()
virtual void	serverFree ()=0
bool	setClientConfiguration (const PaCO::PacoTopology_t &ctopo)
virtual bool	setComId (long id)
void	setCommunicator (void *comm)
virtual void	setDataPtr (void *dataPtr)=0
virtual void	setDescr (void *descr)=0
virtual void	setDestTopology (PaCO::PacoTopology_t topo)=0
void	setFabric (Fabrique *f)
bool	setGlobalDataConfiguration (const PaCO::PacoGlobalData_t &gd)
bool	setLocalDataConfiguration (const PaCO::PacoLocalData_t &ld)
bool	setMode (const PaCO::distLoc_t mode)
virtual void	setNodeRank (long Rank)=0
bool	setServerConfiguration (const PaCO::PacoTopology_t &stopo)
virtual void	setSourceTopology (PaCO::PacoTopology_t topo)=0
virtual	~ParisBlockMPC ()

Private Attributes
PaCO::PacoTopology_t	_clttopo
void *	_comm
Abstrait *	_darray
Fabrique *	_fab
PaCO::PacoGlobalData_t	_gd
LocalData_t	_ld
PaCO::distLoc_t	_mode
int	_remaining
PaCO::PacoTopology_t	_srvtopo
vAbstrait *	_vdarray

Detailed Description

Definition at line 7 of file ParisBlockMPC.h.

Constructor & Destructor Documentation

ParisBlockMPC()

ParisBlockMPC::ParisBlockMPC

(

Fabrique *

f

)

Definition at line 5 of file ParisBlockMPC.cc.

References _clttopo, _darray, _srvtopo, _vdarray, setFabric(), and PaCO::PacoTopology_s::total.

Referenced by ParisBlockMPC_fab::paco_create().

                                         { 
  setFabric(f);
  _darray = f->creer();
  _vdarray = f->vcreer(); 
  _vdarray->clear(); 
  
  _clttopo.total = 123; // debug
  _srvtopo.total = 123; // debug
}

Here is the call graph for this function:

~ParisBlockMPC()

ParisBlockMPC::~ParisBlockMPC ( )

virtual

Definition at line 15 of file ParisBlockMPC.cc.

References _darray, _fab, and _vdarray.

                              { 
  delete _fab; delete _darray; delete _vdarray;
} 

Member Function Documentation

clientFree()

virtual void DistributionLibrary::clientFree ( )

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, GaBro, and ParisBasicExample.

computePiecesToSend()

virtual PieceToSend* DistributionLibrary::computePiecesToSend ( unsigned &  size )

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, and GaBro.

computeReceive()

bool ParisBlockMPC::computeReceive

(

Abstrait *

darray

)

Compute communication schedule on the server side.

Definition at line 44 of file ParisBlockMPC.cc.

References _clttopo, _comm, _darray, _ld, _mode, _remaining, _srvtopo, _vdarray, computeReceiveDataBlock1D(), nbofPart(), posofPart(), setClientConfiguration(), setMode(), and PaCO::PacoTopology_s::total.

Referenced by setCommunicator().

                                                   {

  this->setClientConfiguration(darray->topo());  

  // Get the mode of the client
  this->setMode(darray->mode());

  unsigned nb  = nbofPart(_mode, _clttopo.total, _srvtopo.total, _ld.rank);

  unsigned pos;

  // In server side redistribution, empty dist for server nodes whose id > max client node
  if (darray->dist().length() != 0 ) {
    pos = posofPart(_mode, _srvtopo.total, darray->dist()[0].rank);
  } else {
    pos = 0;
  }

  // Initialize _vdarray & remaining (assumed clean)
  if (_vdarray->size() == 0) {
    // _vdarray is empty: so let's define its size
    _vdarray->size(nb);
    _remaining = nb;
  }


  fprintf(stderr, "computeReceive: Node %d : set entry %d/%d to %p\n", _ld.rank, pos, nb, darray);
  _vdarray->setAbstrait(pos, darray);
  _remaining--;

  fprintf(stderr, "computeReceive: Node %d : got %d of %d data\n", _ld.rank, _vdarray->size() - _remaining, _vdarray->size());

  if (_remaining == 0) {
    computeReceiveDataBlock1D(_vdarray, _mode, _srvtopo.total, _ld.rank, _darray, _comm);
    return true;
  } else {
    return false;
  }
}

Here is the call graph for this function:

computeSend()

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

Compute communication schedule on the client side.

Definition at line 38 of file ParisBlockMPC.cc.

References _clttopo, _comm, _gd, _ld, _mode, _srvtopo, and computeSendDataBlock1D().

Referenced by setCommunicator().

                                                                                              {
  _ld.base = (char*) data;

  computeSendDataBlock1D(_gd, _ld, _clttopo, _srvtopo, vdarray, destid, _mode, _comm);
}

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.

{ return false;}

getClientData()

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

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, and GaBro.

getDescr()

virtual void* DistributionLibrary::getDescr ( )

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, GaBro, and ParisBasicExample.

getDestTopology()

virtual PaCO::PacoTopology_t DistributionLibrary::getDestTopology ( )

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, GaBro, and ParisBasicExample.

getMode()

const PaCO::distLoc_t & ParisBlockMPC::getMode

(

)

const

Definition at line 23 of file ParisBlockMPC.cc.

References _mode.

Referenced by setCommunicator().

{ return _mode; }

getNodeRank()

virtual long DistributionLibrary::getNodeRank ( )

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, GaBro, and ParisBasicExample.

getResult()

Abstrait * ParisBlockMPC::getResult

(

)

const

If computeReceive returns ok, get the data.

Definition at line 84 of file ParisBlockMPC.cc.

References _darray.

Referenced by setCommunicator().

{ return _darray; }

getServerData()

virtual void* DistributionLibrary::getServerData ( long &  length )

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, GaBro, and ParisBasicExample.

getSourceTopology()

virtual PaCO::PacoTopology_t DistributionLibrary::getSourceTopology ( )

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, GaBro, and ParisBasicExample.

insertData()

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

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, and GaBro.

reset()

void ParisBlockMPC::reset

(

)

Definition at line 21 of file ParisBlockMPC.cc.

References _vdarray.

Referenced by setCommunicator().

{ _vdarray->clear(); }

serverFree()

virtual void DistributionLibrary::serverFree ( )

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, GaBro, and ParisBasicExample.

setClientConfiguration()

bool ParisBlockMPC::setClientConfiguration

(

const PaCO::PacoTopology_t &

ctopo

)

Definition at line 27 of file ParisBlockMPC.cc.

References _clttopo.

Referenced by computeReceive(), and setCommunicator().

{ _clttopo = ctopo; return true; }

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().

{ return false;}

setCommunicator()

void ParisBlockMPC::setCommunicator ( void *  comm )

inlinevirtual

Implements DistributionLibrary.

Definition at line 31 of file ParisBlockMPC.h.

References computeReceive(), computeSend(), getMode(), getResult(), reset(), setClientConfiguration(), setFabric(), setGlobalDataConfiguration(), setLocalDataConfiguration(), setMode(), and setServerConfiguration().

{_comm = comm;}

Here is the call graph for this function:

setDataPtr()

virtual void DistributionLibrary::setDataPtr ( void *  dataPtr )

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, GaBro, and ParisBasicExample.

setDescr()

virtual void DistributionLibrary::setDescr ( void *  descr )

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, GaBro, and ParisBasicExample.

setDestTopology()

virtual void DistributionLibrary::setDestTopology ( PaCO::PacoTopology_t  topo )

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, GaBro, and ParisBasicExample.

Referenced by PaCO_operation::configureTopo().

setFabric()

void ParisBlockMPC::setFabric

(

Fabrique *

f

)

Definition at line 19 of file ParisBlockMPC.cc.

References _fab.

Referenced by ParisBlockMPC(), and setCommunicator().

{ _fab = f; }

setGlobalDataConfiguration()

bool ParisBlockMPC::setGlobalDataConfiguration

(

const PaCO::PacoGlobalData_t &

gd

)

Definition at line 30 of file ParisBlockMPC.cc.

References _gd.

Referenced by setCommunicator().

{ _gd = gd; return true; }

setLocalDataConfiguration()

bool ParisBlockMPC::setLocalDataConfiguration

(

const PaCO::PacoLocalData_t &

ld

)

Definition at line 31 of file ParisBlockMPC.cc.

References _ld, PaCO::PacoLocalData_s::len, PaCO::PacoLocalData_s::rank, and PaCO::PacoLocalData_s::start.

Referenced by setCommunicator().

                                                                             {
  _ld.rank  = ld.rank;
  _ld.start = ld.start;
  _ld.len  = ld.len;
  return true;
}

setMode()

bool ParisBlockMPC::setMode

(

const PaCO::distLoc_t

mode

)

Definition at line 25 of file ParisBlockMPC.cc.

References _mode.

Referenced by computeReceive(), and setCommunicator().

{ _mode = mode; return true; } // true if ok

setNodeRank()

virtual void DistributionLibrary::setNodeRank ( long  Rank )

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, GaBro, and ParisBasicExample.

Referenced by PaCO_operation::configureTopo().

setServerConfiguration()

bool ParisBlockMPC::setServerConfiguration

(

const PaCO::PacoTopology_t &

stopo

)

Definition at line 28 of file ParisBlockMPC.cc.

References _srvtopo.

Referenced by setCommunicator().

{ _srvtopo = stopo; return true; }

setSourceTopology()

virtual void DistributionLibrary::setSourceTopology ( PaCO::PacoTopology_t  topo )

pure virtualinherited

Implemented in BasicBC, Controlled, Identity, GaBro, and ParisBasicExample.

Referenced by PaCO_operation::configureTopo().

Member Data Documentation

_clttopo

PaCO::PacoTopology_t ParisBlockMPC::_clttopo

private

Definition at line 11 of file ParisBlockMPC.h.

Referenced by computeReceive(), computeSend(), ParisBlockMPC(), and setClientConfiguration().

_comm

void* ParisBlockMPC::_comm

private

Definition at line 18 of file ParisBlockMPC.h.

Referenced by computeReceive(), and computeSend().

_darray

Abstrait* ParisBlockMPC::_darray

private

Definition at line 21 of file ParisBlockMPC.h.

Referenced by computeReceive(), getResult(), ParisBlockMPC(), and ~ParisBlockMPC().

_fab

Fabrique* ParisBlockMPC::_fab

private

Definition at line 20 of file ParisBlockMPC.h.

Referenced by setFabric(), and ~ParisBlockMPC().

_gd

PaCO::PacoGlobalData_t ParisBlockMPC::_gd

private

Definition at line 13 of file ParisBlockMPC.h.

Referenced by computeSend(), and setGlobalDataConfiguration().

_ld

LocalData_t ParisBlockMPC::_ld

private

Definition at line 16 of file ParisBlockMPC.h.

Referenced by computeReceive(), computeSend(), and setLocalDataConfiguration().

_mode

PaCO::distLoc_t ParisBlockMPC::_mode

private

Definition at line 10 of file ParisBlockMPC.h.

Referenced by computeReceive(), computeSend(), getMode(), and setMode().

_remaining

int ParisBlockMPC::_remaining

private

Definition at line 23 of file ParisBlockMPC.h.

Referenced by computeReceive().

_srvtopo

PaCO::PacoTopology_t ParisBlockMPC::_srvtopo

private

Definition at line 12 of file ParisBlockMPC.h.

Referenced by computeReceive(), computeSend(), ParisBlockMPC(), and setServerConfiguration().

_vdarray

vAbstrait* ParisBlockMPC::_vdarray

private

Definition at line 22 of file ParisBlockMPC.h.

Referenced by computeReceive(), ParisBlockMPC(), reset(), and ~ParisBlockMPC().

---

The documentation for this class was generated from the following files:

• ParisBlockMPC.h
• ParisBlockMPC.cc