#include <SalomeHPContainerTools.hxx>

Collaboration diagram for YACS::ENGINE::SalomeHPContainerVectOfHelper:

Public Member Functions
std::size_t	size () const

void	resize (std::size_t sz)

std::size_t	getNumberOfFreePlace () const

void	allocateFor (const std::vector< const Task * > &nodes)

void	release (const Task *node)

std::size_t	locateTask (const Task *node) const

const SalomeContainerMonoHelper *	at (std::size_t pos) const

SalomeContainerMonoHelper *	at (std::size_t pos)

const SalomeContainerMonoHelper *	getHelperOfTaskThreadSafe (const SalomeHPContainer cont, const Task node) const

const SalomeContainerMonoHelper *	getHelperOfTask (const Task *node) const

SalomeContainerMonoHelper *	getHelperOfTaskThreadSafe (SalomeHPContainer cont, const Task node)

SalomeContainerMonoHelper *	getHelperOfTask (const Task *node)

Private Member Functions
void	checkNoCurrentWork () const

void	checkPosInVec (std::size_t pos) const

Private Attributes
std::vector< bool >	_whichOccupied

std::vector< BASES::AutoRefCnt < YACS::ENGINE::SalomeContainerMonoHelper > >	_launchModeType

std::map< const Task *, std::size_t >	_currentlyWorking

Detailed Description

Definition at line 39 of file SalomeHPContainerTools.hxx.

Member Function Documentation

void SalomeHPContainerVectOfHelper::allocateFor ( const std::vector< const Task * > & nodes )

Definition at line 47 of file SalomeHPContainerTools.cxx.

References _currentlyWorking, _whichOccupied, and gui.graph::distance().

Referenced by YACS::ENGINE::SalomeHPContainer::allocateFor().

 {
   for(std::vector<const Task *>::const_iterator it=nodes.begin();it!=nodes.end();it++)
     {
       if(!(*it))
         continue;
       if(_currentlyWorking.find(*it)!=_currentlyWorking.end())
         throw Exception("Searching to allocate for a ServiceNode instance already declared as allocated !");
       std::vector<bool>::iterator it2(std::find(_whichOccupied.begin(),_whichOccupied.end(),false));
       if(it2==_whichOccupied.end())
         throw Exception("All ressources are already occupied ! You are expected to wait for released resources !");
       std::size_t pos(std::distance(_whichOccupied.begin(),it2));
       _currentlyWorking[*it]=pos; _whichOccupied[pos]=true;
     }
 }

const SalomeContainerMonoHelper* YACS::ENGINE::SalomeHPContainerVectOfHelper::at ( std::size_t pos ) const

inline

Definition at line 48 of file SalomeHPContainerTools.hxx.

References _launchModeType, and checkPosInVec().

Referenced by YACS::ENGINE::SalomeHPContainer::shutdown().

48 { checkPosInVec(pos); return _launchModeType[pos]; }

SalomeContainerMonoHelper* YACS::ENGINE::SalomeHPContainerVectOfHelper::at ( std::size_t pos )

inline

Definition at line 49 of file SalomeHPContainerTools.hxx.

References _launchModeType, and checkPosInVec().

49 { checkPosInVec(pos); return _launchModeType[pos]; }

void SalomeHPContainerVectOfHelper::checkNoCurrentWork ( ) const

private

Definition at line 106 of file SalomeHPContainerTools.cxx.

References _currentlyWorking, and _launchModeType.

Referenced by resize().

 {
   for(std::map<const Task *,std::size_t >::const_iterator it=_currentlyWorking.begin();it!=_currentlyWorking.end();it++)
     if((*it).first)
       throw Exception("Something wrong a node is still declared to be using the ressource !");
   for(std::vector< YACS::BASES::AutoRefCnt<SalomeContainerMonoHelper> >::const_iterator it=_launchModeType.begin();it!=_launchModeType.end();it++)
     if((*it)->isAlreadyStarted(0))
       throw Exception("Some of the containers have be started ! Please shutdown them before !");
 }

void SalomeHPContainerVectOfHelper::checkPosInVec ( std::size_t pos ) const

private

Definition at line 116 of file SalomeHPContainerTools.cxx.

References _launchModeType.

Referenced by at(), and locateTask().

 {
   if(pos<0 || pos>=_launchModeType.size())
     throw Exception("The task has been found, but its id is not in the correct range ! resize of of container size during run ?");
 }

const SalomeContainerMonoHelper * SalomeHPContainerVectOfHelper::getHelperOfTask ( const Task * node ) const

Definition at line 90 of file SalomeHPContainerTools.cxx.

References _launchModeType, and locateTask().

Referenced by YACS::ENGINE::SalomeHPContainer::getFullPlacementId(), and YACS::ENGINE::SalomeHPContainer::getPlacementId().

 {
   return _launchModeType[locateTask(node)];
 }

SalomeContainerMonoHelper * SalomeHPContainerVectOfHelper::getHelperOfTask ( const Task * node )

Definition at line 101 of file SalomeHPContainerTools.cxx.

References _launchModeType, and locateTask().

 {
   return _launchModeType[locateTask(node)];
 }

const SalomeContainerMonoHelper * SalomeHPContainerVectOfHelper::getHelperOfTaskThreadSafe	(	const SalomeHPContainer *	cont,
		const Task *	node
	)		const

Definition at line 84 of file SalomeHPContainerTools.cxx.

References _launchModeType, and locateTask().

Referenced by YACS::ENGINE::SalomeHPContainer::isAlreadyStarted().

 {
   YACS::BASES::AutoLocker<Container> alck(const_cast<SalomeHPContainer *>(cont));
   return _launchModeType[locateTask(node)];
 }

SalomeContainerMonoHelper * SalomeHPContainerVectOfHelper::getHelperOfTaskThreadSafe	(	SalomeHPContainer *	cont,
		const Task *	node
	)

Definition at line 95 of file SalomeHPContainerTools.cxx.

References _launchModeType, and locateTask().

 {
   YACS::BASES::AutoLocker<Container> alck(cont);
   return _launchModeType[locateTask(node)];
 }

std::size_t SalomeHPContainerVectOfHelper::getNumberOfFreePlace ( ) const

Definition at line 42 of file SalomeHPContainerTools.cxx.

References _whichOccupied.

Referenced by YACS::ENGINE::SalomeHPContainer::getNumberOfFreePlace().

 {
   return std::count(_whichOccupied.begin(),_whichOccupied.end(),false);
 }

std::size_t SalomeHPContainerVectOfHelper::locateTask ( const Task * node ) const

Definition at line 74 of file SalomeHPContainerTools.cxx.

References _currentlyWorking, checkPosInVec(), and PMMLBasicsTestLauncher::ret.

Referenced by getHelperOfTask(), and getHelperOfTaskThreadSafe().

 {
   std::map< const Task *,std::size_t >::const_iterator it(_currentlyWorking.find(node));
   if(it==_currentlyWorking.end())
     throw Exception("current Node to be located is not marked as launched !");
   std::size_t ret((*it).second);
   checkPosInVec(ret);
   return ret;
 }

void SalomeHPContainerVectOfHelper::release ( const Task * node )

Definition at line 63 of file SalomeHPContainerTools.cxx.

References _currentlyWorking, and _whichOccupied.

Referenced by YACS::ENGINE::SalomeHPContainer::release().

 {
   if(!node)
     return ;
   std::map< const Task *,std::size_t >::iterator it(_currentlyWorking.find(node));
   if(it==_currentlyWorking.end())
     throw Exception("Request to release a resource not declared as working !");
   _whichOccupied[(*it).second]=false;
   _currentlyWorking.erase(it);
 }

void SalomeHPContainerVectOfHelper::resize ( std::size_t sz )

Definition at line 29 of file SalomeHPContainerTools.cxx.

References _currentlyWorking, _launchModeType, _whichOccupied, checkNoCurrentWork(), and CORBAEngineTest::i.

Referenced by YACS::ENGINE::SalomeHPContainer::setSizeOfPool().

 {
   std::size_t oldSize(_launchModeType.size());
   if(sz==oldSize)
     return;
   checkNoCurrentWork();
   _whichOccupied.resize(sz); std::fill(_whichOccupied.begin(),_whichOccupied.end(),false);
   _launchModeType.resize(sz);
   for(std::size_t i=oldSize;i<sz;i++)
       _launchModeType[i]=new SalomeContainerMonoHelper;
   _currentlyWorking.clear();
 }