#include <ForEachLoop.hxx>

Collaboration diagram for YACS::ENGINE::ForEachLoopPassedData:

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::ForEachLoopPassedData	(	const std::vector< unsigned int > &	passedIds,
		const std::vector< SequenceAny * > &	passedOutputs,
		const std::vector< std::string > &	nameOfOutputs
	)

Definition at line 301 of file ForEachLoop.cxx.

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

                                                                                                                                                                               :_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();
     }
 }

ForEachLoopPassedData::ForEachLoopPassedData ( const ForEachLoopPassedData & copy )

Definition at line 321 of file ForEachLoop.cxx.

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

ForEachLoopPassedData::~ForEachLoopPassedData ( )

Definition at line 329 of file ForEachLoop.cxx.

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

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

Member Function Documentation

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

Definition at line 443 of file ForEachLoop.cxx.

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

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

 {
   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);
         }
     }
 }

void ForEachLoopPassedData::checkCompatibilyWithNb ( int nbOfElts ) const

Definition at line 344 of file ForEachLoop.cxx.

References _flagsIds, and _passedIds.

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

 {
   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());
         }
     }
 }

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

Definition at line 378 of file ForEachLoop.cxx.

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

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

 {
   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());
         }
     }
 }

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

inline

Definition at line 140 of file ForEachLoop.hxx.

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

140 {return _passedIds;}

int ForEachLoopPassedData::getNumberOfElementsToDo ( ) const

Definition at line 436 of file ForEachLoop.cxx.

References _flagsIds, _passedIds, and PMMLBasicsTestLauncher::ret.

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

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

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

inline

Definition at line 135 of file ForEachLoop.hxx.

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

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

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

inline

Definition at line 142 of file ForEachLoop.hxx.

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

142 {return _nameOfOutputs;}

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

inline

Definition at line 141 of file ForEachLoop.hxx.

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

141 {return _passedOutputs;}

void ForEachLoopPassedData::init ( )

Definition at line 339 of file ForEachLoop.cxx.

References _flagsIds.

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

 {
   _flagsIds.clear();
 }

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 399 of file ForEachLoop.cxx.

References _flagsIds, and PMMLBasicsTestLauncher::ret.

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

 {
   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 !");
 }

int ForEachLoopPassedData::toAbsIdNot ( int localId ) const

Equivalent to toAbsId except that only ON are considered here.

Definition at line 419 of file ForEachLoop.cxx.

References _flagsIds, and PMMLBasicsTestLauncher::ret.

Referenced by assignAlreadyDone().

 {
   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 !");
 }