Base class for all schema objects. More...

#include <Proc.hxx>

Inheritance diagram for YACS::ENGINE::Proc:

[legend]

Collaboration diagram for YACS::ENGINE::Proc:

[legend]

Public Types
typedef std::map< std::string, Logger * >	LoggerMap

Public Member Functions
	Proc (const std::string &name)

virtual	~Proc ()

virtual TypeCode *	createType (const std::string &name, const std::string &kind)

virtual TypeCode *	createInterfaceTc (const std::string &id, const std::string &name, std::list< TypeCodeObjref * > ltc)
	Create an object reference TypeCode. More...

virtual TypeCode *	createSequenceTc (const std::string &id, const std::string &name, TypeCode *content)
	Create a sequence TypeCode. More...

virtual TypeCode *	createStructTc (const std::string &id, const std::string &name)

virtual TypeCode *	getTypeCode (const std::string &name)

virtual void	setTypeCode (const std::string &name, TypeCode *t)

virtual Container *	createContainer (const std::string &name, const std::string &kind="")
	Create a new Container and store it in containerMap. More...

virtual ComponentInstance *	createComponentInstance (const std::string &componame, const std::string &name="", const std::string &kind="")
	Create a new ComponentInstance and add it into componentInstanceMap. More...

virtual void	addComponentInstance (ComponentInstance *inst, const std::string &name="", bool resetCtr=false)
	Add a ComponentInstance into componentInstanceMap. More...

virtual void	removeComponentInstance (ComponentInstance *inst)
	Remove a componentInstance from the componentInstanceMap. More...

virtual void	removeContainer (Container *cont)
	Remove a container from the containerMap. More...

virtual void	accept (Visitor *visitor)

virtual Proc *	getProc ()
	Return the proc (this) More...

virtual const Proc *	getProc () const
	Return the proc (this) More...

virtual void	updateContainersAndComponents ()

YACS::StatesForNode	getNodeState (int numId)

std::string	getNodeProgress (int numId)

int	getGlobalProgressPercent ()

std::string	getInPortValue (int nodeNumId, std::string portName)

std::string	setInPortValue (std::string nodeName, std::string portName, std::string value)

std::string	getOutPortValue (int nodeNumId, std::string portName)

std::string	getNodeErrorDetails (int nodeNumId)

std::string	getNodeErrorReport (int nodeNumId)

std::string	getNodeContainerLog (int nodeNumId)

std::string	getXMLState (int numId)

std::list< int >	getNumIds ()

std::list< std::string >	getIds ()

virtual Logger *	getLogger (const std::string &name)

virtual void	writeDot (std::ostream &os) const
	Dump to the input stream a dot representation of the node. More...

void	setName (const std::string &name)

virtual std::string	typeName ()

virtual bool	getEdition ()

virtual void	setEdition (bool edition)

virtual void	modified ()
	Sets Proc in modified state and update state if in edition mode. More...

virtual void	saveSchema (const std::string &xmlSchemaFile)
	Save Proc in XML schema file. More...

virtual void	saveState (const std::string &xmlStateFile)
	Save Proc state in XML state file. More...

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

	Bloc (const std::string &name)
	Create a Bloc node with a given name. More...

virtual	~Bloc ()

bool	isFinished ()
	Indicate if the bloc execution is finished. More...

int	getNumberOfCFLinks () const

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

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

void	exUpdateState ()
	Update the bloc state. More...

bool	edAddChild (Node *DISOWNnode)
	Add a child node to the bloc. More...

void	edRemoveChild (Node *node)

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

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

std::vector< std::list< Node * > >	splitIntoIndependantGraph () const

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

virtual void	writeDot (std::ostream &os) const
	Dump to the input stream a dot representation of the node. More...

void	accept (Visitor *visitor)

template<bool direction>
void	findAllPathsStartingFrom (Node start, std::list< std::vector< Node > > &vec, std::map< Node , std::set< Node > > &accelStr) const

template<bool direction>
void	findAllNodesStartingFrom (Node start, std::set< Node > &result, std::map< Node , std::set< Node > > &accelStr, LinkInfo &info) const

virtual std::string	typeName ()

int	getMaxLevelOfParallelism () const

void	getWeightRegardingDPL (ComplexWeight *weight)

void	removeRecursivelyRedundantCL ()

void	partitionRegardingDPL (const PartDefinition pd, std::map< ComposedNode , YACS::BASES::AutoRefCnt< PartDefinition > > &zeMap)

void	fitToPlayGround (const PlayGround *pg)

void	propagePlayGround (const PlayGround *pg)

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

bool	isMultiplicitySpecified (unsigned &value) const

void	forceMultiplicity (unsigned value)

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

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

bool	isFinished ()

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
	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)
	Add a dataflow link between two data ports. More...

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

virtual bool	edAddChild (Node *DISOWNnode)

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

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

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

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

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

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

virtual bool	isRepeatedUnpredictablySeveralTimes () const

virtual bool	isLoop () 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
	Get the input port name. More...

std::string	getOutPortName (const OutPort *) const

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

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

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

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

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

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

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

void	checkConsistency (LinkInfo &info) const

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

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

ComposedNode *	getRootNode () const

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

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

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

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

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

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

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

virtual void	init (bool start=true)

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

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

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...

void	writeDotInFile (const std::string &fileName) const

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

virtual std::list< ElementaryNode * >	getRecursiveConstituents () const =0

virtual std::list< ProgressWeight >	getProgressWeight () const =0

virtual int	getNumberOfInputPorts () const =0

virtual int	getNumberOfOutputPorts () const =0

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

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

virtual std::list< InputPort * >	getSetOfInputPort () const =0

virtual std::list< OutputPort * >	getSetOfOutputPort () const =0

virtual std::list< InputPort * >	getLocalInputPorts () const =0

virtual std::list< OutputPort * >	getLocalOutputPorts () const =0

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...

virtual std::string	getInPortName (const InPort *) const =0

virtual std::string	getOutPortName (const OutPort *) const =0

virtual std::list< InputDataStreamPort * >	getSetOfInputDataStreamPort () const =0

virtual std::list< OutputDataStreamPort * >	getSetOfOutputDataStreamPort () const =0

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

InPropertyPort *	getInPropertyPort () const

virtual OutPort *	getOutPort (const std::string &name) const

virtual std::set< OutPort * >	getAllOutPortsLeavingCurrentScope () const =0

virtual std::set< InPort * >	getAllInPortsComingFromOutsideOfCurrentScope () const =0

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

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

virtual InputPort *	getInputPort (const std::string &name) const

virtual OutputPort *	getOutputPort (const std::string &name) const =0

virtual InputDataStreamPort *	getInputDataStreamPort (const std::string &name) const =0

virtual OutputDataStreamPort *	getOutputDataStreamPort (const std::string &name) const =0

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

bool	operator> (const Node &other) const

bool	operator< (const Node &other) const

std::string	getImplementation () const

DynParaLoop *	getClosestDPLAmongAncestors () const

virtual ComposedNode *	getRootNode () 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 Node *	getChildByName (const std::string &name) const =0

virtual Proc *	getProc ()

virtual const Proc *	getProc () const

virtual void	accept (Visitor *visitor)=0

virtual int	getMaxLevelOfParallelism () const =0

virtual void	getWeightRegardingDPL (ComplexWeight *weight)=0

virtual void	partitionRegardingDPL (const PartDefinition pd, std::map< ComposedNode , YACS::BASES::AutoRefCnt< PartDefinition > > &zeMap)=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	typeName ()

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 void	edUpdateState ()
	update the status of the node More...

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

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)

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

Public Member Functions inherited from YACS::ENGINE::Scheduler
virtual void	init (bool start=true)=0

virtual bool	isFinished ()=0

virtual void	exUpdateState ()=0

virtual std::string	getName () const =0

virtual std::string	getTaskName (Task *task) const =0

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

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

virtual void	notifyFrom (const Task sender, YACS::Event event, const Executor execInst)=0

virtual DeploymentTree	getDeploymentTree () const =0

virtual bool	isPlacementPredictableB4Run () const =0

virtual bool	isMultiplicitySpecified (unsigned &value) const =0

virtual void	forceMultiplicity (unsigned value)=0

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

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

virtual	~Scheduler ()

Public Attributes
std::map< std::string, Node * >	nodeMap

std::map< std::string, ServiceNode * >	serviceMap

std::map< std::string, InlineNode * >	inlineMap

std::map< std::string, TypeCode * >	typeMap

std::map< std::string, Container * >	containerMap

std::map< std::string, ComponentInstance * >	componentInstanceMap

std::vector< std::string >	names

LoggerMap	_loggers

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

Protected Member Functions
void	removeContainers ()

Protected Member Functions inherited from YACS::ENGINE::Bloc
Node *	simpleClone (ComposedNode *father, bool editionOnly=true) const

bool	areAllSubNodesFinished () const

bool	areAllSubNodesDone () const

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

void	checkNoCyclePassingThrough (Node *node)

std::vector< std::pair< OutGate , InGate > >	getSetOfInternalCFLinks () const

YACS::Event	updateStateOnFinishedEventFrom (Node *node)

YACS::Event	updateStateOnFailedEventFrom (Node node, const Executor execInst)
	Notify this bloc that a node has failed. More...

void	initComputation () const

void	performCFComputationsOnlyOneLevel (LinkInfo &info) const

void	performCFComputations (LinkInfo &info) const

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

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

bool	areLinked (Node start, Node end, bool fw) const
	Check if two nodes are linked. More...

bool	arePossiblyRunnableAtSameTime (Node start, Node end) const
	Check if two nodes can run in parallel. More...

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

void	seekOkAndUseless1 (std::vector< Node * > &okAndUseless1, std::set< Node * > &allNodes) const

void	seekUseless2 (std::vector< Node * > &useless2, std::set< Node * > &allNodes) const

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

	StaticDefinedComposedNode (const StaticDefinedComposedNode &other, ComposedNode *father)

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

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

	ComposedNode (const ComposedNode &other, ComposedNode *father)

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

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

void	edDisconnectAllLinksWithMe ()

virtual Node *	getChildByShortName (const std::string &name) const =0

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)

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)

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

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

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

virtual void	checkNoCyclePassingThrough (Node *node)=0

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

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

void	checkNoCrossHierachyWith (Node *node) const

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

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 void	performDuplicationOfPlacement (const Node &other)=0
	performs a duplication of placement using clone method of containers and components. clone behaviour is driven by attachOnCloning attribute. More...

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

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

virtual void	exForwardFailed ()

virtual void	exForwardFinished ()

virtual void	edDisconnectAllLinksWithMe ()

Protected Attributes
bool	_edition

int	_compoinstctr

Protected Attributes inherited from YACS::ENGINE::Bloc
std::list< Node * >	_setOfNode

std::map< Node , std::set< Node > > *	_fwLinks
	For internal calculations. More...

std::map< Node , std::set< Node > > *	_bwLinks
	For internal calculations. More...

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

Node *	_eventReceiver =nullptr

Friends
std::ostream &	operator<< (std::ostream &os, const Proc &p)

Additional Inherited Members
Static Public Member Functions inherited from YACS::ENGINE::ComposedNode
static ComposedNode *	getLowestCommonAncestor (Node node1, Node node2)
	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...

static void	checkValidityOfNodeName (const std::string &name)

Static Public Attributes inherited from YACS::ENGINE::ComposedNode
static const char	SEP_CHAR_BTW_LEVEL [] ="."

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

Static Protected Member Functions inherited from YACS::ENGINE::Bloc
static void	verdictForOkAndUseless1 (const std::map< Node , std::list< OutPort > > &pool, InputPort end, const std::vector< Node > &candidates, unsigned char &alreadyFed, bool direction, LinkInfo &info)

static void	verdictForCollapses (const std::map< Node , std::list< OutPort > > &pool, InputPort end, const std::set< Node > &candidates, unsigned char &alreadyFed, bool direction, LinkInfo &info)

Static Protected Member Functions inherited from YACS::ENGINE::ComposedNode
static bool	splitNamesBySep (const std::string &globalName, const char separator[], std::string &firstPart, std::string &lastPart, bool priority)
	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)

static ComposedNode *	checkHavingCommonFather (Node node1, Node node2)

Static Protected Attributes inherited from YACS::ENGINE::ComposedNode
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

Detailed Description

Base class for all schema objects.

This is an abstract class that must be specialized in runtime.

Definition at line 43 of file Proc.hxx.

Member Typedef Documentation

◆ LoggerMap

typedef std::map<std::string, Logger*> YACS::ENGINE::Proc::LoggerMap

Definition at line 95 of file Proc.hxx.

Constructor & Destructor Documentation

◆ Proc()

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

Definition at line 48 of file Proc.cxx.

                               :Bloc(name),_edition(false),_compoinstctr(0)
{
  Runtime *theRuntime=getRuntime();
  DEBTRACE("theRuntime->_tc_double->ref: " << theRuntime->_tc_double->getRefCnt());
  DEBTRACE("theRuntime->_tc_int->ref: " << theRuntime->_tc_int->getRefCnt());
  DEBTRACE("theRuntime->_tc_string->ref: " << theRuntime->_tc_string->getRefCnt());
  DEBTRACE("theRuntime->_tc_bool->ref: " << theRuntime->_tc_bool->getRefCnt());
  DEBTRACE("theRuntime->_tc_file->ref: " << theRuntime->_tc_file->getRefCnt());
  theRuntime->_tc_double->incrRef();
  theRuntime->_tc_string->incrRef();
  theRuntime->_tc_int->incrRef();
  theRuntime->_tc_bool->incrRef();
  theRuntime->_tc_file->incrRef();
  typeMap["double"]=theRuntime->_tc_double;
  typeMap["string"]=theRuntime->_tc_string;
  typeMap["int"]=theRuntime->_tc_int;
  typeMap["bool"]=theRuntime->_tc_bool;
  typeMap["file"]=theRuntime->_tc_file;
}

References YACS::ENGINE::Runtime::_tc_bool, YACS::ENGINE::Runtime::_tc_double, YACS::ENGINE::Runtime::_tc_file, YACS::ENGINE::Runtime::_tc_int, YACS::ENGINE::Runtime::_tc_string, DEBTRACE, YACS::ENGINE::RefCounter::getRefCnt(), YACS::ENGINE::getRuntime(), YACS::ENGINE::RefCounter::incrRef(), theRuntime, and typeMap.

◆ ~Proc()

Proc::~Proc ( )

virtual

Definition at line 68 of file Proc.cxx.

{
  DEBTRACE("Proc::~Proc");
  //for the moment all nodes are owned, so no need to manage their destruction
  //nodeMap, inlineMap, serviceMap will be cleared automatically
  //but we need to destroy TypeCodes
  std::map<std::string, TypeCode *>::iterator pt;
  for(pt=typeMap.begin();pt!=typeMap.end();pt++)
    ((*pt).second)->decrRef();
 
  removeContainers();
 
  //get rid of loggers in logger map
  std::map<std::string, Logger*>::const_iterator lt;
  for(lt=_loggers.begin();lt!=_loggers.end();lt++)
    delete (*lt).second;
}

References _loggers, DEBTRACE, removeContainers(), and typeMap.

Member Function Documentation

◆ accept()

void Proc::accept ( Visitor * visitor )

virtual

Reimplemented from YACS::ENGINE::Bloc.

Definition at line 199 of file Proc.cxx.

{
  visitor->visitProc(this);
}

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

Referenced by dumpState(), Handler(), main(), YACS::ENGINE::SchemaSave::save(), saveSchema(), YACS::ENGINE::SalomeProc::saveSchema(), saveState(), and YACS::ENGINE::schemaSaveStateUnsafe().

◆ addComponentInstance()

void Proc::addComponentInstance	(	ComponentInstance *	inst,
		const std::string &	name = `""`,
		bool	resetCtr = `false`
	)

virtual

Add a ComponentInstance into componentInstanceMap.

If the name == "", the component instance is automatically named with a unique (in the Proc) name

Parameters

inst	the component instance
name	the component instance name
resetCtr	try to reuse instance number previously released, false by default

Definition at line 526 of file Proc.cxx.

{
  if(name != "")
    {
      inst->setName(name);
      inst->setAnonymous(false);
      if(componentInstanceMap.count(name)!=0)
        componentInstanceMap[name]->decrRef();
      componentInstanceMap[name]=inst;
      inst->incrRef();
    }
  else
    {
      //automatic naming : componame_<_compoinstctr>
      std::string instname;
      std::string componame=inst->getCompoName();
      if (resetCtr)
        _compoinstctr = 0;        
      while(1)
        {
          std::ostringstream buffer;
          buffer << ++_compoinstctr;
          instname=componame+"_"+buffer.str();
          if(componentInstanceMap.count(instname)==0)
            {
              inst->setName(instname);
              componentInstanceMap[instname]=inst;
              inst->incrRef();
              break;
            }
        }
    }
}

References _compoinstctr, componentInstanceMap, YACS::ENGINE::ComponentInstance::getCompoName(), YACS::ENGINE::RefCounter::incrRef(), YACS::ENGINE::ComponentInstance::setAnonymous(), and YACS::ENGINE::ComponentInstance::setName().

Referenced by createComponentInstance(), YACS::HMI::CommandAddComponentInstance::localExecute(), YACS::HMI::CommandAddComponentFromCatalog::localExecute(), and YACS::HMI::CommandAssociateServiceToComponent::localReverse().

◆ createComponentInstance()

ComponentInstance * Proc::createComponentInstance	(	const std::string &	componame,
		const std::string &	name = `""`,
		const std::string &	kind = `""`
	)

virtual

Create a new ComponentInstance and add it into componentInstanceMap.

If the name == "", the component instance is automatically named with a unique (in the Proc) name

Parameters

componame	the component name
name	the component instance name
kind	the component instance kind (depends on runtime)

Returns: the created ComponentInstance

Definition at line 599 of file Proc.cxx.

{
  ComponentInstance* inst=  getRuntime()->createComponentInstance(componame,kind);
  addComponentInstance(inst,name);
  return inst;
}

References addComponentInstance(), YACS::ENGINE::Runtime::createComponentInstance(), and YACS::ENGINE::getRuntime().

Referenced by YACS::servicetypeParser< T >::component(), and YACS::proctypeParser< T >::componentinstance().

◆ createContainer()

Container * Proc::createContainer	(	const std::string &	name,
		const std::string &	kind = `""`
	)

virtual

Create a new Container and store it in containerMap.

Parameters

name	the container name and key in containerMap
kind	the container kind (depends on runtime)

Returns: the created Container

Definition at line 506 of file Proc.cxx.

{
  Container *co(getRuntime()->createContainer(kind));
  co->setName(name);
  if(containerMap.count(name)!=0)
    containerMap[name]->decrRef();
  containerMap[name]=co;
  co->incrRef();
  co->setProc(this);
  return co;
}

References containerMap, createContainer(), YACS::ENGINE::getRuntime(), YACS::ENGINE::RefCounter::incrRef(), YACS::ENGINE::Container::setName(), and YACS::ENGINE::Container::setProc().

Referenced by YACS::proctypeParser< T >::container(), createContainer(), YACS::servertypeParser< T >::loadcontainer(), and YACS::ENGINE::SalomeProc::SalomeProc().

◆ createInterfaceTc()

TypeCode * Proc::createInterfaceTc	(	const std::string &	id,
		const std::string &	name,
		std::list< TypeCodeObjref * >	ltc
	)

virtual

Create an object reference TypeCode.

Parameters

id	the TypeCode repository id
name	the TypeCode name
ltc	a liste of object reference TypeCode to use as base types for this type

Returns: the created TypeCode

Reimplemented in YACS::ENGINE::SalomeProc.

Definition at line 132 of file Proc.cxx.

{
  TypeCode* t = TypeCode::interfaceTc(id.c_str(),name.c_str(),ltc);
  if(typeMap.count(name)!=0)
    typeMap[name]->decrRef();
  typeMap[name]=t;
  t->incrRef();
  return t;
}

References YACS::ENGINE::TypeCode::interfaceTc(), gui.Appli::t, and typeMap.

Referenced by YACS::ENGINE::SalomeProc::createInterfaceTc(), and YACS::objtypeParser::post().

◆ createSequenceTc()

TypeCode * Proc::createSequenceTc	(	const std::string &	id,
		const std::string &	name,
		TypeCode *	content
	)

virtual

Create a sequence TypeCode.

Parameters

id	the TypeCode repository id ("" for normal use)
name	the TypeCode name
content	the element TypeCode

Returns: the created TypeCode

Definition at line 150 of file Proc.cxx.

{
  TypeCode* t = TypeCode::sequenceTc(id.c_str(),name.c_str(),content);
  if(typeMap.count(name)!=0)
    typeMap[name]->decrRef();
  typeMap[name]=t;
  t->incrRef();
  return t;
}

References YACS::ENGINE::TypeCode::sequenceTc(), gui.Appli::t, and typeMap.

Referenced by YACS::seqtypeParser::post().

◆ createStructTc()

TypeCode * Proc::createStructTc	(	const std::string &	id,
		const std::string &	name
	)

virtual

Reimplemented in YACS::ENGINE::SalomeProc.

Definition at line 161 of file Proc.cxx.

{
  TypeCode* t = TypeCode::structTc(id.c_str(),name.c_str());
  if(typeMap.count(name)!=0)
    typeMap[name]->decrRef();
  typeMap[name]=t;
  t->incrRef();
  return t;
}

References YACS::ENGINE::TypeCode::structTc(), gui.Appli::t, and typeMap.

Referenced by YACS::ENGINE::SalomeProc::createStructTc(), and YACS::structtypeParser::post().

◆ createType()

TypeCode * Proc::createType	(	const std::string &	name,
		const std::string &	kind
	)

virtual

Definition at line 103 of file Proc.cxx.

{
  TypeCode* t;
  if(kind=="double")
    t=getRuntime()->_tc_double;
  else if(kind=="string")
    t=getRuntime()->_tc_string;
  else if(kind=="int")
    t=getRuntime()->_tc_int;
  else if(kind=="bool")
    t=getRuntime()->_tc_bool;
  else
    throw Exception("Unknown kind");
 
  if(typeMap.count(name)!=0)
    typeMap[name]->decrRef();
  t->incrRef();
  typeMap[name]=t;
  t->incrRef();
  return t;
}

References YACS::ENGINE::Runtime::_tc_bool, YACS::ENGINE::Runtime::_tc_double, YACS::ENGINE::Runtime::_tc_int, YACS::ENGINE::Runtime::_tc_string, YACS::ENGINE::getRuntime(), gui.Appli::t, and typeMap.

Referenced by YACS::proctypeParser< T >::type().

◆ getEdition()

virtual bool YACS::ENGINE::Proc::getEdition ( )

inlinevirtual

Definition at line 97 of file Proc.hxx.

97{return _edition;}

◆ getGlobalProgressPercent()

int Proc::getGlobalProgressPercent ( )

Definition at line 234 of file Proc.cxx.

{
  list<ProgressWeight> weightList = getProgressWeight();
  int weightDone = 0;
  int weightTotal = 0;
  int progressPercent = 0;
  for(list<ProgressWeight>::const_iterator iter=weightList.begin();iter!=weightList.end();iter++)
    {
      weightDone += (*iter).weightDone;
      weightTotal += (*iter).weightTotal;
    }
  if (weightTotal > 0)
    progressPercent = int(float(weightDone) / float(weightTotal) * 100);
  return progressPercent;
}

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

◆ getIds()

std::list< std::string > Proc::getIds ( )

Definition at line 417 of file Proc.cxx.

{
  list<YACS::ENGINE::Node *> nodes = getAllRecursiveConstituents();
  int len = nodes.size();
  list<string> ids;
  for( list<YACS::ENGINE::Node *>::const_iterator iter = nodes.begin();
       iter != nodes.end(); iter++)
    {
      ids.push_back(getChildName(*iter));
    }
  ids.push_back("_root_");
  return ids;
}

References YACS::ENGINE::ComposedNode::getAllRecursiveConstituents(), and YACS::ENGINE::ComposedNode::getChildName().

◆ getInPortValue()

std::string Proc::getInPortValue	(	int	nodeNumId,
		std::string	portName
	)

Definition at line 265 of file Proc.cxx.

{
  DEBTRACE("Proc::getInPortValue " << nodeNumId << " " << portName);
  stringstream msg;
  if(YACS::ENGINE::Node::idMap.count(nodeNumId) == 0)
    {
      msg << "<value><error>unknown node id: " << nodeNumId << "</error></value>";
      return msg.str();
    }
  try
    {
      YACS::ENGINE::Node* node = YACS::ENGINE::Node::idMap[nodeNumId];
      InputPort * inputPort = node->getInputPort(portName);
      return inputPort->getAsString();
    }
  catch(YACS::Exception& ex)
    {
      DEBTRACE("Proc::getInPortValue " << ex.what());
      msg << "<value><error>" << ex.what() << "</error></value>";
      return msg.str();
    }
}

References DEBTRACE, testCppPluginInvokation::ex, YACS::ENGINE::DataPort::getAsString(), YACS::ENGINE::Node::getInputPort(), and YACS::ENGINE::Node::idMap.

Referenced by YACS::HMI::GuiExecutor::updateSchema().

◆ getLogger()

Logger * Proc::getLogger ( const std::string & name )

virtual

Definition at line 431 of file Proc.cxx.

{
  Logger* logger;
  LoggerMap::const_iterator it = _loggers.find(name);
 
  if (it != _loggers.end())
  {
    logger = it->second;
  }
  else
  {
    logger = new Logger(name);
    _loggers[name]=logger;
  }
  return logger;
}

References _loggers.

Referenced by YACS::YACSLoader::load(), YACS::ENGINE::ProcCataLoader::loadCata(), YACS::HMI::GenericGui::loadSchema(), YACS::parser::logError(), main(), YACS::HMI::GenericGui::onImportSchema(), YACS::HMI::GenericGui::onImportSupervSchema(), YACS::HMI::GenericGui::onLoadAndRunSchema(), YACS::HMI::EditionProc::synchronize(), and YACS::HMI::BatchJobsListDialog::userOK().

◆ getNodeContainerLog()

std::string Proc::getNodeContainerLog ( int nodeNumId )

Definition at line 390 of file Proc.cxx.

{
  DEBTRACE("Proc::getNodeContainerLog " << nodeNumId);
  stringstream msg;
  if(YACS::ENGINE::Node::idMap.count(nodeNumId) == 0)
    {
      msg << "Unknown node id " << nodeNumId;
      return msg.str();
    }
  YACS::ENGINE::Node* node = YACS::ENGINE::Node::idMap[nodeNumId];
  return node->getContainerLog();
}

References DEBTRACE, YACS::ENGINE::Node::getContainerLog(), and YACS::ENGINE::Node::idMap.

◆ getNodeErrorDetails()

std::string Proc::getNodeErrorDetails ( int nodeNumId )

Definition at line 364 of file Proc.cxx.

{
  DEBTRACE("Proc::getNodeErrorDetails " << nodeNumId);
  stringstream msg;
  if(YACS::ENGINE::Node::idMap.count(nodeNumId) == 0)
    {
      msg << "Unknown node id " << nodeNumId;
      return msg.str();
    }
  YACS::ENGINE::Node* node = YACS::ENGINE::Node::idMap[nodeNumId];
  return node->getErrorDetails();
}

References DEBTRACE, YACS::ENGINE::Node::getErrorDetails(), and YACS::ENGINE::Node::idMap.

◆ getNodeErrorReport()

std::string Proc::getNodeErrorReport ( int nodeNumId )

Definition at line 377 of file Proc.cxx.

{
  DEBTRACE("Proc::getNodeErrorReport " << nodeNumId);
  stringstream msg;
  if(YACS::ENGINE::Node::idMap.count(nodeNumId) == 0)
    {
      msg << "Unknown node id " << nodeNumId;
      return msg.str();
    }
  YACS::ENGINE::Node* node = YACS::ENGINE::Node::idMap[nodeNumId];
  return node->getErrorReport();
}

References DEBTRACE, YACS::ENGINE::Node::getErrorReport(), and YACS::ENGINE::Node::idMap.

◆ getNodeProgress()

std::string Proc::getNodeProgress ( int numId )

Definition at line 222 of file Proc.cxx.

{
  std::string progress = "0";
  if(YACS::ENGINE::Node::idMap.count(numId) == 0)
    {
      cerr << "Unknown node id " << numId << endl;
    }
  else if (YACS::ENGINE::ComposedNode* node = dynamic_cast<YACS::ENGINE::ComposedNode*>(YACS::ENGINE::Node::idMap[numId]))
    progress = node->getProgress();
  return progress;
}

References YACS::ENGINE::Node::idMap.

◆ getNodeState()

YACS::StatesForNode Proc::getNodeState ( int numId )

Definition at line 210 of file Proc.cxx.

{
  if(YACS::ENGINE::Node::idMap.count(numId) == 0)
    {
      cerr << "Unknown node id " << numId << endl;
      return YACS::UNDEFINED;
    }
  YACS::ENGINE::Node* node = YACS::ENGINE::Node::idMap[numId];
  YACS::StatesForNode state = node->getEffectiveState();
  return state;
}

References YACS::ENGINE::Node::getEffectiveState(), YACS::ENGINE::Node::idMap, yacsorb.CORBAEngineTest::state, and YACS::UNDEFINED.

Referenced by YACS::HMI::GuiExecutor::updateSchema().

◆ getNumIds()

std::list< int > Proc::getNumIds ( )

Definition at line 403 of file Proc.cxx.

{
  list<YACS::ENGINE::Node *> nodes = getAllRecursiveConstituents();
  int len = nodes.size();
  list<int> numids;
  for( list<YACS::ENGINE::Node *>::const_iterator iter = nodes.begin();
       iter != nodes.end(); iter++)
    {
      numids.push_back((*iter)->getNumId());
    }
  numids.push_back(this->getNumId());
  return numids;
}

References YACS::ENGINE::ComposedNode::getAllRecursiveConstituents(), YACS::ENGINE::Node::getNumId(), and yacsorb.CORBAEngineTest::numids.

◆ getOutPortValue()

std::string Proc::getOutPortValue	(	int	nodeNumId,
		std::string	portName
	)

Definition at line 341 of file Proc.cxx.

{
  DEBTRACE("Proc::getOutPortValue " << nodeNumId << " " << portName);
  stringstream msg;
  if(YACS::ENGINE::Node::idMap.count(nodeNumId) == 0)
    {
      msg << "<value><error>unknown node id: " << nodeNumId << "</error></value>";
      return msg.str();
    }
  try
    {
      YACS::ENGINE::Node* node = YACS::ENGINE::Node::idMap[nodeNumId];
      OutputPort * outputPort = node->getOutputPort(portName);
      return outputPort->getAsString();
    }
  catch(YACS::Exception& ex)
    {
      DEBTRACE("Proc::getOutPortValue " << ex.what());
      msg << "<value><error>" << ex.what() << "</error></value>";
      return msg.str();
    }
}

References DEBTRACE, testCppPluginInvokation::ex, YACS::ENGINE::DataPort::getAsString(), YACS::ENGINE::Node::getOutputPort(), and YACS::ENGINE::Node::idMap.

Referenced by YACS::HMI::GuiExecutor::updateSchema().

◆ getProc() [1/2]

Proc * Proc::getProc ( )

virtual

Return the proc (this)

Reimplemented from YACS::ENGINE::Node.

Definition at line 607 of file Proc.cxx.

{
  return this;
}

◆ getProc() [2/2]

const Proc * Proc::getProc ( ) const

virtual

Return the proc (this)

Reimplemented from YACS::ENGINE::Node.

Definition at line 613 of file Proc.cxx.

{
  return this;
}

◆ getTypeCode()

TypeCode * Proc::getTypeCode ( const std::string & name )

virtual

Definition at line 171 of file Proc.cxx.

{
  TypeCode* aTC=0;
  if(typeMap.count(name)==0)
    aTC=getRuntime()->getTypeCode(name);
  else
    aTC=typeMap[name];
 
  if(!aTC)
    {
      std::stringstream msg;
      msg << "Type " << name << " does not exist" ;
      msg << " (" <<__FILE__ << ":" << __LINE__ << ")";
      throw Exception(msg.str());
    }
 
  return aTC;
}

References YACS::ENGINE::getRuntime(), YACS::ENGINE::Runtime::getTypeCode(), and typeMap.

◆ getXMLState()

std::string Proc::getXMLState ( int numId )

Definition at line 250 of file Proc.cxx.

{
  if(YACS::ENGINE::Node::idMap.count(numId) == 0)
    {
      cerr << "Unknown node id " << numId << endl;
      return "<state>unknown</state>";
    }
  YACS::ENGINE::Node* node = YACS::ENGINE::Node::idMap[numId];
  stringstream msg;
  msg << "<state>" << node->getEffectiveState() << "</state>";
  msg << "<name>" << node->getQualifiedName() << "</name>";
  msg << "<id>" << numId << "</id>";
  return msg.str();
}

References YACS::ENGINE::Node::getEffectiveState(), YACS::ENGINE::Node::getQualifiedName(), and YACS::ENGINE::Node::idMap.

◆ modified()

void Proc::modified ( )

virtual

Sets Proc in modified state and update state if in edition mode.

Reimplemented from YACS::ENGINE::Node.

Definition at line 459 of file Proc.cxx.

{
  DEBTRACE("Proc::modified() " << _edition);
  _modified=1;
  if(_edition)
    edUpdateState();
}

References _edition, YACS::ENGINE::Node::_modified, DEBTRACE, and YACS::ENGINE::ComposedNode::edUpdateState().

◆ removeComponentInstance()

void Proc::removeComponentInstance ( ComponentInstance * inst )

virtual

Remove a componentInstance from the componentInstanceMap.

To be used for a componentInstance with no service nodes referenced.

Parameters

inst	the component instance

Definition at line 566 of file Proc.cxx.

{
  if (componentInstanceMap.count(inst->getInstanceName()))
    {
      componentInstanceMap.erase(inst->getInstanceName());
      inst->decrRef();
    }
}

References componentInstanceMap, YACS::ENGINE::RefCounter::decrRef(), and YACS::ENGINE::ComponentInstance::getInstanceName().

Referenced by YACS::HMI::CommandAddComponentInstance::localReverse(), and YACS::HMI::CommandAddComponentFromCatalog::localReverse().

◆ removeContainer()

void Proc::removeContainer ( Container * cont )

virtual

Remove a container from the containerMap.

To be used for a container with no componentInstance referenced.

Parameters

cont	the container

Definition at line 581 of file Proc.cxx.

{
  if (containerMap.count(cont->getName()))
    {
      containerMap.erase(cont->getName());
      cont->decrRef();
    }
}

References containerMap, YACS::ENGINE::RefCounter::decrRef(), and YACS::ENGINE::Container::getName().

Referenced by YACS::HMI::SubjectContainerBase::~SubjectContainerBase().

◆ removeContainers()

void Proc::removeContainers ( )

protected

Definition at line 491 of file Proc.cxx.

{
  //get rid of containers in container map
  std::map<std::string, Container*>::const_iterator it;
  for(it=containerMap.begin();it!=containerMap.end();it++)
    ((*it).second)->decrRef();
  containerMap.clear();
}

References containerMap.

Referenced by updateContainersAndComponents(), and ~Proc().

◆ saveSchema()

void Proc::saveSchema ( const std::string & xmlSchemaFile )

virtual

Save Proc in XML schema file.

Parameters

xmlSchemaFile the file name

Definition at line 471 of file Proc.cxx.

{
  VisitorSaveSchema vss(this);
  vss.openFileSchema(xmlSchemaFile);
  accept(&vss);
  vss.closeFileSchema();
}

References accept(), YACS::ENGINE::VisitorSaveSchema::closeFileSchema(), and YACS::ENGINE::VisitorSaveSchema::openFileSchema().

◆ saveState()

void Proc::saveState ( const std::string & xmlStateFile )

virtual

Save Proc state in XML state file.

deprecated. See VisitorSalomeSaveState and schemaSaveState in order to deal with the execution state of ForEachLoop.

Parameters

xmlStateFile the file name

Definition at line 483 of file Proc.cxx.

{
  VisitorSaveState vst(this);
  vst.openFileDump(xmlStateFile);
  accept(&vst);
  vst.closeFileDump();
}

References accept(), YACS::ENGINE::VisitorSaveState::closeFileDump(), and YACS::ENGINE::VisitorSaveState::openFileDump().

◆ setEdition()

void Proc::setEdition ( bool edition )

virtual

Definition at line 448 of file Proc.cxx.

{
  DEBTRACE("Proc::setEdition: " << edition);
  _edition=edition;
  if(_edition)
    edUpdateState();
}

References _edition, DEBTRACE, and YACS::ENGINE::ComposedNode::edUpdateState().

Referenced by YACS::HMI::GenericGui::createContext(), and YACS::HMI::QtGuiContext::~QtGuiContext().

◆ setInPortValue()

std::string Proc::setInPortValue	(	std::string	nodeName,
		std::string	portName,
		std::string	value
	)

Definition at line 288 of file Proc.cxx.

{
  DEBTRACE("Proc::setInPortValue " << nodeName << " " << portName << " " << value);
 
  try
    {
      YACS::ENGINE::Node* node = YACS::ENGINE::Proc::nodeMap[nodeName];
      YACS::ENGINE::InputPort* inputPort = node->getInputPort(portName);
 
      switch (inputPort->edGetType()->kind())
        {
          case Double:
            {
              double val = atof(value.c_str());
              inputPort->edInit(val);
            }
            break;
          case Int:
            {
              int val = atoi(value.c_str());
              inputPort->edInit(val);
            }
            break;
          case String:
            inputPort->edInit(value.c_str());
            break;
          case Bool:
            {
              if((!value.compare("False")) || (!value.compare("false")))
                inputPort->edInit(false);
              else if ((!value.compare("True")) || (!value.compare("true")))
                inputPort->edInit(true);
              else
              {
                int val = atoi(value.c_str());
                inputPort->edInit(val);
              }
            }
            break;
          default:
            DEBTRACE("Proc::setInPortValue: filtered type: " << inputPort->edGetType()->kind());
        }
      return value;
    }
  catch(YACS::Exception& ex)
    {
      DEBTRACE("Proc::setInPortValue " << ex.what());
      stringstream msg;
      msg << "<value><error>" << ex.what() << "</error></value>";
      return msg.str();
    }
}

References YACS::ENGINE::Bool, DEBTRACE, YACS::ENGINE::Double, YACS::ENGINE::DataPort::edGetType(), YACS::ENGINE::InputPort::edInit(), testCppPluginInvokation::ex, YACS::ENGINE::Node::getInputPort(), YACS::ENGINE::Int, YACS::ENGINE::TypeCode::kind(), nodeMap, and YACS::ENGINE::String.

Referenced by main().

◆ setName()

void Proc::setName ( const std::string & name )

Definition at line 204 of file Proc.cxx.

{
  Node::checkValidityOfNodeName(name);
  _name = name;
}

References YACS::ENGINE::Node::_name, and YACS::ENGINE::Node::checkValidityOfNodeName().

Referenced by YACS::proctypeParser< T >::name().

◆ setTypeCode()

void Proc::setTypeCode	(	const std::string &	name,
		TypeCode *	t
	)

virtual

Definition at line 190 of file Proc.cxx.

{
  if(typeMap.count(name)!=0)
    typeMap[name]->decrRef();
  typeMap[name]=t;
  t->incrRef();
}

References gui.Appli::t, and typeMap.

◆ typeName()

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

inlinevirtual

Reimplemented from YACS::ENGINE::Bloc.

Reimplemented in YACS::ENGINE::SalomeProc.

Definition at line 84 of file Proc.hxx.

84{return "YACS__ENGINE__Proc";}

Referenced by YACS::ENGINE::DistributedPythonNode::execute().

◆ updateContainersAndComponents()

void Proc::updateContainersAndComponents ( )

virtual

This method is useful if this has been modified recursively and an update is needed between all the containers and components refered by children and little children and maps.

Definition at line 622 of file Proc.cxx.

{
  std::map<std::string, Container*> myContainerMap;
  std::map<std::string, ComponentInstance*> myComponentInstanceMap;
  DeploymentTree treeToDup(getDeploymentTree());
  vector<Container *> conts(treeToDup.getAllContainers());
  for(vector<Container *>::const_iterator iterCt=conts.begin();iterCt!=conts.end();iterCt++)
    {
      Container *tmp(*iterCt);
      if(tmp)
        {
          if(myContainerMap.find(tmp->getName())!=myContainerMap.end())
            {
              std::ostringstream oss; oss << "Proc::updateContainersAndComponents : more than one container instance with name \"" << tmp->getName() << "\" !";
              throw YACS::Exception(oss.str());
            }
          myContainerMap[tmp->getName()]=tmp;
          tmp->incrRef();
        }
      vector<ComponentInstance *> comps=treeToDup.getComponentsLinkedToContainer(*iterCt);
      for(vector<ComponentInstance *>::iterator iterCp=comps.begin();iterCp!=comps.end();iterCp++)
        {
          ComponentInstance *tmp2(*iterCp);
          if(tmp2)
            {
              if(myComponentInstanceMap.find(tmp2->getCompoName())!=myComponentInstanceMap.end())
                {
                  std::ostringstream oss; oss << "Proc::updateContainersAndComponents : more than one component instance with name \"" << tmp2->getCompoName() << "\" !";
                  throw YACS::Exception(oss.str());
                }
            }
          myComponentInstanceMap[tmp2->getCompoName()]=tmp2;
          tmp2->incrRef();
        }
    }
  removeContainers();
  containerMap=myContainerMap;
  componentInstanceMap=myComponentInstanceMap;
}

References componentInstanceMap, containerMap, YACS::ENGINE::DeploymentTree::getAllContainers(), YACS::ENGINE::ComponentInstance::getCompoName(), YACS::ENGINE::DeploymentTree::getComponentsLinkedToContainer(), YACS::ENGINE::ComposedNode::getDeploymentTree(), YACS::ENGINE::Container::getName(), YACS::ENGINE::RefCounter::incrRef(), and removeContainers().

◆ writeDot()

void Proc::writeDot ( std::ostream & os ) const

virtual

Dump to the input stream a dot representation of the node.

Parameters

os	: the input stream

Reimplemented from YACS::ENGINE::Bloc.

Definition at line 86 of file Proc.cxx.

{
  os << "digraph " << getQualifiedName() << " {\n" ;
  os << "node [ style=\"filled\" ];\n" ;
  os << "compound=true;";
  os << "states [label=< <TABLE> <TR> <TD BGCOLOR=\"pink\" > Ready</TD> <TD BGCOLOR=\"magenta\" > Toload</TD> </TR> <TR> <TD BGCOLOR=\"magenta\" > Loaded</TD> <TD BGCOLOR=\"purple\" > Toactivate</TD> </TR> <TR> <TD BGCOLOR=\"blue\" > Activated</TD> <TD BGCOLOR=\"green\" > Done</TD> </TR> <TR> <TD BGCOLOR=\"red\" > Error</TD> <TD BGCOLOR=\"orange\" > Failed</TD> </TR> <TR> <TD BGCOLOR=\"grey\" > Disabled</TD> <TD BGCOLOR=\"white\" > Pause</TD> </TR> </TABLE>> \n shape = plaintext \n style = invis \n ];\n";
 
  Bloc::writeDot(os);
  os << "}\n" ;
}

References YACS::ENGINE::Node::getQualifiedName(), and YACS::ENGINE::Bloc::writeDot().

Referenced by driverTest(), and main().

Friends And Related Function Documentation

◆ operator<<

std::ostream & operator<<	(	std::ostream &	os,
		const Proc &	p
	)

friend

Definition at line 97 of file Proc.cxx.

{
  os << "Proc" ;
  return os;
}

Member Data Documentation

◆ _compoinstctr

int YACS::ENGINE::Proc::_compoinstctr

protected

Definition at line 108 of file Proc.hxx.

Referenced by addComponentInstance().

◆ _edition

bool YACS::ENGINE::Proc::_edition

protected

Definition at line 107 of file Proc.hxx.

Referenced by modified(), and setEdition().

◆ _loggers

LoggerMap YACS::ENGINE::Proc::_loggers

Definition at line 96 of file Proc.hxx.

Referenced by getLogger(), and ~Proc().

◆ componentInstanceMap

std::map<std::string, ComponentInstance*> YACS::ENGINE::Proc::componentInstanceMap

Definition at line 92 of file Proc.hxx.

◆ containerMap

std::map<std::string, Container*> YACS::ENGINE::Proc::containerMap

Definition at line 91 of file Proc.hxx.

◆ inlineMap

std::map<std::string, InlineNode*> YACS::ENGINE::Proc::inlineMap

Definition at line 89 of file Proc.hxx.

Referenced by YACS::looptypeParser< T >::inline_(), YACS::casetypeParser::inline_(), YACS::bloctypeParser< T >::inline_(), YACS::servertypeParser< T >::node(), YACS::looptypeParser< T >::node(), YACS::casetypeParser::node(), YACS::bloctypeParser< T >::node(), YACS::nodetypeParser< T >::post(), YACS::looptypeParser< T >::remote(), YACS::casetypeParser::remote(), YACS::bloctypeParser< T >::remote(), YACS::looptypeParser< T >::server(), YACS::casetypeParser::server(), and YACS::bloctypeParser< T >::server().

◆ names

std::vector<std::string> YACS::ENGINE::Proc::names

Definition at line 93 of file Proc.hxx.

◆ nodeMap

std::map<std::string, Node*> YACS::ENGINE::Proc::nodeMap

Definition at line 87 of file Proc.hxx.

◆ serviceMap

std::map<std::string, ServiceNode*> YACS::ENGINE::Proc::serviceMap

Definition at line 88 of file Proc.hxx.

Referenced by YACS::servicetypeParser< T >::node(), YACS::looptypeParser< T >::service(), YACS::casetypeParser::service(), YACS::bloctypeParser< T >::service(), YACS::looptypeParser< T >::sinline(), YACS::casetypeParser::sinline(), and YACS::bloctypeParser< T >::sinline().

◆ typeMap

std::map<std::string, TypeCode*> YACS::ENGINE::Proc::typeMap

Definition at line 90 of file Proc.hxx.

Referenced by YACS::HMI::SubjectProc::addSubjectDataType(), YACS::objtypeParser::base(), YACS::HMI::MenusBase::buildForEachMenu(), YACS::seqtypeParser::content(), YACS::HMI::GuiEditor::CreateForEachLoop(), createInterfaceTc(), createSequenceTc(), createStructTc(), createType(), gui.cataitems.TypesItem::getChildren(), YACS::HMI::CommandAddDataTypeFromCatalog::getTypeCode(), getTypeCode(), YACS::ENGINE::Visitor::getTypeCodeMap(), YACS::inlinetypeParser< T >::inport(), YACS::servertypeParser< T >::instream(), YACS::servicetypeParser< T >::instream(), YACS::ENGINE::ProcCataLoader::loadCata(), YACS::HMI::SubjectProc::loadTypes(), YACS::HMI::CommandAddDataTypeFromCatalog::localExecute(), YACS::HMI::CommandAddInputPortFromCatalog::localExecute(), YACS::HMI::CommandAddOutputPortFromCatalog::localExecute(), YACS::structtypeParser::member(), YACS::inlinetypeParser< T >::outport(), YACS::servertypeParser< T >::outstream(), YACS::servicetypeParser< T >::outstream(), YACS::outnodetypeParser< T >::parameter(), YACS::presettypeParser< T >::parameter(), YACS::structtypeParser::post(), YACS::foreachlooptypeParser< T >::postAttr(), Proc(), YACS::HMI::SubjectProc::removeSubjectDataType(), setTypeCode(), and ~Proc().

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

src/engine/Proc.hxx
src/engine/Proc.cxx

Public Types

Public Member Functions

Public Attributes

Protected Member Functions

Protected Attributes

Friends

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ LoggerMap

Constructor & Destructor Documentation

◆ Proc()

◆ ~Proc()

Member Function Documentation

◆ accept()

◆ addComponentInstance()

◆ createComponentInstance()

◆ createContainer()

◆ createInterfaceTc()

◆ createSequenceTc()

◆ createStructTc()

◆ createType()

◆ getEdition()

◆ getGlobalProgressPercent()

◆ getIds()

◆ getInPortValue()

◆ getLogger()

◆ getNodeContainerLog()

◆ getNodeErrorDetails()

◆ getNodeErrorReport()

◆ getNodeProgress()

◆ getNodeState()

◆ getNumIds()

◆ getOutPortValue()

◆ getProc() [1/2]

◆ getProc() [2/2]

◆ getTypeCode()

◆ getXMLState()

◆ modified()

◆ removeComponentInstance()

◆ removeContainer()

◆ removeContainers()

◆ saveSchema()

◆ saveState()

◆ setEdition()

◆ setInPortValue()

◆ setName()

◆ setTypeCode()

◆ typeName()

◆ updateContainersAndComponents()

◆ writeDot()

Friends And Related Function Documentation

◆ operator<<

Member Data Documentation

◆ _compoinstctr

◆ _edition

◆ _loggers

◆ componentInstanceMap

◆ containerMap

◆ inlineMap

◆ names

◆ nodeMap

◆ serviceMap

◆ typeMap