YACS::ENGINE::PartDefinition Class Reference

#include <PlayGround.hxx>

Inheritance diagram for YACS::ENGINE::PartDefinition:

Collaboration diagram for YACS::ENGINE::PartDefinition:

Public Member Functions
const PlayGround *	getPlayGround () const
int	getSpaceSize () const
void	stashPart (int nbCoresStashed, double weightOfRemain, YACS::BASES::AutoRefCnt< PartDefinition > &pdStashed, YACS::BASES::AutoRefCnt< PartDefinition > &pdRemain) const
std::vector< std::size_t >	computeWorkerIdsCovered (int nbCoresPerComp) const
virtual std::string	printSelf () const =0
virtual std::vector< bool >	getCoresOn () const =0
virtual PartDefinition *	copy () const =0
virtual int	getNumberOfCoresConsumed () const =0
Public Member Functions inherited from YACS::ENGINE::RefCounter
unsigned int	getRefCnt () const
void	incrRef () const
bool	decrRef () const

Static Public Member Functions
static YACS::BASES::AutoRefCnt< PartDefinition >	BuildFrom (const PlayGround *pg, const std::vector< int > &coreIds)

Protected Member Functions
	PartDefinition (const PlayGround *pg)
	PartDefinition (const PartDefinition &other)
virtual	~PartDefinition ()
Protected Member Functions inherited from YACS::ENGINE::RefCounter
	RefCounter ()
	RefCounter (const RefCounter &other)
virtual	~RefCounter ()

Private Attributes
YACS::BASES::AutoConstRefCnt< PlayGround >	_pg

Additional Inherited Members
Static Public Attributes inherited from YACS::ENGINE::RefCounter
static unsigned int	_totalCnt =0
Protected Attributes inherited from YACS::ENGINE::RefCounter
unsigned int	_cnt

Detailed Description

Definition at line 118 of file PlayGround.hxx.

Constructor & Destructor Documentation

PartDefinition() [1/2]

PartDefinition::PartDefinition ( const PlayGround *  pg )

protected

Definition at line 590 of file PlayGround.cxx.

{
  _pg.takeRef(pg);
}

References _pg.

PartDefinition() [2/2]

PartDefinition::PartDefinition ( const PartDefinition &  other )

protected

Definition at line 595 of file PlayGround.cxx.

                                                         :_pg(other._pg)
{
}

~PartDefinition()

PartDefinition::~PartDefinition ( )

protectedvirtual

Definition at line 599 of file PlayGround.cxx.

{
}

Member Function Documentation

BuildFrom()

YACS::BASES::AutoRefCnt< PartDefinition > PartDefinition::BuildFrom ( const PlayGround *  pg, const std::vector< int > &  coreIds  )

static

Definition at line 612 of file PlayGround.cxx.

{
  int spaceSz(pg->getNumberOfCoresAvailable()),sz(coreIds.size());
  if(sz>spaceSz)
    throw Exception("PartDefinition::BuildFrom : error 1 !");
  if(sz==0)
    throw Exception("PartDefinition::BuildFrom : error 2 !");
  int zeStart(coreIds.front()),zeEnd(coreIds.back());
  if(zeStart<0 || zeEnd<zeStart)
    throw Exception("PartDefinition::BuildFrom : error ! The content of core Ids is not OK !");
  for(std::size_t i=0;i<sz-1;i++)
    if(coreIds[i+1]<coreIds[i])
      throw Exception("PartDefinition::BuildFrom : error ! The content of core Ids is not OK 2 !");
  if(zeEnd-zeStart+1!=sz)
    {
      YACS::BASES::AutoRefCnt<PartDefinition> pd(new NonContigPartDefinition(pg,coreIds));
      return pd;
    }
  if(sz==spaceSz)
    {
      YACS::BASES::AutoRefCnt<PartDefinition> pd(new AllPartDefinition(pg));
      return pd;
    }
  YACS::BASES::AutoRefCnt<PartDefinition> pd(new ContigPartDefinition(pg,zeStart,zeEnd+1));
  return pd;
}

References YACS::ENGINE::PlayGround::getNumberOfCoresAvailable(), and yacsorb.CORBAEngineTest::i.

Referenced by YACS::ENGINE::PlayGround::partition(), and stashPart().

computeWorkerIdsCovered()

std::vector< std::size_t > PartDefinition::computeWorkerIdsCovered

(

int

nbCoresPerComp

)

const

you must garantee coherence between PlayGround::deduceMachineFrom, PlayGround::getNumberOfWorkers, and PartDefinition::computeWorkerIdsCovered

Definition at line 677 of file PlayGround.cxx.

{
  std::vector<bool> coresOn(getCoresOn());
  return _pg->getWorkerIdsFullyFetchedBy(nbCoresPerComp,coresOn);
}

References _pg, and getCoresOn().

copy()

virtual PartDefinition* YACS::ENGINE::PartDefinition::copy ( ) const

pure virtual

Implemented in YACS::ENGINE::AllPartDefinition, YACS::ENGINE::NonContigPartDefinition, and YACS::ENGINE::ContigPartDefinition.

Referenced by YACS::ENGINE::PlayGround::partition(), and YACS::ENGINE::DynParaLoop::partitionRegardingDPL().

getCoresOn()

virtual std::vector<bool> YACS::ENGINE::PartDefinition::getCoresOn ( ) const

pure virtual

Implemented in YACS::ENGINE::AllPartDefinition, YACS::ENGINE::NonContigPartDefinition, and YACS::ENGINE::ContigPartDefinition.

Referenced by computeWorkerIdsCovered(), YACS::ENGINE::PlayGround::partition(), and stashPart().

getNumberOfCoresConsumed()

virtual int YACS::ENGINE::PartDefinition::getNumberOfCoresConsumed ( ) const

pure virtual

Implemented in YACS::ENGINE::AllPartDefinition, YACS::ENGINE::NonContigPartDefinition, and YACS::ENGINE::ContigPartDefinition.

getPlayGround()

const PlayGround* YACS::ENGINE::PartDefinition::getPlayGround ( ) const

inline

Definition at line 127 of file PlayGround.hxx.

{ return _pg; }

Referenced by YACS::ENGINE::PlayGround::partition(), YACS::ENGINE::ForkBlocPoint::partitionRegardingDPL(), and stashPart().

getSpaceSize()

int YACS::ENGINE::PartDefinition::getSpaceSize ( ) const

inline

Definition at line 128 of file PlayGround.hxx.

{ return _pg->getNumberOfCoresAvailable(); }

Referenced by YACS::ENGINE::NonContigPartDefinition::checkOKIds(), YACS::ENGINE::ContigPartDefinition::ContigPartDefinition(), YACS::ENGINE::ContigPartDefinition::getCoresOn(), YACS::ENGINE::NonContigPartDefinition::getCoresOn(), YACS::ENGINE::AllPartDefinition::getCoresOn(), and YACS::ENGINE::AllPartDefinition::getNumberOfCoresConsumed().

printSelf()

virtual std::string YACS::ENGINE::PartDefinition::printSelf ( ) const

pure virtual

Implemented in YACS::ENGINE::AllPartDefinition, YACS::ENGINE::NonContigPartDefinition, and YACS::ENGINE::ContigPartDefinition.

stashPart()

void PartDefinition::stashPart	(	int	nbCoresStashed,
		double	weightOfRemain,
		YACS::BASES::AutoRefCnt< PartDefinition > &	pdStashed,
		YACS::BASES::AutoRefCnt< PartDefinition > &	pdRemain
	)		const

Definition at line 639 of file PlayGround.cxx.

{
  if(nbCoresStashed<=0)
    throw Exception("stashPart : Invalid nbCoresStashed value !");
  if(weightOfRemain<=0.)
    throw Exception("stashPart : Invalid weight !");
  std::vector<bool> coresOn(getCoresOn());
  int nbCoresAvailable(std::count(coresOn.begin(),coresOn.end(),true));
  std::vector<int> ids(PlayGround::BuildVectOfIdsFromVecBool(coresOn));
  if(nbCoresAvailable==0)
    throw Exception("PartDefinition::stashPart : no available cores !");
  if(nbCoresAvailable<=nbCoresStashed)
    {
      int n0((int)(1./(1.+weightOfRemain)*nbCoresAvailable)); n0=std::max(n0,1);
      int n1(nbCoresAvailable-n0);
      if(n1<=0)
        {
          pdStashed=PartDefinition::BuildFrom(getPlayGround(),ids);
          pdRemain=PartDefinition::BuildFrom(getPlayGround(),ids);
        }
      else
        {
          std::vector<int> ids0(ids.begin(),ids.begin()+n0),ids1(ids.begin()+n0,ids.end());
          pdStashed=PartDefinition::BuildFrom(getPlayGround(),ids0);
          pdRemain=PartDefinition::BuildFrom(getPlayGround(),ids1);
        }
    }
  else
    {
      std::vector<int> ids0(ids.begin(),ids.begin()+nbCoresStashed),ids1(ids.begin()+nbCoresStashed,ids.end());
      pdStashed=PartDefinition::BuildFrom(getPlayGround(),ids0);
      pdRemain=PartDefinition::BuildFrom(getPlayGround(),ids1);
    }
}

References BuildFrom(), YACS::ENGINE::PlayGround::BuildVectOfIdsFromVecBool(), getCoresOn(), and getPlayGround().

Member Data Documentation

_pg

YACS::BASES::AutoConstRefCnt<PlayGround> YACS::ENGINE::PartDefinition::_pg

private

Definition at line 136 of file PlayGround.hxx.

Referenced by computeWorkerIdsCovered(), and PartDefinition().

---

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

• src/engine/PlayGround.hxx
• src/engine/PlayGround.cxx