#include <PythonNode.hxx>

Inheritance diagram for YACS::ENGINE::PyFuncNode:

Collaboration diagram for YACS::ENGINE::PyFuncNode:

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

	PyFuncNode (const std::string &name)

virtual	~PyFuncNode ()

virtual void	init (bool start=true)

virtual void	checkBasicConsistency () const throw (Exception)

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

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

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

virtual std::string	typeName ()

Public Member Functions inherited from YACS::ENGINE::InlineFuncNode
virtual void	setFname (const std::string &fname)
	Set the function name to use in node execution. More...

virtual std::string	getFname ()

void	accept (Visitor *visitor)

virtual	~InlineFuncNode ()

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

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

ComponentInstance *	getComponent ()

const ComponentInstance *	getComponent () const

YACS::StatesForNode	getState () const

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

void	edRemovePort (Port *port) throw (Exception)

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

ComposedNode *	getDynClonerIfExists (const ComposedNode *levelToStop) const

int	getNumberOfInputPorts () const

int	getNumberOfOutputPorts () const

std::string	getInPortName (const InPort *) const throw (Exception)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

template<class PORT >
void	edRemovePortTypedFromSet (PORT port, std::list< PORT > &setOfPorts) throw (Exception)

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

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

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	getEffectiveState () const
	Return the node state in the context of its father. More...

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

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

InGate *	getInGate ()

OutGate *	getOutGate ()

const std::string &	getName () const

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

ComposedNode *	getFather () const

const std::string	getId () const

bool	exIsControlReady () const

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

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

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

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

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

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

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

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

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

InPropertyPort *	getInPropertyPort () const throw (Exception)

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

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

bool	operator> (const Node &other) const

bool	operator< (const Node &other) const

std::string	getImplementation () const

virtual ComposedNode *	getRootNode () const throw (Exception)

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

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

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

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

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

virtual Proc *	getProc ()

virtual const Proc *	getProc () const

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

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

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

virtual void	applyDPLScope (ComposedNode *gfn)

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

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

virtual std::string	getErrorDetails () const

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

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

virtual int	isModified ()

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

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

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

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

Static Public Attributes
static const char	SCRIPT_FOR_SERIALIZATION []

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

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

	InlineFuncNode (const std::string &name)

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

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

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

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

	Node (const Node &other, ComposedNode *father)

virtual void	exForwardFailed ()

virtual void	exForwardFinished ()

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

	~PythonEntry ()

void	commonRemoteLoad (InlineNode *reqNode)

void	commonRemoteLoadPart1 (InlineNode *reqNode)

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

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

Protected Attributes
PyObject *	_pyfunc

Engines::PyNode_var	_pynode

Protected Attributes inherited from YACS::ENGINE::InlineFuncNode
std::string	_fname

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

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

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

PyObject *	_pyfuncSer

PyObject *	_pyfuncUnser

PyObject *	_pyfuncSimpleSer

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

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

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

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

Detailed Description

Definition at line 98 of file PythonNode.hxx.

Constructor & Destructor Documentation

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

Definition at line 771 of file PythonNode.cxx.

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

Referenced by cloneNode(), and simpleClone().

                                                                    :InlineFuncNode(other,father),_pyfunc(0)
 {
   _implementation = PythonNode::IMPL_NAME;
   {
     AutoGIL agil;
     _context=PyDict_New();
     DEBTRACE( "_context refcnt: " << _context->ob_refcnt );
     if( PyDict_SetItemString( _context, "__builtins__", getSALOMERuntime()->getBuiltins() ))
       {
         stringstream msg;
         msg << "Not possible to set builtins" << __FILE__ << ":" << __LINE__;
         _errorDetails=msg.str();
         throw Exception(msg.str());
       }
   }
 }

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

Definition at line 788 of file PythonNode.cxx.

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

                                            : InlineFuncNode(name),_pyfunc(0)
 {
 
   _implementation = PythonNode::IMPL_NAME;
   DEBTRACE( "PyFuncNode::PyFuncNode " << name );
   {
     AutoGIL agil;
     _context=PyDict_New();
     DEBTRACE( "_context refcnt: " << _context->ob_refcnt );
     if( PyDict_SetItemString( _context, "__builtins__", getSALOMERuntime()->getBuiltins() ))
       {
         stringstream msg;
         msg << "Not possible to set builtins" << __FILE__ << ":" << __LINE__;
         _errorDetails=msg.str();
         throw Exception(msg.str());
       }
   }
 }

PyFuncNode::~PyFuncNode ( )

virtual

Definition at line 807 of file PythonNode.cxx.

References _pynode.

 {
   if(!CORBA::is_nil(_pynode))
     {
       _pynode->UnRegister();
     }
 }

Member Function Documentation

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

protectedvirtual

Implements YACS::ENGINE::PythonEntry.

Definition at line 1211 of file PythonNode.cxx.

References _pynode.

 {
   if(!CORBA::is_nil(_pynode))
     {
       Engines::PyNode_var tmpp(Engines::PyNode::_narrow(remoteInterp));
       if(_pynode->_is_equivalent(tmpp))
         return ;
     }
   if(!CORBA::is_nil(_pynode))
     _pynode->UnRegister();
   _pynode=Engines::PyNode::_narrow(remoteInterp);
 }

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

virtual

Reimplemented from YACS::ENGINE::InlineFuncNode.

Definition at line 829 of file PythonNode.cxx.

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

 {
   DEBTRACE("checkBasicConsistency");
   InlineFuncNode::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);
   }
 }

PyFuncNode * PyFuncNode::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 1230 of file PythonNode.cxx.

References YACS::ENGINE::InlineFuncNode::_fname, YACS::ENGINE::InlineNode::_script, YACS::ENGINE::ElementaryNode::_setOfInputPort, YACS::ENGINE::ElementaryNode::_setOfOutputPort, YACS::ENGINE::ElementaryNode::edAddInputPort(), YACS::ENGINE::ElementaryNode::edAddOutputPort(), YACS::ENGINE::DataPort::edGetType(), YACS::ENGINE::DataPort::getName(), gui.Appli::n, p, PyFuncNode(), YACS::ENGINE::InlineFuncNode::setFname(), and YACS::ENGINE::InlineNode::setScript().

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

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

protectedvirtual

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

Implements YACS::ENGINE::PythonEntry.

Definition at line 1194 of file PythonNode.cxx.

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

 {
   if(!CORBA::is_nil(_pynode))
     _pynode->UnRegister();
   _pynode=objContainer->createPyNode(getName().c_str(),getScript().c_str());
 }

void PyFuncNode::execute ( )

virtual

Implements YACS::ENGINE::Task.

Definition at line 938 of file PythonNode.cxx.

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

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

void PyFuncNode::executeLocal ( )

virtual

Definition at line 1073 of file PythonNode.cxx.

References YACS::ENGINE::Node::_errorDetails, _pyfunc, YACS::ENGINE::InlineNode::_script, YACS::ENGINE::ElementaryNode::_setOfInputPort, YACS::ENGINE::ElementaryNode::_setOfOutputPort, DEBTRACE, YACS::ENGINE::DataPort::edGetType(), YACS::ENGINE::DataPort::getName(), YACS::ENGINE::Node::getName(), YACS::ENGINE::ElementaryNode::getNumberOfInputPorts(), YACS::ENGINE::ElementaryNode::getNumberOfOutputPorts(), YACS::ENGINE::InputPyPort::getPyObj(), YACS::ENGINE::TypeCode::kind(), YACS::ENGINE::newPyStdOut(), p, YACS::ENGINE::OutputPyPort::put(), and YACS::Exception::what().

Referenced by execute().

 {
   DEBTRACE( "++++++++++++++ PyFuncNode::execute: " << getName() << " ++++++++++++++++++++" );
 
   int pos=0;
   PyObject* ob;
   if(!_pyfunc)throw Exception("PyFuncNode badly loaded");
   {
       AutoGIL agil;
       DEBTRACE( "---------------PyFuncNode::inputs---------------" );
       PyObject* args = PyTuple_New(getNumberOfInputPorts()) ;
       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() );
           ob=p->getPyObj();
 #ifdef _DEVDEBUG_
           PyObject_Print(ob,stderr,Py_PRINT_RAW);
           cerr << endl;
 #endif
           DEBTRACE( "ob refcnt: " << ob->ob_refcnt );
           Py_INCREF(ob);
           PyTuple_SetItem(args,pos,ob);
           DEBTRACE( "ob refcnt: " << ob->ob_refcnt );
           pos++;
         }
       DEBTRACE( "---------------End PyFuncNode::inputs---------------" );
 
       DEBTRACE( "----------------PyFuncNode::calculation---------------" );
 #ifdef _DEVDEBUG_
       PyObject_Print(_pyfunc,stderr,Py_PRINT_RAW);
       cerr << endl;
       PyObject_Print(args,stderr,Py_PRINT_RAW);
       cerr << endl;
 #endif
       DEBTRACE( "_pyfunc refcnt: " << _pyfunc->ob_refcnt );
       PyObject* result = PyObject_CallObject( _pyfunc , args ) ;
       DEBTRACE( "_pyfunc refcnt: " << _pyfunc->ob_refcnt );
       Py_DECREF(args);
       fflush(stdout);
       fflush(stderr);
       if(result == NULL)
         {
           _errorDetails="";
           PyObject* new_stderr = newPyStdOut(_errorDetails);
           PySys_SetObject((char*)"stderr", new_stderr);
           std::ostringstream stream;
           stream << "/tmp/PythonNode_";
           stream << getpid();
           ofstream errorfile(stream.str().c_str());
           if (errorfile.is_open())
             {
               errorfile << _script;
               errorfile.close();
             }
           PyErr_Print();
           PySys_SetObject((char*)"stderr", PySys_GetObject((char*)"__stderr__"));
           Py_DECREF(new_stderr);
           throw Exception("Error during execution");
         }
       DEBTRACE( "----------------End PyFuncNode::calculation---------------" );
 
       DEBTRACE( "-----------------PyFuncNode::outputs-----------------" );
       int nres=1;
       if(result == Py_None)
         nres=0;
       else if(PyTuple_Check(result))
         nres=PyTuple_Size(result);
 
       if(getNumberOfOutputPorts() != nres)
         {
           std::string msg="Number of output arguments : Mismatch between definition and execution";
           Py_DECREF(result);
           _errorDetails=msg;
           throw Exception(msg);
         }
 
       pos=0;
 #ifdef _DEVDEBUG_
       PyObject_Print(result,stderr,Py_PRINT_RAW);
       cerr << endl;
 #endif
       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() );
               DEBTRACE( "port pos : " << pos );
               if(PyTuple_Check(result))ob=PyTuple_GetItem(result,pos) ;
               else ob=result;
               DEBTRACE( "ob refcnt: " << ob->ob_refcnt );
 #ifdef _DEVDEBUG_
               PyObject_Print(ob,stderr,Py_PRINT_RAW);
               cerr << endl;
 #endif
               p->put(ob);
               pos++;
             }
       }
       catch(ConversionException& ex)
       {
           Py_DECREF(result);
           _errorDetails=ex.what();
           throw;
       }
       DEBTRACE( "-----------------End PyFuncNode::outputs-----------------" );
       Py_DECREF(result);
   }
   DEBTRACE( "++++++++++++++ End PyFuncNode::execute: " << getName() << " ++++++++++++++++++++" );
 }

void PyFuncNode::executeRemote ( )

virtual

Definition at line 946 of file PythonNode.cxx.

