#include <ForEachLoop.hxx>

Collaboration diagram for YACS::ENGINE::ForEachLoopPassedData:

[legend]

Public Member Functions
	ForEachLoopPassedData (const std::vector< unsigned int > &passedIds, const std::vector< SequenceAny * > &passedOutputs, const std::vector< std::string > &nameOfOutputs)

	ForEachLoopPassedData (const ForEachLoopPassedData &copy)

	~ForEachLoopPassedData ()

void	init ()

void	checkCompatibilyWithNb (int nbOfElts) const

void	checkLevel2 (const std::vector< AnyInputPort * > &ports) const

int	getNumberOfEltsAlreadyDone () const

int	toAbsId (int localId) const

int	toAbsIdNot (int localId) const

int	getNumberOfElementsToDo () const

void	assignAlreadyDone (const std::vector< SequenceAny * > &execVals) const

const std::vector< unsigned int > &	getIds () const

const std::vector< SequenceAny * > &	getOutputs () const

const std::vector< std::string > &	getOutputNames () const

Private Attributes
std::vector< unsigned int >	_passedIds

std::vector< SequenceAny * >	_passedOutputs

std::vector< std::string >	_nameOfOutputs

std::vector< bool >	_flagsIds

Detailed Description

Definition at line 126 of file ForEachLoop.hxx.

Constructor & Destructor Documentation

◆ ForEachLoopPassedData() [1/2]

ForEachLoopPassedData::ForEachLoopPassedData	(	const std::vector< unsigned int > &	passedIds,
		const std::vector< SequenceAny * > &	passedOutputs,
		const std::vector< std::string > &	nameOfOutputs
	)

Definition at line 306 of file ForEachLoop.cxx.

                                                                                                                                                                               :_passedIds(passedIds),_passedOutputs(passedOutputs),_nameOfOutputs(nameOfOutputs)
 {
   std::size_t sz(_passedIds.size()),sz1(passedOutputs.size()),sz2(nameOfOutputs.size());
   if(sz1!=sz2)
     throw YACS::Exception("ForEachLoopPassedData::ForEachLoopPassedData : nameOfOutputs and passedOutputs must have the same size !");
   for(std::vector<SequenceAny *>::iterator it=_passedOutputs.begin();it!=_passedOutputs.end();it++)
     {
       const SequenceAny *elt(*it);
       if(elt)
         if(sz!=(std::size_t)elt->size())
           throw YACS::Exception("ForEachLoopPassedData::ForEachLoopPassedData : incoherent input of passed data !");
     }
   for(std::vector<SequenceAny *>::iterator it=_passedOutputs.begin();it!=_passedOutputs.end();it++)
     {
       SequenceAny *elt(*it);
       if(elt)
         elt->incrRef();
     }
 }

References _passedIds, _passedOutputs, YACS::ENGINE::RefCounter::incrRef(), and YACS::ENGINE::SequenceAny::size().

◆ ForEachLoopPassedData() [2/2]

ForEachLoopPassedData::ForEachLoopPassedData ( const ForEachLoopPassedData & copy )

Definition at line 326 of file ForEachLoop.cxx.

 : _passedIds(copy._passedIds),
   _passedOutputs(copy._passedOutputs),
   _nameOfOutputs(copy._nameOfOutputs),
   _flagsIds(copy._flagsIds)
 {
 }

◆ ~ForEachLoopPassedData()

ForEachLoopPassedData::~ForEachLoopPassedData ( )

Definition at line 334 of file ForEachLoop.cxx.

 {
   for(std::vector<SequenceAny *>::iterator it=_passedOutputs.begin();it!=_passedOutputs.end();it++)
     {
       SequenceAny *elt(*it);
       if(elt)
         elt->decrRef();
     }
 }

References _passedOutputs, and YACS::ENGINE::RefCounter::decrRef().

Member Function Documentation

◆ assignAlreadyDone()

void ForEachLoopPassedData::assignAlreadyDone ( const std::vector< SequenceAny * > & execVals ) const

Definition at line 448 of file ForEachLoop.cxx.

 {
   std::size_t sz(execVals.size());
   if(_passedOutputs.size()!=sz)
     throw YACS::Exception("ForEachLoopPassedData::assignedAlreadyDone : mismatch of size of vectors !");
   for(std::size_t i=0;i<sz;i++)
     {
       SequenceAny *elt(_passedOutputs[i]);
       SequenceAny *eltDestination(execVals[i]);
       if(!elt)
         throw YACS::Exception("ForEachLoopPassedData::assignedAlreadyDone : presence of null elt !");
       unsigned int szOfElt(elt->size());
       for(unsigned int j=0;j<szOfElt;j++)
         {
           AnyPtr elt1((*elt)[j]);
           int jAbs(toAbsIdNot(j));
           eltDestination->setEltAtRank(jAbs,elt1);
         }
     }
 }

References _passedOutputs, yacsorb.CORBAEngineTest::i, YACS::ENGINE::SequenceAny::setEltAtRank(), YACS::ENGINE::SequenceAny::size(), and toAbsIdNot().

Referenced by YACS::ENGINE::ForEachLoopGen::exUpdateState().

◆ checkCompatibilyWithNb()

void ForEachLoopPassedData::checkCompatibilyWithNb ( int nbOfElts ) const

Definition at line 349 of file ForEachLoop.cxx.

 {
   if(nbOfElts<0)
     throw YACS::Exception("ForEachLoopPassedData::checkCompatibilyWithNb : nb of elts is expected to be > 0 !");
   std::size_t sizeExp(_passedIds.size()),nbOfElts2(nbOfElts);
   if(nbOfElts2<sizeExp)
     throw YACS::Exception("ForEachLoopPassedData::checkCompatibilyWithNb : Invalid nb of elemts in input seq regarding passed data set !");
   for(std::vector<unsigned int>::const_iterator it=_passedIds.begin();it!=_passedIds.end();it++)
     {
       if((*it)>=nbOfElts2)
         throw YACS::Exception("ForEachLoopPassedData::checkCompatibilyWithNb : Invalid nb of elemts in input seq regarding passed data set 2 !");
     }
   _flagsIds.resize(nbOfElts);
   std::fill(_flagsIds.begin(),_flagsIds.end(),false);
   for(std::vector<unsigned int>::const_iterator it=_passedIds.begin();it!=_passedIds.end();it++)
     {
       if(*it<nbOfElts)
         {
           if(!_flagsIds[*it])
             _flagsIds[*it]=true;
           else
             {
               std::ostringstream oss; oss << "ForEachLoopPassedData::checkCompatibilyWithNb : id " << *it << " in list of ids appears more than once !";
               throw YACS::Exception(oss.str());
             }
         }
       else
         {
           std::ostringstream oss; oss << "ForEachLoopPassedData::checkCompatibilyWithNb : Presence of id " << *it << " in list of ids ! Must be in [0," <<  nbOfElts << ") !";
           throw YACS::Exception(oss.str());
         }
     }
 }

References _flagsIds, and _passedIds.

Referenced by YACS::ENGINE::ForEachLoopGen::exUpdateState().

◆ checkLevel2()

void ForEachLoopPassedData::checkLevel2 ( const std::vector< AnyInputPort * > & ports ) const

Definition at line 383 of file ForEachLoop.cxx.

 {
   std::size_t sz(_nameOfOutputs.size());
   if(sz!=ports.size())
     throw YACS::Exception("ForEachLoopPassedData::checkLevel2 : mismatch of size of vectors !");
   for(std::size_t i=0;i<sz;i++)
     {
       AnyInputPort *elt(ports[i]);
       if(!elt)
         throw YACS::Exception("ForEachLoopPassedData::checkLevel2 : presence of null instance !");
       if(_nameOfOutputs[i]!=elt->getName())
         {
           std::ostringstream oss; oss << "ForEachLoopPassedData::checkLevel2 : At pos #" << i << " the name is not OK !";
           throw YACS::Exception(oss.str());
         }
     }
 }

References _nameOfOutputs, YACS::ENGINE::DataPort::getName(), and yacsorb.CORBAEngineTest::i.

Referenced by YACS::ENGINE::ForEachLoopGen::exUpdateState().

◆ getIds()

const std::vector<unsigned int>& YACS::ENGINE::ForEachLoopPassedData::getIds ( ) const

inline

Definition at line 140 of file ForEachLoop.hxx.

140 {return _passedIds;}

Referenced by YACS::ENGINE::VisitorSalomeSaveState::visitForEachLoop().

◆ getNumberOfElementsToDo()

int ForEachLoopPassedData::getNumberOfElementsToDo ( ) const

Definition at line 441 of file ForEachLoop.cxx.

 {
   std::size_t nbAllElts(_flagsIds.size());
   std::size_t ret(nbAllElts-_passedIds.size());
   return ret;
 }

References _flagsIds, and _passedIds.

Referenced by YACS::ENGINE::ForEachLoopGen::getFinishedId().

◆ getNumberOfEltsAlreadyDone()

int YACS::ENGINE::ForEachLoopPassedData::getNumberOfEltsAlreadyDone ( ) const

inline

Definition at line 135 of file ForEachLoop.hxx.

135 { return (int)_passedIds.size(); }

Referenced by YACS::ENGINE::ForEachLoopGen::exUpdateState().

◆ getOutputNames()

const std::vector<std::string>& YACS::ENGINE::ForEachLoopPassedData::getOutputNames ( ) const

inline

Definition at line 142 of file ForEachLoop.hxx.

142 {return _nameOfOutputs;}

Referenced by YACS::ENGINE::VisitorSalomeSaveState::visitForEachLoop().

◆ getOutputs()

const std::vector<SequenceAny *>& YACS::ENGINE::ForEachLoopPassedData::getOutputs ( ) const

inline

Definition at line 141 of file ForEachLoop.hxx.

141 {return _passedOutputs;}

Referenced by YACS::ENGINE::VisitorSalomeSaveState::visitForEachLoop().

◆ init()

void ForEachLoopPassedData::init ( )

Definition at line 344 of file ForEachLoop.cxx.

 {
   _flagsIds.clear();
 }

References _flagsIds.

Referenced by YACS::ENGINE::ForEachLoopGen::init().

◆ toAbsId()

int ForEachLoopPassedData::toAbsId ( int localId ) const

performs local to abs id. Input localId refers to an id in all jobs to perform. Returned id refers to pos in whole output sequences.

Definition at line 404 of file ForEachLoop.cxx.

 {
   if(localId<0)
     throw YACS::Exception("ForEachLoopPassedData::toAbsId : local pos must be >= 0 !");
   int ret(0),curLocId(0);
   for(std::vector<bool>::const_iterator it=_flagsIds.begin();it!=_flagsIds.end();it++,ret++)
     {
       if(!*it)
         {
           if(localId==curLocId)
             return ret;
           curLocId++;
         }
     }
   throw YACS::Exception("ForEachLoopPassedData::toAbsId : not referenced Id !");
 }

References _flagsIds.

Referenced by YACS::ENGINE::ForEachLoopGen::exUpdateState(), and YACS::ENGINE::ForEachLoopGen::updateStateForWorkNodeOnFinishedEventFrom().

◆ toAbsIdNot()

int ForEachLoopPassedData::toAbsIdNot ( int localId ) const

Equivalent to toAbsId except that only ON are considered here.

Definition at line 424 of file ForEachLoop.cxx.

 {
   if(localId<0)
     throw YACS::Exception("ForEachLoopPassedData::toAbsIdNot : local pos must be >= 0 !");
   int ret(0),curLocId(0);
   for(std::vector<bool>::const_iterator it=_flagsIds.begin();it!=_flagsIds.end();it++,ret++)
     {
       if(*it)//<- diff is here !
         {
           if(localId==curLocId)
             return ret;
           curLocId++;
         }
     }
   throw YACS::Exception("ForEachLoopPassedData::toAbsIdNot : not referenced Id !");
 }

References _flagsIds.

Referenced by assignAlreadyDone().

Member Data Documentation

◆ _flagsIds

std::vector<bool> YACS::ENGINE::ForEachLoopPassedData::_flagsIds

mutableprivate

Definition at line 148 of file ForEachLoop.hxx.

Referenced by checkCompatibilyWithNb(), getNumberOfElementsToDo(), init(), toAbsId(), and toAbsIdNot().

◆ _nameOfOutputs

std::vector<std::string> YACS::ENGINE::ForEachLoopPassedData::_nameOfOutputs

private

Definition at line 147 of file ForEachLoop.hxx.

Referenced by checkLevel2().

◆ _passedIds

std::vector<unsigned int> YACS::ENGINE::ForEachLoopPassedData::_passedIds

private

Definition at line 145 of file ForEachLoop.hxx.

Referenced by checkCompatibilyWithNb(), ForEachLoopPassedData(), and getNumberOfElementsToDo().

◆ _passedOutputs

std::vector<SequenceAny *> YACS::ENGINE::ForEachLoopPassedData::_passedOutputs

private

Definition at line 146 of file ForEachLoop.hxx.

Referenced by assignAlreadyDone(), ForEachLoopPassedData(), and ~ForEachLoopPassedData().

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

src/engine/ForEachLoop.hxx
src/engine/ForEachLoop.cxx

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ ForEachLoopPassedData() [1/2]

◆ ForEachLoopPassedData() [2/2]

◆ ~ForEachLoopPassedData()

Member Function Documentation

◆ assignAlreadyDone()

◆ checkCompatibilyWithNb()

◆ checkLevel2()

◆ getIds()

◆ getNumberOfElementsToDo()

◆ getNumberOfEltsAlreadyDone()

◆ getOutputNames()

◆ getOutputs()

◆ init()

◆ toAbsId()

◆ toAbsIdNot()

Member Data Documentation

◆ _flagsIds

◆ _nameOfOutputs

◆ _passedIds

◆ _passedOutputs