#include <PythonNode.hxx>

Inheritance diagram for YACS::ENGINE::PythonNode:

[legend]

Collaboration diagram for YACS::ENGINE::PythonNode:

[legend]

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

	PythonNode (const std::string &name)

virtual	~PythonNode ()

virtual void	checkBasicConsistency () const

virtual void	execute ()

virtual void	load ()

virtual void	loadRemote ()

virtual void	loadLocal ()

virtual void	executeRemote ()

virtual void	executeLocal ()

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

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

bool	canAcceptImposedResource () override

bool	hasImposedResource () const override

bool	isUsingPythonCache () const

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

PythonNode *	cloneNode (const std::string &name)
	Create a new node of same type with a given name. More...

virtual std::string	typeName ()

void	applyDPLScope (ComposedNode *gfn)

void	setSqueezeStatusWithExceptions (bool sqStatus, const std::vector< std::string > &squeezeExceptions)

void	setSqueezeStatus (bool sqStatus)

bool	getSqueezeStatus () const

void	squeezeMemorySafe ()

Public Member Functions inherited from YACS::ENGINE::InlineNode
virtual void	setScript (const std::string &script)
	Set the script (as a string) to execute. More...

virtual std::string	getScript ()

virtual InlineNode *	cloneNode (const std::string &name)
	Return a new InlineNode node by making a copy of this node. More...

virtual void	accept (Visitor *visitor)

virtual	~InlineNode ()

virtual std::string	typeName ()

virtual void	setExecutionMode (const std::string &mode)

virtual std::string	getExecutionMode ()

virtual void	setContainer (Container *container)

virtual Container *	getContainer ()

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

bool	isDeployable () const

int	getMaxLevelOfParallelism () const

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 Member Functions
static void	ExecuteLocalInternal (const std::string &codeStr, PyObject *context, std::string &errorDetails)

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 Member Functions inherited from YACS::ENGINE::PythonEntry
static bool	IsProxy (PyObject *ob)

static bool	GetDestroyStatus (PyObject *ob)

static void	DoNotTouchFileIfProxy (PyObject *ob)

static void	UnlinkOnDestructorIfProxy (PyObject *ob)

static void	IfProxyDoSomething (PyObject ob, const char meth)

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

static const char	IMPL_NAME [] ="Python"

static const char	SCRIPT_FOR_SERIALIZATION []

static const char	REMOTE_NAME [] ="remote"

static const char	DPL_INFO_NAME [] ="my_dpl_localization"

Static Public Attributes inherited from YACS::ENGINE::InlineNode
static const char	LOCAL_STR [] ="local"

static const char	REMOTE_STR [] ="remote"

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

Static Public Attributes inherited from YACS::ENGINE::PythonEntry
static const char	SCRIPT_FOR_SIMPLE_SERIALIZATION []

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

void	createRemoteAdaptedPyInterpretor (Engines::Container_ptr objContainer)
	returns an object, you have to deal with (UnRegister) More...

Engines::PyNodeBase_var	retrieveDftRemotePyInterpretorIfAny (Engines::Container_ptr objContainer) const
	returns (if any) an object, you have to deal with (UnRegister) More...

void	assignRemotePyInterpretor (Engines::PyNodeBase_var remoteInterp)

Engines::PyNodeBase_var	getRemoteInterpreterHandle ()

const char *	getSerializationScript () const

std::string	pythonEntryName () const

void	squeezeMemory ()

void	squeezeMemoryRemote ()

void	freeKernelPynode ()

Protected Member Functions inherited from YACS::ENGINE::InlineNode
	InlineNode (const InlineNode &other, ComposedNode *father)

	InlineNode (const std::string &name)

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

Protected Member Functions inherited from YACS::ENGINE::PythonEntry
	PythonEntry ()

	~PythonEntry ()

virtual void	assignRemotePyInterpretor (Engines::PyNodeBase_var remoteInterp)=0

virtual Engines::PyNodeBase_var	retrieveDftRemotePyInterpretorIfAny (Engines::Container_ptr objContainer) const =0
	returns (if any) an object, you have to deal with (UnRegister) More...

virtual void	createRemoteAdaptedPyInterpretor (Engines::Container_ptr objContainer)=0
	returns an object, you have to deal with (UnRegister) More...

virtual Engines::PyNodeBase_var	getRemoteInterpreterHandle ()=0

virtual const char *	getSerializationScript () const =0

void	commonRemoteLoad (InlineNode *reqNode)

void	loadRemoteContainer (InlineNode *reqNode)

Engines::Container_var	loadPythonAdapter (InlineNode *reqNode, bool &isInitializeRequested)

void	loadRemoteContext (InlineNode *reqNode, Engines::Container_ptr objContainer, bool isInitializeRequested)

virtual bool	hasImposedResource () const

Protected Attributes
bool	_autoSqueeze = false

std::set< std::string >	_nonSqueezableOutputNodes
	list on output port name excluded from the squeeze mecanism More...

Engines::PyScriptNode_var	_pynode

Protected Attributes inherited from YACS::ENGINE::InlineNode
std::string	_script

std::string	_mode

Container *	_container

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

Protected Attributes inherited from YACS::ENGINE::PythonEntry
PyObject *	_context

PyObject *	_pyfuncSer

PyObject *	_pyfuncUnser

PyObject *	_pyfuncSimpleSer

std::string	_imposedResource

std::string	_imposedContainer

Private Member Functions
void	executeLocalInternal (const std::string &codeStr)

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

Static Protected Member Functions inherited from YACS::ENGINE::PythonEntry
static std::string	GetContainerLog (const std::string &mode, Container container, const Task askingTask)

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

static int	_total = 0

Static Protected Attributes inherited from YACS::ENGINE::PythonEntry
static PyObject *	_pyClsBigObject = nullptr

Detailed Description

Definition at line 75 of file PythonNode.hxx.

Constructor & Destructor Documentation

◆ PythonNode() [1/2]

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

Definition at line 418 of file PythonNode.cxx.

                                                                   :
InlineNode(other,father),_autoSqueeze(other._autoSqueeze),_nonSqueezableOutputNodes(other._nonSqueezableOutputNodes)
{
  _pynode = Engines::PyScriptNode::_nil();
  _implementation=IMPL_NAME;
  {
    AutoGIL agil;
    _context=PyDict_New();
    if( PyDict_SetItemString( _context, "__builtins__", getSALOMERuntime()->getBuiltins() ))
      {
        stringstream msg;
        msg << "Impossible to set builtins" << __FILE__ << ":" << __LINE__;
        _errorDetails=msg.str();
        throw Exception(msg.str());
      }
  }
}

References YACS::ENGINE::PythonEntry::_context, YACS::ENGINE::Node::_errorDetails, YACS::ENGINE::Node::_implementation, _pynode, YACS::ENGINE::getSALOMERuntime(), and IMPL_NAME.

Referenced by cloneNode(), and simpleClone().

◆ PythonNode() [2/2]

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

Definition at line 436 of file PythonNode.cxx.

                                           :InlineNode(name)
{
  _pynode = Engines::PyScriptNode::_nil();
  _implementation=IMPL_NAME;
  {
    AutoGIL agil;
    _context=PyDict_New();
    if( PyDict_SetItemString( _context, "__builtins__", getSALOMERuntime()->getBuiltins() ))
      {
        stringstream msg;
        msg << "Impossible to set builtins" << __FILE__ << ":" << __LINE__;
        _errorDetails=msg.str();
        throw Exception(msg.str());
      }
  }
}

References YACS::ENGINE::PythonEntry::_context, YACS::ENGINE::Node::_errorDetails, YACS::ENGINE::Node::_implementation, _pynode, YACS::ENGINE::getSALOMERuntime(), and IMPL_NAME.

◆ ~PythonNode()

PythonNode::~PythonNode ( )

virtual

Definition at line 453 of file PythonNode.cxx.

{
  freeKernelPynode();
}

References freeKernelPynode().

Member Function Documentation

◆ applyDPLScope()

void PythonNode::applyDPLScope ( ComposedNode * gfn )

virtual

Method called by the Executor only if the executor is sensitive of scope of DynParaLoop. This method is virtual and empty because by default nothing is done.

Reimplemented from YACS::ENGINE::Node.

Definition at line 1050 of file PythonNode.cxx.

{
  std::vector< std::pair<std::string,int> > ret(getDPLScopeInfo(gfn));
  if(ret.empty())
    return ;
  //
  PyObject *ob(0);
  {
    AutoGIL agil;
    std::size_t sz(ret.size());
    ob=PyList_New(sz);
    for(std::size_t i=0;i<sz;i++)
      {
        const std::pair<std::string,int>& p(ret[i]);
        PyObject *elt(PyTuple_New(2));
        PyTuple_SetItem(elt,0,PyUnicode_FromString(p.first.c_str()));
        PyTuple_SetItem(elt,1,PyLong_FromLong(p.second));
        PyList_SetItem(ob,i,elt);
      }
  }
  if(_mode==REMOTE_NAME)
    {
      Engines::pickledArgs_var serializationInputCorba(new Engines::pickledArgs);
      {
        AutoGIL agil;
        PyObject *serializationInput(PyObject_CallFunctionObjArgs(_pyfuncSimpleSer,ob,NULL));
        Py_XDECREF(ob);
        char *serializationInputC(0);
        Py_ssize_t len;
        if (PyBytes_AsStringAndSize(serializationInput, &serializationInputC, &len))
          throw Exception("DistributedPythonNode problem in python pickle");
        serializationInputCorba->length(len);
        for(int i=0; i < len ; i++)
          serializationInputCorba[i]=serializationInputC[i];
        Py_XDECREF(serializationInput);
      }
      _pynode->defineNewCustomVar(DPL_INFO_NAME,serializationInputCorba);
    }
  else
    {
      AutoGIL agil;
      PyDict_SetItemString(_context,DPL_INFO_NAME,ob);
      Py_XDECREF(ob);
    }
}

References YACS::ENGINE::PythonEntry::_context, YACS::ENGINE::InlineNode::_mode, YACS::ENGINE::PythonEntry::_pyfuncSimpleSer, _pynode, DPL_INFO_NAME, YACS::ENGINE::Node::getDPLScopeInfo(), yacsorb.CORBAEngineTest::i, p, and REMOTE_NAME.

◆ assignRemotePyInterpretor()

void PythonNode::assignRemotePyInterpretor ( Engines::PyNodeBase_var remoteInterp )

protectedvirtual

Implements YACS::ENGINE::PythonEntry.

Definition at line 1005 of file PythonNode.cxx.

{
  if(CORBA::is_nil(_pynode))
    _pynode=Engines::PyScriptNode::_narrow(remoteInterp);
  else
  {
    Engines::PyScriptNode_var tmpp(Engines::PyScriptNode::_narrow(remoteInterp));
    if(!_pynode->_is_equivalent(tmpp))
    {
      freeKernelPynode();
      _pynode=Engines::PyScriptNode::_narrow(remoteInterp);
    }
  }
  _pynode->assignNewCompiledCode(getScript().c_str());
}

References _pynode, freeKernelPynode(), and YACS::ENGINE::InlineNode::getScript().

◆ canAcceptImposedResource()

bool PythonNode::canAcceptImposedResource ( )

overridevirtual

Reimplemented from YACS::ENGINE::Task.

Definition at line 941 of file PythonNode.cxx.

{
  return _container != nullptr && _container->canAcceptImposedResource();
}

References YACS::ENGINE::InlineNode::_container, and YACS::ENGINE::Container::canAcceptImposedResource().

◆ checkBasicConsistency()

void PythonNode::checkBasicConsistency ( ) const

virtual

Reimplemented from YACS::ENGINE::ElementaryNode.

Definition at line 458 of file PythonNode.cxx.

{
  DEBTRACE("checkBasicConsistency");
  InlineNode::checkBasicConsistency();
  {
    AutoGIL agil;
    PyObject* res;
    res=Py_CompileString(_script.c_str(),getName().c_str(),Py_file_input);
    if(res == NULL)
      {
        std::string error="";
        PyObject* new_stderr = newPyStdOut(error);
        PySys_SetObject((char*)"stderr", new_stderr);
        PyErr_Print();
        PySys_SetObject((char*)"stderr", PySys_GetObject((char*)"__stderr__"));
        Py_DECREF(new_stderr);
        throw Exception(error);
      }
    else
      Py_XDECREF(res);
  }
}

References YACS::ENGINE::InlineNode::_script, YACS::ENGINE::ElementaryNode::checkBasicConsistency(), DEBTRACE, YACS::ENGINE::Node::getName(), and YACS::ENGINE::newPyStdOut().

◆ cloneNode()

PythonNode * PythonNode::cloneNode ( const std::string & name )

virtual

Create a new node of same type with a given name.

Reimplemented from YACS::ENGINE::InlineNode.

Definition at line 1027 of file PythonNode.cxx.

{
  PythonNode* n=new PythonNode(name);
  n->setScript(_script);
  list<InputPort *>::iterator iter;
  for(iter = _setOfInputPort.begin(); iter != _setOfInputPort.end(); iter++)
    {
      InputPyPort *p=(InputPyPort *)*iter;
      DEBTRACE( "port name: " << p->getName() );
      DEBTRACE( "port kind: " << p->edGetType()->kind() );
      n->edAddInputPort(p->getName(),p->edGetType());
    }
  list<OutputPort *>::iterator iter2;
  for(iter2 = _setOfOutputPort.begin(); iter2 != _setOfOutputPort.end(); iter2++)
    {
      OutputPyPort *p=(OutputPyPort *)*iter2;
      DEBTRACE( "port name: " << p->getName() );
      DEBTRACE( "port kind: " << p->edGetType()->kind() );
      n->edAddOutputPort(p->getName(),p->edGetType());
    }
  return n;
}

References YACS::ENGINE::InlineNode::_script, YACS::ENGINE::ElementaryNode::_setOfInputPort, YACS::ENGINE::ElementaryNode::_setOfOutputPort, DEBTRACE, YACS::ENGINE::ComposedNode::getName(), gui.Appli::n, p, and PythonNode().

◆ createRemoteAdaptedPyInterpretor()

void PythonNode::createRemoteAdaptedPyInterpretor ( Engines::Container_ptr objContainer )

protectedvirtual

returns an object, you have to deal with (UnRegister)

Implements YACS::ENGINE::PythonEntry.

Definition at line 988 of file PythonNode.cxx.

{
  freeKernelPynode();
  _pynode=objContainer->createPyScriptNode(pythonEntryName().c_str(),getScript().c_str());
  _pynode->Register();
}

References _pynode, freeKernelPynode(), YACS::ENGINE::InlineNode::getScript(), and pythonEntryName().

◆ execute()

void PythonNode::execute ( )

virtual

Implements YACS::ENGINE::Task.

Definition at line 501 of file PythonNode.cxx.

{
  if(_mode==PythonNode::REMOTE_NAME)
    executeRemote();
  else
    executeLocal();
}

References YACS::ENGINE::InlineNode::_mode, executeLocal(), executeRemote(), and REMOTE_NAME.

◆ executeLocal()

void PythonNode::executeLocal ( )

virtual

Definition at line 778 of file PythonNode.cxx.

{
  DEBTRACE( "++++++++++++++ PyNode::executeLocal: " << getName() << " ++++++++++++++++++++" );
  {
    AutoGIL agil;
    std::ostringstream unpxy; unpxy << "from SALOME_PyNode import UnProxyObjectSimpleLocal" << std::endl;
    DEBTRACE( "---------------PyNode::inputs---------------" );
    list<InputPort *>::iterator iter2;
    for(iter2 = _setOfInputPort.begin(); iter2 != _setOfInputPort.end(); iter2++)
      {
        InputPyPort *p=(InputPyPort *)*iter2;
        DEBTRACE( "port name: " << p->getName() );
        DEBTRACE( "port kind: " << p->edGetType()->kind() );
        PyObject* ob=p->getPyObj();
        DEBTRACE( "ob refcnt: " << ob->ob_refcnt ); 
        unpxy << p->getName() << " = UnProxyObjectSimpleLocal( " << p->getName() << " )" << std::endl;
#ifdef _DEVDEBUG_
        PyObject_Print(ob,stderr,Py_PRINT_RAW);
        cerr << endl;
#endif
        int ier=PyDict_SetItemString(_context,p->getName().c_str(),ob);
        DEBTRACE( "after PyDict_SetItemString:ob refcnt: " << ob->ob_refcnt );
      }
 
    DEBTRACE( "---------------End PyNode::inputs---------------" );
 
    //calculation
    DEBTRACE( "----------------PyNode::calculation---------------" );
  
    if( ! getSqueezeStatus() )
      executeLocalInternal( unpxy.str() );
 
    executeLocalInternal( _script );
 
    DEBTRACE( "-----------------PyNode::outputs-----------------" );
    list<OutputPort *>::iterator iter;
    try
    {
        for(iter = _setOfOutputPort.begin(); iter != _setOfOutputPort.end(); iter++)
          {
            OutputPyPort *p=(OutputPyPort *)*iter;
            DEBTRACE( "port name: " << p->getName() );
            DEBTRACE( "port kind: " << p->edGetType()->kind() );
            PyObject *ob=PyDict_GetItemString(_context,p->getName().c_str());
            if(ob==NULL)
              {
                std::string msg="Error during execution: there is no variable ";
                msg=msg+p->getName()+" in node context";
                _errorDetails=msg;
                throw Exception(msg);
              }
            DEBTRACE( "PyNode::outputs::ob refcnt: " << ob->ob_refcnt );
#ifdef _DEVDEBUG_
            PyObject_Print(ob,stderr,Py_PRINT_RAW);
            cerr << endl;
#endif
            p->put(ob);
            if(!isUsingPythonCache())
              PyDict_DelItemString(_context,p->getName().c_str());
          }
    }
    catch(ConversionException& ex)
    {
        _errorDetails=ex.what();
        throw;
    }
    if(_autoSqueeze)
      squeezeMemory();
    DEBTRACE( "-----------------End PyNode::outputs-----------------" );
    if(!isUsingPythonCache())
    {
      for(iter2 = _setOfInputPort.begin(); iter2 != _setOfInputPort.end(); iter2++)
      {
        AutoPyRef pStr = PyUnicode_FromString( (*iter2)->getName().c_str() );
        if( PyDict_Contains(_context,pStr) == 1 )
          { PyDict_DelItem(_context,pStr); }
      }
    }
  }
  DEBTRACE( "++++++++++++++ End PyNode::execute: " << getName() << " ++++++++++++++++++++" );
}

References _autoSqueeze, YACS::ENGINE::PythonEntry::_context, YACS::ENGINE::Node::_errorDetails, YACS::ENGINE::InlineNode::_script, YACS::ENGINE::ElementaryNode::_setOfInputPort, YACS::ENGINE::ElementaryNode::_setOfOutputPort, DEBTRACE, testCppPluginInvokation::ex, executeLocalInternal(), YACS::ENGINE::ComposedNode::getName(), YACS::ENGINE::Node::getName(), getSqueezeStatus(), isUsingPythonCache(), p, and squeezeMemory().

Referenced by execute().

◆ executeLocalInternal()

void PythonNode::executeLocalInternal ( const std::string & codeStr )

private

Definition at line 773 of file PythonNode.cxx.

{
  ExecuteLocalInternal(codeStr,_context,_errorDetails);
}

References YACS::ENGINE::PythonEntry::_context, YACS::ENGINE::Node::_errorDetails, and ExecuteLocalInternal().

Referenced by executeLocal().

◆ ExecuteLocalInternal()

void PythonNode::ExecuteLocalInternal	(	const std::string &	codeStr,
		PyObject *	context,
		std::string &	errorDetails
	)

static

Definition at line 733 of file PythonNode.cxx.

{
  DEBTRACE(  code );
  DEBTRACE( "context refcnt: " << context->ob_refcnt );
  std::ostringstream stream;
  stream << "/tmp/PythonNode_";
  stream << getpid();
  AutoPyRef code=Py_CompileString(codeStr.c_str(), stream.str().c_str(), Py_file_input);
  if(code == NULL)
  {
    errorDetails=""; 
    AutoPyRef new_stderr = newPyStdOut(errorDetails);
    PySys_SetObject((char*)"stderr", new_stderr);
    PyErr_Print();
    PySys_SetObject((char*)"stderr", PySys_GetObject((char*)"__stderr__"));
    throw YACS::Exception("Error during execution");
  }
  {
    AutoPyRef res = PyEval_EvalCode(  code, context, context);
  }
  DEBTRACE( "context refcnt: " << context->ob_refcnt );
  fflush(stdout);
  fflush(stderr);
  if(PyErr_Occurred ())
  {
    errorDetails="";
    AutoPyRef new_stderr = newPyStdOut(errorDetails);
    PySys_SetObject((char*)"stderr", new_stderr);
    ofstream errorfile(stream.str().c_str());
    if (errorfile.is_open())
      {
        errorfile << codeStr;
        errorfile.close();
      }
    PyErr_Print();
    PySys_SetObject((char*)"stderr", PySys_GetObject((char*)"__stderr__"));
    throw YACS::Exception("Error during execution");
  }
}

References DEBTRACE, and YACS::ENGINE::newPyStdOut().

Referenced by executeLocalInternal(), and YACS::ENGINE::RuntimeSALOME::launchSubProcess().

◆ executeRemote()

void PythonNode::executeRemote ( )

virtual

Definition at line 509 of file PythonNode.cxx.

{
  DEBTRACE( "++++++++++++++ PyNode::executeRemote: " << getName() << " ++++++++++++++++++++" );
  if(!_pyfuncSer)
    throw Exception("PythonNode badly loaded");
  //
  if(dynamic_cast<HomogeneousPoolContainer *>(getContainer()))
    {
      bool dummy;
      loadPythonAdapter(this,dummy);
      _pynode->assignNewCompiledCode(getScript().c_str());
    }
  // not managed by unique_ptr here because destructed by the order of client.
  SenderByteImpl *serializationInputCorba = nullptr;
  AutoPyRef serializationInput;
  {
#if PY_VERSION_HEX < 0x03070000
      std::unique_lock<std::mutex> lock(data_mutex);
#endif
      AutoGIL agil;
      PyObject *args(0),*ob(0);
      //===========================================================================
      // Get inputs in input ports, build a Python dict and pickle it
      //===========================================================================
      args = PyDict_New();
      std::list<InputPort *>::iterator iter2;
      int pos(0);
      for(iter2 = _setOfInputPort.begin(); iter2 != _setOfInputPort.end(); ++iter2)
        {
          InputPyPort *p=(InputPyPort *)*iter2;
          ob=p->getPyObj();
          PyDict_SetItemString(args,p->getName().c_str(),ob);
          pos++;
        }
#ifdef _DEVDEBUG_
      PyObject_Print(args,stderr,Py_PRINT_RAW);
      std::cerr << endl;
#endif
      serializationInput.set(PyObject_CallFunctionObjArgs(_pyfuncSer,args,nullptr));
      Py_DECREF(args);
      //The pickled string may contain NULL characters so use PyString_AsStringAndSize
      char *serializationInputC(nullptr);
      Py_ssize_t len;
      if (PyBytes_AsStringAndSize(serializationInput, &serializationInputC, &len))
        throw Exception("DistributedPythonNode problem in python pickle");
      // no copy here. The C byte array of Python is taken  as this into CORBA sequence to avoid copy
      serializationInputCorba = new SenderByteImpl(serializationInputC,len);
  }
 
  //get the list of output argument names
  std::list<OutputPort *>::iterator iter;
  Engines::listofstring myseq;
  myseq.length(getNumberOfOutputPorts());
  int pos=0;
  for(iter = _setOfOutputPort.begin(); iter != _setOfOutputPort.end(); ++iter)
    {
      OutputPyPort *p=(OutputPyPort *)*iter;
      myseq[pos]=p->getName().c_str();
      DEBTRACE( "port name: " << p->getName() );
      DEBTRACE( "port kind: " << p->edGetType()->kind() );
      DEBTRACE( "port pos : " << pos );
      pos++;
    }
  //===========================================================================
  // Execute in remote Python node
  //===========================================================================
  DEBTRACE( "-----------------starting remote python invocation-----------------" );
  std::unique_ptr<SALOME::SenderByteSeq> resultCorba;
  try
    {
      //pass outargsname and dict serialized
      SALOME::SenderByte_var serializationInputRef = serializationInputCorba->_this();
      DEBUG_YACSTRACE("Before execute first of " << getId());
      _pynode->executeFirst(serializationInputRef);
      //serializationInput and serializationInputCorba are no more needed for server. Release it.
      {
        AutoGIL agil;
        serializationInput.set(nullptr);
      }
      resultCorba.reset( _pynode->executeSecond(myseq) );
      DEBUG_YACSTRACE("After execute second of " << getId());
    }
  catch( const SALOME::SALOME_Exception& ex )
    {
      std::ostringstream msg; msg << "Exception on remote python invocation" << std::endl << ex.details.text.in() << std::endl;
      msg << "PyScriptNode CORBA ref : ";
      {
        CORBA::ORB_ptr orb(getSALOMERuntime()->getOrb());
        if(!CORBA::is_nil(orb))
        {
          CORBA::String_var IOR(orb->object_to_string(_pynode));
          msg << IOR;
        }
      }
      msg << std::endl;
      _errorDetails=msg.str();
      throw Exception(msg.str());
    }
  catch(CORBA::COMM_FAILURE& ex)
    {
      std::ostringstream msg;
      msg << "Exception on remote python invocation." << std::endl ;
      msg << "Caught system exception COMM_FAILURE -- unable to contact the "
          << "object." << std::endl;
      _errorDetails=msg.str();
      throw Exception(msg.str());
    }
  catch(CORBA::SystemException& ex)
    {
      std::ostringstream msg;
      msg << "Exception on remote python invocation." << std::endl ;
      msg << "Caught a CORBA::SystemException." ;
      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();
      msg << std::endl;
      _errorDetails=msg.str();
      throw Exception(msg.str());
    }
  catch(CORBA::Exception& ex)
    {
      std::ostringstream msg;
      msg << "Exception on remote python invocation." << std::endl ;
      msg << "Caught CORBA::Exception. " ;
      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();
      msg << std::endl;
      _errorDetails=msg.str();
      throw Exception(msg.str());
    }
  catch(omniORB::fatalException& fe)
    {
      std::ostringstream msg;
      msg << "Exception on remote python invocation." << std::endl ;
      msg << "Caught omniORB::fatalException:" << std::endl;
      msg << "  file: " << fe.file() << std::endl;
      msg << "  line: " << fe.line() << std::endl;
      msg << "  mesg: " << fe.errmsg() << std::endl;
      _errorDetails=msg.str();
      throw Exception(msg.str());
    }
  DEBTRACE( "-----------------end of remote python invocation-----------------" );
  //===========================================================================
  // Get results, unpickle and put them in output ports
  //===========================================================================
  {
#if PY_VERSION_HEX < 0x03070000
      std::unique_lock<std::mutex> lock(data_mutex);
#endif
      AutoGIL agil;
      DEBTRACE( "-----------------PythonNode::outputs-----------------" );
      int nres( resultCorba->length() );
 
      if(getNumberOfOutputPorts() != nres)
        {
          std::string msg="Number of output arguments : Mismatch between definition and execution";
          _errorDetails=msg;
          throw Exception(msg);
        }
      pos=0;
      try
      {
          for(iter = _setOfOutputPort.begin(); iter != _setOfOutputPort.end(); ++iter)
            {
              OutputPyPort *p=(OutputPyPort *)*iter;
              DEBUG_YACSTRACE("Start of dealing with output " << p->getName() << " of "<< getId());
              DEBTRACE( "port name: " << p->getName() );
              DEBTRACE( "port kind: " << p->edGetType()->kind() );
              DEBTRACE( "port pos : " << pos );
              SALOME::SenderByte_var elt = (*resultCorba)[pos];
              SeqByteReceiver recv(elt);
              unsigned long length = 0;
              char *resultCorbaC = recv.data(length);
              {
                AutoPyRef resultPython=PyMemoryView_FromMemory(resultCorbaC,length,PyBUF_READ);
                AutoPyRef args = PyTuple_New(1);
                PyTuple_SetItem(args,0,resultPython.retn());
                AutoPyRef ob = PyObject_CallObject(_pyfuncUnser,args);
                if (!ob)
                {
                  std::stringstream msg;
                  msg << "Conversion with pickle of output ports failed !";
                  msg << " : " << __FILE__ << ":" << __LINE__;
                  _errorDetails=msg.str();
                  throw YACS::ENGINE::ConversionException(msg.str());
                }
                UnlinkOnDestructorIfProxy(ob);
                DEBUG_YACSTRACE("Assign PyObj output " << p->getName() << " of "<< getId());
                p->put( ob );
                DEBUG_YACSTRACE("End of assign PyObj output " << p->getName() << " of "<< getId());
              }
              pos++;
            }
      }
      catch(ConversionException& ex)
      {
          _errorDetails=ex.what();
          throw;
      }
      if(_autoSqueeze)
        squeezeMemoryRemote();
  }
  //
  if(!isUsingPythonCache())
  {
    freeKernelPynode();
    bool dummy;
    Engines::Container_var cont(GetContainerObj(this,dummy));
    cont->removePyScriptNode(getId().c_str());
  }
  DEBTRACE( "++++++++++++++ ENDOF PyNode::executeRemote: " << getName() << " ++++++++++++++++++++" );
}

References _autoSqueeze, YACS::ENGINE::Node::_errorDetails, YACS::ENGINE::PythonEntry::_pyfuncSer, YACS::ENGINE::PythonEntry::_pyfuncUnser, _pynode, YACS::ENGINE::ElementaryNode::_setOfInputPort, YACS::ENGINE::ElementaryNode::_setOfOutputPort, driver_internal::args, data_mutex, DEBTRACE, DEBUG_YACSTRACE, testCppPluginInvokation::ex, freeKernelPynode(), YACS::ENGINE::InlineNode::getContainer(), GetContainerObj(), YACS::ENGINE::Node::getId(), YACS::ENGINE::ComposedNode::getName(), YACS::ENGINE::Node::getName(), YACS::ENGINE::ElementaryNode::getNumberOfOutputPorts(), YACS::ENGINE::getSALOMERuntime(), YACS::ENGINE::InlineNode::getScript(), isUsingPythonCache(), YACS::ENGINE::PythonEntry::loadPythonAdapter(), orb, p, squeezeMemoryRemote(), and YACS::ENGINE::PythonEntry::UnlinkOnDestructorIfProxy().

Referenced by execute().

◆ freeKernelPynode()

void PythonNode::freeKernelPynode ( )

protected

Definition at line 967 of file PythonNode.cxx.

{
  if(!CORBA::is_nil(_pynode))
  {
    try
    {
      _pynode->UnRegister();
    }
    catch(...)
    {
      DEBTRACE("Trouble when pynode->UnRegister!")
    }
    _pynode = Engines::PyScriptNode::_nil();
  }
}

References _pynode, and DEBTRACE.

Referenced by assignRemotePyInterpretor(), createRemoteAdaptedPyInterpretor(), executeRemote(), shutdown(), and ~PythonNode().

◆ getContainerLog()

std::string PythonNode::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 915 of file PythonNode.cxx.

{
  return PythonEntry::GetContainerLog(_mode,_container,this);
}

References YACS::ENGINE::InlineNode::_container, YACS::ENGINE::InlineNode::_mode, and YACS::ENGINE::PythonEntry::GetContainerLog().

◆ getRemoteInterpreterHandle()

Engines::PyNodeBase_var PythonNode::getRemoteInterpreterHandle ( )

protectedvirtual

Implements YACS::ENGINE::PythonEntry.

Definition at line 1021 of file PythonNode.cxx.

{
  return Engines::PyNodeBase::_narrow(_pynode);
}

References _pynode.

◆ getSerializationScript()

const char * YACS::ENGINE::PythonNode::getSerializationScript ( ) const

inlineprotectedvirtual

Implements YACS::ENGINE::PythonEntry.

Definition at line 84 of file PythonNode.hxx.

84{ return SCRIPT_FOR_SERIALIZATION; }

YACS::ENGINE::PythonNode::SCRIPT_FOR_SERIALIZATION

static const char SCRIPT_FOR_SERIALIZATION[]

Definition: PythonNode.hxx:124

◆ getSqueezeStatus()

bool YACS::ENGINE::PythonNode::getSqueezeStatus ( ) const

inline

Definition at line 112 of file PythonNode.hxx.

112{ return _autoSqueeze; }

Referenced by executeLocal().

◆ hasImposedResource()

bool PythonNode::hasImposedResource ( ) const

overridevirtual

Reimplemented from YACS::ENGINE::PythonEntry.

Definition at line 946 of file PythonNode.cxx.

{
  return PythonEntry::hasImposedResource();
}

References YACS::ENGINE::PythonEntry::hasImposedResource().

◆ imposeResource()

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

overridevirtual

Reimplemented from YACS::ENGINE::Task.

Definition at line 931 of file PythonNode.cxx.

{
  if(!resource_name.empty() && !container_name.empty())
  {
    _imposedResource = resource_name;
    _imposedContainer = container_name;
  }
}

References YACS::ENGINE::PythonEntry::_imposedContainer, and YACS::ENGINE::PythonEntry::_imposedResource.

◆ isUsingPythonCache()

bool PythonNode::isUsingPythonCache ( ) const

Definition at line 959 of file PythonNode.cxx.

{
  bool found = false;
  if(_container)
    found = _container->isUsingPythonCache();
  return found;
}

References YACS::ENGINE::InlineNode::_container, and YACS::ENGINE::Container::isUsingPythonCache().

Referenced by executeLocal(), executeRemote(), and pythonEntryName().

◆ load()

void PythonNode::load ( )

virtual

Reimplemented from YACS::ENGINE::ElementaryNode.

Definition at line 481 of file PythonNode.cxx.

{
  DEBTRACE( "---------------PyNode::load function---------------" );
  if(_mode==PythonNode::REMOTE_NAME)
    loadRemote();
  else
    loadLocal();
}

References YACS::ENGINE::InlineNode::_mode, DEBTRACE, loadLocal(), loadRemote(), and REMOTE_NAME.

◆ loadLocal()

void PythonNode::loadLocal ( )

virtual

Definition at line 490 of file PythonNode.cxx.

{
  DEBTRACE( "---------------PyNode::loadLocal function---------------" );
  // do nothing
}

References DEBTRACE.

Referenced by load().

◆ loadRemote()

void PythonNode::loadRemote ( )

virtual

Definition at line 496 of file PythonNode.cxx.

{
  commonRemoteLoad(this);
}

References YACS::ENGINE::PythonEntry::commonRemoteLoad().

Referenced by load().

◆ pythonEntryName()

std::string PythonNode::pythonEntryName ( ) const

protected

Definition at line 951 of file PythonNode.cxx.

{
  if(isUsingPythonCache())
    return "DEFAULT_NAME_FOR_UNIQUE_PYTHON_NODE_ENTRY";
  else
    return getId();
}

References YACS::ENGINE::Node::getId(), and isUsingPythonCache().

Referenced by createRemoteAdaptedPyInterpretor(), and retrieveDftRemotePyInterpretorIfAny().

◆ retrieveDftRemotePyInterpretorIfAny()

Engines::PyNodeBase_var PythonNode::retrieveDftRemotePyInterpretorIfAny ( Engines::Container_ptr objContainer ) const

protectedvirtual

returns (if any) an object, you have to deal with (UnRegister)

Implements YACS::ENGINE::PythonEntry.

Definition at line 995 of file PythonNode.cxx.

{
  Engines::PyScriptNode_var ret(objContainer->getDefaultPyScriptNode(pythonEntryName().c_str()));
  if(!CORBA::is_nil(ret))
    {
      ret->Register();
    }
  return Engines::PyNodeBase::_narrow(ret);
}

References pythonEntryName().

◆ setSqueezeStatus()

void YACS::ENGINE::PythonNode::setSqueezeStatus ( bool sqStatus )

inline

Definition at line 111 of file PythonNode.hxx.

111{ _autoSqueeze=sqStatus; }

Referenced by main(), and setSqueezeStatusWithExceptions().

◆ setSqueezeStatusWithExceptions()

void PythonNode::setSqueezeStatusWithExceptions	(	bool	sqStatus,
		const std::vector< std::string > &	squeezeExceptions
	)

[EDF28562]

Parameters

in	squeezeExceptions list on output port name excluded from the squeeze mecanism

Definition at line 864 of file PythonNode.cxx.

{
  this->setSqueezeStatus(sqStatus);
  this->_nonSqueezableOutputNodes = std::set<std::string>(squeezeExceptions.begin(), squeezeExceptions.end());
}

References _nonSqueezableOutputNodes, and setSqueezeStatus().

◆ shutdown()

void PythonNode::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 920 of file PythonNode.cxx.

{
  DEBTRACE("PythonNode::shutdown " << level);
  if(_mode=="local")return;
  if(_container)
    {
      freeKernelPynode();
      _container->shutdown(level);
    }
}

References YACS::ENGINE::InlineNode::_container, YACS::ENGINE::InlineNode::_mode, DEBTRACE, freeKernelPynode(), and YACS::ENGINE::Container::shutdown().

◆ simpleClone()

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

protectedvirtual

Implements YACS::ENGINE::Node.

Definition at line 983 of file PythonNode.cxx.

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

References PythonNode().

◆ squeezeMemory()

void PythonNode::squeezeMemory ( )

protected

Definition at line 879 of file PythonNode.cxx.

{
  for(auto p : _setOfInputPort)
    {
      PyDict_DelItemString(_context,p->getName().c_str());
      InputPyPort *p2(static_cast<InputPyPort *>(p));
      if(p2->canSafelySqueezeMemory())
        p2->put(Py_None);
    }
  for(auto p : _setOfOutputPort)
    {
      if (!this->_nonSqueezableOutputNodes.empty() && this->_nonSqueezableOutputNodes.find(p->getName()) != this->_nonSqueezableOutputNodes.end())
        continue;
      PyDict_DelItemString(_context,p->getName().c_str());
      OutputPyPort *p2(static_cast<OutputPyPort *>(p));
      p2->putWithoutForward(Py_None);
    }
}

References YACS::ENGINE::PythonEntry::_context, _nonSqueezableOutputNodes, YACS::ENGINE::ElementaryNode::_setOfInputPort, YACS::ENGINE::ElementaryNode::_setOfOutputPort, YACS::ENGINE::InPort::canSafelySqueezeMemory(), YACS::ENGINE::ComposedNode::getName(), p, YACS::ENGINE::InputPyPort::put(), and YACS::ENGINE::OutputPyPort::putWithoutForward().

Referenced by executeLocal(), and squeezeMemorySafe().

◆ squeezeMemoryRemote()

void PythonNode::squeezeMemoryRemote ( )

protected

Definition at line 898 of file PythonNode.cxx.

{
  for(auto p : _setOfInputPort)
    {
      InputPyPort *p2(static_cast<InputPyPort *>(p));
      if(p2->canSafelySqueezeMemory())
        p2->put(Py_None);
    }
  for(auto p : _setOfOutputPort)
    {
      if (!this->_nonSqueezableOutputNodes.empty() && this->_nonSqueezableOutputNodes.find(p->getName()) != this->_nonSqueezableOutputNodes.end())
        continue;
      OutputPyPort *p2(static_cast<OutputPyPort *>(p));
      p2->putWithoutForward(Py_None);
    }
}

References _nonSqueezableOutputNodes, YACS::ENGINE::ElementaryNode::_setOfInputPort, YACS::ENGINE::ElementaryNode::_setOfOutputPort, YACS::ENGINE::InPort::canSafelySqueezeMemory(), YACS::ENGINE::ComposedNode::getName(), p, YACS::ENGINE::InputPyPort::put(), and YACS::ENGINE::OutputPyPort::putWithoutForward().

Referenced by executeRemote(), and squeezeMemorySafe().

◆ squeezeMemorySafe()

void PythonNode::squeezeMemorySafe ( )

Definition at line 870 of file PythonNode.cxx.

{
  AutoGIL agil;
  if(_mode==PythonNode::REMOTE_NAME)
    this->squeezeMemoryRemote();
  else
    this->squeezeMemory();
}

References YACS::ENGINE::InlineNode::_mode, REMOTE_NAME, squeezeMemory(), and squeezeMemoryRemote().

◆ typeName()

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

inlinevirtual

Reimplemented from YACS::ENGINE::InlineNode.

Definition at line 108 of file PythonNode.hxx.

108{ return "YACS__ENGINE__PythonNode"; }

Member Data Documentation

◆ _autoSqueeze

bool YACS::ENGINE::PythonNode::_autoSqueeze = false

protected

Definition at line 128 of file PythonNode.hxx.

Referenced by executeLocal(), and executeRemote().

◆ _nonSqueezableOutputNodes

std::set<std::string> YACS::ENGINE::PythonNode::_nonSqueezableOutputNodes

protected

list on output port name excluded from the squeeze mecanism

Definition at line 130 of file PythonNode.hxx.

Referenced by setSqueezeStatusWithExceptions(), squeezeMemory(), and squeezeMemoryRemote().

◆ _pynode

Engines::PyScriptNode_var YACS::ENGINE::PythonNode::_pynode

protected

Definition at line 131 of file PythonNode.hxx.

Referenced by applyDPLScope(), assignRemotePyInterpretor(), createRemoteAdaptedPyInterpretor(), executeRemote(), freeKernelPynode(), getRemoteInterpreterHandle(), and PythonNode().

◆ DPL_INFO_NAME

const char PythonNode::DPL_INFO_NAME ="my_dpl_localization"

static

Definition at line 126 of file PythonNode.hxx.

Referenced by applyDPLScope().

◆ IMPL_NAME

const char PythonNode::IMPL_NAME ="Python"

static

Definition at line 123 of file PythonNode.hxx.

Referenced by YACS::ENGINE::RuntimeSALOME::adapt(), YACS::ENGINE::RuntimeSALOME::adaptNeutral(), YACS::ENGINE::RuntimeSALOME::createInputPort(), YACS::ENGINE::RuntimeSALOME::createOutputPort(), YACS::ENGINE::PyFuncNode::PyFuncNode(), PythonNode(), YACS::ENGINE::RuntimeSALOME::RuntimeSALOME(), and YACS::ENGINE::SalomePythonNode::SalomePythonNode().

◆ KIND

const char PythonNode::KIND ="Python"

static

Definition at line 122 of file PythonNode.hxx.

Referenced by YACS::ENGINE::RuntimeSALOME::createFuncNode(), YACS::ENGINE::RuntimeSALOME::createScriptNode(), and YACS::ENGINE::DistributedPythonNode::getKind().

◆ REMOTE_NAME

const char PythonNode::REMOTE_NAME ="remote"

static

Definition at line 125 of file PythonNode.hxx.

Referenced by applyDPLScope(), execute(), YACS::ENGINE::PyFuncNode::execute(), load(), YACS::ENGINE::PyFuncNode::load(), and squeezeMemorySafe().

◆ SCRIPT_FOR_SERIALIZATION

const char PythonNode::SCRIPT_FOR_SERIALIZATION

static

Initial value:

="import pickle\n"
    "def pickleForDistPyth2009(kws):\n"
    "  return pickle.dumps(((),kws),-1)\n"
    "\n"
    "def unPickleForDistPyth2009(st):\n"
    "  args=pickle.loads(st)\n"
    "  return args\n"

Definition at line 124 of file PythonNode.hxx.

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

src/runtime/PythonNode.hxx
src/runtime/PythonNode.cxx

Public Member Functions

Static Public Member Functions

Static Public Attributes

Protected Member Functions

Protected Attributes

Private Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ PythonNode() [1/2]

◆ PythonNode() [2/2]

◆ ~PythonNode()

Member Function Documentation

◆ applyDPLScope()

◆ assignRemotePyInterpretor()

◆ canAcceptImposedResource()

◆ checkBasicConsistency()

◆ cloneNode()

◆ createRemoteAdaptedPyInterpretor()

◆ execute()

◆ executeLocal()

◆ executeLocalInternal()

◆ ExecuteLocalInternal()

◆ executeRemote()

◆ freeKernelPynode()

◆ getContainerLog()

◆ getRemoteInterpreterHandle()

◆ getSerializationScript()

◆ getSqueezeStatus()

◆ hasImposedResource()

◆ imposeResource()

◆ isUsingPythonCache()

◆ load()

◆ loadLocal()

◆ loadRemote()

◆ pythonEntryName()

◆ retrieveDftRemotePyInterpretorIfAny()

◆ setSqueezeStatus()

◆ setSqueezeStatusWithExceptions()

◆ shutdown()

◆ simpleClone()

◆ squeezeMemory()

◆ squeezeMemoryRemote()

◆ squeezeMemorySafe()

◆ typeName()

Member Data Documentation

◆ _autoSqueeze

◆ _nonSqueezableOutputNodes

◆ _pynode

◆ DPL_INFO_NAME

◆ IMPL_NAME

◆ KIND

◆ REMOTE_NAME

◆ SCRIPT_FOR_SERIALIZATION