#include <DistributedPythonNode.hxx>

Inheritance diagram for YACS::ENGINE::DistributedPythonNode:

Collaboration diagram for YACS::ENGINE::DistributedPythonNode:

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

	DistributedPythonNode (const DistributedPythonNode &other, ComposedNode *father)

	~DistributedPythonNode ()

void	execute ()

void	load ()

std::string	getEffectiveKindOfServer () const
	this method returns the type of container expected More...

std::string	getKind () const
	this method returns the type of input/output expected More...

ServerNode *	createNode (const std::string &name) const

virtual std::string	typeName ()

Public Member Functions inherited from YACS::ENGINE::ServerNode
	ServerNode (const std::string &name)

	ServerNode (const ServerNode &other, ComposedNode *father)

void	accept (Visitor *visitor)

bool	isDeployable () const
	By definition of ServerNode class. More...

virtual	~ServerNode ()

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

virtual	~InlineFuncNode ()

virtual void	checkBasicConsistency () const throw (Exception)

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

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)

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	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	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 std::string	getContainerLog ()
	returns a string that contains the name of the container log file if it exists 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	KIND [] ="DistPython"

static const char	IMPL_NAME [] ="Python"

static const char	SALOME_CONTAINER_METHOD_IDL [] ="createPyNode"

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

Protected Attributes
PyObject *	_context

PyObject *	_pyfuncSer

PyObject *	_pyfuncUnser

Engines::PyNode_var	_pynode

Private Member Functions
void	initMySelf ()

void	dealException (CORBA::Exception exc, const char method, const char *ref)

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 Attributes inherited from YACS::ENGINE::Node
static const char	SEP_CHAR_IN_PORT [] ="."

static int	_total = 0

Detailed Description

Definition at line 44 of file DistributedPythonNode.hxx.

Constructor & Destructor Documentation

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

Definition at line 44 of file DistributedPythonNode.cxx.

References initMySelf().

Referenced by createNode().

                                                                  :ServerNode(name),_context(0),_pyfuncSer(0),_pyfuncUnser(0)
 {
   initMySelf();
 }

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

Definition at line 49 of file DistributedPythonNode.cxx.

References initMySelf().

                                                                                                     :ServerNode(other,father),_context(0),_pyfuncSer(0),_pyfuncUnser(0)
 {
   initMySelf();
 }

DistributedPythonNode::~DistributedPythonNode ( )

Definition at line 54 of file DistributedPythonNode.cxx.

References _context.

 {
   AutoGIL agil;
   Py_DECREF(_context);
 }

Member Function Documentation

ServerNode * DistributedPythonNode::createNode ( const std::string & name ) const

virtual

Implements YACS::ENGINE::ServerNode.

Definition at line 270 of file DistributedPythonNode.cxx.

References YACS::ENGINE::InlineNode::_container, DistributedPythonNode(), PMMLBasicsTestLauncher::ret, and YACS::ENGINE::InlineNode::setContainer().

 {
   ServerNode *ret=new DistributedPythonNode(name);
   ret->setContainer(_container);
   return ret;
 }

void DistributedPythonNode::dealException	(	CORBA::Exception *	exc,
		const char *	method,
		const char *	ref
	)

private

Definition at line 284 of file DistributedPythonNode.cxx.

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

 {
   if( exc )
     {
       DEBTRACE( "An exception was thrown!" );
       DEBTRACE( "The raised exception is of Type:" << exc->_name() );
 
       CORBA::SystemException* sysexc;
       sysexc=CORBA::SystemException::_downcast(exc);
       if(sysexc != NULL)
         {
           // It's a SystemException
           DEBTRACE( "minor code: " << sysexc->minor() );
           DEBTRACE( "completion code: " << sysexc->completed() );
           std::string text="Execution problem: ";
           std::string excname=sysexc->_name();
           if(excname == "BAD_OPERATION")
             {
               text=text+"bad operation detected";
             }
           else if(excname == "MARSHAL" && sysexc->minor() == omni::MARSHAL_PassEndOfMessage)
             {
               text=text+"probably an error in arguments of service '" + method + "' from component '" +ref+ "'";
             }
           else if(excname == "COMM_FAILURE" && sysexc->minor() == omni::COMM_FAILURE_UnMarshalResults)
             {
               text=text+"probably an error in output arguments of service '" + method + "' from component '" +ref+ "'";
             }
           else if(excname == "COMM_FAILURE" && sysexc->minor() == omni::COMM_FAILURE_UnMarshalArguments)
             {
               text=text+"probably an error in input arguments of service '" + method + "' from component '" +ref+ "'";
             }
           else if(excname == "COMM_FAILURE" && sysexc->minor() == omni::COMM_FAILURE_WaitingForReply)
             {
               text=text+"probably an error in input arguments of service '" + method + "' from component '" +ref+ "'";
             }
           else
             {
               DEBTRACE(sysexc->NP_minorString() );
               text=text+"System Exception "+ excname;
             }
           _errorDetails=text;
           throw Exception(text);
         }
 
       // Not a System Exception
       CORBA::UnknownUserException* userexc;
       userexc=CORBA::UnknownUserException::_downcast(exc);
       if(userexc != NULL)
         {
           CORBA::Any anyExcept = userexc->exception(); 
 
           const SALOME::SALOME_Exception* salexc;
           if(anyExcept >>= salexc)
             {
               DEBTRACE("SALOME_Exception: "<< salexc->details.sourceFile);
               DEBTRACE("SALOME_Exception: "<<salexc->details.lineNumber);
               _errorDetails=salexc->details.text;
               throw Exception("Execution problem: Salome Exception occurred" + getErrorDetails() );
             }
           std::string msg="Execution problem: User Exception occurred";
           _errorDetails=msg;
           throw Exception(msg);
         }
       std::string msg="Execution problem";
       _errorDetails=msg;
       throw Exception(msg);
     }
 }

void DistributedPythonNode::execute ( )

virtual

Implements YACS::ENGINE::Task.

Definition at line 161 of file DistributedPythonNode.cxx.

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

 {
   YACSTRACE(1,"+++++++++++++++++ DistributedPythonNode::execute: " << getName() << " " << getFname() << " +++++++++++++++++" );
   PyObject* ob;
   if(!_pyfuncSer)
     throw Exception("DistributedPythonNode badly loaded");
   Engines::pickledArgs *serializationInputCorba(0);
   PyObject *args(0);
   {
     AutoGIL agil;
 
     DEBTRACE( "---------------DistributedPythonNode::inputs---------------" );
     args = PyTuple_New(getNumberOfInputPorts()) ;
     int pos=0;
     for(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);
       }
     PyObject *serializationInput=PyObject_CallObject(_pyfuncSer,args);
     std::string serializationInputC=PyString_AsString(serializationInput);
     serializationInputCorba=new Engines::pickledArgs;
     int len=serializationInputC.length();
     serializationInputCorba->length(serializationInputC.length());
     for(int i=0;i<serializationInputC.length();i++)
       (*serializationInputCorba)[i]=serializationInputC[i];
     Py_DECREF(serializationInput);
   }
   //serializationInputCorba[serializationInputC.length()]='\0';
   DEBTRACE( "-----------------DistributedPythonNode starting remote python invocation-----------------" );
   Engines::pickledArgs *resultCorba;
   try
   {
       resultCorba=_pynode->execute(getFname().c_str(),*serializationInputCorba);
   }
   catch(...)
   {
       std::string msg="Exception on remote python invocation";
       _errorDetails=msg;
       throw Exception(msg);
   }
   DEBTRACE( "-----------------DistributedPythonNode end of remote python invocation-----------------" );
   //
   delete serializationInputCorba;
   char *resultCorbaC=new char[resultCorba->length()+1];
   resultCorbaC[resultCorba->length()]='\0';
   for(int i=0;i<resultCorba->length();i++)
     resultCorbaC[i]=(*resultCorba)[i];
   delete resultCorba;
   {
     AutoGIL agil;
     args = PyTuple_New(1);
     PyObject* resultPython=PyString_FromString(resultCorbaC);
     delete [] resultCorbaC;
     PyTuple_SetItem(args,0,resultPython);
     PyObject *finalResult=PyObject_CallObject(_pyfuncUnser,args);
     DEBTRACE( "-----------------DistributedPythonNode::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(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);
           }
     }
     catch(ConversionException& ex)
     {
         Py_DECREF(finalResult);
         _errorDetails=ex.what();
         throw;
     }
   }
   DEBTRACE( "++++++++++++++ End DistributedPythonNode::execute: " << getName() << " ++++++++++++++++++++" );
 }

std::string DistributedPythonNode::getEffectiveKindOfServer ( ) const

virtual

this method returns the type of container expected

Implements YACS::ENGINE::ServerNode.

Definition at line 259 of file DistributedPythonNode.cxx.

 {
   return "Salome";
 }

std::string DistributedPythonNode::getKind ( ) const

this method returns the type of input/output expected

not a bug : this is to use classical python port translators.

Definition at line 264 of file DistributedPythonNode.cxx.

References YACS::ENGINE::PythonNode::KIND.

 {
   return PythonNode::KIND;
 }

void DistributedPythonNode::initMySelf ( )

private

Definition at line 277 of file DistributedPythonNode.cxx.

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

Referenced by DistributedPythonNode().

 {
   _implementation = DistributedPythonNode::IMPL_NAME;
   AutoGIL agil;
   _context=PyDict_New();
 }

void DistributedPythonNode::load ( )

virtual

Reimplemented from YACS::ENGINE::ServerNode.

Definition at line 60 of file DistributedPythonNode.cxx.

References YACS::ENGINE::InlineNode::_container, _context, YACS::ENGINE::Node::_errorDetails, _pyfuncSer, _pyfuncUnser, _pynode, YACS::ENGINE::SalomeContainerTmpForHP::BuildFrom(), DEBTRACE, YACS::ENGINE::SalomeContainer::getContainerPtr(), YACS::ENGINE::Node::getName(), YACS::ENGINE::getSALOMERuntime(), YACS::ENGINE::InlineNode::getScript(), YACS::ENGINE::Container::isAlreadyStarted(), YACS::ENGINE::ServerNode::load(), and YACS::ENGINE::newPyStdOut().

 {
   bool isContAlreadyStarted(false);
   if(_container)
     isContAlreadyStarted=_container->isAlreadyStarted(this);
   ServerNode::load();
   {
     AutoGIL agil;
     if( PyDict_SetItemString( _context, "__builtins__", getSALOMERuntime()->getBuiltins() ))
       {
         stringstream msg;
         msg << "Impossible to set builtins" << __FILE__ << ":" << __LINE__;
         _errorDetails=msg.str();
         throw Exception(msg.str());
       }
     const char picklizeScript[]="import cPickle\ndef pickleForDistPyth2009(*args,**kws):\n  return cPickle.dumps((args,kws),-1)\n\ndef unPickleForDistPyth2009(st):\n  args=cPickle.loads(st)\n  return args\n";
     PyObject *res=PyRun_String(picklizeScript,Py_file_input,_context,_context);
     if(res == 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");
         return;
       }
     Py_DECREF(res);
     _pyfuncSer=PyDict_GetItemString(_context,"pickleForDistPyth2009");
     _pyfuncUnser=PyDict_GetItemString(_context,"unPickleForDistPyth2009");
     if(_pyfuncSer == 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");
       }
     if(_pyfuncUnser == 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");
       }
 
     Engines::Container_var objContainer=Engines::Container::_nil();
     if(!_container)
       throw Exception("No container specified !");
     SalomeContainer *containerCast0(dynamic_cast<SalomeContainer *>(_container));
     SalomeHPContainer *containerCast1(dynamic_cast<SalomeHPContainer *>(_container));
     if(containerCast0)
       objContainer=containerCast0->getContainerPtr(this);
     else if(containerCast1)
       {
         YACS::BASES::AutoCppPtr<SalomeContainerTmpForHP> tmpCont(SalomeContainerTmpForHP::BuildFrom(containerCast1,this));
         objContainer=tmpCont->getContainerPtr(this);
       }
     else
       throw Exception("Unrecognized type of container ! Salome one is expected !");
     if(CORBA::is_nil(objContainer))
       throw Exception("Container corba pointer is NULL !");
 
     try
     {
         if(containerCast0 || !isContAlreadyStarted)
           {
             _pynode = objContainer->createPyNode(getName().c_str(),getScript().c_str());
           }
         else
           {
             Engines::PyNode_var dftPyScript(objContainer->getDefaultPyNode(getName().c_str()));
             if(CORBA::is_nil(dftPyScript))
               _pynode = objContainer->createPyNode(getName().c_str(),getScript().c_str());
             else
               _pynode = dftPyScript;
           }
     }
     catch( const SALOME::SALOME_Exception& ex )
     {
         std::string msg="Exception on remote python node creation ";
         msg += '\n';
         msg += ex.details.text.in();
         _errorDetails=msg;
         throw Exception(msg);
     }
 
     if(CORBA::is_nil(_pynode))
       throw Exception("In DistributedPythonNode the ref in NULL ! ");
 
 
     DEBTRACE( "---------------End PyfuncSerNode::load function---------------" );
   }
 }

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

protectedvirtual

Implements YACS::ENGINE::Node.

Definition at line 39 of file DistributedPythonNode.cxx.

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

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

inlinevirtual

Reimplemented from YACS::ENGINE::ServerNode.

Definition at line 59 of file DistributedPythonNode.hxx.

59 {return "YACS__ENGINE__DistributedPythonNode";}

Member Data Documentation

PyObject* YACS::ENGINE::DistributedPythonNode::_context

protected

Definition at line 68 of file DistributedPythonNode.hxx.

Referenced by initMySelf(), load(), and ~DistributedPythonNode().

PyObject* YACS::ENGINE::DistributedPythonNode::_pyfuncSer

protected

Definition at line 69 of file DistributedPythonNode.hxx.

Referenced by execute(), and load().

PyObject* YACS::ENGINE::DistributedPythonNode::_pyfuncUnser

protected

Definition at line 70 of file DistributedPythonNode.hxx.

Referenced by execute(), and load().

Engines::PyNode_var YACS::ENGINE::DistributedPythonNode::_pynode

protected

Definition at line 71 of file DistributedPythonNode.hxx.

Referenced by execute(), and load().

const char DistributedPythonNode::IMPL_NAME ="Python"

static

Definition at line 65 of file DistributedPythonNode.hxx.

Referenced by initMySelf().

const char DistributedPythonNode::KIND ="DistPython"

static

Definition at line 64 of file DistributedPythonNode.hxx.

const char DistributedPythonNode::SALOME_CONTAINER_METHOD_IDL ="createPyNode"

static

Definition at line 66 of file DistributedPythonNode.hxx.

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

src/runtime/DistributedPythonNode.hxx
src/runtime/DistributedPythonNode.cxx

Public Member Functions

Static Public Attributes

Protected Member Functions

Protected Attributes

Private Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation