YACS::ENGINE::ComposedNode Class Reference

Base class for all composed nodes. More...

#include <ComposedNode.hxx>

Inheritance diagram for YACS::ENGINE::ComposedNode:

Collaboration diagram for YACS::ENGINE::ComposedNode:

Classes
struct	SortHierarc

Public Member Functions
virtual	~ComposedNode ()
bool	isFinished ()
void	init (bool start=true)
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)
virtual bool	isPlacementPredictableB4Run () const =0
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...
virtual bool	edAddDFLink (OutPort *start, InPort *end) throw (Exception)
	Connect an OutPort to an InPort and add the necessary control link. More...
virtual bool	edAddChild (Node *DISOWNnode) throw (Exception)
virtual void	edRemoveChild (Node *node) throw (Exception)
	Remove a child node. 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 bool	isRepeatedUnpredictablySeveralTimes () const
virtual std::list< Node * >	edGetDirectDescendants () const =0
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::list< ProgressWeight >	getProgressWeight () const
	Get the progress weight for all elementary nodes. More...
std::string	getInPortName (const InPort *) const throw (Exception)
	Get the input port name. More...
std::string	getOutPortName (const OutPort *) const throw (Exception)
int	getNumberOfInputPorts () const
int	getNumberOfOutputPorts () const
std::list< InputPort * >	getSetOfInputPort () const
std::list< OutputPort * >	getSetOfOutputPort () const
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::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
OutPort *	getOutPort (const std::string &name) const throw (Exception)
InputPort *	getInputPort (const std::string &name) const throw (Exception)
	Get an input port given its name. More...
OutputPort *	getOutputPort (const std::string &name) const throw (Exception)
	Get an output port given its name. More...
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 std::string	typeName ()
virtual void	edUpdateState ()
	update the status of the node More...
virtual void	checkBasicConsistency () const throw (Exception)
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 ()
void	accept (Visitor *visitor)
virtual void	cleanNodes ()
	Clean the composed node in case of not clean exit. More...
virtual std::string	getProgress () const
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	writeDot (std::ostream &os) const
	Dump to the input stream a dot representation of the node. More...
virtual void	exUpdateState ()
	Update the node state. More...
virtual void	exFailedState ()
	Notify this node that its execution has failed. More...
virtual void	exDisabledState ()
	Notify this node that it has been disabled. More...
virtual void	getReadyTasks (std::vector< Task * > &tasks)=0
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
virtual int	getMaxLevelOfParallelism () const =0
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 void	exUpdateState ()=0
virtual void	selectRunnableTasks (std::vector< Task * > &tasks)=0
virtual bool	isMultiplicitySpecified (unsigned &value) const =0
virtual void	forceMultiplicity (unsigned value)=0
virtual	~Scheduler ()

Static Public Member Functions
static ComposedNode *	getLowestCommonAncestor (Node *node1, Node *node2) throw (Exception)
	Retrieves the lowest common ancestor of 2 nodes. More...
static std::string	getLowestCommonAncestorStr (const std::string &node1, const std::string &node2)
Static Public Member Functions inherited from YACS::ENGINE::Node
static std::string	getStateName (YACS::StatesForNode state)
	Return the name of a state. More...

Protected Member Functions
	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 ()
virtual Node *	getChildByShortName (const std::string &name) const =0 throw (Exception)
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	updateStateOnFinishedEventFrom (Node *node)=0
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)
virtual void	buildDelegateOf (InPort *&port, OutPort *initialStart, const std::list< ComposedNode * > &pointsOfView)
virtual void	buildDelegateOf (std::pair< OutPort *, OutPort * > &port, InPort *finalTarget, const std::list< ComposedNode * > &pointsOfView)
virtual void	getDelegateOf (InPort *&port, OutPort *initialStart, const std::list< ComposedNode * > &pointsOfView) throw (Exception)
virtual void	getDelegateOf (std::pair< OutPort *, OutPort * > &port, InPort *finalTarget, const std::list< ComposedNode * > &pointsOfView) throw (Exception)
virtual void	releaseDelegateOf (InPort *&port, OutPort *initialStart, const std::list< ComposedNode * > &pointsOfView) throw (Exception)
virtual void	releaseDelegateOf (OutPort *portDwn, OutPort *portUp, InPort *finalTarget, const std::list< ComposedNode * > &pointsOfView) throw (Exception)
virtual void	checkNoCyclePassingThrough (Node *node)=0 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)
virtual 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 =0
void	solveObviousOrDelegateCFLinks (const std::list< OutPort * > &starts, InputPort *end, unsigned char &alreadyFed, bool direction, LinkInfo &info) const
virtual 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::Node
	Node (const std::string &name)
	Node (const Node &other, ComposedNode *father)
virtual Node *	simpleClone (ComposedNode *father, bool editionOnly=true) const =0
virtual void	exForwardFailed ()
virtual void	exForwardFinished ()

Static Protected Member Functions
static bool	splitNamesBySep (const std::string &globalName, const char separator[], std::string &firstPart, std::string &lastPart, bool priority) throw (Exception)
	Splits name globalName in 2 parts using separator. More...
Static Protected Member Functions inherited from YACS::ENGINE::Node
static void	checkValidityOfPortName (const std::string &name) throw (Exception)
static ComposedNode *	checkHavingCommonFather (Node *node1, Node *node2) throw (Exception)

Static Protected Attributes
static const char	SEP_CHAR_BTW_LEVEL [] ="."
static const unsigned char	FED_ST = 2
static const unsigned char	FREE_ST = 0
static const unsigned char	FED_DS_ST = 1
Static Protected Attributes inherited from YACS::ENGINE::Node
static const char	SEP_CHAR_IN_PORT [] ="."
static int	_total = 0

Friends
class	Bloc
class	Loop
class	OutPort
class	ElementaryNode

Additional Inherited Members
Public Attributes inherited from YACS::ENGINE::Node
YACS::Colour	_colour
Static Public Attributes inherited from YACS::ENGINE::Node
static std::map< int, Node * >	idMap
Protected Attributes inherited from YACS::ENGINE::Node
InGate	_inGate
OutGate	_outGate
InPropertyPort *	_inPropertyPort
std::string	_name
ComposedNode *	_father
YACS::StatesForNode	_state
int	_modified
std::string	_errorDetails
int	_numId
std::string	_implementation
std::map< std::string, std::string >	_propertyMap

Detailed Description

Base class for all composed nodes.

This is an abstract class that must be specialized.

Definition at line 42 of file ComposedNode.hxx.

Constructor & Destructor Documentation

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

protected

Definition at line 54 of file ComposedNode.cxx.

                                               :Node(name)
{
}

ComposedNode::ComposedNode ( const ComposedNode &  other, ComposedNode *  father  )

protected

Definition at line 58 of file ComposedNode.cxx.

                                                                         :Node(other,father)
{
}

ComposedNode::~ComposedNode ( )

virtual

Definition at line 62 of file ComposedNode.cxx.

{
}

Member Function Documentation

void ComposedNode::accept ( Visitor *  visitor )

virtual

Implements YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Loop, YACS::ENGINE::Switch, YACS::ENGINE::DynParaLoop, YACS::ENGINE::OptimizerLoop, YACS::ENGINE::Proc, YACS::ENGINE::ForLoop, and YACS::ENGINE::WhileLoop.

Definition at line 1491 of file ComposedNode.cxx.

References edGetDirectDescendants().

Referenced by YACS::ENGINE::Executor::saveState().

{
  list<Node *> constituents=edGetDirectDescendants();
  for(list<Node *>::iterator iter=constituents.begin(); iter!=constituents.end(); iter++)
    {
      (*iter)->accept(visitor);
    }
}

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

protectedvirtual

Reimplemented in YACS::ENGINE::Loop, YACS::ENGINE::OptimizerLoop, and YACS::ENGINE::DynParaLoop.

Definition at line 1460 of file ComposedNode.cxx.

Referenced by edAddLink().

{
}

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

protectedvirtual

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Loop, YACS::ENGINE::Switch, YACS::ENGINE::OptimizerLoop, and YACS::ENGINE::DynParaLoop.

Definition at line 1464 of file ComposedNode.cxx.

{
}

void ComposedNode::checkBasicConsistency ( ) const throw (Exception)

virtual

Reimplemented in YACS::ENGINE::Loop, YACS::ENGINE::DynParaLoop, and YACS::ENGINE::OptimizerLoop.

Definition at line 1588 of file ComposedNode.cxx.

References DEBTRACE, and getLocalInputPorts().

Referenced by YACS::ENGINE::DynParaLoop::checkBasicConsistency(), YACS::ENGINE::Loop::checkBasicConsistency(), and edUpdateState().

{
  DEBTRACE("ComposedNode::checkBasicConsistency");
  std::list<InputPort *>::const_iterator iter;
  std::list<InputPort *> inports=getLocalInputPorts();
  for(iter=inports.begin();iter!=inports.end();iter++)
    (*iter)->checkBasicConsistency();
}

void ComposedNode::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 in YACS::ENGINE::Loop, YACS::ENGINE::Switch, YACS::ENGINE::OptimizerLoop, YACS::ENGINE::DynParaLoop, YACS::ENGINE::Bloc, and YACS::ENGINE::ForLoop.

Definition at line 803 of file ComposedNode.cxx.

References FED_ST, YACS::ENGINE::Port::getNode(), YACS::ENGINE::I_BACK, isInMyDescendance(), YACS::ENGINE::LinkInfo::pushInfoLink(), YACS::ENGINE::LinkInfo::pushWarnLink(), solveObviousOrDelegateCFLinks(), and YACS::ENGINE::W_BACK_COLLAPSE_EL.

Referenced by YACS::ENGINE::Switch::checkCFLinks(), and YACS::ENGINE::Loop::checkCFLinks().

{
  static const char what[]="ComposedNode::checkCFLinks : Internal error occured - uncorrect hierarchy detected !";
  Node *nodeEnd=isInMyDescendance(end->getNode());
  if(!nodeEnd)
    return solveObviousOrDelegateCFLinks(starts,end,alreadyFed,direction,info);
  //This case is typically dedicated when direct son is ElementaryNode and self link is defined on this.
  if(!dynamic_cast<ElementaryNode *>(nodeEnd))
    throw Exception(what);

  list< OutPort *>::const_iterator iter=starts.begin();
  Node *nodeStart=(*iter)->getNode();
  iter++;
  if(nodeEnd!=nodeStart)
    throw Exception(what);

  for(;iter!=starts.end();iter++)
    if((*iter)->getNode()!=nodeStart)
      throw Exception(what);
  //Ok at this step we are sure that we have back links on the same elementary node.
  if(starts.size()>1)
    for(iter=starts.begin();iter!=starts.end();iter++)
      info.pushWarnLink(*iter,end,W_BACK_COLLAPSE_EL);
  else//here no need to look at 'alreadyFed' var because it is waranteed to be equal to FREE_ST by construction.
    info.pushInfoLink(*(starts.begin()),end,I_BACK);
  alreadyFed=FED_ST;
}

void ComposedNode::checkConsistency

(

LinkInfo &

info

)

const throw (Exception)

Definition at line 611 of file ComposedNode.cxx.

References YACS::ENGINE::E_NEVER_SET_INPUTPORT, and YACS::Exception::what().

Referenced by main(), YACS::HMI::GenericGui::onRunLoadedSchema(), and YACS::HMI::EditionProc::synchronize().

{
  info.clearAll();
  info.setPointOfView((ComposedNode *)this);
  performCFComputations(info);
  list<InputPort *> setOfInToTest=getSetOfInputPort();
  for(list<InputPort *>::iterator iter1=setOfInToTest.begin();iter1!=setOfInToTest.end();iter1++)
    {
      vector<OutPort *> candidateForAdvCheck;
      set<OutPort *> outPorts=(*iter1)->edSetOutPort();
      //Filtering among outPorts, which of them, are candidates to fill *iter1 at the current scope.
      for(set<OutPort *>::iterator iter2=outPorts.begin();iter2!=outPorts.end();iter2++)
        {
          (*iter2)->checkConsistency(info);
          ComposedNode *manager=getLowestCommonAncestor((*iter2)->getNode(),(*iter1)->getNode());
          if(isInMyDescendance(manager))
            candidateForAdvCheck.push_back(*iter2);
        }
      if(!candidateForAdvCheck.empty())
        //End of filtering. Now regarding CF constraints for the current InPutPort.
        try
          {
            checkLinksCoherenceRegardingControl(candidateForAdvCheck,*iter1,info);
          }
        catch(YACS::Exception& ex)
          {
            std::string what=ex.what();
            what += "\nfor input port: ";
            what += (*iter1)->getNode()->getName();
            what += ".";
            what += (*iter1)->getName();

            destructCFComputations(info);
            throw YACS::Exception(what);
          }
      else
        //No backlinks
        if(!(*iter1)->canBeNull() && !(*iter1)->edIsManuallyInitialized())
          info.pushErrLink(0,*iter1,E_NEVER_SET_INPUTPORT);
    }
  destructCFComputations(info);
}

virtual void YACS::ENGINE::ComposedNode::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

protectedpure virtual

Implemented in YACS::ENGINE::Loop, YACS::ENGINE::DynParaLoop, YACS::ENGINE::OptimizerLoop, YACS::ENGINE::Bloc, YACS::ENGINE::ForLoop, and YACS::ENGINE::StaticDefinedComposedNode.

Referenced by checkLinksCoherenceRegardingControl().

DeploymentTree ComposedNode::checkDeploymentTree

(

bool

deep

)

const throw (Exception)

Perform check of deployment consistency of the current graph.

Parameters

deep	if true a deep check is perfomed. Typically has to be called by an executor before any attempt to launch an execution.

Definition at line 189 of file ComposedNode.cxx.

References YACS::ENGINE::DeploymentTree::appendTask(), YACS::ENGINE::DeploymentTree::DEPLOYABLE_BUT_NOT_SPECIFIED, YACS::ENGINE::DeploymentTree::DUP_TASK_NOT_COMPATIBLE_WITH_EXISTING_TREE, and PMMLBasicsTestLauncher::ret.

{
  DeploymentTree ret;
  list< ElementaryNode * > tasks=getRecursiveConstituents();
  for(list< ElementaryNode * >::iterator iter=tasks.begin();iter!=tasks.end();iter++)
    {
      switch(ret.appendTask(*iter,(*iter)->getDynClonerIfExists(this)))
        {
        case DeploymentTree::DUP_TASK_NOT_COMPATIBLE_WITH_EXISTING_TREE:
          {
            string what("ComposedNode::checkDeploymentTree : ServiceNode with name \""); what+=(*iter)->getName();
            what+="\" coexists in a component with an another Task which context is incompatible with it.";
            throw Exception(what);
          }
        case DeploymentTree::DEPLOYABLE_BUT_NOT_SPECIFIED :
          {
            if(deep)
              {
                string what("ComposedNode::checkDeploymentTree : ServiceNode with name \""); what+=(*iter)->getName();
                what+="\" is deployable but no component is specified on it.";
                throw Exception(what);
              }
          }
        }
    }
  return ret;
}

void ComposedNode::checkInMyDescendance ( Node *  nodeToTest ) const throw (Exception)

protected

Check if a node is in the descendance of this node.

Note

Check that 'nodeToTest' is in descendance of 'this' OR equal to 'this'

Exceptions

Exception

: If 'nodeToTest' is NOT in descendance of 'this' AND not equal to 'this'

Parameters

nodeToTest

: the node to check

Definition at line 1013 of file ComposedNode.cxx.

References YACS::ENGINE::Node::_father.

{
  const char whatC[]=" is not the descendance of node ";
  if(nodeToTest==0)
    {
      string what("node "); what+= nodeToTest->getName(); what+=" ";
      what+=whatC; what+=_name;
      throw Exception(what);
    }
  if((ComposedNode *)nodeToTest==this)
    return;
  ComposedNode *iter=nodeToTest->_father;
  while(iter!=0 && iter!=this)
    iter=iter->_father;
  if(iter==0)
    {
      string what("node "); what+= nodeToTest->getName(); what+=" ";
      what+=whatC; what+=_name;
      throw Exception(what);
    }
}

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

protectedvirtual

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Switch, YACS::ENGINE::OptimizerLoop, YACS::ENGINE::DynParaLoop, and YACS::ENGINE::WhileLoop.

Definition at line 1443 of file ComposedNode.cxx.

Referenced by YACS::ENGINE::DynParaLoop::checkLinkPossibility(), and edAddLink().

{
  if((dynamic_cast<DataFlowPort *>(start) || dynamic_cast<DataFlowPort *>(end))
     && (dynamic_cast<DataStreamPort *>(start) || dynamic_cast<DataStreamPort *>(end)))
    {//cross protocol required : deeper check needed
      bool isOK=false;
      list<ComposedNode *>::const_iterator iter;
      for(iter=pointsOfViewStart.begin();iter!=pointsOfViewStart.end() && !isOK;iter++)
        isOK=(*iter)->isRepeatedUnpredictablySeveralTimes();
      for(iter=pointsOfViewEnd.begin();iter!=pointsOfViewEnd.end() && !isOK;iter++)
        isOK=(*iter)->isRepeatedUnpredictablySeveralTimes();
      if(!isOK)
        throw Exception("ComposedNode::checkLinkPossibility : Request for cross protocol link impossible.");
    }
}

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

protected

call it only for 'starts' to 'end' links DEALED by 'this'.

Definition at line 713 of file ComposedNode.cxx.

References checkControlDependancy(), YACS::ENGINE::E_COLLAPSE_DS, and YACS::ENGINE::E_ONLY_BACKWARD_DEFINED.

{
  map < ComposedNode *, list<OutPort *>, SortHierarc > outputs;//forward link classical
  vector<OutPort *> outputsCross;//forward link cross
  map < ComposedNode *, list<OutPort *>, SortHierarc > outputsBw;//backward
  vector<OutPort *>::const_iterator iter1;
  //vector<DataPort *> history=((*iter1).second)[0]->calculateHistoryOfLinkWith(end);
  //DataPort *cross=DataPort::isCrossingType(history);
  for(iter1=starts.begin();iter1!=starts.end();iter1++)
    {
      ComposedNode *manager=getLowestCommonAncestor((*iter1)->getNode(),end->getNode());
      manager->checkControlDependancy((*iter1), end, false, outputs, outputsCross, outputsBw, info);
    }
  //Ok now let's regarding outputs all combinations : (outputs.size())*(outputs.size()-1)/2
  unsigned char isAlreadyFed=FREE_ST;
  //Dealing excusively with DS. Level is useless here because simultaneity is required for DS.
  if(outputsCross.size()>0)
    {
      isAlreadyFed=FED_DS_ST;
      if(outputsCross.size()>1)
        for(vector< OutPort *>::const_iterator iter1=outputsCross.begin();iter1!=(outputsCross.end()-2);iter1++)
          info.pushErrLink(*iter1,end,E_COLLAPSE_DS);
    }
  map < ComposedNode *, list<OutPort *>, SortHierarc >::iterator iter3=outputs.begin();
  for(;iter3!=outputs.end();iter3++)
    ((*iter3).first)->checkCFLinks((*iter3).second,end,isAlreadyFed,true,info);
  if(isAlreadyFed==FREE_ST)
    if(!end->edIsManuallyInitialized())
      info.pushErrLink(0,end,E_ONLY_BACKWARD_DEFINED);
  isAlreadyFed=FREE_ST;
  //
  map < ComposedNode *, list<OutPort *>, SortHierarc >::reverse_iterator iter5=outputsBw.rbegin();
  for(;iter5!=outputsBw.rend();iter5++)
    ((*iter5).first)->checkCFLinks((*iter5).second,end,isAlreadyFed,false,info);
}

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

protected

This method check that G1 <- G2 <- G3 <- G1 does not happened. Typically called by methods that set a hierarchy (Bloc::edAddChild, Loop::edSetNode, ...).

Definition at line 658 of file ComposedNode.cxx.

Referenced by YACS::ENGINE::DynParaLoop::checkConsistencyAndSetNode(), and YACS::ENGINE::Loop::edSetNode().

{
  ComposedNode *nodeC=dynamic_cast<ComposedNode *>(node);
  if(!nodeC)
    return ;
  list<ComposedNode *> ascendants=getAllAscendanceOf();
  if(find(ascendants.begin(),ascendants.end(),nodeC)!=ascendants.end())
    {
      const char what[]="ComposedNode::checkNoCrossHierachyWith : ComposedNode with name \"";
      string stream(what); stream+=node->getName(); stream+="\" is already in hierarchy ascendance of node with name \"";
      stream+=_name; stream+="\" ; So it can't be now in its descendance !";
      throw Exception(stream);
    }
}

virtual void YACS::ENGINE::ComposedNode::checkNoCyclePassingThrough ( Node *  node ) throw (Exception)

protectedpure virtual

Implemented in YACS::ENGINE::Loop, YACS::ENGINE::ForEachLoop, YACS::ENGINE::Switch, YACS::ENGINE::OptimizerLoop, and YACS::ENGINE::Bloc.

void ComposedNode::cleanNodes ( )

virtual

Clean the composed node in case of not clean exit.

This method should be called on a control-c or sigterm

Reimplemented from YACS::ENGINE::Node.

Definition at line 1614 of file ComposedNode.cxx.

References DEBTRACE, and edGetDirectDescendants().

Referenced by Handler().

{
  DEBTRACE("ComposedNode::cleanNodes");
  list<Node *> nodes=edGetDirectDescendants();
  for(list<Node *>::iterator iter=nodes.begin();iter!=nodes.end();iter++)
    (*iter)->cleanNodes();
}

void ComposedNode::connected

(

)

Definition at line 1487 of file ComposedNode.cxx.

{
}

void ComposedNode::destructCFComputations ( LinkInfo &  info ) const

protectedvirtual

destroy recursively all results of initial computations.

Reimplemented in YACS::ENGINE::Bloc.

Definition at line 683 of file ComposedNode.cxx.

References edGetDirectDescendants().

Referenced by YACS::ENGINE::Bloc::destructCFComputations().

{
  list<Node *> nodes=edGetDirectDescendants();
  for(list<Node *>::iterator iter=nodes.begin();iter!=nodes.end();iter++)
    if(dynamic_cast<ComposedNode *>(*iter))
      ((ComposedNode *)(*iter))->destructCFComputations(info);
}

bool ComposedNode::edAddCFLink	(	Node *	nodeS,
		Node *	nodeE
	)		throw (Exception)

Add a controlflow link between two nodes.

Add a controlflow link between two nodes by calling edAddLink on their control ports

Definition at line 417 of file ComposedNode.cxx.

Referenced by YACS::ENGINE::Bloc::Bloc(), YACS::HMI::CommandAddControlLink::localExecute(), and YACS::HMI::SubjectNode::restoreLinks().

{
  return edAddLink(nodeS->getOutGate(),nodeE->getInGate());
}

bool ComposedNode::edAddChild ( Node *  DISOWNnode ) throw (Exception)

virtual

Reimplemented in YACS::ENGINE::Loop, YACS::ENGINE::Switch, YACS::ENGINE::DynParaLoop, and YACS::ENGINE::Bloc.

Definition at line 527 of file ComposedNode.cxx.

Referenced by YACS::HMI::CommandReparentNode::localExecute(), YACS::HMI::CommandPutInComposedNode::localExecute(), YACS::HMI::CommandCopyNode::localExecute(), YACS::HMI::CommandReparentNode::localReverse(), YACS::HMI::CommandPutInComposedNode::localReverse(), and YACS::HMI::SubjectNode::registerUndoDestroy().

{
  return false; // --- reimplemented in derived classes
}

bool ComposedNode::edAddDFLink ( OutPort *  start, InPort *  end  ) throw (Exception)

virtual

Connect an OutPort to an InPort and add the necessary control link.

Connect the ports with a data link (edAddLink) and add a control flow link between the children of the lowest common ancestor node.

Parameters

start	: the OutPort to connect
end	: the InPort to connect

Returns

true if a new link has been created, false otherwise.

Reimplemented in YACS::ENGINE::Loop, and YACS::ENGINE::DynParaLoop.

Definition at line 329 of file ComposedNode.cxx.

References DEBTRACE, YACS::ENGINE::Node::getFather(), YACS::ENGINE::Node::getName(), and PMMLBasicsTestLauncher::ret.

Referenced by YACS::ENGINE::ElementaryNode::getReadyTasks(), YACS::HMI::CommandAddLink::localExecute(), and YACS::HMI::SubjectNode::restoreLinks().

{
  Node* n1=start->getNode();
  Node* n2=end->getNode();
  DEBTRACE( n1->getName() << ":" << n2->getName())
  ComposedNode* father=getLowestCommonAncestor(n1,n2);
  DEBTRACE( "ComposedNode::edAddDFLink: this="<<this->getName() 
            << " father=" << father->getName() )
  DEBTRACE( "ComposedNode::edAddDFLink: OutPort=" << start->getName()
            << " InPort=" << end->getName() )
  if (father != this)
    {
      bool ret = father->edAddDFLink(start,end); // special treatement for loop
      return ret;
    }
  if(n2 == father)
    throw Exception("Back link authorized only in special context (loop for example)");

  bool ret= edAddLink(start,end);
  if(n1 != father)
    {
      //add a control link only if nodes are not in the same descendance
      //if n1 == father (n2 is after n1) : the control link is not needed 
      //if n2 == father (n1 is after n2) : it's a back link authorized only in loop context
      while(n1->getFather() != father)
        n1=n1->getFather();
      while(n2->getFather() != father)
        n2=n2->getFather();
      try
        {
          edAddCFLink(n1,n2);
        }
      catch (Exception& ex)
        {
          // --- remove DF link already created in case of cycle dtection
          DEBTRACE("Cycle detected, remove CF link");
          if(start->isAlreadyLinkedWith(end))
            edRemoveLink(start, end);
          throw ex;          
        }
    }
  return ret;
}

bool ComposedNode::edAddLink	(	OutPort *	start,
		InPort *	end
	)		throw (Exception)

Add a dataflow link between two data ports.

Precondition : 'start' AND 'end' are in/outputPort contained in a node in descendance of 'this'.

Exceptions

Exception

: if incompatibility between input and output (type), or 'start'/'end' is/are NOT in/outputPort contained in a node in descendance of 'this', or a multiple link to an input not supporting it.

Returns

true if a new link has been created, false otherwise.

Definition at line 273 of file ComposedNode.cxx.

References YACS::ENGINE::Node::_father, buildDelegateOf(), checkLinkPossibility(), DEBTRACE, YACS::ENGINE::Node::getAllAscendanceOf(), and PMMLBasicsTestLauncher::ret.

Referenced by YACS::ENGINE::Bloc::Bloc(), YACS::ENGINE::Loop::buildDelegateOf(), YACS::ENGINE::DynParaLoop::cloneAndPlaceNodesCoherently(), YACS::ENGINE::DynParaLoop::DynParaLoop(), edAddLink(), YACS::ENGINE::ForLoop::ForLoop(), YACS::ENGINE::ElementaryNode::getReadyTasks(), YACS::HMI::CommandAddLink::localExecute(), YACS::ENGINE::OptimizerLoop::OptimizerLoop(), YACS::HMI::SubjectNode::restoreLinks(), and YACS::ENGINE::WhileLoop::WhileLoop().

{
  DEBTRACE("ComposedNode::edAddLink");
  set<OutPort *> represented;

  start->getAllRepresented(represented);
  if(represented.size()!=1)
    {
      bool ret=false;
      for(set<OutPort *>::iterator iter=represented.begin();iter!=represented.end();iter++)
        ret|=edAddLink(*iter,end);
      return ret;
    }
  if(start->isAlreadyLinkedWith(end))
    return false;
  ComposedNode* lwstCmnAnctr=getLowestCommonAncestor(start->getNode(),end->getNode());
  list<ComposedNode *> allAscendanceOfNodeStart=start->getNode()->getAllAscendanceOf(lwstCmnAnctr);
  list<ComposedNode *> allAscendanceOfNodeEnd=end->getNode()->getAllAscendanceOf(lwstCmnAnctr);
  checkInMyDescendance(lwstCmnAnctr);
  lwstCmnAnctr->checkLinkPossibility(start,allAscendanceOfNodeStart,end,allAscendanceOfNodeEnd);
  ComposedNode *iterS;
  if(dynamic_cast<ComposedNode *>(start->getNode()))
    iterS=(ComposedNode *)start->getNode();
  else
    iterS=start->getNode()->_father;
  pair<OutPort *, OutPort *> pO(start,start);
  while(iterS!=lwstCmnAnctr)
    {
      iterS->buildDelegateOf(pO, end, allAscendanceOfNodeEnd);
      iterS=iterS->_father;
    }
  if(dynamic_cast<ComposedNode *>(end->getNode()))
    iterS=(ComposedNode *)end->getNode();
  else
    iterS=end->getNode()->_father;

  InPort *currentPortI=end;
  while(iterS!=lwstCmnAnctr)
    {
      iterS->buildDelegateOf(currentPortI, start, allAscendanceOfNodeStart);
      iterS=iterS->_father;
    }
  bool ret=(pO.first)->addInPort(currentPortI);
  end->edNotifyReferencedBy(pO.second);
  return ret;
}

bool ComposedNode::edAddLink	(	OutGate *	start,
		InGate *	end
	)		throw (Exception)

Add a controlflow link between two control ports.

Note

Precondition : 'start' AND 'end' are in/outGate contained in a node in DIRECT descendance of 'this'.

Exceptions

Exception

: If a cycle has been detected, or incompatibility between input and output, or 'start'/'end' is/are NOT in/outputPort contained in a node in descendance of 'this', or a mutilple link to an input not supporting it.

Returns

true if a new link has been created, false otherwise.

Definition at line 383 of file ComposedNode.cxx.

References DEBTRACE, edAddLink(), and PMMLBasicsTestLauncher::ret.

{
  Node* n1=start->getNode();
  Node* n2=end->getNode();
  if(n1==n2)
    throw Exception("ComposedNode::edAddLink: can not add a control link to a node with itself",1);
  ComposedNode* father=checkHavingCommonFather(start->getNode(),end->getNode());
  if(father==0)
    throw Exception("ComposedNode::edAddLink: Trying to add CF link on orphan nodes.");
  if(father!=this)
    {
      checkInMyDescendance(father);
      return father->edAddLink(start,end);
    }
  bool ret=start->edAddInGate(end);
  if(ret)
    try
      {
        checkNoCyclePassingThrough(end->getNode());
      }
    catch (Exception& ex)
      {
        // --- remove  created CF link in case of cycle detection
        DEBTRACE("Cycle detected, remove CF link");
        edRemoveCFLink(start->getNode(), end->getNode());
        throw ex;
      }
  return ret;
}

void ComposedNode::edDisconnectAllLinksWithMe ( )

protectedvirtual

Called typically by ComposedNode to correctly update DF/CF/DS links

Reimplemented from YACS::ENGINE::Node.

Definition at line 899 of file ComposedNode.cxx.

References DEBTRACE, YACS::ENGINE::Node::edDisconnectAllLinksWithMe(), getSetOfLinksComingInCurrentScope(), and getSetOfLinksLeavingCurrentScope().

{
  //CF
  DEBTRACE("-");
  Node::edDisconnectAllLinksWithMe();
  //Leaving part
  DEBTRACE("--");
  vector< pair<OutPort *, InPort *> > linksToDestroy=getSetOfLinksLeavingCurrentScope();
  vector< pair<OutPort *, InPort *> >::iterator iter;
  for(iter=linksToDestroy.begin();iter!=linksToDestroy.end();iter++)
    {
      DEBTRACE("---");
      (*iter).first->removeInPort((*iter).second,true);
    }
  //Arriving part
  vector< pair<InPort *, OutPort *> > linksToDestroy2=getSetOfLinksComingInCurrentScope();
  vector< pair<InPort *, OutPort *> >::iterator iter2;
  for(iter2=linksToDestroy2.begin();iter2!=linksToDestroy2.end();iter2++)
    {
      DEBTRACE("----");
      (*iter2).second->removeInPort((*iter2).first,true);
    }
}

virtual std::list<Node *> YACS::ENGINE::ComposedNode::edGetDirectDescendants ( ) const

pure virtual

Implemented in YACS::ENGINE::Loop, YACS::ENGINE::Switch, YACS::ENGINE::DynParaLoop, and YACS::ENGINE::Bloc.

Referenced by YACS::HMI::GuiEditor::_createNode(), accept(), YACS::HMI::SceneBlocItem::arrangeCanvasNodes(), YACS::HMI::SceneComposedNodeItem::arrangeNodes(), cleanNodes(), destructCFComputations(), edUpdateState(), YACS::ENGINE::VisitorSaveSchema::getAllNodes(), getAllRecursiveConstituents(), getAllRecursiveNodes(), YACS::HMI::SchemaComposedNodeItem::getDirectDescendants(), getErrorReport(), YACS::HMI::SceneBlocItem::getNodesInfo(), getNumberOfInputPorts(), getNumberOfOutputPorts(), getProgressWeight(), getRecursiveConstituents(), getSetOfInputDataStreamPort(), getSetOfInputPort(), getSetOfOutputDataStreamPort(), getSetOfOutputPort(), YACS::HMI::SubjectComposedNode::loadChildren(), YACS::HMI::SubjectComposedNode::loadLinks(), performCFComputations(), YACS::HMI::GuiEditor::PutSubjectInBloc(), removeRecursivelyRedundantCL(), resetState(), shutdown(), YACS::ENGINE::VisitorSaveSchema::writeControls(), YACS::ENGINE::VisitorSaveSchema::writeSimpleDataLinks(), and YACS::ENGINE::VisitorSaveSchema::writeSimpleStreamLinks().

void ComposedNode::edRemoveCFLink	(	Node *	nodeS,
		Node *	nodeE
	)		throw (Exception)

Remove a controlflow link.

Definition at line 423 of file ComposedNode.cxx.

Referenced by YACS::ENGINE::Bloc::removeRecursivelyRedundantCL(), and YACS::HMI::SubjectControlLink::~SubjectControlLink().

{
  edRemoveLink(nodeS->getOutGate(),nodeE->getInGate());
}

void ComposedNode::edRemoveChild ( Node *  node ) throw (Exception)

virtual

Remove a child node.

Reimplemented in YACS::ENGINE::Loop, YACS::ENGINE::Switch, YACS::ENGINE::DynParaLoop, and YACS::ENGINE::Bloc.

Definition at line 533 of file ComposedNode.cxx.

Referenced by YACS::ENGINE::DynParaLoop::checkConsistencyAndSetNode(), YACS::ENGINE::Switch::edReleaseCase(), YACS::ENGINE::Bloc::edRemoveChild(), YACS::ENGINE::DynParaLoop::edRemoveChild(), YACS::ENGINE::Loop::edRemoveChild(), YACS::ENGINE::Loop::edRemoveNode(), YACS::ENGINE::Loop::edSetNode(), YACS::HMI::CommandReparentNode::localExecute(), YACS::HMI::CommandPutInComposedNode::localExecute(), YACS::HMI::CommandReparentNode::localReverse(), YACS::HMI::CommandPutInComposedNode::localReverse(), YACS::ENGINE::DynParaLoop::removeNode(), and YACS::HMI::SubjectNode::~SubjectNode().

{
  if(!node)
    return;
  if (node->_father!=this)
    {
      string what("node "); what+= node->getName() ; what+=" is not a child of node "; what += getName();
      throw Exception(what);
    }
  node->edDisconnectAllLinksWithMe();
  node->_father = 0;
  //set _modified flag so edUpdateState() can refresh state
  modified();
}

void ComposedNode::edRemoveLink	(	OutPort *	start,
		InPort *	end
	)		throw (Exception)

Remove a dataflow link.

Precondition : 'start' AND 'end' are in/outputPort contained in a node in descendance of 'this'.

Exceptions

Exception

: If the specified link does not exist. The content of Exception is different in accordance with the link from 'start' to 'end' implies DF/DS gateway.

Definition at line 437 of file ComposedNode.cxx.

References YACS::ENGINE::Node::_father, getDelegateOf(), getName(), and releaseDelegateOf().

Referenced by YACS::ENGINE::InPort::edRemoveAllLinksLinkedWithMe(), and YACS::HMI::SubjectLink::localclean().

{
  if(!start->isAlreadyLinkedWith(end))
    throw Exception("ComposedNode::edRemoveLink : unexisting link");
  ComposedNode* lwstCmnAnctr=getLowestCommonAncestor(start->getNode(),end->getNode());
  checkInMyDescendance(lwstCmnAnctr);
  list<ComposedNode *> allAscendanceOfNodeStart=start->getNode()->getAllAscendanceOf(lwstCmnAnctr);
  list<ComposedNode *> allAscendanceOfNodeEnd=end->getNode()->getAllAscendanceOf(lwstCmnAnctr);

  // --- Part of test if the link from 'start' to 'end' really exist particulary all eventually intermediate ports created

  ComposedNode *iterS=start->getNode()->_father;
  pair<OutPort *,OutPort *> currentPortO(start,start);
  vector<pair< ComposedNode * , pair < OutPort* , OutPort *> > > needsToDestroyO;

  Node *nodeOTemp=start->getNode();
  if(*nodeOTemp<*lwstCmnAnctr)
    {
      iterS=nodeOTemp->_father;
      while(iterS!=lwstCmnAnctr)
        {
          if (!iterS)
            {
              stringstream what;
              what << "ComposedNode::edRemoveLink: "
                   << start->getNode()->getName() << "." <<start->getName() << "->"
                   << end->getNode()->getName() << "." << end->getName();
              throw Exception(what.str());
            }
          OutPort *tmp=currentPortO.first;
          iterS->getDelegateOf(currentPortO, end, allAscendanceOfNodeEnd);
          needsToDestroyO.push_back(pair< ComposedNode * , pair < OutPort* , OutPort *> >(iterS,pair<OutPort* , OutPort *> (tmp,currentPortO.first)));
          iterS=iterS->_father;
        }
    }
  Node *nodeTemp=end->getNode();
  InPort * currentPortI=end;
  if(*nodeTemp<*lwstCmnAnctr)
    {
      iterS=nodeTemp->_father;    
      while(iterS!=lwstCmnAnctr)
        {
          if (!iterS)
            {
              stringstream what;
              what << "ComposedNode::edRemoveLink: "
                   << start->getNode()->getName() << "." <<start->getName() << "->"
                   << end->getNode()->getName() << "." << end->getName();
              throw Exception(what.str());
            }
          iterS->getDelegateOf(currentPortI, start, allAscendanceOfNodeStart);
          iterS=iterS->_father;
        }
    }
  // --- End of test for evt intermediate ports created
  
  (currentPortO.first)->removeInPort(currentPortI,false);
  set<OutPort *> repr;
  (currentPortO.second)->getAllRepresented(repr);
  if(repr.size()==1)
    end->edNotifyDereferencedBy(currentPortO.second);

  // --- Performing deletion of intermediate ports
  
  iterS=start->getNode()->_father;
  vector<pair< ComposedNode * , pair < OutPort* , OutPort *> > >::reverse_iterator iter;
  for(iter=needsToDestroyO.rbegin();iter!=needsToDestroyO.rend();iter++)
    (*iter).first->releaseDelegateOf(((*iter).second).first, ((*iter).second).second, end,allAscendanceOfNodeEnd);
  nodeTemp=end->getNode();
  if(*nodeTemp<*lwstCmnAnctr)
    {
      iterS=end->getNode()->_father;
      currentPortI=end;
      while(iterS!=lwstCmnAnctr)
        {
          iterS->releaseDelegateOf(currentPortI, start, allAscendanceOfNodeStart);
          iterS=iterS->_father;
        }
    }
}

void ComposedNode::edRemoveLink	(	OutGate *	start,
		InGate *	end
	)		throw (Exception)

Remove a controlflow link.

Definition at line 519 of file ComposedNode.cxx.

{
  ComposedNode* father=checkHavingCommonFather(start->getNode(),end->getNode());
  if(father!=this)
    throw Exception("edRemoveLink : nodes not in direct descendance of this");
  start->edRemoveInGate(end);
}

void ComposedNode::edUpdateState ( )

virtual

update the status of the node

Only useful when editing a schema Do nothing in base Node : to implement in derived classes

Reimplemented from YACS::ENGINE::Node.

Definition at line 1517 of file ComposedNode.cxx.

References YACS::ENGINE::Node::_errorDetails, YACS::ENGINE::Node::_modified, YACS::ENGINE::Node::_state, checkBasicConsistency(), DEBTRACE, edGetDirectDescendants(), YACS::INVALID, YACS::READY, YACS::ENGINE::Node::setState(), CORBAEngineTest::state, and YACS::Exception::what().

Referenced by YACS::ENGINE::Proc::modified(), and YACS::ENGINE::Proc::setEdition().

{
  DEBTRACE("ComposedNode::edUpdateState(): " << _state << " " << _modified);
  YACS::StatesForNode state=YACS::READY;

  try
    {
      checkBasicConsistency();
      _errorDetails="";
    }
  catch(Exception& e)
    {
      state=YACS::INVALID;
      _errorDetails=e.what();
    }
  DEBTRACE("ComposedNode::edUpdateState: " << _errorDetails);

  //update children if needed
  list<Node *> constituents=edGetDirectDescendants();
  for(list<Node *>::iterator iter=constituents.begin(); iter!=constituents.end(); iter++)
    {
      if(!(*iter)->isValid())
        state=YACS::INVALID;
    }
  if(state != _state)
    setState(state);
  _modified=0;
}

std::set< InPort * > ComposedNode::getAllInPortsComingFromOutsideOfCurrentScope ( ) const

virtual

List all input ports that are linked to out of scope ports.

List all input ports of 'this' so that, for each it exists at least 1 link coming from outside to it.

Implements YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::Switch.

Definition at line 881 of file ComposedNode.cxx.

References YACS::ENGINE::Node::getSetOfInPort(), isInMyDescendance(), and PMMLBasicsTestLauncher::ret.

Referenced by YACS::ENGINE::Switch::getAllInPortsComingFromOutsideOfCurrentScope(), getSetOfLinksComingInCurrentScope(), and YACS::ENGINE::DynParaLoop::prepareInputsFromOutOfScope().

{
  set<InPort *> ret;
  list<InPort *> temp=getSetOfInPort();
  for(list<InPort *>::iterator iter2=temp.begin();iter2!=temp.end();iter2++)
    {
      set<OutPort *> temp2=(*iter2)->edSetOutPort();
      for(set<OutPort *>::iterator iter3=temp2.begin();iter3!=temp2.end();iter3++)
        if(*iter3)
          if(!isInMyDescendance((*iter3)->getNode()))
            {
              ret.insert(*iter2);
              break;
            }
    }
  return ret;
}

std::set< OutPort * > ComposedNode::getAllOutPortsLeavingCurrentScope ( ) const

virtual

List all output ports of children nodes that are linked to out of scope input ports.

Note

List all output ports of nodes sons of 'this' that are linked to input ports of nodes not in descendance of 'this'. This method contrary to getAllInPortsComingFromOutsideOfCurrentScope is NOT virtual because for the moment all daughter classes have no more hidden YACS::ENGINE::OutPort.

Implements YACS::ENGINE::Node.

Definition at line 857 of file ComposedNode.cxx.

References YACS::ENGINE::Node::getSetOfOutPort(), isInMyDescendance(), and PMMLBasicsTestLauncher::ret.

Referenced by YACS::ENGINE::ForLoop::exUpdateState(), YACS::ENGINE::WhileLoop::exUpdateState(), YACS::ENGINE::OptimizerLoop::exUpdateState(), YACS::ENGINE::Switch::exUpdateState(), YACS::ENGINE::ForEachLoop::exUpdateState(), getSetOfLinksLeavingCurrentScope(), and YACS::ENGINE::OptimizerLoop::initInterceptors().

{
  set<OutPort *> ret;
  list<OutPort *> temp=getSetOfOutPort();
  for(list<OutPort *>::iterator iter2=temp.begin();iter2!=temp.end();iter2++)
    {
      set<InPort *> temp2=(*iter2)->edSetInPort();
      for(set<InPort *>::iterator iter3=temp2.begin();iter3!=temp2.end();iter3++)
        if(!isInMyDescendance((*iter3)->getNode()))
          {
            ret.insert(*iter2);
            break;
          }
    }
  return ret;
}

list< Node * > ComposedNode::getAllRecursiveConstituents ( )

virtual

Idem getAllRecursiveNodes, but this node is NOT included.

Definition at line 1130 of file ComposedNode.cxx.

References edGetDirectDescendants(), and PMMLBasicsTestLauncher::ret.

Referenced by YACS::ENGINE::OptimizerLoop::finalize(), YACS::ENGINE::DynParaLoop::forwardExecStateToOriginalBody(), YACS::ENGINE::Proc::getIds(), YACS::ENGINE::Proc::getNumIds(), and YACS::ENGINE::ForEachLoop::updateStateForWorkNodeOnFinishedEventFrom().

{
  list<Node *> ret;
  list<Node *> setOfNode=edGetDirectDescendants();
  for(list<Node *>::const_iterator iter=setOfNode.begin();iter!=setOfNode.end();iter++)
    {
      if ( dynamic_cast<ComposedNode*> (*iter) )
        {
          list<Node *> myCurrentSet=((ComposedNode*)(*iter))->getAllRecursiveConstituents();
          ret.insert(ret.end(),myCurrentSet.begin(),myCurrentSet.end());
          ret.push_back(*iter);
        }
      else
        {
          list<ElementaryNode *> myCurrentSet=(*iter)->getRecursiveConstituents();
          ret.insert(ret.end(),myCurrentSet.begin(),myCurrentSet.end());
        }
    }
  return ret;
}

list< Node * > ComposedNode::getAllRecursiveNodes

(

)

Get all children nodes elementary and composed including this node.

Definition at line 1152 of file ComposedNode.cxx.

References edGetDirectDescendants(), and PMMLBasicsTestLauncher::ret.

Referenced by YACS::HMI::SubjectNode::registerUndoDestroy().

{
  list<Node *> ret;
  list<Node *> setOfNode=edGetDirectDescendants();
  for(list<Node *>::iterator iter=setOfNode.begin();iter!=setOfNode.end();iter++)
    {
      if ( dynamic_cast<ElementaryNode*> (*iter) )
        {
          list<ElementaryNode *> myCurrentSet=(*iter)->getRecursiveConstituents();
          ret.insert(ret.end(),myCurrentSet.begin(),myCurrentSet.end());
        }
      else
        {
          list<Node *> myCurrentSet=((ComposedNode*)(*iter))->getAllRecursiveNodes();
          ret.insert(ret.end(),myCurrentSet.begin(),myCurrentSet.end());
        }
    }
  ret.push_back(this);
  return ret;
}

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

virtual

Implements YACS::ENGINE::Node.

Definition at line 995 of file ComposedNode.cxx.

References YACS::ENGINE::Node::getChildByName(), and splitNamesBySep().

Referenced by YACS::ENGINE::Bloc::Bloc(), YACS::ENGINE::DynParaLoop::cloneAndPlaceNodesCoherently(), DefineCustomObservers(), YACS::ENGINE::DynParaLoop::forwardExecStateToOriginalBody(), YACS::ENGINE::DynParaLoop::getDynInputPortByAbsName(), YACS::ENGINE::ForEachLoop::getDynOutPortByAbsName(), YACS::HMI::SceneBlocItem::getNodesInfo(), YACS::HMI::YACSGuiLoader::getPrsData(), YACS::HMI::CommandAddNodeFromCatalog::localExecute(), YACS::HMI::CommandReparentNode::localExecute(), YACS::HMI::CommandPutInComposedNode::localExecute(), YACS::HMI::CommandCopyNode::localExecute(), YACS::HMI::CommandRenameNode::localExecute(), YACS::HMI::CommandRenameInDataPort::localExecute(), YACS::HMI::CommandRenameOutDataPort::localExecute(), YACS::HMI::CommandAddInputPortFromCatalog::localExecute(), YACS::HMI::CommandAddOutputPortFromCatalog::localExecute(), YACS::HMI::CommandAddIDSPortFromCatalog::localExecute(), YACS::HMI::CommandAddODSPortFromCatalog::localExecute(), YACS::HMI::CommandOrderInputPorts::localExecute(), YACS::HMI::CommandOrderOutputPorts::localExecute(), YACS::HMI::CommandSetInPortValue::localExecute(), YACS::HMI::CommandSetOutPortValue::localExecute(), YACS::HMI::CommandSetSwitchSelect::localExecute(), YACS::HMI::CommandSetSwitchCase::localExecute(), YACS::HMI::CommandSetForLoopSteps::localExecute(), YACS::HMI::CommandSetWhileCondition::localExecute(), YACS::HMI::CommandSetForEachBranch::localExecute(), YACS::HMI::CommandSetAlgo::localExecute(), YACS::HMI::CommandAddLink::localExecute(), YACS::HMI::CommandAddControlLink::localExecute(), YACS::HMI::CommandSetNodeProperties::localExecute(), YACS::HMI::CommandSetDSPortProperties::localExecute(), YACS::HMI::CommandSetLinkProperties::localExecute(), YACS::HMI::CommandSetFuncNodeFunctionName::localExecute(), YACS::HMI::CommandSetInlineNodeScript::localExecute(), YACS::HMI::CommandSetExecutionMode::localExecute(), YACS::HMI::CommandSetContainer::localExecute(), YACS::HMI::CommandAssociateServiceToComponent::localExecute(), YACS::HMI::CommandAddComponentFromCatalog::localExecute(), YACS::HMI::CommandDestroy::localExecute(), YACS::HMI::CommandAddNodeFromCatalog::localReverse(), YACS::HMI::CommandReparentNode::localReverse(), YACS::HMI::CommandPutInComposedNode::localReverse(), YACS::HMI::CommandCopyNode::localReverse(), YACS::HMI::CommandRenameNode::localReverse(), YACS::HMI::CommandRenameInDataPort::localReverse(), YACS::HMI::CommandRenameOutDataPort::localReverse(), YACS::HMI::CommandAddInputPortFromCatalog::localReverse(), YACS::HMI::CommandAddOutputPortFromCatalog::localReverse(), YACS::HMI::CommandAddIDSPortFromCatalog::localReverse(), YACS::HMI::CommandAddODSPortFromCatalog::localReverse(), YACS::HMI::CommandOrderInputPorts::localReverse(), YACS::HMI::CommandOrderOutputPorts::localReverse(), YACS::HMI::CommandSetInPortValue::localReverse(), YACS::HMI::CommandSetOutPortValue::localReverse(), YACS::HMI::CommandSetSwitchSelect::localReverse(), YACS::HMI::CommandSetSwitchCase::localReverse(), YACS::HMI::CommandSetForLoopSteps::localReverse(), YACS::HMI::CommandSetWhileCondition::localReverse(), YACS::HMI::CommandSetForEachBranch::localReverse(), YACS::HMI::CommandSetAlgo::localReverse(), YACS::HMI::CommandAddLink::localReverse(), YACS::HMI::CommandAddControlLink::localReverse(), YACS::HMI::CommandSetNodeProperties::localReverse(), YACS::HMI::CommandSetDSPortProperties::localReverse(), YACS::HMI::CommandSetLinkProperties::localReverse(), YACS::HMI::CommandSetFuncNodeFunctionName::localReverse(), YACS::HMI::CommandSetInlineNodeScript::localReverse(), YACS::HMI::CommandSetExecutionMode::localReverse(), YACS::HMI::CommandSetContainer::localReverse(), YACS::HMI::CommandAssociateServiceToComponent::localReverse(), YACS::HMI::CommandAddComponentFromCatalog::localReverse(), performDuplicationOfPlacement(), performShallowDuplicationOfPlacement(), YACS::HMI::GuiObserver_i::setConversion(), and YACS::ENGINE::Node::setName().

{
  string potentiallyDirectSonName, remainsPath;
  bool forwardNeeded=ComposedNode::splitNamesBySep(name, SEP_CHAR_BTW_LEVEL,
                                                   potentiallyDirectSonName,remainsPath,false);
  Node *child=getChildByShortName(potentiallyDirectSonName);
  if(!forwardNeeded)
    return child;
  else
    return child->getChildByName(remainsPath);
}

virtual Node* YACS::ENGINE::ComposedNode::getChildByShortName ( const std::string &  name ) const throw (Exception)

protectedpure virtual

Implemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Loop, YACS::ENGINE::Switch, YACS::ENGINE::DynParaLoop, and YACS::ENGINE::Bloc.

string ComposedNode::getChildName

(

const Node *

node

)

const throw (Exception)

Definition at line 964 of file ComposedNode.cxx.

References YACS::ENGINE::Node::_father, and YACS::ENGINE::Node::getQualifiedName().

Referenced by YACS::HMI::SubjectElementaryNode::addIDSPort(), YACS::HMI::SubjectElementaryNode::addInputPort(), YACS::HMI::SubjectElementaryNode::addODSPort(), YACS::HMI::SubjectElementaryNode::addOutputPort(), YACS::HMI::SceneBlocItem::arrangeCanvasNodes(), YACS::HMI::SubjectServiceNode::associateToComponent(), YACS::ENGINE::Bloc::Bloc(), YACS::HMI::SubjectNode::copy(), YACS::HMI::SubjectComposedNode::createNode(), YACS::HMI::Subject::destroy(), YACS::HMI::EditionNode::EditionNode(), YACS::ENGINE::DynParaLoop::forwardExecStateToOriginalBody(), YACS::ENGINE::Node::getDPLScopeInfo(), YACS::ENGINE::Node::getId(), YACS::ENGINE::Proc::getIds(), YACS::ENGINE::LinkInfo::getInfoRepr(), YACS::HMI::SceneBlocItem::getNodesInfo(), getTaskName(), YACS::HMI::CommandReparentNode::localExecute(), YACS::HMI::CommandPutInComposedNode::localExecute(), YACS::HMI::CommandRenameNode::localExecute(), YACS::HMI::CommandSetSwitchCase::localExecute(), YACS::HMI::CommandPutInComposedNode::localReverse(), YACS::HMI::SubjectElementaryNode::OrderDataPorts(), performDuplicationOfPlacement(), performShallowDuplicationOfPlacement(), YACS::HMI::SubjectNode::putInComposedNode(), YACS::HMI::SubjectDataPort::registerUndoDestroy(), YACS::HMI::SubjectInputDataStreamPort::registerUndoDestroy(), YACS::HMI::SubjectOutputDataStreamPort::registerUndoDestroy(), YACS::HMI::SubjectNode::registerUndoDestroy(), YACS::HMI::SubjectLink::registerUndoDestroy(), YACS::HMI::SubjectControlLink::registerUndoDestroy(), YACS::HMI::SubjectNode::reparent(), YACS::HMI::SubjectOptimizerLoop::setAlgorithm(), YACS::HMI::SubjectSwitch::setCase(), YACS::HMI::SubjectServiceNode::setComponentFromCatalog(), YACS::HMI::SubjectWhileLoop::setCondition(), YACS::HMI::SubjectInlineNode::setContainer(), YACS::HMI::SubjectInlineNode::setExecutionMode(), YACS::HMI::SubjectPyFuncNode::setFunctionName(), YACS::HMI::GuiExecutor::setInPortValue(), YACS::HMI::SubjectDataPort::setName(), YACS::HMI::SubjectNode::setName(), YACS::HMI::SubjectDynParaLoop::setNbBranches(), YACS::HMI::SubjectForLoop::setNbSteps(), YACS::HMI::SubjectInputDataStreamPort::setProperties(), YACS::HMI::SubjectOutputDataStreamPort::setProperties(), YACS::HMI::SubjectNode::setProperties(), YACS::HMI::SubjectLink::setProperties(), YACS::HMI::SubjectInlineNode::setScript(), YACS::HMI::SubjectSwitch::setSelect(), YACS::HMI::SubjectInputPort::setValue(), YACS::HMI::SubjectOutputPort::setValue(), YACS::HMI::SubjectControlLink::SubjectControlLink(), YACS::HMI::SubjectLink::SubjectLink(), YACS::HMI::SchemaNodeItem::toggleState(), YACS::HMI::SubjectDataPort::tryCreateLink(), YACS::HMI::SchemaComponentItem::update(), YACS::HMI::EditionNode::update(), YACS::ENGINE::VisitorSaveState::visitBloc(), YACS::ENGINE::VisitorSaveSchema::visitBloc(), YACS::ENGINE::VisitorSaveSchema::visitDynParaLoop(), YACS::ENGINE::VisitorSaveState::visitElementaryNode(), YACS::ENGINE::VisitorSaveSchema::visitElementaryNode(), YACS::ENGINE::VisitorSalomeSaveState::visitForEachLoop(), YACS::ENGINE::VisitorSaveState::visitForEachLoop(), YACS::ENGINE::VisitorSaveSchema::visitForEachLoop(), YACS::ENGINE::VisitorSaveState::visitForLoop(), YACS::ENGINE::VisitorSaveSchema::visitForLoop(), YACS::ENGINE::VisitorSaveSchema::visitInlineFuncNode(), YACS::ENGINE::VisitorSaveSchema::visitInlineNode(), YACS::ENGINE::VisitorSaveState::visitLoop(), YACS::ENGINE::VisitorSaveSchema::visitLoop(), YACS::ENGINE::VisitorSaveState::visitOptimizerLoop(), YACS::ENGINE::VisitorSaveSchema::visitOptimizerLoop(), YACS::ENGINE::VisitorSaveSalomeSchema::visitOutNode(), YACS::ENGINE::VisitorSaveSchema::visitOutNode(), YACS::ENGINE::VisitorSaveSalomeSchema::visitPresetNode(), YACS::ENGINE::VisitorSaveSchema::visitPresetNode(), YACS::ENGINE::VisitorSaveState::visitProc(), YACS::ENGINE::VisitorSaveSchema::visitServerNode(), YACS::ENGINE::VisitorSaveSchema::visitServiceInlineNode(), YACS::ENGINE::VisitorSaveSchema::visitServiceNode(), YACS::ENGINE::VisitorSaveSalomeSchema::visitStudyInNode(), YACS::ENGINE::VisitorSaveSchema::visitStudyInNode(), YACS::ENGINE::VisitorSaveSalomeSchema::visitStudyOutNode(), YACS::ENGINE::VisitorSaveSchema::visitStudyOutNode(), YACS::ENGINE::VisitorSaveState::visitSwitch(), YACS::ENGINE::VisitorSaveSchema::visitSwitch(), YACS::ENGINE::VisitorSaveState::visitWhileLoop(), YACS::ENGINE::VisitorSaveSchema::visitWhileLoop(), YACS::ENGINE::VisitorSaveSchema::writeControls(), YACS::ENGINE::VisitorSaveSchema::writeParametersNode(), YACS::HMI::VisitorSaveGuiSchema::writePresentation(), YACS::ENGINE::VisitorSaveSchema::writeSimpleDataLinks(), and YACS::ENGINE::VisitorSaveSchema::writeSimpleStreamLinks().

{
  string nodeName=node->getQualifiedName();    
  if (!isNodeAlreadyAggregated(node))
    {
      if (node->getName() == "thisIsAFakeNode")
        {
          string child = node->getName()+".thisIsAFakeNode";
          return child;
        }
      else
        {
          string what("node "); what+= node->getName() ; what+=" is not a child of node "; what += getName();
          throw Exception(what);
        }
    }
  
  const Node *father = node->_father;
  while (father != this)
    {
      nodeName = father->getQualifiedName() + SEP_CHAR_BTW_LEVEL + nodeName;
      father = father->_father;
    }
  return nodeName;
}

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

protectedvirtual

Reimplemented in YACS::ENGINE::Loop.

Definition at line 1468 of file ComposedNode.cxx.

Referenced by YACS::ENGINE::OutPort::calculateHistoryOfLinkWith(), and edRemoveLink().

{
}

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

protectedvirtual

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Loop, and YACS::ENGINE::Switch.

Definition at line 1472 of file ComposedNode.cxx.

{
}

DeploymentTree ComposedNode::getDeploymentTree ( ) const

virtual

Essentially for test. Use checkDeploymentTree instead to be sure that returned DeploymentTree is consistent.

Implements YACS::ENGINE::Scheduler.

Definition at line 176 of file ComposedNode.cxx.

References YACS::ENGINE::DeploymentTree::appendTask(), getRecursiveConstituents(), and PMMLBasicsTestLauncher::ret.

Referenced by performDuplicationOfPlacement(), performShallowDuplicationOfPlacement(), and YACS::ENGINE::Proc::updateContainersAndComponents().

{
  DeploymentTree ret;
  list< ElementaryNode * > tasks=getRecursiveConstituents();
  for(list< ElementaryNode * >::iterator iter=tasks.begin();iter!=tasks.end();iter++)
    ret.appendTask(*iter,(*iter)->getDynClonerIfExists(this));
  return ret;
}

std::string ComposedNode::getErrorReport ( )

virtual

returns a string that contains an error report if the node is in error

Reimplemented from YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::DynParaLoop.

Definition at line 1546 of file ComposedNode.cxx.

References YACS::ENGINE::Node::_errorDetails, YACS::ENGINE::Node::_state, DEBTRACE, edGetDirectDescendants(), YACS::ERROR, YACS::FAILED, YACS::ENGINE::Node::getEffectiveState(), getName(), and YACS::INVALID.

Referenced by main(), and YACS::HMI::EditionProc::synchronize().

{
  DEBTRACE("ComposedNode::getErrorReport: " << getName() << " " << _state);
  YACS::StatesForNode effectiveState=getEffectiveState();

  if(effectiveState != YACS::INVALID &&  effectiveState != YACS::ERROR && effectiveState != YACS::FAILED)
    return "";

  std::string report="<error node= " + getName();
  switch(effectiveState)
    {
    case YACS::INVALID:
      report=report+" state= INVALID";
      break;
    case YACS::ERROR:
      report=report+" state= ERROR";
      break;
    case YACS::FAILED:
      report=report+" state= FAILED";
      break;
    default:
      break;
    }
  report=report + ">\n" ;
  if(_errorDetails != "")
    report=report+_errorDetails+"\n";

  list<Node *> constituents=edGetDirectDescendants();
  for(list<Node *>::iterator iter=constituents.begin(); iter!=constituents.end(); iter++)
    {
      std::string rep=(*iter)->getErrorReport();
      if(rep != "")
        {
          report=report+rep+"\n";
        }
    }
  report=report+"</error>";
  return report;
}

string ComposedNode::getInPortName ( const InPort *  inPort ) const throw (Exception)

virtual

Get the input port name.

get the input port name used by the current node, recursively built with children names.

Implements YACS::ENGINE::Node.

Definition at line 1196 of file ComposedNode.cxx.

Referenced by YACS::ENGINE::CollectorSwOutPort::CollectorSwOutPort(), YACS::ENGINE::LinkInfo::getErrRepr(), YACS::ENGINE::LinkInfo::getInfoRepr(), YACS::ENGINE::LinkInfo::getWarnRepr(), and YACS::ENGINE::DynParaLoop::prepareInputsFromOutOfScope().

{
  return getPortName<InPort>(inPort);
}

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

virtual

Implements YACS::ENGINE::Node.

Definition at line 1333 of file ComposedNode.cxx.

References YACS::ENGINE::Node::getInputDataStreamPort(), and YACS::ENGINE::Node::SEP_CHAR_IN_PORT.

{
  string portName, nodeName;
  if(splitNamesBySep(name,Node::SEP_CHAR_IN_PORT,nodeName,portName,true))
    {
      Node *child = getChildByName(nodeName);
      return child->getInputDataStreamPort(portName);
    }
  else
    {
      string what("ComposedNode::getInputDataStreamPort : the port with name "); what+=name; what+=" does not exist on the current level";
      throw Exception(what);
    }
}

InputPort * ComposedNode::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::Node.

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Switch, YACS::ENGINE::OptimizerLoop, YACS::ENGINE::DynParaLoop, YACS::ENGINE::WhileLoop, and YACS::ENGINE::ForLoop.

Definition at line 1293 of file ComposedNode.cxx.

References YACS::ENGINE::Node::getInputPort(), and YACS::ENGINE::Node::SEP_CHAR_IN_PORT.

Referenced by YACS::ENGINE::ForLoop::getInputPort(), YACS::ENGINE::WhileLoop::getInputPort(), YACS::ENGINE::DynParaLoop::getInputPort(), and YACS::ENGINE::Switch::getInputPort().

{
  try {
    return Node::getInputPort(name);
  }
  catch(Exception& e) {}

  string portName, nodeName;
  if(splitNamesBySep(name,Node::SEP_CHAR_IN_PORT,nodeName,portName,true))
    {
      Node *child = getChildByName(nodeName);
      return child->getInputPort(portName);
    }
  else
    {
      string what("ComposedNode::getInputPort : the port with name "); what+=name; what+=" does not exist on the current level";
      throw Exception(what);
    }
}

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

virtual

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

Implements YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Switch, YACS::ENGINE::DynParaLoop, YACS::ENGINE::OptimizerLoop, YACS::ENGINE::ForLoop, and YACS::ENGINE::WhileLoop.

Definition at line 1501 of file ComposedNode.cxx.

Referenced by checkBasicConsistency(), YACS::ENGINE::DynParaLoop::getLocalInputPorts(), YACS::ENGINE::Switch::getLocalInputPorts(), and YACS::HMI::SubjectComposedNode::loadChildren().

{
  std::list<InputPort *> lip; return lip; // empty list
}

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

virtual

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

Implements YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::OptimizerLoop, YACS::ENGINE::DynParaLoop, and YACS::ENGINE::ForLoop.

Definition at line 1507 of file ComposedNode.cxx.

Referenced by YACS::ENGINE::DynParaLoop::getLocalOutputPorts(), and YACS::HMI::SubjectComposedNode::loadChildren().

{
  std::list<OutputPort *> lop; return lop; // empty list
}

ComposedNode * ComposedNode::getLowestCommonAncestor ( Node *  node1, Node *  node2  ) throw (Exception)

static

Retrieves the lowest common ancestor of 2 nodes.

Note

Retrieves the lowest common ancestor of 'node1' AND 'node2'. If 'node1' or 'node2' are both or indiscriminately instances of ComposedNode and that 'node1' is in descendance of 'node2' (resp. 'node2' in descendance of 'node1') 'node2' is returned (resp. 'node1').

Exceptions

Exception

: if 'node1' and 'node2' do not share the same genealogy.

Returns

The lowest common ancestor if it exists.

Definition at line 1046 of file ComposedNode.cxx.

References YACS::ENGINE::Node::_father.

Referenced by YACS::ENGINE::Bloc::Bloc(), YACS::ENGINE::OutPort::calculateHistoryOfLinkWith(), and YACS::ENGINE::ForEachLoop::getFEDeltaBetween().

{
  const char what[]="The two nodes do not share the same genealogy";
  if(node1==0 || node2==0)
    throw Exception(what);
  ComposedNode *temp;
  if(dynamic_cast<ComposedNode *>(node1))
    temp=(ComposedNode *)node1;//->_father;
  else
    temp=(ComposedNode *)node1->_father;
  set<ComposedNode *> s;
  while(temp)
    {
      s.insert(temp);
      temp=temp->_father;
    }
  //
  if(dynamic_cast<ComposedNode *>(node2))
    temp=(ComposedNode *)node2;//->_father;
  else
    temp=(ComposedNode *)node2->_father;
  set<ComposedNode *>::iterator iter=s.find(temp);
  while(temp && iter==s.end())
    {
      iter=s.find(temp);
      temp=temp->_father;
    }
  if(iter==s.end())
    throw Exception(what);
  return *iter;
}

std::string ComposedNode::getLowestCommonAncestorStr ( const std::string &  node1, const std::string &  node2  )

static

Same as getLowestCommonAncestor method except that absolute string representation is considered here instead of instances.

Definition at line 1081 of file ComposedNode.cxx.

References PMMLBasicsTestLauncher::ret, and SEP_CHAR_BTW_LEVEL.

{
  std::string ret;
  std::size_t it1_b(0),it1_e(0),it2_b(0),it2_e(0);
  while(it1_b!=std::string::npos && it2_b!=std::string::npos)
    {
      it1_e=node1.find(SEP_CHAR_BTW_LEVEL,it1_b);
      it2_e=node2.find(SEP_CHAR_BTW_LEVEL,it2_b);
      if(it1_e!=it2_e && it1_e!=std::string::npos && it2_e!=std::string::npos)
        break;
      std::string elt1(node1.substr(it1_b,it1_e-it1_b)),elt2(node2.substr(it2_b,it2_e-it2_b));
      if(elt1!=elt2)
        break;
      if(!ret.empty())
        ret+=SEP_CHAR_BTW_LEVEL;
      ret+=elt1;
      it1_b=node1.find_first_not_of(SEP_CHAR_BTW_LEVEL,it1_e);
      it2_b=node2.find_first_not_of(SEP_CHAR_BTW_LEVEL,it2_e);
    }
  return ret;
}

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

protected

Returns the lowest Node (Elementary or Composed) (is sense of hierachy level ( operator< ) ) containing all 'ports'. Typically use in consistency computation. Precondition : 'ports' must contain at least one element. All elements of 'ports' should be in descendance of 'this'.

Definition at line 696 of file ComposedNode.cxx.

References PMMLBasicsTestLauncher::ret.

Referenced by solveObviousOrDelegateCFLinks().

{
  list< OutPort *>::const_iterator iter=ports.begin();
  Node *ret=(*iter)->getNode();
  iter++;
  for(;iter!=ports.end();iter++)
    {
      Node *tmp=(*iter)->getNode();
      if(*tmp>*ret)
        ret=tmp;
    }
  return ret;
}

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

virtual

Reimplemented in YACS::ENGINE::Switch.

Definition at line 990 of file ComposedNode.cxx.

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

Referenced by YACS::ENGINE::Node::getQualifiedName().

{
  return directSon->getName();
}

std::string ComposedNode::getName ( ) const

virtual

Implements YACS::ENGINE::Scheduler.

Definition at line 165 of file ComposedNode.cxx.

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

Referenced by YACS::HMI::SceneBlocItem::arrangeChildNodes(), YACS::looptypeParser< T >::bloc(), YACS::casetypeParser::bloc(), YACS::bloctypeParser< T >::bloc(), YACS::ENGINE::OptimizerLoop::checkTypeCode(), YACS::ENGINE::DynParaLoop::cloneAndPlaceNodesCoherently(), YACS::ENGINE::CollectorSwOutPort::CollectorSwOutPort(), YACS::HMI::SubjectNode::copy(), YACS::HMI::Subject::destroy(), YACS::ENGINE::DFToDSForLoop::DFToDSForLoop(), YACS::ENGINE::DSToDFForLoop::DSToDFForLoop(), edRemoveLink(), YACS::ENGINE::ForLoop::exUpdateState(), YACS::looptypeParser< T >::foreach(), YACS::casetypeParser::foreach(), YACS::bloctypeParser< T >::foreach(), YACS::looptypeParser< T >::forloop(), YACS::casetypeParser::forloop(), YACS::bloctypeParser< T >::forloop(), YACS::ENGINE::DynParaLoop::getErrorReport(), getErrorReport(), YACS::ENGINE::Node::getId(), YACS::ENGINE::ProcCataLoader::loadCata(), YACS::HMI::CommandReparentNode::localExecute(), YACS::HMI::CommandPutInComposedNode::localExecute(), YACS::HMI::CommandCopyNode::localExecute(), YACS::HMI::CommandRenameNode::localExecute(), YACS::HMI::CommandRenameInDataPort::localExecute(), YACS::HMI::CommandRenameOutDataPort::localExecute(), YACS::HMI::CommandAddLink::localExecute(), YACS::HMI::CommandAddControlLink::localExecute(), YACS::HMI::CommandAssociateServiceToComponent::localExecute(), YACS::HMI::CommandReparentNode::localReverse(), YACS::HMI::CommandPutInComposedNode::localReverse(), YACS::HMI::CommandCopyNode::localReverse(), YACS::HMI::CommandRenameNode::localReverse(), YACS::HMI::CommandRenameInDataPort::localReverse(), YACS::HMI::CommandRenameOutDataPort::localReverse(), YACS::HMI::CommandAssociateServiceToComponent::localReverse(), YACS::looptypeParser< T >::optimizer(), YACS::casetypeParser::optimizer(), YACS::bloctypeParser< T >::optimizer(), YACS::roottypeParser::proc(), YACS::HMI::SubjectNode::registerUndoDestroy(), YACS::HMI::SubjectNode::reparent(), YACS::ENGINE::Node::setName(), YACS::switchtypeParser::state(), YACS::HMI::SubjectControlLink::SubjectControlLink(), YACS::HMI::SubjectLink::SubjectLink(), YACS::looptypeParser< T >::switch_(), YACS::casetypeParser::switch_(), YACS::bloctypeParser< T >::switch_(), YACS::ENGINE::VisitorSaveState::visitBloc(), YACS::ENGINE::VisitorSaveSchema::visitBloc(), YACS::ENGINE::VisitorSalomeSaveState::visitForEachLoop(), YACS::ENGINE::VisitorSaveState::visitForEachLoop(), YACS::ENGINE::VisitorSaveSchema::visitForEachLoop(), YACS::ENGINE::VisitorSaveState::visitForLoop(), YACS::ENGINE::VisitorSaveSchema::visitForLoop(), YACS::ENGINE::VisitorSaveState::visitLoop(), YACS::ENGINE::VisitorSaveState::visitOptimizerLoop(), YACS::ENGINE::VisitorSaveSchema::visitOptimizerLoop(), YACS::ENGINE::VisitorSaveState::visitProc(), YACS::ENGINE::VisitorSaveSchema::visitProc(), YACS::ENGINE::VisitorSaveState::visitSwitch(), YACS::ENGINE::VisitorSaveSchema::visitSwitch(), YACS::ENGINE::VisitorSaveState::visitWhileLoop(), YACS::ENGINE::VisitorSaveSchema::visitWhileLoop(), YACS::looptypeParser< T >::while_(), YACS::casetypeParser::while_(), YACS::bloctypeParser< T >::while_(), YACS::ENGINE::ForEachLoop::writeDot(), and YACS::ENGINE::VisitorSaveSchema::writeSimpleDataLinks().

{
  return Node::getName();
}

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

virtual

Implements YACS::ENGINE::Scheduler.

Definition at line 217 of file ComposedNode.cxx.

References YACS::ENGINE::Node::getReadyTasks(), and PMMLBasicsTestLauncher::ret.

{
  vector<Task *> ret;
  isMore=false;
  getReadyTasks(ret);
  isMore=!ret.empty();
  return ret;
}

int ComposedNode::getNumberOfInputPorts ( ) const

virtual

Implements YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Loop, YACS::ENGINE::Switch, YACS::ENGINE::OptimizerLoop, and YACS::ENGINE::DynParaLoop.

Definition at line 1206 of file ComposedNode.cxx.

References edGetDirectDescendants(), and PMMLBasicsTestLauncher::ret.

Referenced by YACS::ENGINE::DynParaLoop::getNumberOfInputPorts(), YACS::ENGINE::Switch::getNumberOfInputPorts(), and YACS::ENGINE::Loop::getNumberOfInputPorts().

{
  list<Node *> constituents=edGetDirectDescendants();
  int ret=0;
  for(list<Node *>::iterator iter=constituents.begin();iter!=constituents.end();iter++)
    ret+=(*iter)->getNumberOfInputPorts();
  return ret;
}

int ComposedNode::getNumberOfOutputPorts ( ) const

virtual

Implements YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::OptimizerLoop, and YACS::ENGINE::DynParaLoop.

Definition at line 1215 of file ComposedNode.cxx.

References edGetDirectDescendants(), and PMMLBasicsTestLauncher::ret.

Referenced by YACS::ENGINE::DynParaLoop::getNumberOfOutputPorts().

{
  list<Node *> constituents=edGetDirectDescendants();
  int ret=0;
  for(list<Node *>::iterator iter=constituents.begin();iter!=constituents.end();iter++)
    ret+=(*iter)->getNumberOfOutputPorts();
  return ret;
}

OutPort * ComposedNode::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::Node.

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Switch, YACS::ENGINE::OptimizerLoop, YACS::ENGINE::DynParaLoop, and YACS::ENGINE::ForLoop.

Definition at line 1272 of file ComposedNode.cxx.

References YACS::ENGINE::Node::getOutPort(), and YACS::ENGINE::Node::SEP_CHAR_IN_PORT.

Referenced by YACS::ENGINE::Bloc::Bloc(), YACS::ENGINE::ForLoop::getOutPort(), YACS::ENGINE::DynParaLoop::getOutPort(), YACS::ENGINE::Switch::getOutPort(), and YACS::ENGINE::WhileLoop::WhileLoop().

{
  string portName, nodeName;
  if(splitNamesBySep(name,Node::SEP_CHAR_IN_PORT,nodeName,portName,false))
    {
      Node *child = getChildByShortName(nodeName);
      return child->getOutPort(portName);
    }
  else
    {
      string what("ComposedNode::getOutPort : the port with name "); what+=name; what+=" does not exist on the current level";
      throw Exception(what);
    }
}

string ComposedNode::getOutPortName ( const OutPort *  outPort ) const throw (Exception)

virtual

Implements YACS::ENGINE::Node.

Definition at line 1201 of file ComposedNode.cxx.

Referenced by YACS::ENGINE::CollectorSwOutPort::CollectorSwOutPort(), YACS::ENGINE::ForEachLoop::createOutputOutOfScopeInterceptors(), YACS::ENGINE::ForEachLoop::ForEachLoop(), YACS::ENGINE::LinkInfo::getErrRepr(), YACS::ENGINE::LinkInfo::getInfoRepr(), and YACS::ENGINE::LinkInfo::getWarnRepr().

{
  return getPortName<OutPort>(outPort);
}

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

virtual

Implements YACS::ENGINE::Node.

Definition at line 1348 of file ComposedNode.cxx.

References YACS::ENGINE::Node::getOutputDataStreamPort(), and YACS::ENGINE::Node::SEP_CHAR_IN_PORT.

{
  string portName, nodeName;
  if(splitNamesBySep(name,Node::SEP_CHAR_IN_PORT,nodeName,portName,true))
    {
      Node *child = getChildByName(nodeName);
      return child->getOutputDataStreamPort(portName);
    }
  else
    {
      string what("ComposedNode::getOutputDataStreamPort : the port with name "); what+=name; what+=" does not exist on the current level";
      throw Exception(what);
    }
}

OutputPort * ComposedNode::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.

Implements YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::OptimizerLoop, YACS::ENGINE::DynParaLoop, and YACS::ENGINE::ForLoop.

Definition at line 1318 of file ComposedNode.cxx.

References YACS::ENGINE::Node::getOutputPort(), and YACS::ENGINE::Node::SEP_CHAR_IN_PORT.

Referenced by YACS::ENGINE::ForLoop::getOutputPort(), and YACS::ENGINE::DynParaLoop::getOutputPort().

{
  string portName, nodeName;
  if(splitNamesBySep(name,Node::SEP_CHAR_IN_PORT,nodeName,portName,false))
    {
      Node *child = getChildByShortName(nodeName);
      return child->getOutputPort(portName);
    }
  else
    {
      string what("ComposedNode::getOutputPort : the port with name "); what+=name; what+=" does not exist on the current level";
      throw Exception(what);
    }
}

template<class PORT >

std::string YACS::ENGINE::ComposedNode::getPortName ( const PORT *  port ) const throw (Exception)

protected

Definition at line 177 of file ComposedNode.hxx.

References YACS::ENGINE::Node::_father, YACS::ENGINE::Node::getName(), YACS::ENGINE::Node::getQualifiedName(), and YACS::ENGINE::Node::SEP_CHAR_IN_PORT.

Referenced by YACS::ENGINE::Bloc::Bloc(), YACS::ENGINE::ForEachLoop::buildDelegateOf(), YACS::ENGINE::DynParaLoop::DynParaLoop(), YACS::ENGINE::ForLoop::ForLoop(), YACS::ENGINE::ForEachLoop::getOutputPortType(), YACS::ENGINE::OptimizerLoop::OptimizerLoop(), YACS::ENGINE::DynParaLoop::putValueOnBranch(), and YACS::ENGINE::WhileLoop::WhileLoop().

    {
      Node *node = port->getNode();
      std::string portName = port->getName();  
      checkInMyDescendance(node);
      Node *father = node;
      while (father != this)
        {
          portName = father->getQualifiedName() + Node::SEP_CHAR_IN_PORT + portName;
          father = father->_father;
        }
      return portName;
    }

virtual std::string YACS::ENGINE::ComposedNode::getProgress ( ) const

inlinevirtual

Reimplemented in YACS::ENGINE::ForEachLoop, and YACS::ENGINE::ForLoop.

Definition at line 125 of file ComposedNode.hxx.

{ return "0"; }

list< ProgressWeight > ComposedNode::getProgressWeight ( ) const

virtual

Get the progress weight for all elementary nodes.

Only elementary nodes have weight. A simple composed node only sum up weight of all his descendants (working is different for loop or switch nodes)

Implements YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Switch, and YACS::ENGINE::ForLoop.

Definition at line 1179 of file ComposedNode.cxx.

References edGetDirectDescendants(), and PMMLBasicsTestLauncher::ret.

Referenced by YACS::ENGINE::Proc::getGlobalProgressPercent().

{
  list<ProgressWeight> ret;
  list<Node *> setOfNode=edGetDirectDescendants();
  for(list<Node *>::const_iterator iter=setOfNode.begin();iter!=setOfNode.end();iter++)
    {
      list<ProgressWeight> myCurrentSet=((ComposedNode*)(*iter))->getProgressWeight();
      ret.insert(ret.end(),myCurrentSet.begin(),myCurrentSet.end());
    }
  return ret;
}

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

virtual

Implements YACS::ENGINE::Node.

Definition at line 1117 of file ComposedNode.cxx.

References edGetDirectDescendants(), and PMMLBasicsTestLauncher::ret.

Referenced by getDeploymentTree(), performDuplicationOfPlacement(), and performShallowDuplicationOfPlacement().

{
  list<ElementaryNode *> ret;
  list<Node *> setOfNode=edGetDirectDescendants();
  for(list<Node *>::const_iterator iter=setOfNode.begin();iter!=setOfNode.end();iter++)
    {
      list<ElementaryNode *> myCurrentSet=(*iter)->getRecursiveConstituents();
      ret.insert(ret.end(),myCurrentSet.begin(),myCurrentSet.end());
    }
  return ret;
}

ComposedNode * ComposedNode::getRootNode ( ) const throw (Exception)

virtual

Reimplemented from YACS::ENGINE::Node.

Definition at line 923 of file ComposedNode.cxx.

References YACS::ENGINE::Node::_father, and YACS::ENGINE::Node::getRootNode().

Referenced by YACS::ENGINE::CollectorSwOutPort::CollectorSwOutPort().

{
  if(!_father)
    return (ComposedNode *)this;
  return Node::getRootNode();
}

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

virtual

Implements YACS::ENGINE::Node.

Definition at line 1248 of file ComposedNode.cxx.

References edGetDirectDescendants(), and PMMLBasicsTestLauncher::ret.

Referenced by YACS::HMI::SubjectComposedNode::loadChildren().

{
  list<Node *> constituents=edGetDirectDescendants();
  list<InputDataStreamPort *> ret;
  for(list<Node *>::iterator iter=constituents.begin();iter!=constituents.end();iter++)
    {
      list<InputDataStreamPort *> currentsPorts=(*iter)->getSetOfInputDataStreamPort();
      ret.insert(ret.end(),currentsPorts.begin(),currentsPorts.end());
    }
  return ret;
}

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

virtual

Implements YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Loop, YACS::ENGINE::Switch, YACS::ENGINE::DynParaLoop, and YACS::ENGINE::OptimizerLoop.

Definition at line 1224 of file ComposedNode.cxx.

References edGetDirectDescendants(), and PMMLBasicsTestLauncher::ret.

Referenced by YACS::ENGINE::DynParaLoop::getSetOfInputPort(), YACS::ENGINE::Switch::getSetOfInputPort(), and YACS::ENGINE::Loop::getSetOfInputPort().

{
  list<Node *> constituents=edGetDirectDescendants();
  list<InputPort *> ret;
  for(list<Node *>::iterator iter=constituents.begin();iter!=constituents.end();iter++)
    {
      list<InputPort *> currentsPorts=(*iter)->getSetOfInputPort();
      ret.insert(ret.end(),currentsPorts.begin(),currentsPorts.end());
    }
  return ret;
}

std::vector< std::pair< OutPort *, InPort * > > ComposedNode::getSetOfInternalLinks

(

)

const

Definition at line 583 of file ComposedNode.cxx.

References YACS::ENGINE::Node::getSetOfOutPort(), isInMyDescendance(), and PMMLBasicsTestLauncher::ret.

Referenced by YACS::ENGINE::Bloc::Bloc(), YACS::ENGINE::ForLoop::ForLoop(), YACS::HMI::SubjectComposedNode::loadLinks(), and YACS::ENGINE::WhileLoop::WhileLoop().

{
  vector< pair<OutPort *, InPort *> > ret;
  list<OutPort *> temp=getSetOfOutPort();
  for(list<OutPort *>::const_iterator iter2=temp.begin();iter2!=temp.end();iter2++)
    {
      set<InPort *> temp2=(*iter2)->edSetInPort();
      for(set<InPort *>::iterator iter3=temp2.begin();iter3!=temp2.end();iter3++)
        if(isInMyDescendance((*iter3)->getNode()))
          ret.push_back(pair<OutPort *, InPort *>((*iter2),(*iter3)));
    }
  return ret;
}

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

virtual

Implements YACS::ENGINE::Node.

Definition at line 831 of file ComposedNode.cxx.

References getAllInPortsComingFromOutsideOfCurrentScope(), isInMyDescendance(), and PMMLBasicsTestLauncher::ret.

Referenced by edDisconnectAllLinksWithMe().

{
  vector< pair<InPort *, OutPort *> > ret;
  set<InPort *> ports=getAllInPortsComingFromOutsideOfCurrentScope();
  for(set<InPort *>::iterator iter2=ports.begin();iter2!=ports.end();iter2++)
    {
      set<OutPort *> temp2=(*iter2)->edSetOutPort();
      for(set<OutPort *>::iterator iter3=temp2.begin();iter3!=temp2.end();iter3++)
        {
          if(isInMyDescendance((*iter3)->getNode()))continue;
          std::set<OutPort *> trueOutPorts;
          (*iter3)->getAllRepresented(trueOutPorts);
          for(std::set<OutPort *>::iterator iter4=trueOutPorts.begin();iter4!=trueOutPorts.end();++iter4)
            ret.push_back(pair<InPort *, OutPort *>(*iter2,*iter4));
        }
    }
  return ret;
}

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

virtual

Implements YACS::ENGINE::Node.

Definition at line 597 of file ComposedNode.cxx.

References getAllOutPortsLeavingCurrentScope(), isInMyDescendance(), and PMMLBasicsTestLauncher::ret.

Referenced by edDisconnectAllLinksWithMe().

{
  vector< pair<OutPort *, InPort *> > ret;
  std::set<OutPort *> ports=getAllOutPortsLeavingCurrentScope();
  for(set<OutPort *>::iterator iter2=ports.begin();iter2!=ports.end();iter2++)
    {
      set<InPort *> temp2=(*iter2)->edSetInPort();
      for(set<InPort *>::iterator iter3=temp2.begin();iter3!=temp2.end();iter3++)
        if(!isInMyDescendance((*iter3)->getNode()))
          ret.push_back(pair<OutPort *, InPort *>(*iter2,*iter3));
    }
  return ret;
}

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

virtual

Implements YACS::ENGINE::Node.

Definition at line 1260 of file ComposedNode.cxx.

References edGetDirectDescendants(), and PMMLBasicsTestLauncher::ret.

Referenced by YACS::HMI::SubjectComposedNode::loadChildren().

{
  list<Node *> constituents=edGetDirectDescendants();
  list<OutputDataStreamPort *> ret;
  for(list<Node *>::iterator iter=constituents.begin();iter!=constituents.end();iter++)
    {
      list<OutputDataStreamPort *> currentsPorts=(*iter)->getSetOfOutputDataStreamPort();
      ret.insert(ret.end(),currentsPorts.begin(),currentsPorts.end());
    }
  return ret;
}

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

virtual

Implements YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::OptimizerLoop, YACS::ENGINE::DynParaLoop, and YACS::ENGINE::ForLoop.

Definition at line 1236 of file ComposedNode.cxx.

References edGetDirectDescendants(), and PMMLBasicsTestLauncher::ret.

Referenced by YACS::ENGINE::ForLoop::getSetOfOutputPort(), and YACS::ENGINE::DynParaLoop::getSetOfOutputPort().

{
  list<Node *> constituents=edGetDirectDescendants();
  list<OutputPort *> ret;
  for(list<Node *>::iterator iter=constituents.begin();iter!=constituents.end();iter++)
    {
      list<OutputPort *> currentsPorts=(*iter)->getSetOfOutputPort();
      ret.insert(ret.end(),currentsPorts.begin(),currentsPorts.end());
    }
  return ret;
}

std::string ComposedNode::getTaskName ( Task *  task ) const

virtual

Implements YACS::ENGINE::Scheduler.

Definition at line 170 of file ComposedNode.cxx.

References getChildName().

{
  return getChildName(dynamic_cast<ElementaryNode *>(task));
}

void ComposedNode::init ( bool  start = true )

virtual

initialisation of all input and output ports and gates, for execution

Reimplemented from YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Loop, YACS::ENGINE::Switch, YACS::ENGINE::OptimizerLoop, YACS::ENGINE::DynParaLoop, YACS::ENGINE::WhileLoop, YACS::ENGINE::SalomeProc, and YACS::ENGINE::ForLoop.

Definition at line 160 of file ComposedNode.cxx.

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

Referenced by YACS::ENGINE::DynParaLoop::init(), YACS::ENGINE::Switch::init(), and YACS::ENGINE::Loop::init().

{
  Node::init(start);
}

bool ComposedNode::isFinished ( )

virtual

Implements YACS::ENGINE::Scheduler.

Definition at line 151 of file ComposedNode.cxx.

References YACS::ENGINE::Node::_state, YACS::DISABLED, YACS::DONE, YACS::ERROR, and YACS::FAILED.

Referenced by YACS::ENGINE::OptimizerLoop::isFullyBusy(), YACS::ENGINE::ForEachLoop::updateStateForWorkNodeOnFinishedEventFrom(), and YACS::ENGINE::OptimizerLoop::updateStateOnFinishedEventFrom().

{
  if(_state==YACS::DONE)return true;
  if(_state==YACS::ERROR)return true;
  if(_state==YACS::FAILED)return true;
  if(_state==YACS::DISABLED)return true;
  return false;
}

Node * ComposedNode::isInMyDescendance

(

Node *

nodeToTest

)

const

Returns the parent of a node that is the direct child of this node.

Note

if 'nodeToTest'=='this' this is returned. Else if 'nodeToTest' is in descendance of 'this' the direct son is returned. Else 0 is returned.

Parameters

nodeToTest

: the node to check

Definition at line 945 of file ComposedNode.cxx.

References YACS::ENGINE::Node::_father.

Referenced by YACS::ENGINE::DynParaLoop::buildDelegateOf(), YACS::ENGINE::Loop::buildDelegateOf(), YACS::ENGINE::ForLoop::checkCFLinks(), YACS::ENGINE::Bloc::checkCFLinks(), YACS::ENGINE::DynParaLoop::checkCFLinks(), checkCFLinks(), YACS::ENGINE::Bloc::checkControlDependancy(), YACS::ENGINE::DynParaLoop::cloneAndPlaceNodesCoherently(), getAllInPortsComingFromOutsideOfCurrentScope(), YACS::ENGINE::Switch::getAllInPortsComingFromOutsideOfCurrentScope(), getAllOutPortsLeavingCurrentScope(), YACS::ENGINE::DynParaLoop::getDynInputPortByAbsName(), YACS::HMI::SceneBlocItem::getNodesInfo(), getSetOfInternalLinks(), getSetOfLinksComingInCurrentScope(), getSetOfLinksLeavingCurrentScope(), YACS::ENGINE::OptimizerLoop::initInterceptors(), YACS::HMI::SubjectComposedNode::removeExternalControlLinks(), YACS::ENGINE::VisitorSaveSchema::writeControls(), YACS::ENGINE::VisitorSaveSchema::writeSimpleDataLinks(), and YACS::ENGINE::VisitorSaveSchema::writeSimpleStreamLinks().

{
  if(nodeToTest==0)
    return 0;
  if((ComposedNode *)nodeToTest==this)
    return (Node *)this;
  Node *iterBack=nodeToTest;
  ComposedNode *iter=nodeToTest->_father;
  while(iter!=0 && iter!=this)
    {
      iterBack=iter;
      iter=iter->_father;
    }
  if(iter!=0)
    return iterBack;
  else
    return 0;
}

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

virtual

Reimplemented in YACS::ENGINE::Bloc.

Definition at line 1512 of file ComposedNode.cxx.

Referenced by YACS::ENGINE::Node::setName().

{
  return false;
}

bool ComposedNode::isNodeAlreadyAggregated

(

const Node *

node

)

const

Check that Node 'node' is already a direct son of this.

Definition at line 931 of file ComposedNode.cxx.

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

{
  list<ComposedNode *> nodeAncestors = node->getAllAscendanceOf();
  return find(nodeAncestors.begin(),nodeAncestors.end(),(ComposedNode *)this)!=nodeAncestors.end();
}

virtual bool YACS::ENGINE::ComposedNode::isPlacementPredictableB4Run ( ) const

pure virtual

Implements YACS::ENGINE::Scheduler.

Implemented in YACS::ENGINE::DynParaLoop, and YACS::ENGINE::StaticDefinedComposedNode.

virtual bool YACS::ENGINE::ComposedNode::isRepeatedUnpredictablySeveralTimes ( ) const

inlinevirtual

Reimplemented in YACS::ENGINE::Loop.

Definition at line 78 of file ComposedNode.hxx.

{ return false; }

void ComposedNode::loaded

(

)

Definition at line 1484 of file ComposedNode.cxx.

{
}

void ComposedNode::notifyFrom ( const Task *  sender, YACS::Event  event, const Executor *  execInst  )

virtual

Notify the node a task has emitted an event.

TO COMMENT MORE

Note

Runtime called method. Overloads the Scheduler::notifyFrom abstract method. Typically Called in Executor (in a parallel thread or not) by the Task 'task' to inform the scheduler that an event coded 'event' (in Executor static const var) happened. Contrary to updateStateFrom several levels may exist between 'sender' and 'this'.

Parameters

sender	: task emitting event
event	: event emitted

Called by Executor::functionForTaskExecution on YACS::FINISH event

Called by Executor::launchTask on YACS::START event

Calls ComposedNode::updateStateFrom to update state from task to root node

Implements YACS::ENGINE::Scheduler.

Definition at line 243 of file ComposedNode.cxx.

References YACS::ENGINE::Node::_father, DEBTRACE, YACS::NOEVENT, and updateStateFrom().

{
  DEBTRACE("ComposedNode::notifyFrom " << event);
  ElementaryNode *taskTyped=dynamic_cast<ElementaryNode *>((Task *)sender);
  YACS::Event curEvent=event;
  Node *lminus1LevelNode=taskTyped;
  ComposedNode *curLevelNode=taskTyped->_father;
  if(!curLevelNode)//Specific case of loop when 0 turn is specified without any enclosing bloc.
    return ;
  curEvent=curLevelNode->updateStateFrom(lminus1LevelNode,curEvent,execInst);
  while(curEvent!=YACS::NOEVENT && curLevelNode!=this)
    {
      lminus1LevelNode=curLevelNode;
      curLevelNode=curLevelNode->_father;
      curEvent=curLevelNode->updateStateFrom(lminus1LevelNode,curEvent,execInst);
    }
}

void ComposedNode::performCFComputations ( LinkInfo &  info ) const

protectedvirtual

perform recursively all CF computations.

Reimplemented in YACS::ENGINE::Bloc.

Definition at line 674 of file ComposedNode.cxx.

References edGetDirectDescendants().

Referenced by YACS::ENGINE::Bloc::performCFComputations().

{
  list<Node *> nodes=edGetDirectDescendants();
  for(list<Node *>::iterator iter=nodes.begin();iter!=nodes.end();iter++)
    if(dynamic_cast<ComposedNode *>(*iter))
      ((ComposedNode *)(*iter))->performCFComputations(info);
}

void ComposedNode::performDuplicationOfPlacement ( const Node &  other )

protectedvirtual

performs a duplication of placement using clone method of containers and components. clone behaviour is driven by attachOnCloning attribute.

Implements YACS::ENGINE::Node.

Definition at line 66 of file ComposedNode.cxx.

References YACS::ENGINE::Container::clone(), YACS::ENGINE::ComponentInstance::clone(), YACS::ENGINE::RefCounter::decrRef(), YACS::ENGINE::DeploymentTree::getAllContainers(), getChildByName(), getChildName(), YACS::ENGINE::DeploymentTree::getComponentsLinkedToContainer(), getDeploymentTree(), getRecursiveConstituents(), YACS::ENGINE::DeploymentTree::getTasksLinkedToComponent(), YACS::ENGINE::DeploymentTree::getTasksLinkedToContainer(), and YACS::ENGINE::ComponentInstance::setContainer().

{
  const ComposedNode &otherC=*(dynamic_cast<const ComposedNode *>(&other));
  DeploymentTree treeToDup=otherC.getDeploymentTree();
  list< ElementaryNode * > clones=otherC.getRecursiveConstituents();
  vector<Container *> conts=treeToDup.getAllContainers();
  //iterate on all containers
  for(vector<Container *>::iterator iterCt=conts.begin();iterCt!=conts.end();iterCt++)
    {
      vector<ComponentInstance *> comps=treeToDup.getComponentsLinkedToContainer(*iterCt);
      Container *contCloned=0;
      if((*iterCt))
        contCloned=(*iterCt)->clone();

      //iterate on all component instances linked to the container
      for(vector<ComponentInstance *>::iterator iterCp=comps.begin();iterCp!=comps.end();iterCp++)
        {
          vector<Task *> tasks=treeToDup.getTasksLinkedToComponent(*iterCp);
          ComponentInstance *curCloned=(*iterCp)->clone();
          curCloned->setContainer(contCloned);
          for(vector<Task *>::iterator iterT=tasks.begin();iterT!=tasks.end();iterT++)
            {
              //No risk for static cast : appendTask called by ComposedNode.
              list< ElementaryNode * >::iterator res=find(clones.begin(),clones.end(),(ElementaryNode *)(*iterT));
              //No risk here to because called only on cloning process...
              ServiceNode *nodeC=(ServiceNode *)getChildByName(otherC.getChildName(*res));
              nodeC->setComponent(curCloned);
            }
          curCloned->decrRef();
        }

      // iterate on all tasks linked to the container
      vector<Task *> tasks=treeToDup.getTasksLinkedToContainer(*iterCt);
      for(vector<Task *>::iterator iterT=tasks.begin();iterT!=tasks.end();iterT++)
        {
          std::list< ElementaryNode * >::iterator res=find(clones.begin(),clones.end(),(ElementaryNode *)(*iterT));
          InlineFuncNode *nodeC=(InlineFuncNode *)getChildByName(otherC.getChildName(*res));
          nodeC->setContainer(contCloned);
        }

      // ended with current container
      if(contCloned)
        contCloned->decrRef();
    }
}

void ComposedNode::performShallowDuplicationOfPlacement ( const Node &  other )

protectedvirtual

performs a also duplication of placement but here containers and components are not copied at all whatever the value of attachedOnCloning.

Implements YACS::ENGINE::Node.

Definition at line 112 of file ComposedNode.cxx.

References YACS::ENGINE::DeploymentTree::getAllContainers(), getChildByName(), getChildName(), YACS::ENGINE::DeploymentTree::getComponentsLinkedToContainer(), getDeploymentTree(), getRecursiveConstituents(), YACS::ENGINE::DeploymentTree::getTasksLinkedToComponent(), YACS::ENGINE::DeploymentTree::getTasksLinkedToContainer(), and YACS::ENGINE::ComponentInstance::setContainer().

{
  const ComposedNode &otherC=*(dynamic_cast<const ComposedNode *>(&other));
  DeploymentTree treeToDup=otherC.getDeploymentTree();
  list< ElementaryNode * > clones=otherC.getRecursiveConstituents();
  vector<Container *> conts=treeToDup.getAllContainers();
  //iterate on all containers
  for(vector<Container *>::iterator iterCt=conts.begin();iterCt!=conts.end();iterCt++)
    {
      vector<ComponentInstance *> comps=treeToDup.getComponentsLinkedToContainer(*iterCt);
      Container *contCloned((*iterCt));

      //iterate on all component instances linked to the container
      for(vector<ComponentInstance *>::iterator iterCp=comps.begin();iterCp!=comps.end();iterCp++)
        {
          vector<Task *> tasks=treeToDup.getTasksLinkedToComponent(*iterCp);
          ComponentInstance *curCloned((*iterCp));
          curCloned->setContainer(contCloned);
          for(vector<Task *>::iterator iterT=tasks.begin();iterT!=tasks.end();iterT++)
            {
              //No risk for static cast : appendTask called by ComposedNode.
              list< ElementaryNode * >::iterator res=find(clones.begin(),clones.end(),(ElementaryNode *)(*iterT));
              //No risk here to because called only on cloning process...
              ServiceNode *nodeC=(ServiceNode *)getChildByName(otherC.getChildName(*res));
              nodeC->setComponent(curCloned);
            }
        }

      // iterate on all tasks linked to the container
      vector<Task *> tasks=treeToDup.getTasksLinkedToContainer(*iterCt);
      for(vector<Task *>::iterator iterT=tasks.begin();iterT!=tasks.end();iterT++)
        {
          std::list< ElementaryNode * >::iterator res=find(clones.begin(),clones.end(),(ElementaryNode *)(*iterT));
          InlineFuncNode *nodeC=(InlineFuncNode *)getChildByName(otherC.getChildName(*res));
          nodeC->setContainer(contCloned);
        }
    }
}

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

protectedvirtual

Reimplemented in YACS::ENGINE::Loop.

Definition at line 1476 of file ComposedNode.cxx.

Referenced by edRemoveLink().

{
}

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

protectedvirtual

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Loop, and YACS::ENGINE::Switch.

Definition at line 1480 of file ComposedNode.cxx.

{
}

void ComposedNode::removeRecursivelyRedundantCL ( )

virtual

This method recursively all redundant control links in this.

Reimplemented in YACS::ENGINE::Bloc.

Definition at line 1106 of file ComposedNode.cxx.

References edGetDirectDescendants(), and removeRecursivelyRedundantCL().

Referenced by YACS::ENGINE::Bloc::removeRecursivelyRedundantCL(), and removeRecursivelyRedundantCL().

{
  std::list<Node *> dd(edGetDirectDescendants());
  for(std::list<Node *>::const_iterator it=dd.begin();it!=dd.end();it++)
    {
      ComposedNode *elt(dynamic_cast<ComposedNode *>(*it));
      if(elt)
        elt->removeRecursivelyRedundantCL();
    }
}

void ComposedNode::resetState ( int  level )

virtual

Reset the state of the node and its children depending on the parameter level.

Reimplemented from YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::ForEachLoop.

Definition at line 1623 of file ComposedNode.cxx.

References YACS::ENGINE::Node::_state, YACS::ACTIVATED, DEBTRACE, edGetDirectDescendants(), YACS::ERROR, YACS::FAILED, and YACS::ENGINE::Node::resetState().

Referenced by main(), and YACS::ENGINE::ForEachLoop::resetState().

{
  if(level==0)return;

  DEBTRACE("ComposedNode::resetState " << level << "," << _state);
  if( _state==YACS::ERROR || _state==YACS::FAILED || _state==YACS::ACTIVATED )
    {
      Node::resetState(level);
      std::list<Node *> nodes=edGetDirectDescendants();
      for(std::list<Node *>::iterator iter=nodes.begin();iter!=nodes.end();iter++)
        (*iter)->resetState(level);
    }
}

void ComposedNode::shutdown ( int  level )

virtual

Stop all pending activities of the composed node.

This method should be called when a Proc is finished and must be deleted from the YACS server

Reimplemented from YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::DynParaLoop.

Definition at line 1601 of file ComposedNode.cxx.

References DEBTRACE, and edGetDirectDescendants().

Referenced by Handler(), and main().

{
  if(level==0)return;
  DEBTRACE("ComposedNode::shutdown");
  list<Node *> nodes=edGetDirectDescendants();
  for(list<Node *>::iterator iter=nodes.begin();iter!=nodes.end();iter++)
    (*iter)->shutdown(level);
}

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

protected

Internal method during CF links. This methode is in charge to statuate on links consistency in the case that no control flow defined by user is set.

Definition at line 753 of file ComposedNode.cxx.

References YACS::ENGINE::E_COLLAPSE_DFDS, FED_ST, FREE_ST, getLowestNodeDealingAll(), YACS::ENGINE::I_BACK, YACS::ENGINE::I_BACK_USELESS, YACS::ENGINE::I_USELESS, YACS::ENGINE::LinkInfo::pushErrLink(), YACS::ENGINE::LinkInfo::pushInfoLink(), YACS::ENGINE::LinkInfo::pushWarnLink(), YACS::ENGINE::W_BACK_COLLAPSE_EL, YACS::ENGINE::W_BACK_COLLAPSE_EL_AND_USELESS, YACS::ENGINE::W_COLLAPSE_EL, and YACS::ENGINE::W_COLLAPSE_EL_AND_USELESS.

Referenced by YACS::ENGINE::ForLoop::checkCFLinks(), YACS::ENGINE::DynParaLoop::checkCFLinks(), YACS::ENGINE::OptimizerLoop::checkCFLinks(), checkCFLinks(), and YACS::ENGINE::Loop::checkCFLinks().

{
  static const char what[]="ComposedNode::solveObviousOrDelegateCFLinks : Internal error occured - uncorrect hierarchy detected !";
  if(starts.size()==1)
    {
      if(alreadyFed==FREE_ST)
        {
          if(!direction)
            info.pushInfoLink(*(starts.begin()),end,I_BACK);
          alreadyFed=FED_ST;
        }
      else if(alreadyFed==FED_ST)
        info.pushInfoLink(*(starts.begin()),end,direction ?  I_USELESS : I_BACK_USELESS);
      else
        info.pushErrLink(*(starts.begin()),end,E_COLLAPSE_DFDS);
    }
  else
    {
      Node *levelOfDecision=getLowestNodeDealingAll(starts);
      if(levelOfDecision==this)
        throw Exception(what);
      if(dynamic_cast<ElementaryNode *>(levelOfDecision))
        {
          WarnReason reason;
          if(alreadyFed==FREE_ST || alreadyFed==FED_ST)
            {
              if(alreadyFed==FREE_ST)
                {
                  reason=direction ? W_COLLAPSE_EL : W_BACK_COLLAPSE_EL;
                  alreadyFed=FED_ST;
                }
              else
                reason=direction ? W_COLLAPSE_EL_AND_USELESS : W_BACK_COLLAPSE_EL_AND_USELESS;
              for(list< OutPort *>::const_iterator iter=starts.begin();iter!=starts.end();iter++)
                info.pushWarnLink(*iter,end,reason);
            }
        }
      else
        ((ComposedNode *)levelOfDecision)->checkCFLinks(starts,end,alreadyFed,direction,info);
    }
}

bool ComposedNode::splitNamesBySep ( const std::string &  globalName, const char  separator[], std::string &  firstPart, std::string &  lastPart, bool  priority  ) throw (Exception)

staticprotected

Splits name globalName in 2 parts using separator.

Note

'priority' specifies if during search process of 'separator' the max part is for 'firstPart' (priority=true) or 'lastPart' (priority=false).

Exceptions

Exception

: 'lastPart' or 'firstPart' is empty.

Returns

true if split process succeeds false otherwise (typically when character separator was not found).

Definition at line 557 of file ComposedNode.cxx.

Referenced by getChildByName(), YACS::ENGINE::DynParaLoop::getDynInputPortByAbsName(), and YACS::ENGINE::ForEachLoop::getDynOutPortByAbsName().

{
  const string delims(separator);
  string portName, nodeName;
  string::size_type idx;
  if(priority)
    idx = globalName.find_last_of(delims);
  else
    idx = globalName.find_first_of(delims);
  if (idx == string::npos)
    {
      firstPart=globalName;
      lastPart="";
      return false;
    }
  firstPart = globalName.substr(0,idx);
  lastPart = globalName.substr(idx+1);
  if ((firstPart.empty()) || (lastPart.empty()))
    {
      string what("the name "); what+= globalName ; what+=" is not a valid port name";
      throw Exception(what);
    }
  return true;
}

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

inlinevirtual

Reimplemented from YACS::ENGINE::Node.

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Loop, YACS::ENGINE::Switch, YACS::ENGINE::OptimizerLoop, YACS::ENGINE::Proc, YACS::ENGINE::Bloc, YACS::ENGINE::ForLoop, YACS::ENGINE::WhileLoop, YACS::ENGINE::SalomeProc, and YACS::ENGINE::SalomeOptimizerLoop.

Definition at line 107 of file ComposedNode.hxx.

{return "YACS__ENGINE__ComposedNode";}

YACS::Event ComposedNode::updateStateFrom ( Node *  node, YACS::Event  event, const Executor *  execInst  )

protected

Update node state on receiving event from a node.

Note

Runtime called method. Perform, the state updating, from the son node 'node' emitting the event 'event' (among Executor static const var). WARNING Precondition : this == node->_father

Returns

The event (among Executor static const var) destinated to this->_father node to perform eventually up level update.

Calls ComposedNode::updateStateOnStartEventFrom if event is YACS::START

Calls ComposedNode::updateStateOnFinishedEventFrom if event is YACS::FINISH

Called by ComposedNode::notifyFrom

Definition at line 1378 of file ComposedNode.cxx.

References YACS::ENGINE::Node::_errorDetails, YACS::ABORT, DEBTRACE, YACS::ERROR, YACS::ENGINE::Node::exForwardFailed(), YACS::FINISH, YACS::ENGINE::Node::getName(), YACS::NOEVENT, YACS::ENGINE::Node::setState(), YACS::START, updateStateOnFailedEventFrom(), updateStateOnFinishedEventFrom(), updateStateOnStartEventFrom(), and YACS::Exception::what().

Referenced by notifyFrom().

{
  DEBTRACE("updateStateFrom: " << node->getName() << " " << event);
  try
    {
      switch(event)
        {
        case YACS::START:
          return updateStateOnStartEventFrom(node);
          break;
        case YACS::FINISH:
          return updateStateOnFinishedEventFrom(node);
          break;
        case YACS::ABORT:
          return updateStateOnFailedEventFrom(node,execInst);
          break;
        default:
          return YACS::NOEVENT;//TODO unexpected type of event
          break;
        }
    }
  catch(YACS::Exception& ex)
    {
      //unexpected exception: probably a bug in engine
      //try to keep a consistent global state
      DEBTRACE( "updateStateFrom: " << ex.what() );
      _errorDetails="Internal error: ";
      _errorDetails=_errorDetails + ex.what();
      setState(YACS::ERROR);
      exForwardFailed();
      return YACS::ABORT;
    }
  catch(...)
    {
      //unexpected exception: probably a bug in engine
      //try to keep a consistent global state
      setState(YACS::ERROR);
      exForwardFailed();
      return YACS::ABORT;
    }
}

YACS::Event ComposedNode::updateStateOnFailedEventFrom ( Node *  node, const Executor *  execInst  )

protectedvirtual

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

Reimplemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::DynParaLoop, YACS::ENGINE::OptimizerLoop, and YACS::ENGINE::Bloc.

Definition at line 1437 of file ComposedNode.cxx.

References YACS::ABORT, YACS::FAILED, and YACS::ENGINE::Node::setState().

Referenced by updateStateFrom().

{
   setState(YACS::FAILED);
   return YACS::ABORT;
}

virtual YACS::Event YACS::ENGINE::ComposedNode::updateStateOnFinishedEventFrom ( Node *  node )

protectedpure virtual

Implemented in YACS::ENGINE::ForEachLoop, YACS::ENGINE::Switch, YACS::ENGINE::OptimizerLoop, YACS::ENGINE::Bloc, YACS::ENGINE::ForLoop, and YACS::ENGINE::WhileLoop.

Referenced by updateStateFrom().

YACS::Event ComposedNode::updateStateOnStartEventFrom ( Node *  node )

protectedvirtual

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

Update the ComposedNode state and return the ComposedNode change state

Parameters

node	: the child node that has started

Returns

the loop state change

Definition at line 1430 of file ComposedNode.cxx.

References YACS::ACTIVATED, YACS::ENGINE::Node::setState(), and YACS::START.

Referenced by updateStateFrom().

{
  setState(YACS::ACTIVATED);
  return YACS::START;
}

Friends And Related Function Documentation

friend class Bloc

friend

Definition at line 44 of file ComposedNode.hxx.

friend class ElementaryNode

friend

Definition at line 47 of file ComposedNode.hxx.

friend class Loop

friend

Definition at line 45 of file ComposedNode.hxx.

friend class OutPort

friend

Definition at line 46 of file ComposedNode.hxx.

Member Data Documentation

const unsigned char YACS::ENGINE::ComposedNode::FED_DS_ST = 1

staticprotected

Definition at line 173 of file ComposedNode.hxx.

Referenced by YACS::ENGINE::Bloc::checkCFLinks().

const unsigned char YACS::ENGINE::ComposedNode::FED_ST = 2

staticprotected

Definition at line 171 of file ComposedNode.hxx.

Referenced by YACS::ENGINE::ForLoop::checkCFLinks(), YACS::ENGINE::Bloc::checkCFLinks(), YACS::ENGINE::DynParaLoop::checkCFLinks(), YACS::ENGINE::Switch::checkCFLinks(), checkCFLinks(), solveObviousOrDelegateCFLinks(), YACS::ENGINE::Bloc::verdictForCollapses(), and YACS::ENGINE::Bloc::verdictForOkAndUseless1().

const unsigned char YACS::ENGINE::ComposedNode::FREE_ST = 0

staticprotected

Definition at line 172 of file ComposedNode.hxx.

Referenced by YACS::ENGINE::ForLoop::checkCFLinks(), YACS::ENGINE::Bloc::checkCFLinks(), YACS::ENGINE::DynParaLoop::checkCFLinks(), solveObviousOrDelegateCFLinks(), YACS::ENGINE::Bloc::verdictForCollapses(), and YACS::ENGINE::Bloc::verdictForOkAndUseless1().

const char ComposedNode::SEP_CHAR_BTW_LEVEL ="."

staticprotected

Definition at line 49 of file ComposedNode.hxx.

Referenced by getLowestCommonAncestorStr().

---

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

• src/engine/ComposedNode.hxx
• src/engine/ComposedNode.cxx