References YACS::ENGINE::Node::_errorDetails, YACS::ENGINE::PythonEntry::_pyfuncSer, YACS::ENGINE::PythonEntry::_pyfuncUnser, _pynode, YACS::ENGINE::ElementaryNode::_setOfInputPort, YACS::ENGINE::ElementaryNode::_setOfOutputPort, YACS::ENGINE::PythonEntry::commonRemoteLoadPart2(), DEBTRACE, YACS::ENGINE::DataPort::edGetType(), YACS::ENGINE::InlineNode::getContainer(), YACS::ENGINE::InlineFuncNode::getFname(), YACS::ENGINE::DataPort::getName(), YACS::ENGINE::Node::getName(), YACS::ENGINE::ElementaryNode::getNumberOfInputPorts(), YACS::ENGINE::ElementaryNode::getNumberOfOutputPorts(), YACS::ENGINE::InputPyPort::getPyObj(), YACS::ENGINE::InlineNode::getScript(), CORBAEngineTest::i, YACS::ENGINE::TypeCode::kind(), p, YACS::ENGINE::OutputPyPort::put(), and YACS::Exception::what().

Referenced by execute().

 {
   DEBTRACE( "++++++++++++++ PyFuncNode::executeRemote: " << getName() << " ++++++++++++++++++++" );
   if(!_pyfuncSer)
     throw Exception("DistributedPythonNode badly loaded");
   //
   if(dynamic_cast<HomogeneousPoolContainer *>(getContainer()))
     {
       bool dummy;
       commonRemoteLoadPart2(this,dummy);
       _pynode->executeAnotherPieceOfCode(getScript().c_str());
     }
   //
   Engines::pickledArgs_var serializationInputCorba(new Engines::pickledArgs);;
   {
       AutoGIL agil;
       PyObject *ob(0);
       //===========================================================================
       // Get inputs in input ports, build a Python tuple and pickle it
       //===========================================================================
       PyObject *args(PyTuple_New(getNumberOfInputPorts()));
       int pos(0);
       for(std::list<InputPort *>::iterator iter2 = _setOfInputPort.begin(); iter2 != _setOfInputPort.end(); iter2++,pos++)
         {
           InputPyPort *p=(InputPyPort *)*iter2;
           ob=p->getPyObj();
           Py_INCREF(ob);
           PyTuple_SetItem(args,pos,ob);
         }
 #ifdef _DEVDEBUG_
       PyObject_Print(args,stderr,Py_PRINT_RAW);
       std::cerr << endl;
 #endif
       PyObject *serializationInput=PyObject_CallObject(_pyfuncSer,args);
       Py_DECREF(args);
       //The pickled string may contain NULL characters so use PyString_AsStringAndSize
       char *serializationInputC(0);
       Py_ssize_t len;
       if (PyString_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_DECREF(serializationInput);
   }
 
   //===========================================================================
   // Execute in remote Python node
   //===========================================================================
   DEBTRACE( "-----------------starting remote python invocation-----------------" );
   Engines::pickledArgs_var resultCorba;
   try
     {
       resultCorba=_pynode->execute(getFname().c_str(),serializationInputCorba);
     }
   catch( const SALOME::SALOME_Exception& ex )
     {
       std::string msg="Exception on remote python invocation";
       msg += '\n';
       msg += ex.details.text.in();
       _errorDetails=msg;
       throw Exception(msg);
     }
   DEBTRACE( "-----------------end of remote python invocation-----------------" );
   //===========================================================================
   // Get results, unpickle and put them in output ports
   //===========================================================================
   char *resultCorbaC=new char[resultCorba->length()+1];
   resultCorbaC[resultCorba->length()]='\0';
   for(int i=0;i<resultCorba->length();i++)
     resultCorbaC[i]=resultCorba[i];
 
   {
       AutoGIL agil;
 
       PyObject *resultPython(PyString_FromStringAndSize(resultCorbaC,resultCorba->length()));
       delete [] resultCorbaC;
       PyObject *args(PyTuple_New(1)),*ob(0);
       PyTuple_SetItem(args,0,resultPython);
       PyObject *finalResult=PyObject_CallObject(_pyfuncUnser,args);
       Py_DECREF(args);
 
       DEBTRACE( "-----------------PythonNode::outputs-----------------" );
       int nres=1;
       if(finalResult == Py_None)
         nres=0;
       else if(PyTuple_Check(finalResult))
         nres=PyTuple_Size(finalResult);
 
       if(getNumberOfOutputPorts() != nres)
         {
           std::string msg="Number of output arguments : Mismatch between definition and execution";
           Py_DECREF(finalResult);
           _errorDetails=msg;
           throw Exception(msg);
         }
 
       try
       {
           int pos(0);
           for(std::list<OutputPort *>::iterator iter = _setOfOutputPort.begin(); iter != _setOfOutputPort.end(); iter++, pos++)
             {
               OutputPyPort *p=(OutputPyPort *)*iter;
               DEBTRACE( "port name: " << p->getName() );
               DEBTRACE( "port kind: " << p->edGetType()->kind() );
               DEBTRACE( "port pos : " << pos );
               if(PyTuple_Check(finalResult))
                 ob=PyTuple_GetItem(finalResult,pos) ;
               else
                 ob=finalResult;
               DEBTRACE( "ob refcnt: " << ob->ob_refcnt );
               p->put(ob);
             }
           Py_DECREF(finalResult);
       }
       catch(ConversionException& ex)
       {
           Py_DECREF(finalResult);
           _errorDetails=ex.what();
           throw;
       }
   }
 
   DEBTRACE( "++++++++++++++ ENDOF PyFuncNode::executeRemote: " << getName() << " ++++++++++++++++++++" );
 }

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

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

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

Engines::PyNodeBase_var PyFuncNode::getRemoteInterpreterHandle ( )

protectedvirtual

Implements YACS::ENGINE::PythonEntry.

Definition at line 1224 of file PythonNode.cxx.

References _pynode.

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

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

inlineprotectedvirtual

Implements YACS::ENGINE::PythonEntry.

Definition at line 107 of file PythonNode.hxx.

107 { return SCRIPT_FOR_SERIALIZATION; }

void PyFuncNode::init ( bool start = true )

virtual

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

Reimplemented from YACS::ENGINE::ElementaryNode.

Definition at line 815 of file PythonNode.cxx.

References YACS::ENGINE::Node::_state, YACS::DISABLED, YACS::ENGINE::Node::exDisabledState(), YACS::ENGINE::ElementaryNode::initCommonPartWithoutStateManagement(), YACS::LOADED, YACS::READY, YACS::ENGINE::Node::setState(), and YACS::TORECONNECT.

 {
   initCommonPartWithoutStateManagement(start);
   if(_state == YACS::DISABLED)
     {
       exDisabledState(); // to refresh propagation of DISABLED state
       return ;
     }
   if(start) //complete initialization
     setState(YACS::READY);
   else if(_state > YACS::LOADED)// WARNING FuncNode has internal vars (CEA usecase) ! Partial initialization (inside a loop). Exclusivity of funcNode.
     setState(YACS::TORECONNECT);
 }

void PyFuncNode::load ( )

virtual

Reimplemented from YACS::ENGINE::ElementaryNode.

Definition at line 852 of file PythonNode.cxx.

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

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

void PyFuncNode::loadLocal ( )

virtual

Definition at line 866 of file PythonNode.cxx.

References YACS::ENGINE::PythonEntry::_context, YACS::ENGINE::Node::_errorDetails, YACS::ENGINE::InlineFuncNode::_fname, _pyfunc, YACS::ENGINE::InlineNode::_script, YACS::ENGINE::ElementaryNode::_setOfOutputPort, DEBTRACE, YACS::ENGINE::DataPort::edGetType(), YACS::ENGINE::DataPort::getName(), YACS::ENGINE::Node::getName(), YACS::ENGINE::TypeCode::kind(), YACS::ENGINE::newPyStdOut(), and p.

Referenced by load().

 {
   DEBTRACE( "---------------PyFuncNode::load function " << getName() << " ---------------" );
   DEBTRACE(  _script );
 
 #ifdef _DEVDEBUG_
   list<OutputPort *>::iterator iter;
   for(iter = _setOfOutputPort.begin(); iter != _setOfOutputPort.end(); iter++)
     {
       OutputPyPort *p=(OutputPyPort *)*iter;
       DEBTRACE( "port name: " << p->getName() );
       DEBTRACE( "port kind: " << p->edGetType()->kind() );
     }
 #endif
 
   {
     AutoGIL agil;
     DEBTRACE( "_context refcnt: " << _context->ob_refcnt );
 
     std::ostringstream stream;
     stream << "/tmp/PythonNode_";
     stream << getpid();
 
     PyObject* code=Py_CompileString(_script.c_str(), stream.str().c_str(), Py_file_input);
     if(code == NULL)
       {
         _errorDetails="";
         PyObject* new_stderr = newPyStdOut(_errorDetails);
         PySys_SetObject((char*)"stderr", new_stderr);
         PyErr_Print();
         PySys_SetObject((char*)"stderr", PySys_GetObject((char*)"__stderr__"));
         Py_DECREF(new_stderr);
         throw Exception("Error during execution");
       }
     PyObject *res = PyEval_EvalCode((PyCodeObject *)code, _context, _context);
     Py_DECREF(code);
     Py_XDECREF(res);
 
     DEBTRACE( "_context refcnt: " << _context->ob_refcnt );
     if(PyErr_Occurred ())
       {
         _errorDetails="";
         PyObject* new_stderr = newPyStdOut(_errorDetails);
         PySys_SetObject((char*)"stderr", new_stderr);
         ofstream errorfile(stream.str().c_str());
         if (errorfile.is_open())
           {
             errorfile << _script;
             errorfile.close();
           }
         PyErr_Print();
         PySys_SetObject((char*)"stderr", PySys_GetObject((char*)"__stderr__"));
         Py_DECREF(new_stderr);
         throw Exception("Error during execution");
         return;
       }
     _pyfunc=PyDict_GetItemString(_context,_fname.c_str());
     DEBTRACE( "_pyfunc refcnt: " << _pyfunc->ob_refcnt );
     if(_pyfunc == NULL)
       {
         _errorDetails="";
         PyObject* new_stderr = newPyStdOut(_errorDetails);
         PySys_SetObject((char*)"stderr", new_stderr);
         PyErr_Print();
         PySys_SetObject((char*)"stderr", PySys_GetObject((char*)"__stderr__"));
         Py_DECREF(new_stderr);
         throw Exception("Error during execution");
       }
     DEBTRACE( "---------------End PyFuncNode::load function---------------" );
   }
 }

void PyFuncNode::loadRemote ( )

virtual

Definition at line 861 of file PythonNode.cxx.

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

Referenced by load().

 {
   commonRemoteLoad(this);
 }

Engines::PyNodeBase_var PyFuncNode::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 1201 of file PythonNode.cxx.

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

 {
   Engines::PyNode_var ret(objContainer->getDefaultPyNode(getName().c_str()));
   if(!CORBA::is_nil(ret))
     {
       ret->Register();
     }
   return Engines::PyNodeBase::_narrow(ret);
 }

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

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

 {
   DEBTRACE("PyFuncNode::shutdown " << level);
   if(_mode=="local")return;
   if(_container)
     {
       if(!CORBA::is_nil(_pynode)) _pynode->UnRegister();
       _pynode=Engines::PyNode::_nil();
       _container->shutdown(level);
     }
 }

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

protectedvirtual

Implements YACS::ENGINE::Node.

Definition at line 1189 of file PythonNode.cxx.

References PyFuncNode().

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

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

inlinevirtual

Reimplemented from YACS::ENGINE::InlineFuncNode.

Definition at line 123 of file PythonNode.hxx.

123 { return "YACS__ENGINE__PyFuncNode"; }

Member Data Documentation

PyObject* YACS::ENGINE::PyFuncNode::_pyfunc

protected

Definition at line 127 of file PythonNode.hxx.

Referenced by executeLocal(), and loadLocal().

Engines::PyNode_var YACS::ENGINE::PyFuncNode::_pynode

protected

Definition at line 128 of file PythonNode.hxx.

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

const char PyFuncNode::SCRIPT_FOR_SERIALIZATION

static

Initial value:

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

Definition at line 125 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 Attributes

Protected Member Functions

Protected Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation