Class for for loop node. More...

#include <ForLoop.hxx>

Inheritance diagram for YACS::ENGINE::ForLoop:

Collaboration diagram for YACS::ENGINE::ForLoop:

Public Member Functions
	ForLoop (const ForLoop &other, ComposedNode *father, bool editionOnly)

	ForLoop (const std::string &name)

void	exUpdateState ()
	Update the state of the for loop. More...

void	exUpdateProgress ()

void	init (bool start=true)
	Initialize the node. More...

InputPort *	edGetNbOfTimesInputPort ()

Node *	simpleClone (ComposedNode *father, bool editionOnly=true) const

InputPort *	getInputPort (const std::string &name) const throw (Exception)
	Get an input port given its name. More...

OutPort *	getOutPort (const std::string &name) const throw (Exception)

OutputPort *	getOutputPort (const std::string &name) const throw (Exception)
	Get an output port given its name. More...

std::list< InputPort * >	getLocalInputPorts () const
	redefined on derived class of ComposedNode. by default a ComposedNode has no port by itself More...

std::list< OutputPort * >	getLocalOutputPorts () const
	redefined on derived class of ComposedNode. by default a ComposedNode has no port by itself More...

std::list< OutputPort * >	getSetOfOutputPort () const

virtual void	accept (Visitor *visitor)

InputPort *	getDecisionPort () const
	Returns the port which value is used to take decision about the continuation of the loop. More...

OutputPort *	edGetIndexPort ()

virtual std::string	typeName ()

std::string	getProgress () const

std::list< ProgressWeight >	getProgressWeight () const
	Get the progress weight for all elementary nodes. More...

int	getNbSteps () const

Public Member Functions inherited from YACS::ENGINE::Loop
	Loop (const Loop &other, ComposedNode *father, bool editionOnly)

	Loop (const std::string &name)

	~Loop ()

void	init (bool start=true)

int	getNbOfTurns () const

Node *	edSetNode (Node *DISOWNnode)

virtual bool	edAddChild (Node *DISOWNnode) throw (Exception)

Node *	edRemoveNode ()

virtual void	checkBasicConsistency () const throw (Exception)

void	getReadyTasks (std::vector< Task * > &tasks)
	Collect all the child nodes that are ready. More...

void	edRemoveChild (Node *node) throw (Exception)
	Remove a child node. More...

bool	isRepeatedUnpredictablySeveralTimes () const

std::list< Node * >	edGetDirectDescendants () const

std::list< InputPort * >	getSetOfInputPort () const

int	getNumberOfInputPorts () const

int	getMaxLevelOfParallelism () const

Node *	getChildByShortName (const std::string &name) const throw (Exception)

virtual bool	edAddDFLink (OutPort start, InPort end) throw (Exception)
	Connect an OutPort to an InPort and add control link if necessary. More...

void	writeDot (std::ostream &os) const
	Dump the node state to a stream. More...

Public Member Functions inherited from YACS::ENGINE::StaticDefinedComposedNode
bool	isPlacementPredictableB4Run () const

bool	isMultiplicitySpecified (unsigned &value) const

void	forceMultiplicity (unsigned value)

void	selectRunnableTasks (std::vector< Task * > &tasks)

Public Member Functions inherited from YACS::ENGINE::ComposedNode
virtual	~ComposedNode ()

bool	isFinished ()

virtual void	shutdown (int level)
	Stop all pending activities of the composed node. More...

virtual void	resetState (int level)
	Reset the state of the node and its children depending on the parameter level. More...

std::string	getName () const

std::string	getTaskName (Task *task) const

DeploymentTree	getDeploymentTree () const
	Essentially for test. Use checkDeploymentTree instead to be sure that returned DeploymentTree is consistent. More...

DeploymentTree	checkDeploymentTree (bool deep) const throw (Exception)
	Perform check of deployment consistency of the current graph. More...

std::vector< Task * >	getNextTasks (bool &isMore)

void	notifyFrom (const Task sender, YACS::Event event, const Executor execInst)
	Notify the node a task has emitted an event. More...

bool	edAddLink (OutPort start, InPort end) throw (Exception)
	Add a dataflow link between two data ports. More...

bool	edAddLink (OutGate start, InGate end) throw (Exception)
	Add a controlflow link between two control ports. More...

bool	edAddCFLink (Node nodeS, Node nodeE) throw (Exception)
	Add a controlflow link between two nodes. More...

void	edRemoveCFLink (Node nodeS, Node nodeE) throw (Exception)
	Remove a controlflow link. More...

void	edRemoveLink (OutPort start, InPort end) throw (Exception)
	Remove a dataflow link. More...

void	edRemoveLink (OutGate start, InGate end) throw (Exception)
	Remove a controlflow link. More...

virtual void	removeRecursivelyRedundantCL ()

std::list< ElementaryNode * >	getRecursiveConstituents () const

std::list< Node * >	getAllRecursiveNodes ()
	Get all children nodes elementary and composed including this node. More...

virtual std::list< Node * >	getAllRecursiveConstituents ()
	Idem getAllRecursiveNodes, but this node is NOT included. More...

std::string	getInPortName (const InPort *) const throw (Exception)
	Get the input port name. More...

std::string	getOutPortName (const OutPort *) const throw (Exception)

int	getNumberOfOutputPorts () const

std::set< OutPort * >	getAllOutPortsLeavingCurrentScope () const
	List all output ports of children nodes that are linked to out of scope input ports. More...

std::set< InPort * >	getAllInPortsComingFromOutsideOfCurrentScope () const
	List all input ports that are linked to out of scope ports. More...

std::list< InputDataStreamPort * >	getSetOfInputDataStreamPort () const

std::list< OutputDataStreamPort * >	getSetOfOutputDataStreamPort () const

InputDataStreamPort *	getInputDataStreamPort (const std::string &name) const throw (Exception)

OutputDataStreamPort *	getOutputDataStreamPort (const std::string &name) const throw (Exception)

std::vector< std::pair < OutPort , InPort > >	getSetOfInternalLinks () const

virtual std::vector< std::pair < OutPort , InPort > >	getSetOfLinksLeavingCurrentScope () const

void	checkConsistency (LinkInfo &info) const throw (Exception)

virtual std::vector< std::pair < InPort , OutPort > >	getSetOfLinksComingInCurrentScope () const

virtual void	edUpdateState ()
	update the status of the node More...

virtual std::string	getErrorReport ()
	returns a string that contains an error report if the node is in error More...

ComposedNode *	getRootNode () const throw (Exception)

bool	isNodeAlreadyAggregated (const Node *node) const
	Check that Node 'node' is already a direct son of this. More...

virtual bool	isNameAlreadyUsed (const std::string &name) const

Node *	isInMyDescendance (Node *nodeToTest) const
	Returns the parent of a node that is the direct child of this node. More...

std::string	getChildName (const Node *node) const throw (Exception)

virtual std::string	getMyQualifiedName (const Node *directSon) const

Node *	getChildByName (const std::string &name) const throw (Exception)

void	loaded ()

void	connected ()

virtual void	cleanNodes ()
	Clean the composed node in case of not clean exit. More...

Public Member Functions inherited from YACS::ENGINE::Node
virtual	~Node ()

Node *	clone (ComposedNode *father, bool editionOnly=true) const
	This method MUST NEVER BE VIRTUAL More...

Node *	cloneWithoutCompAndContDeepCpy (ComposedNode *father, bool editionOnly=true) const
	This method MUST NEVER BE VIRTUAL More...

void	setState (YACS::StatesForNode theState)
	Sets the given state for node. More...

virtual YACS::StatesForNode	getState () const

virtual YACS::StatesForNode	getEffectiveState () const
	Return the node state in the context of its father. More...

virtual YACS::StatesForNode	getEffectiveState (const Node *) const
	Return the effective state of a node in the context of this one (its father) More...

std::string	getColorState (YACS::StatesForNode state) const
	Return the color associated to a state. More...

InGate *	getInGate ()

OutGate *	getOutGate ()

const std::string &	getName () const

void	setName (const std::string &name)
	Change the name of the node. More...

ComposedNode *	getFather () const

const std::string	getId () const

bool	exIsControlReady () const

std::list< Node * >	getOutNodes () const

virtual void	exFailedState ()
	Notify this node that its execution has failed. More...

virtual void	exDisabledState ()
	Notify this node that it has been disabled. More...

std::list< InPort * >	getSetOfInPort () const

std::list< OutPort * >	getSetOfOutPort () const

virtual std::set< InputPort * >	edGetSetOfUnitializedInputPort () const
	Becomes deprecated soon. Replaced by ComposedNode::CheckConsistency. More...

virtual bool	edAreAllInputPortInitialized () const
	Becomes deprecated soon. Replaced by ComposedNode::CheckConsistency. More...

InPort *	getInPort (const std::string &name) const throw (Exception)

InPropertyPort *	getInPropertyPort () const throw (Exception)

std::list< ComposedNode * >	getAllAscendanceOf (ComposedNode *levelToStop=0) const

bool	operator> (const Node &other) const

bool	operator< (const Node &other) const

std::string	getImplementation () const

virtual void	setProperty (const std::string &name, const std::string &value)

virtual std::string	getProperty (const std::string &name)

std::map< std::string, std::string >	getProperties ()

std::map< std::string, std::string >	getPropertyMap ()

virtual void	setProperties (std::map< std::string, std::string > properties)

virtual Proc *	getProc ()

virtual const Proc *	getProc () const

std::string	getQualifiedName () const
	same as Node::getName() in most cases, but differs for children of switch More...

int	getNumId ()
	return node instance identifiant, unique for each node instance More...

std::vector< std::pair < std::string, int > >	getDPLScopeInfo (ComposedNode *gfn)

virtual void	applyDPLScope (ComposedNode *gfn)

virtual void	sendEvent (const std::string &event)
	emit notification to all observers registered with the dispatcher More...

virtual void	sendEvent2 (const std::string &event, void *something)
	emit notification to all observers registered with the dispatcher More...

virtual std::string	getErrorDetails () const

virtual void	setErrorDetails (const std::string &error)

virtual void	modified ()
	Sets Node in modified state and its father if it exists. More...

virtual int	isModified ()

virtual int	isValid ()
	indicates if the node is valid (returns 1) or not (returns 0) More...

virtual std::string	getContainerLog ()
	returns a string that contains the name of the container log file if it exists More...

virtual void	ensureLoading ()
	Put this node into TOLOAD state when possible. More...

virtual void	getCoupledNodes (std::set< Task * > &coupledNodes)

Public Member Functions inherited from YACS::ENGINE::Scheduler
virtual	~Scheduler ()

Protected Member Functions
YACS::Event	updateStateOnFinishedEventFrom (Node *node)
	Method used to notify the node that a child node has ended. More...

void	checkCFLinks (const std::list< OutPort * > &starts, InputPort *end, unsigned char &alreadyFed, bool direction, LinkInfo &info) const
	check control flow links More...

void	checkControlDependancy (OutPort start, InPort end, bool cross, std::map< ComposedNode , std::list< OutPort >, SortHierarc > &fw, std::vector< OutPort * > &fwCross, std::map< ComposedNode , std::list< OutPort >, SortHierarc > &bw, LinkInfo &info) const

Protected Member Functions inherited from YACS::ENGINE::Loop
void	buildDelegateOf (InPort &port, OutPort initialStart, const std::list< ComposedNode * > &pointsOfView)

void	buildDelegateOf (std::pair< OutPort , OutPort > &port, InPort finalTarget, const std::list< ComposedNode > &pointsOfView)

void	getDelegateOf (InPort &port, OutPort initialStart, const std::list< ComposedNode * > &pointsOfView) throw (Exception)

void	getDelegateOf (std::pair< OutPort , OutPort > &port, InPort finalTarget, const std::list< ComposedNode > &pointsOfView) throw (Exception)

void	releaseDelegateOf (InPort &port, OutPort initialStart, const std::list< ComposedNode * > &pointsOfView) throw (Exception)

void	releaseDelegateOf (OutPort portDwn, OutPort portUp, InPort finalTarget, const std::list< ComposedNode > &pointsOfView) throw (Exception)

void	checkNoCyclePassingThrough (Node *node) throw (Exception)

void	checkControlDependancy (OutPort start, InPort end, bool cross, std::map< ComposedNode , std::list< OutPort >, SortHierarc > &fw, std::vector< OutPort * > &fwCross, std::map< ComposedNode , std::list< OutPort >, SortHierarc > &bw, LinkInfo &info) const

void	checkCFLinks (const std::list< OutPort * > &starts, InputPort *end, unsigned char &alreadyFed, bool direction, LinkInfo &info) const
	check control flow links More...

Protected Member Functions inherited from YACS::ENGINE::StaticDefinedComposedNode
	StaticDefinedComposedNode (const std::string &name)

	StaticDefinedComposedNode (const StaticDefinedComposedNode &other, ComposedNode *father)

void	checkControlDependancy (OutPort start, InPort end, bool cross, std::map< ComposedNode , std::list< OutPort >, SortHierarc > &fw, std::vector< OutPort * > &fwCross, std::map< ComposedNode , std::list< OutPort >, SortHierarc > &bw, LinkInfo &info) const

Protected Member Functions inherited from YACS::ENGINE::ComposedNode
	ComposedNode (const std::string &name)

	ComposedNode (const ComposedNode &other, ComposedNode *father)

void	performDuplicationOfPlacement (const Node &other)
	performs a duplication of placement using clone method of containers and components. clone behaviour is driven by attachOnCloning attribute. More...

void	performShallowDuplicationOfPlacement (const Node &other)
	performs a also duplication of placement but here containers and components are not copied at all whatever the value of attachedOnCloning. More...

void	edDisconnectAllLinksWithMe ()

YACS::Event	updateStateFrom (Node node, YACS::Event event, const Executor execInst)
	Update node state on receiving event from a node. More...

virtual YACS::Event	updateStateOnStartEventFrom (Node *node)
	Method used to notify the node that a child node has started. More...

virtual YACS::Event	updateStateOnFailedEventFrom (Node node, const Executor execInst)
	Method used to notify the node that a child node has failed. More...

virtual void	checkLinkPossibility (OutPort start, const std::list< ComposedNode > &pointsOfViewStart, InPort end, const std::list< ComposedNode > &pointsOfViewEnd) throw (Exception)

void	checkInMyDescendance (Node *nodeToTest) const throw (Exception)
	Check if a node is in the descendance of this node. More...

template<class PORT >
std::string	getPortName (const PORT *port) const throw (Exception)

void	checkNoCrossHierachyWith (Node *node) const throw (Exception)

virtual void	performCFComputations (LinkInfo &info) const
	perform recursively all CF computations. More...

virtual void	destructCFComputations (LinkInfo &info) const
	destroy recursively all results of initial computations. More...

Node *	getLowestNodeDealingAll (const std::list< OutPort * > &ports) const

void	checkLinksCoherenceRegardingControl (const std::vector< OutPort * > &starts, InputPort *end, LinkInfo &info) const throw (Exception)

void	solveObviousOrDelegateCFLinks (const std::list< OutPort * > &starts, InputPort *end, unsigned char &alreadyFed, bool direction, LinkInfo &info) const

Protected Member Functions inherited from YACS::ENGINE::Node
	Node (const std::string &name)

	Node (const Node &other, ComposedNode *father)

virtual void	exForwardFailed ()

virtual void	exForwardFinished ()

Protected Attributes
AnyInputPort	_nbOfTimesPort

AnyOutputPort	_indexPort

Protected Attributes inherited from YACS::ENGINE::Loop
Node *	_node

int	_nbOfTurns

FakeNodeForLoop *	_nodeForNullTurnOfLoops

std::set< DSToDFForLoop * >	_inputsTraducer

std::set< DFToDSForLoop * >	_outputsTraducer

Static Protected Attributes
static const char	NAME_OF_INDEX [] ="index"

static const char	NAME_OF_NSTEPS_NUMBER [] ="nsteps"

Additional Inherited Members
Static Public Member Functions inherited from YACS::ENGINE::Loop
static TypeCode *	MappingDF2DS (TypeCode *type) throw (Exception)

static TypeCode *	MappingDS2DF (TypeCode *type) throw (Exception)

Public Attributes inherited from YACS::ENGINE::Node
YACS::Colour	_colour

Static Public Attributes inherited from YACS::ENGINE::Node
static std::map< int, Node * >	idMap

Static Protected Member Functions inherited from YACS::ENGINE::Loop
static bool	isNecessaryToBuildSpecificDelegateDF2DS (const std::list< ComposedNode * > &pointsOfView)

Detailed Description

Class for for loop node.

This kind of loop makes a fixed number of steps and stops

Definition at line 32 of file ForLoop.hxx.

Constructor & Destructor Documentation

ForLoop::ForLoop	(	const ForLoop &	other,
		ComposedNode *	father,
		bool	editionOnly
	)

Definition at line 50 of file ForLoop.cxx.

References YACS::ENGINE::ComposedNode::edAddLink(), YACS::ENGINE::Node::getInPort(), getOutPort(), YACS::ENGINE::ComposedNode::getPortName(), and YACS::ENGINE::ComposedNode::getSetOfInternalLinks().

Referenced by simpleClone().

                                                                             :Loop(other,father,editionOnly),
                                                                                _nbOfTimesPort(other._nbOfTimesPort,this),
                                                                                _indexPort(other._indexPort,this)
 {
   //Copy Data linking
   std::vector< std::pair<OutPort *, InPort *> > linksToReproduce=other.getSetOfInternalLinks();
   std::vector< std::pair<OutPort *, InPort *> >::iterator iter=linksToReproduce.begin();
   for(;iter!=linksToReproduce.end();++iter)
     {
       OutPort* pout = iter->first;
       InPort* pin = iter->second;
       edAddLink(getOutPort(other.getPortName(pout)),getInPort(other.getPortName(pin)));
     }
 }

ForLoop::ForLoop ( const std::string & name )

Definition at line 45 of file ForLoop.cxx.

                                      :Loop(name),_nbOfTimesPort(NAME_OF_NSTEPS_NUMBER,this,Runtime::_tc_int),
                                                      _indexPort(NAME_OF_INDEX,this,Runtime::_tc_int)
 {
 }

Member Function Documentation

void ForLoop::accept ( Visitor * visitor )

virtual

Reimplemented from YACS::ENGINE::Loop.

Definition at line 173 of file ForLoop.cxx.

References YACS::ENGINE::Visitor::visitForLoop().

 {
   visitor->visitForLoop(this);
 }

void ForLoop::checkCFLinks	(	const std::list< OutPort * > &	starts,
		InputPort *	end,
		unsigned char &	alreadyFed,
		bool	direction,
		LinkInfo &	info
	)		const

protectedvirtual

check control flow links

Parameters

starts	If different of 0, must aggregate at leat 1 element.
end	:
alreadyFed	in/out parameter. Indicates if 'end' ports is already and surely set or fed by an another port.
direction	If true : forward direction else backward direction.
info	: informations collectedduring the check

Reimplemented from YACS::ENGINE::ComposedNode.

Definition at line 220 of file ForLoop.cxx.

References _indexPort, YACS::ENGINE::ComposedNode::FED_ST, YACS::ENGINE::ComposedNode::FREE_ST, YACS::ENGINE::Port::getNode(), YACS::ENGINE::I_USELESS, YACS::ENGINE::ComposedNode::isInMyDescendance(), YACS::ENGINE::LinkInfo::pushInfoLink(), and YACS::ENGINE::ComposedNode::solveObviousOrDelegateCFLinks().

 {
   const char what[]="ForLoop::checkCFLinks : internal error.";
   Node *nodeEnd=end->getNode();
   if(nodeEnd==this)
     {//In this case 'end' port is a special port of this (for exemple ForLoop::_nbOfTimesPort)
       solveObviousOrDelegateCFLinks(starts,end,alreadyFed,direction,info);
     }
   else if(isInMyDescendance(nodeEnd)==0)
     {
       solveObviousOrDelegateCFLinks(starts,end,alreadyFed,direction,info);
     }
   else
     {//no forwarding here.
       if(starts.size()!=1)
         throw Exception(what);
 
       Node *nodeStart=(*(starts.begin()))->getNode();
       if(nodeStart==this)
         {
           // Link between the loop and the internal node
           if(*(starts.begin())!=&_indexPort)
             throw Exception(what);
         }
       else
         {
           // Link from internal node to internal node
           if(nodeEnd!=nodeStart)
             throw Exception(what);
         }
 
       if(alreadyFed==FREE_ST)
         alreadyFed=FED_ST;
       else if(alreadyFed==FED_ST)
         {
           info.pushInfoLink(*(starts.begin()),end,I_USELESS);
         }
     }
 }

void ForLoop::checkControlDependancy	(	OutPort *	start,
		InPort *	end,
		bool	cross,
		std::map< ComposedNode , std::list< OutPort >, SortHierarc > &	fw,
		std::vector< OutPort * > &	fwCross,
		std::map< ComposedNode , std::list< OutPort >, SortHierarc > &	bw,
		LinkInfo &	info
	)		const

protectedvirtual

Implements YACS::ENGINE::ComposedNode.

Definition at line 206 of file ForLoop.cxx.

References _indexPort, and YACS::ENGINE::StaticDefinedComposedNode::checkControlDependancy().

 {
   //First testing if start==indexPort. This is the only case possible in theory.
   if(start != &_indexPort)
     return StaticDefinedComposedNode::checkControlDependancy(start,end,cross,fw,fwCross,bw,info);
   if(cross)
     throw Exception("Internal error occured - cross type link detected on decision port of a loop. Forbidden !");
   fw[(ComposedNode *)this].push_back(start);
 }

OutputPort* YACS::ENGINE::ForLoop::edGetIndexPort ( )

inline

Definition at line 55 of file ForLoop.hxx.

55 { return &_indexPort; }

InputPort* YACS::ENGINE::ForLoop::edGetNbOfTimesInputPort ( )

inline

Definition at line 45 of file ForLoop.hxx.

Referenced by YACS::HMI::SubjectForLoop::getValue(), YACS::HMI::CommandSetForLoopSteps::localExecute(), YACS::HMI::CommandSetForLoopSteps::localReverse(), YACS::ENGINE::nodeParser::onEnd(), YACS::ENGINE::VisitorSaveState::visitForLoop(), and YACS::ENGINE::VisitorSaveSchema::visitForLoop().

45 { return &_nbOfTimesPort; }

void ForLoop::exUpdateProgress ( )

Definition at line 167 of file ForLoop.cxx.

References YACS::ENGINE::Node::sendEvent().

Referenced by init(), and updateStateOnFinishedEventFrom().

 {
   // emit notification to all observers registered with the dispatcher on any change of the node's state
   sendEvent("progress");
 }

void ForLoop::exUpdateState ( )

virtual

Update the state of the for loop.

If the inGate port is ready goes to YACS::ACTIVATED state If the steps number is 0, create an special internal node

Reimplemented from YACS::ENGINE::Node.

Definition at line 103 of file ForLoop.cxx.

References YACS::ENGINE::Node::_inGate, _nbOfTimesPort, YACS::ENGINE::Loop::_node, YACS::ENGINE::Loop::_nodeForNullTurnOfLoops, YACS::ENGINE::Node::_state, YACS::ACTIVATED, DEBTRACE, YACS::DISABLED, YACS::ENGINE::InGate::exIsReady(), YACS::ENGINE::Node::exUpdateState(), YACS::ENGINE::Loop::FakeNodeForLoop, YACS::ENGINE::ComposedNode::getAllOutPortsLeavingCurrentScope(), YACS::ENGINE::AnyInputPort::getIntValue(), YACS::ENGINE::ComposedNode::getName(), YACS::ENGINE::AnyInputPort::isEmpty(), and YACS::ENGINE::Node::setState().

 {
   DEBTRACE("ForLoop::exUpdateState " << getName() << " " << _state);
   if(_state == YACS::DISABLED)
     return;
   if(_inGate.exIsReady())
     {
       setState(YACS::ACTIVATED);
       _node->exUpdateState();
       if(_nbOfTimesPort.isEmpty())
         {
           delete _nodeForNullTurnOfLoops;
           _nodeForNullTurnOfLoops=new FakeNodeForLoop(this,false,true);
         }
       else
         {
           if(_nbOfTimesPort.getIntValue()==0)
             {
               bool normalFinish=getAllOutPortsLeavingCurrentScope().empty();
               delete _nodeForNullTurnOfLoops;
               _nodeForNullTurnOfLoops=new FakeNodeForLoop(this,normalFinish);
             }
           else if(_nbOfTimesPort.getIntValue()<0)
             {
               delete _nodeForNullTurnOfLoops;
               _nodeForNullTurnOfLoops=new FakeNodeForLoop(this,false);
             }
           else
             {
               delete _nodeForNullTurnOfLoops;
               _nodeForNullTurnOfLoops=0;
             }
         }
     }
 }

InputPort* YACS::ENGINE::ForLoop::getDecisionPort ( ) const

inlinevirtual

Returns the port which value is used to take decision about the continuation of the loop.

Implements YACS::ENGINE::Loop.

Definition at line 54 of file ForLoop.hxx.

54 { return (InputPort *)&_nbOfTimesPort; }

InputPort * ForLoop::getInputPort ( const std::string & name ) const throw (Exception)

virtual

Get an input port given its name.

Contrary to YACS::ENGINE::ComposedNode::getOutputPort, this method is NOT recursive and so the leaf of type ElementaryNode aggregating this InputPort is directly invoked.

Reimplemented from YACS::ENGINE::ComposedNode.

Definition at line 70 of file ForLoop.cxx.

References YACS::ENGINE::ComposedNode::getInputPort().

 {
     if(name == NAME_OF_NSTEPS_NUMBER)return (InputPort*)&_nbOfTimesPort;
     return Loop::getInputPort(name);
 
 }

std::list< InputPort * > ForLoop::getLocalInputPorts ( ) const

virtual

redefined on derived class of ComposedNode. by default a ComposedNode has no port by itself

Reimplemented from YACS::ENGINE::ComposedNode.

Definition at line 178 of file ForLoop.cxx.

References _nbOfTimesPort, and PMMLBasicsTestLauncher::ret.

 {
   list<InputPort *> ret;
   ret.push_back((InputPort *)&_nbOfTimesPort);
   return ret;
 }

std::list< OutputPort * > ForLoop::getLocalOutputPorts ( ) const

virtual

redefined on derived class of ComposedNode. by default a ComposedNode has no port by itself

Reimplemented from YACS::ENGINE::ComposedNode.

Definition at line 199 of file ForLoop.cxx.

References getOutputPort(), NAME_OF_INDEX, and PMMLBasicsTestLauncher::ret.

 {
   list<OutputPort *> ret;
   ret.push_back(getOutputPort(NAME_OF_INDEX)); 
   return ret;
 }

int ForLoop::getNbSteps ( ) const

Definition at line 269 of file ForLoop.cxx.

References _nbOfTimesPort, YACS::ENGINE::AnyInputPort::getIntValue(), and YACS::ENGINE::AnyInputPort::isEmpty().

Referenced by getProgress(), and getProgressWeight().

 {
   AnyInputPort* aNbStepsPort = (AnyInputPort*)&_nbOfTimesPort;
   int nbSteps = 0;
   if (aNbStepsPort && !aNbStepsPort->isEmpty())
     nbSteps = aNbStepsPort->getIntValue();
   return nbSteps;
 }

OutPort * ForLoop::getOutPort ( const std::string & name ) const throw (Exception)

virtual

Note: : Contrary to getOutputPort method, this method returns the output port at highest level, possible. That is to say in some ComposedNode, like ForEachLoop or Switch, an outport inside 'this' is seen differently than the true outport.

Reimplemented from YACS::ENGINE::ComposedNode.

Definition at line 185 of file ForLoop.cxx.

References YACS::ENGINE::ComposedNode::getOutPort().

Referenced by ForLoop().

 {
   if(name==NAME_OF_INDEX)
     return (OutPort *)&_indexPort;
   return Loop::getOutPort(name);
 }

OutputPort * ForLoop::getOutputPort ( const std::string & name ) const throw (Exception)

virtual

Get an output port given its name.

Contrary to YACS::ENGINE::ComposedNode::getInputPort, this method is recursive and go down hierarchy step by step to complete its work.

Reimplemented from YACS::ENGINE::ComposedNode.

Definition at line 192 of file ForLoop.cxx.

References YACS::ENGINE::ComposedNode::getOutputPort().

Referenced by getLocalOutputPorts().

 {
   if(name==NAME_OF_INDEX)
     return (OutputPort *)&_indexPort;
   return Loop::getOutputPort(name);
 }

std::string ForLoop::getProgress ( ) const

virtual

Reimplemented from YACS::ENGINE::ComposedNode.

Definition at line 278 of file ForLoop.cxx.

References YACS::ENGINE::Loop::_nbOfTurns, and getNbSteps().

 {
   std::stringstream aProgress;
   aProgress << "0";
   int nbSteps = getNbSteps();
   if (nbSteps > 0 && _nbOfTurns >= 0)
     {
       aProgress.str("");
       aProgress << _nbOfTurns << "/" << nbSteps;
     }
   return aProgress.str();
 }

list< ProgressWeight > ForLoop::getProgressWeight ( ) const

virtual

Get the progress weight for all elementary nodes.

Only elementary nodes have weight. For each node in the loop, the weight done is multiplied by the number of steps done and the weight total by the number total of steps

Reimplemented from YACS::ENGINE::ComposedNode.

Definition at line 297 of file ForLoop.cxx.

References YACS::ENGINE::Loop::edGetDirectDescendants(), YACS::ENGINE::Loop::getNbOfTurns(), getNbSteps(), and PMMLBasicsTestLauncher::ret.

 {
   list<ProgressWeight> ret;
   list<Node *> setOfNode=edGetDirectDescendants();
   int nbStepsDone=getNbOfTurns();
   int nbStepsTotal=getNbSteps();
   for(list<Node *>::const_iterator iter=setOfNode.begin();iter!=setOfNode.end();iter++)
     {
       list<ProgressWeight> myCurrentSet=(*iter)->getProgressWeight();
         for(list<ProgressWeight>::iterator iter=myCurrentSet.begin();iter!=myCurrentSet.end();iter++)
           {
             (*iter).weightDone=((*iter).weightTotal) * nbStepsDone;
             (*iter).weightTotal*=nbStepsTotal;
           }
         ret.insert(ret.end(),myCurrentSet.begin(),myCurrentSet.end());
     }
   return ret;
 }

std::list< OutputPort * > ForLoop::getSetOfOutputPort ( ) const

virtual

Reimplemented from YACS::ENGINE::ComposedNode.

Definition at line 261 of file ForLoop.cxx.

References _indexPort, YACS::ENGINE::ComposedNode::getSetOfOutputPort(), and PMMLBasicsTestLauncher::ret.

 {
   list<OutputPort *> ret=ComposedNode::getSetOfOutputPort();
   ret.push_back((OutputPort *)&_indexPort);
   return ret;
 }

void ForLoop::init ( bool start = true )

virtual

Initialize the node.

Parameters

start,: a boolean flag to indicate the initialization mode

If start is true, it's a complete initialization (with port values initialization) If start is false, there is no port values initialization

Reimplemented from YACS::ENGINE::ComposedNode.

Definition at line 85 of file ForLoop.cxx.

References _indexPort, _nbOfTimesPort, YACS::ENGINE::Loop::_nbOfTurns, DEBTRACE, YACS::ENGINE::RefCounter::decrRef(), YACS::ENGINE::OutputPort::exInit(), YACS::ENGINE::InputPort::exInit(), exUpdateProgress(), YACS::ENGINE::Loop::init(), YACS::ENGINE::AtomAny::New(), and YACS::ENGINE::AnyOutputPort::put().

 {
   DEBTRACE("ForLoop::init " << start);
   Loop::init(start);
   _nbOfTimesPort.exInit(start);
   _indexPort.exInit();
   Any* tmp=AtomAny::New(_nbOfTurns);
   _indexPort.put(tmp);
   tmp->decrRef();
   exUpdateProgress();
 }

Node * ForLoop::simpleClone	(	ComposedNode *	father,
		bool	editionOnly = `true`
	)		const

virtual

Implements YACS::ENGINE::Node.

Definition at line 65 of file ForLoop.cxx.

References ForLoop().

 {
   return new ForLoop(*this,father,editionOnly);
 }

virtual std::string YACS::ENGINE::ForLoop::typeName ( )

inlinevirtual

Reimplemented from YACS::ENGINE::Loop.

Definition at line 56 of file ForLoop.hxx.

56 {return "YACS__ENGINE__ForLoop";}

YACS::Event ForLoop::updateStateOnFinishedEventFrom ( Node * node )

protectedvirtual

Method used to notify the node that a child node has ended.

Update the loop state and return the loop change state

Parameters

node	: the child node that has ended

Returns: the loop state change

Implements YACS::ENGINE::ComposedNode.

Definition at line 146 of file ForLoop.cxx.

References _indexPort, _nbOfTimesPort, YACS::ENGINE::Loop::_nbOfTurns, YACS::ENGINE::Loop::_node, YACS::ACTIVATED, DEBTRACE, YACS::ENGINE::RefCounter::decrRef(), YACS::DONE, exUpdateProgress(), YACS::ENGINE::Node::exUpdateState(), YACS::FINISH, YACS::ENGINE::AnyInputPort::getIntValue(), YACS::ENGINE::Node::getName(), YACS::ENGINE::Node::init(), YACS::ENGINE::AtomAny::New(), YACS::NOEVENT, YACS::ENGINE::AnyOutputPort::put(), and YACS::ENGINE::Node::setState().

 {
   DEBTRACE("ForLoop::updateStateOnFinishedEventFrom " << node->getName());
   exUpdateProgress();
   if((++_nbOfTurns)>=_nbOfTimesPort.getIntValue())
     {
       setState(YACS::DONE);
       return YACS::FINISH;
     }
   else
     {
       Any* tmp=AtomAny::New(_nbOfTurns);
       _indexPort.put(tmp);
       tmp->decrRef();
       setState(YACS::ACTIVATED);
       _node->init(false);
       _node->exUpdateState();
     }
   return YACS::NOEVENT;
 }

Member Data Documentation

AnyOutputPort YACS::ENGINE::ForLoop::_indexPort

protected

Definition at line 38 of file ForLoop.hxx.

Referenced by checkCFLinks(), checkControlDependancy(), getSetOfOutputPort(), init(), and updateStateOnFinishedEventFrom().

AnyInputPort YACS::ENGINE::ForLoop::_nbOfTimesPort

protected

Definition at line 37 of file ForLoop.hxx.

Referenced by exUpdateState(), getLocalInputPorts(), getNbSteps(), init(), and updateStateOnFinishedEventFrom().

const char ForLoop::NAME_OF_INDEX ="index"

staticprotected

Definition at line 35 of file ForLoop.hxx.

Referenced by getLocalOutputPorts().

const char ForLoop::NAME_OF_NSTEPS_NUMBER ="nsteps"

staticprotected

Definition at line 36 of file ForLoop.hxx.

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

src/engine/ForLoop.hxx
src/engine/ForLoop.cxx

Public Member Functions

Protected Member Functions

Protected Attributes

Static Protected Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation