Class for Salome component Service Node. More...

#include <CORBANode.hxx>

Inheritance diagram for YACS::ENGINE::SalomeNode:

[legend]

Collaboration diagram for YACS::ENGINE::SalomeNode:

[legend]

Public Member Functions
	SalomeNode (const SalomeNode &other, ComposedNode *father)

	SalomeNode (const std::string &name)
	SalomeNode constructor. More...

virtual	~SalomeNode ()

virtual void	execute ()
	Execute the service on the component associated to the node. More...

virtual ServiceNode *	createNode (const std::string &name)
	Create a SalomeNode with the same component object and no input or output port. More...

virtual std::string	getKind () const
	Return the service node kind. More...

virtual std::string	typeName ()

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

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

Public Member Functions inherited from YACS::ENGINE::ServiceNode
virtual void	load ()
	Load the component associated to the node. More...

virtual bool	isDeployable () const
	By definition of ServiceNode class. More...

virtual void	setComponent (ComponentInstance *compo)
	Associate an existing component instance to this service node AND check the consistency regarding the deployment from root node point of view. More...

virtual ComponentInstance *	getComponent ()
	Return the associated component instance. More...

virtual const ComponentInstance *	getComponent () const

virtual Container *	getContainer ()
	Return the associated container. More...

virtual void	setRef (const std::string &ref)
	Associate a new component instance to this service node. More...

virtual std::string	getRef ()

virtual void	setMethod (const std::string &method)

virtual std::string	getMethod ()

virtual ServiceNode *	createNode (const std::string &name)=0

virtual	~ServiceNode ()

virtual void	accept (Visitor *visitor)

virtual std::string	getKind () const
	Return the service node kind. More...

virtual std::string	typeName ()

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

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

void	init (bool start=true)

bool	isDeployable () const

ComponentInstance *	getComponent ()

const ComponentInstance *	getComponent () const

Container *	getContainer ()

YACS::StatesForNode	getState () const

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

void	edRemovePort (Port *port)

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

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

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

virtual void	checkBasicConsistency () const

ComposedNode *	getDynClonerIfExists (const ComposedNode *levelToStop) const

int	getNumberOfInputPorts () const

int	getNumberOfOutputPorts () const

std::string	getInPortName (const InPort *) const

std::string	getOutPortName (const OutPort *) const

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

OutputPort *	getOutputPort (const std::string &name) const

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

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

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

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

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

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

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

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

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

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

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

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

virtual InputPort *	createInputPort (const std::string &inputPortName, TypeCode *type)

virtual OutputPort *	createOutputPort (const std::string &outputPortName, TypeCode *type)

virtual InputDataStreamPort *	createInputDataStreamPort (const std::string &inputPortDSName, TypeCode *type)

virtual OutputDataStreamPort *	createOutputDataStreamPort (const std::string &outputPortDSName, TypeCode *type)

virtual InputPort *	edAddInputPort (const std::string &inputPortName, TypeCode *type)

virtual OutputPort *	edAddOutputPort (const std::string &outputPortName, TypeCode *type)

virtual InputDataStreamPort *	edAddInputDataStreamPort (const std::string &inputPortDSName, TypeCode *type)

virtual OutputDataStreamPort *	edAddOutputDataStreamPort (const std::string &outputPortDSName, TypeCode *type)

virtual void	edOrderInputPorts (const std::list< InputPort * > &ports)

virtual void	edOrderOutputPorts (const std::list< OutputPort * > &ports)

virtual std::string	typeName ()

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

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

int	getMaxLevelOfParallelism () const

ComplexWeight *	getWeight ()

void	setWeight (double elementaryWeight)

void	getWeightRegardingDPL (ComplexWeight *weight)

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

void	begin ()

bool	isReady ()

void	finished ()

void	aborted ()

void	loaded ()
	Notify this node that it is loaded. More...

void	connected ()
	Notify this node that it is connected. More...

virtual std::string	getErrorDetails ()
	Give a description of error when node status is ERROR. More...

virtual void	initService ()

virtual void	connectService ()

virtual void	disconnectService ()

virtual void	load ()

virtual void	getCoupledTasks (std::set< Task * > &coupledSet)
	Calls getCoupledNodes for Task interface. More...

virtual void	getCoupledNodes (std::set< Task * > &coupledSet)
	Put all nodes that are coupled to this node in coupledSet. More...

void	accept (Visitor *visitor)

virtual void	addDatastreamPortToInitMultiService (const std::string &port_name, int number)

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::Task
virtual void	begin ()=0

virtual bool	isReady ()=0

virtual void	execute ()=0

virtual void	load ()=0

virtual void	loaded ()=0

virtual void	connected ()=0

virtual void	initService ()=0

virtual void	connectService ()=0

virtual void	disconnectService ()=0

virtual void	getCoupledTasks (std::set< Task * > &coupledSet)=0

virtual bool	isDeployable () const =0

virtual ComponentInstance *	getComponent ()=0

virtual const ComponentInstance *	getComponent () const =0

virtual Container *	getContainer ()=0

virtual YACS::StatesForNode	getState () const =0

virtual void	finished ()=0

virtual void	aborted ()=0

virtual void	imposeResource (const std::string &resource_name, const std::string &container_name)

virtual bool	canAcceptImposedResource ()

virtual bool	hasImposedResource () const

virtual	~Task ()

Static Public Attributes
static const char	KIND [] ="Salome"

Static Public Attributes inherited from YACS::ENGINE::ServiceNode
static const char	KIND [] =""

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

Protected Member Functions
Node *	simpleClone (ComposedNode *father, bool editionOnly) const

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

	ServiceNode (const ServiceNode &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...

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

	ElementaryNode (const ElementaryNode &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	initCommonPartWithoutStateManagement (bool start)

virtual void	createMultiDatastreamPorts ()

void	edDisconnectAllLinksWithMe ()

bool	areAllInputPortsValid () const

template<class PORT >
PORT *	getPort (const std::string &name, const std::list< PORT * > &setOfPorts) const

template<class PORT , class ENUMTYPE >
PORT *	edAddPort (const std::string &portName, std::list< PORT * > &setOfPorts, ENUMTYPE type)

template<class PORT , class ENUMTYPE >
bool	edCheckAddPort (const std::string &portName, std::list< PORT * > &setOfPorts, ENUMTYPE type)

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 ()

Private Attributes
YACS::BASES::Mutex	_mutex

Additional Inherited Members
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)

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

Static Protected Member Functions inherited from YACS::ENGINE::ElementaryNode
template<class PORT >
static void	edRemovePortTypedFromSet (PORT port, std::list< PORT > &setOfPorts)

template<class PORT >
static bool	isPortNameAlreadyExist (const std::string &portName, const std::list< PORT * > &setOfPorts)

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

static ComposedNode *	checkHavingCommonFather (Node node1, Node node2)

Protected Attributes inherited from YACS::ENGINE::ServiceNode
ComponentInstance *	_component

std::string	_method

std::string	_ref

Protected Attributes inherited from YACS::ENGINE::ElementaryNode
std::list< InputPort * >	_setOfInputPort

std::list< OutputPort * >	_setOfOutputPort

std::list< InputDataStreamPort * >	_setOfInputDataStreamPort

std::list< OutputDataStreamPort * >	_setOfOutputDataStreamPort

ComplexWeight	_weight

bool	_createDatastreamPorts

bool	_multi_port_node

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

Static Protected Attributes inherited from YACS::ENGINE::Node
static const char	SEP_CHAR_IN_PORT [] ="."

static int	_total = 0

Detailed Description

Class for Salome component Service Node.

See also: InputCorbaPort; OutputCorbaPort

Definition at line 67 of file CORBANode.hxx.

Constructor & Destructor Documentation

◆ SalomeNode() [1/2]

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

Definition at line 286 of file CORBANode.cxx.

                                                                  :ServiceNode(other,father)
{
  _implementation=CORBANode::IMPL_NAME;
}

References YACS::ENGINE::Node::_implementation, and YACS::ENGINE::CORBANode::IMPL_NAME.

Referenced by createNode(), and simpleClone().

◆ SalomeNode() [2/2]

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

SalomeNode constructor.

Definition at line 281 of file CORBANode.cxx.

                                           :ServiceNode(name)
{
  _implementation=CORBANode::IMPL_NAME;
}

References YACS::ENGINE::Node::_implementation, and YACS::ENGINE::CORBANode::IMPL_NAME.

◆ ~SalomeNode()

SalomeNode::~SalomeNode ( )

virtual

Definition at line 291 of file CORBANode.cxx.

292{

293}

Member Function Documentation

◆ createNode()

ServiceNode * SalomeNode::createNode ( const std::string & name )

virtual

Create a SalomeNode with the same component object and no input or output port.

Parameters

name	: node name

Returns: a new SalomeNode node

Implements YACS::ENGINE::ServiceNode.

Definition at line 844 of file CORBANode.cxx.

{
  SalomeNode* node=new SalomeNode(name);
  node->setComponent(_component);
  return node;
}

References YACS::ENGINE::ServiceNode::_component, SalomeNode(), and YACS::ENGINE::ServiceNode::setComponent().

◆ execute()

void SalomeNode::execute ( )

virtual

Execute the service on the component associated to the node.

Implements YACS::ENGINE::Task.

Definition at line 518 of file CORBANode.cxx.

{
  YACSTRACE(1,"+++++++++++++++++ SalomeNode::execute: " << getName() << " " << _method << " +++++++++++++++++" );
  {
    CORBA::Object_var objComponent=((SalomeComponent*)_component)->getCompoPtr();
    Engines::EngineComponent_var compo=Engines::EngineComponent::_narrow(objComponent);
 
    // Set component properties
    std::map<std::string,std::string> amap=getProperties();
    if(amap.size() > 0)
      {
        Engines::FieldsDict_var dico = new Engines::FieldsDict;
        dico->length(amap.size());
        std::map<std::string,std::string>::const_iterator it;
        int i=0;
        for(it = amap.begin(); it != amap.end(); ++it)
          {
            dico[i].key=CORBA::string_dup(it->first.c_str());
            dico[i].value <<=it->second.c_str();
            i++;
          }
        compo->setProperties(dico);
      }
 
    //DII request building :
    // a service gets all its in parameters first
    // then all its out parameters
    // no inout parameters
    // the return value (if any) is the first out parameter
    //
    CORBA::Request_var req ;
    try
      {
        req = objComponent->_request(_method.c_str());
      }
    catch(CORBA::SystemException& ex)
      {
        std::string msg="component '" +_ref+ "' has no service '" + _method+ "'";
        _errorDetails=msg;
        throw Exception(msg);
      }
    CORBA::NVList_ptr arguments = req->arguments() ;
 
    DEBTRACE( "+++++++++++++++++SalomeNode::inputs+++++++++++++++++" );
    int in_param=0;
    //in parameters
    list<InputPort *>::iterator iter2;
    for(iter2 = _setOfInputPort.begin(); iter2 != _setOfInputPort.end(); iter2++)
    {
          InputCorbaPort *p=(InputCorbaPort *)*iter2;
          if(p->edGetType()->isA(Runtime::_tc_file))
            continue;
          DEBTRACE( "port name: " << p->getName() );
          DEBTRACE( "port kind: " << p->edGetType()->kind() );
          CORBA::Any* ob=p->getAny();
#ifdef _DEVDEBUG_
          CORBA::TypeCode_var tc=ob->type();
          switch(p->edGetType()->kind())
          {
          case Double:
            CORBA::Double d;
            *ob >>= d;
            DEBTRACE( d )
            break;
          case Int:
            CORBA::Long l;
            *ob >>= l;
            DEBTRACE( l )
            break;
          case String:
            const char *s;
            *ob >>= s;
            DEBTRACE( s )
            break;
          case Objref:
            DEBTRACE( tc->id() )
            break;
          default:
            break;
          }
#endif
          //add_value makes a copy of any. Copy will be deleted with request
          arguments->add_value( p->getName().c_str() , *ob , CORBA::ARG_IN ) ;
          in_param=in_param+1;
    }
    //in files
    int nfiles=0;
    DEBTRACE("checkInputFilesToService: " << _method);
    try
      {
        for(iter2 = _setOfInputPort.begin(); iter2 != _setOfInputPort.end(); iter2++)
          {
            InputCorbaPort *p=(InputCorbaPort *)*iter2;
            if(!p->edGetType()->isA(Runtime::_tc_file))
              continue;
            std::string filename=p->getName();
            // replace ':' by '.'. Needed because port name can not contain '.'
            string::size_type debut =filename.find_first_of(':',0);
            while(debut != std::string::npos)
              {
                 filename[debut]='.';
                 debut=filename.find_first_of(':',debut);
              }
            DEBTRACE( "inport with file: " << filename );
            Engines::Salome_file_var isf=compo->setInputFileToService(_method.c_str(),p->getName().c_str());
            isf->setDistributedFile(filename.c_str());
            Engines::Salome_file_ptr osf;
            CORBA::Any* any=p->getAny();
            *any >>= osf;
            isf->connect(osf);
            nfiles++;
          }
        if(nfiles)
          compo->checkInputFilesToService(_method.c_str());
      }
    catch( const SALOME::SALOME_Exception& ex )
      {
        std::string text="Execution problem in checkInputFilesToService: ";
        text += (const char*)ex.details.text;
        _errorDetails=text;
        throw Exception(text);
      }
    catch(CORBA::SystemException& ex)
      {
        std::string msg="Execution problem: component probably does not support files ??";
        _errorDetails=msg;
        throw Exception(msg);
      }
    
    //out parameters
    DEBTRACE( "+++++++++++++++++SalomeNode::outputs+++++++++++++++++" )
    list<OutputPort *>::iterator iter;
    for(iter = _setOfOutputPort.begin(); iter != _setOfOutputPort.end(); iter++)
    {
          OutputCorbaPort *p=(OutputCorbaPort *)*iter;
          DEBTRACE( "port name: " << p->getName() )
          DEBTRACE( "port kind: " << p->edGetType()->kind() )
          if(p->edGetType()->isA(Runtime::_tc_file))
            continue;
          CORBA::Any* ob=p->getAnyOut();
          //add_value makes a copy of any. Copy will be deleted with request
          arguments->add_value( p->getName().c_str() , *ob , CORBA::ARG_OUT );
          delete ob;
    }
 
    //return value
    //if return type is set to void (not mandatory, it's set by default)
    //the return value will not be marshalled as a return value but 
    //as the first out argument (don't forget to add it as the first output argument)
    req->set_return_type(CORBA::_tc_void);
    //user exceptions
    req->exceptions()->add(SALOME::_tc_SALOME_Exception);
    
    DEBTRACE( "+++++++++++++++++SalomeNode::calculation+++++++++++++++++" << _method )
    req->invoke();
    CORBA::Exception *exc =req->env()->exception();
    if( exc )
    {
      DEBTRACE( "An exception was thrown!" )
      DEBTRACE( "The raised exception is of Type:" << exc->_name() )
 
      CORBA::SystemException* sysexc;
      sysexc=CORBA::SystemException::_downcast(exc);
      if(sysexc != NULL)
        {
          // It's a SystemException
          DEBTRACE( "minor code: " << sysexc->minor() );
          DEBTRACE( "completion code: " << sysexc->completed() );
          std::string text="Execution problem: ";
          std::string excname=sysexc->_name();
          if(excname == "BAD_OPERATION")
            {
              text=text+"component '" +_ref+ "' has no service '" + _method+ "'";
            }
          else if(excname == "BAD_PARAM")
            {
              text=text+"A parameter (input or output) passed to the call is out of range or otherwise considered illegal.\n";
              text=text+"Minor code: "+sysexc->NP_minorString();
            }
          else if(excname == "MARSHAL" && sysexc->minor() == omni::MARSHAL_PassEndOfMessage)
            {
              text=text+"probably an error in arguments of service '" + _method + "' from component '" +_ref+ "'";
            }
          else if(excname == "COMM_FAILURE" && sysexc->minor() == omni::COMM_FAILURE_UnMarshalResults)
            {
              text=text+"probably an error in output arguments of service '" + _method + "' from component '" +_ref+ "'";
            }
          else if(excname == "COMM_FAILURE" && sysexc->minor() == omni::COMM_FAILURE_UnMarshalArguments)
            {
              text=text+"probably an error in input arguments of service '" + _method + "' from component '" +_ref+ "'";
            }
          else if(excname == "COMM_FAILURE" && sysexc->minor() == omni::COMM_FAILURE_WaitingForReply)
            {
              text=text+"probably an error in input arguments of service '" + _method + "' from component '" +_ref+ "'";
            }
          else
            {
              DEBTRACE(sysexc->NP_minorString() );
              text=text+"System Exception "+ excname;
            }
          _errorDetails=text;
          throw Exception(text);
        }
 
      // Not a System Exception
      CORBA::UnknownUserException* userexc;
      userexc=CORBA::UnknownUserException::_downcast(exc);
      if(userexc != NULL)
        {
          CORBA::Any anyExcept = userexc->exception(); 
 
          const SALOME::SALOME_Exception* salexc;
          if(anyExcept >>= salexc)
            {
              DEBTRACE("SALOME_Exception: "<< salexc->details.sourceFile);
              DEBTRACE("SALOME_Exception: "<<salexc->details.lineNumber);
              _errorDetails=salexc->details.text;
              throw Exception("Execution problem: Salome Exception occurred" + getErrorDetails() );
            }
          std::string msg="Execution problem: User Exception occurred";
          _errorDetails=msg;
          throw Exception(msg);
        }
      std::string msg="Execution problem";
      _errorDetails=msg;
      throw Exception(msg);
    }
    
    DEBTRACE( "++++++++++++SalomeNode::outputs++++++++++++" )
    int out_param=in_param;
    for(iter = _setOfOutputPort.begin(); iter != _setOfOutputPort.end(); iter++)
    {
          OutputCorbaPort *p=(OutputCorbaPort *)*iter;
          DEBTRACE( "port name: " << p->getName() );
          DEBTRACE( "port kind: " << p->edGetType()->kind() );
          DEBTRACE( "port number: " << out_param );
          if(p->edGetType()->isA(Runtime::_tc_file))
            continue;
          CORBA::Any *ob=arguments->item(out_param)->value();
#ifdef _DEVDEBUG_
      switch(p->edGetType()->kind())
      {
        case Double:
          CORBA::Double d;
          *ob >>= d;
          DEBTRACE( d )
          break;
        case Int:
          CORBA::Long l;
          *ob >>= l;
          DEBTRACE( l )
          break;
        case String:
          const char *s;
          *ob >>= s;
          DEBTRACE( s )
          break;
        default:
          break;
      }
#endif
        //OutputPort must copy the input Any(ob). 
        //This Any will be deleted with the request.
        //Copy is made by the method put.
        p->put(ob);
        out_param=out_param+1;
    }
 
    //Out files
    nfiles=0;
    DEBTRACE("checkOutputFilesToService: " << _method);
    try
      {
        for(iter = _setOfOutputPort.begin(); iter != _setOfOutputPort.end(); iter++)
          {
            OutputCorbaPort *p=(OutputCorbaPort *)*iter;
            if(!p->edGetType()->isA(Runtime::_tc_file))
              continue;
            // The output port has a file object : special treatment
            std::string filename=p->getName();
            // replace ':' by '.'. Needed because port name can not contain '.'
            string::size_type debut =filename.find_first_of(':',0);
            while(debut != std::string::npos)
              {
                 filename[debut]='.';
                 debut=filename.find_first_of(':',debut);
              }
            DEBTRACE( "outport with file: " << filename );
            Engines::Salome_file_var osf=compo->setOutputFileToService(_method.c_str(),p->getName().c_str());
            osf->setLocalFile(filename.c_str());
            CORBA::Any any;
            any <<= osf;
            p->put(&any);
          }
        if(nfiles)
          compo->checkOutputFilesToService(_method.c_str());
      }
    catch( const SALOME::SALOME_Exception& ex )
      {
        std::string text=(const char*)ex.details.text;
        _errorDetails=text;
        throw Exception("Execution problem in checkOutputFilesToService: " + text);
      }
    catch(CORBA::SystemException& ex)
      {
        std::string msg="Execution problem: component probably does not support files ?";
        _errorDetails=msg;
        throw Exception(msg);
      }
  }
  //Request has been deleted (_var )
  //All anys given to the request are deleted : don't forget to copy them 
  //if you want to keep them
  DEBTRACE( "+++++++++++++++++ End SalomeNode::execute: " << getName() << " +++++++++++++++++" )
}

References YACS::ENGINE::ServiceNode::_component, YACS::ENGINE::Node::_errorDetails, YACS::ENGINE::ServiceNode::_method, YACS::ENGINE::ServiceNode::_ref, YACS::ENGINE::ElementaryNode::_setOfInputPort, YACS::ENGINE::ElementaryNode::_setOfOutputPort, YACS::ENGINE::Runtime::_tc_file, DEBTRACE, yacsorb.CORBAEngineTest::dico, YACS::ENGINE::Double, testCppPluginInvokation::ex, YACS::ENGINE::ElementaryNode::getErrorDetails(), YACS::ENGINE::ComposedNode::getName(), YACS::ENGINE::Node::getName(), YACS::ENGINE::Node::getProperties(), yacsorb.CORBAEngineTest::i, YACS::ENGINE::Int, testCppPluginInvokation::l, YACS::ENGINE::Objref, p, YACS::ENGINE::String, and YACSTRACE.

◆ getContainerLog()

std::string SalomeNode::getContainerLog ( )

virtual

returns a string that contains the name of the container log file if it exists

Do nothing here. To subclass

Reimplemented from YACS::ENGINE::Node.

Definition at line 851 of file CORBANode.cxx.

{
  std::string msg="Component is not loaded";
  try
    {
      CORBA::Object_var objComponent=((SalomeComponent*)_component)->getCompoPtr();
      Engines::EngineComponent_var compo=Engines::EngineComponent::_narrow(objComponent);
      if( !CORBA::is_nil(compo) )
        {
          Engines::Container_var cont= compo->GetContainerRef();
          CORBA::String_var logname = cont->logfilename();
          DEBTRACE(logname);
          msg=logname;
          std::string::size_type pos = msg.find(":");
          msg=msg.substr(pos+1);
        }
    }
  catch(CORBA::COMM_FAILURE& ex) 
    {
      msg = ":Component no longer reachable: Caught system exception COMM_FAILURE";
      msg += " -- unable to contact the object.";
    }
  catch(CORBA::SystemException& ex) 
    {
      msg = ":Component no longer reachable: Caught a CORBA::SystemException.\n";
      CORBA::Any tmp;
      tmp <<= ex;
      CORBA::TypeCode_var tc = tmp.type();
      const char *p = tc->name();
      if ( *p != '\0' ) 
        msg += p;
      else  
        msg += tc->id();
    }
  catch(CORBA::Exception& ex) 
    {
      msg = ":Component no longer reachable: Caught CORBA::Exception.\n";
      CORBA::Any tmp;
      tmp <<= ex;
      CORBA::TypeCode_var tc = tmp.type();
      const char *p = tc->name();
      if ( *p != '\0' ) 
        msg += p;
      else  
        msg += tc->id();
    }
  catch(omniORB::fatalException& fe) 
    {
      msg = ":Component no longer reachable: Caught omniORB::fatalException.\n";
      stringstream log;
      log << "  file: " << fe.file() << endl;
      log << "  line: " << fe.line() << endl;
      log << "  mesg: " << fe.errmsg() << endl;
      msg += log.str();
    }
  catch(...) 
    {
      msg = ":Component no longer reachable: Caught unknown exception.";
    }
  return msg;
}

References YACS::ENGINE::ServiceNode::_component, DEBTRACE, testCppPluginInvokation::ex, gui.logview::log, and p.

◆ getKind()

std::string SalomeNode::getKind ( ) const

virtual

Return the service node kind.

A runtime can provide several implementations of a service node. Each implementation has a different kind. A ComponentInstance can be associated to a ServiceNode with the same kind.

Reimplemented from YACS::ENGINE::ServiceNode.

Definition at line 275 of file CORBANode.cxx.

{
  return KIND;
}

References KIND.

◆ shutdown()

void SalomeNode::shutdown ( int level )

virtual

Stop all pending activities of the node.

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

Reimplemented from YACS::ENGINE::Node.

Definition at line 913 of file CORBANode.cxx.

{
  DEBTRACE("SalomeNode::shutdown " << level);
  if(_component)
    _component->shutdown(level);
}

References YACS::ENGINE::ServiceNode::_component, DEBTRACE, and YACS::ENGINE::ComponentInstance::shutdown().

◆ simpleClone()

Node * SalomeNode::simpleClone	(	ComposedNode *	father,
		bool	editionOnly
	)		const

protectedvirtual

Implements YACS::ENGINE::Node.

Definition at line 834 of file CORBANode.cxx.

{
  return new SalomeNode(*this,father);
}

References SalomeNode().

◆ typeName()

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

inlinevirtual

Reimplemented from YACS::ENGINE::ServiceNode.

Definition at line 79 of file CORBANode.hxx.

79{return "YACS__ENGINE__SalomeNode";}

Member Data Documentation

◆ _mutex

YACS::BASES::Mutex YACS::ENGINE::SalomeNode::_mutex

private

Definition at line 93 of file CORBANode.hxx.

◆ KIND

const char SalomeNode::KIND ="Salome"

static

Definition at line 78 of file CORBANode.hxx.

Referenced by YACS::ENGINE::RuntimeSALOME::createCompoNode(), YACS::ENGINE::RuntimeSALOME::createFuncNode(), YACS::ENGINE::RuntimeSALOME::createRefNode(), YACS::ENGINE::RuntimeSALOME::createScriptNode(), YACS::ENGINE::RuntimeSALOME::createSInlineNode(), and getKind().

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

src/runtime/CORBANode.hxx
src/runtime/CORBANode.cxx

Public Member Functions

Static Public Attributes

Protected Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ SalomeNode() [1/2]

◆ SalomeNode() [2/2]

◆ ~SalomeNode()

Member Function Documentation

◆ createNode()

◆ execute()

◆ getContainerLog()

◆ getKind()

◆ shutdown()

◆ simpleClone()

◆ typeName()

Member Data Documentation

◆ _mutex

◆ KIND