#include "PythonPorts.hxx"
+#include "TypeConversions.hxx"
+#include "Node.hxx"
#include <iostream>
+#include <sstream>
+
+//#define _DEVDEBUG_
+#include "YacsTrace.hxx"
using namespace YACS::ENGINE;
using namespace std;
-InputPyPort::InputPyPort(const string& name, Node *node, TypeCode * type)
- : InputPort(name, node, type), Port(node)
+InputPyPort::InputPyPort(const std::string& name, Node *node, TypeCode * type)
+ : InputPort(name, node, type), DataPort(name, node, type), Port(node), _data(Py_None),_initData(Py_None)
+{
+ Py_INCREF(_data);
+ Py_INCREF(_initData);
+}
+InputPyPort::~InputPyPort()
+{
+ PyGILState_STATE gstate = PyGILState_Ensure();
+ DEBTRACE( "_data refcnt: " << _data->ob_refcnt );
+ DEBTRACE( "_initData refcnt: " << _initData->ob_refcnt );
+ Py_XDECREF(_data);
+ Py_XDECREF(_initData);
+ PyGILState_Release(gstate);
+}
+
+InputPyPort::InputPyPort(const InputPyPort& other, Node *newHelder):InputPort(other,newHelder),DataPort(other,newHelder),Port(other,newHelder)
{
- _impl = "Python";
+ _initData=other._initData;
+ Py_INCREF(_initData);
+ _data=other._data;
+ Py_INCREF(_data);
+}
+
+bool InputPyPort::edIsManuallyInitialized() const
+{
+ return _initData!=Py_None;
+}
+
+void InputPyPort::edRemoveManInit()
+{
+ Py_XDECREF(_initData);
+ _initData=Py_None;
+ Py_INCREF(_initData);
+ InputPort::edRemoveManInit();
}
void InputPyPort::put(const void *data) throw(ConversionException)
{
put((PyObject *)data);
- _empty = false;
}
void InputPyPort::put(PyObject *data) throw(ConversionException)
{
- cerr << "InputPyPort::put" << endl;
+ Py_XDECREF(_data);
_data = data;
+ Py_INCREF(_data);
+ DEBTRACE( "_data refcnt: " << _data->ob_refcnt );
+}
+
+InputPort *InputPyPort::clone(Node *newHelder) const
+{
+ return new InputPyPort(*this,newHelder);
}
PyObject * InputPyPort::getPyObj() const
return _data;
}
+void *InputPyPort::get() const throw(Exception)
+{
+ return (void*) _data;
+}
+bool InputPyPort::isEmpty()
+{
+ return _data == Py_None;
+}
-OutputPyPort::OutputPyPort(const string& name, Node *node, TypeCode * type)
- : OutputPort(name, node, type), Port(node)
+//! Save the current data value for further reinitialization of the port
+/*!
+ *
+ */
+void InputPyPort::exSaveInit()
+{
+ Py_XDECREF(_initData);
+ _initData=_data;
+ Py_INCREF(_initData);
+ DEBTRACE( "_initData.ob refcnt: " << _initData->ob_refcnt );
+ DEBTRACE( "_data.ob refcnt: " << _data->ob_refcnt );
+}
+
+//! Restore the saved data value to current data value
+/*!
+ * If no data has been saved (_initData == 0) don't restore
+ */
+void InputPyPort::exRestoreInit()
+{
+ if(!_initData)return;
+ Py_XDECREF(_data);
+ _data=_initData;
+ Py_INCREF(_data);
+ DEBTRACE( "_initData.ob refcnt: " << _initData->ob_refcnt );
+ DEBTRACE( "_data.ob refcnt: " << _data->ob_refcnt );
+}
+
+std::string InputPyPort::dump()
+{
+ if( _data == Py_None)
+ return "<value>None</value>";
+
+ InterpreterUnlocker l;
+ if (edGetType()->kind() != YACS::ENGINE::Objref)
+ return convertPyObjectXml(edGetType(), _data);
+ if (! _stringRef.empty())
+ return _stringRef;
+ else
+ return convertPyObjectXml(edGetType(), _data);
+// {
+// stringstream msg;
+// msg << "Cannot retreive init reference string for port " << _name
+// << " on node " << _node->getName();
+// throw Exception(msg.str());
+// }
+}
+
+
+OutputPyPort::OutputPyPort(const std::string& name, Node *node, TypeCode * type)
+ : OutputPort(name, node, type), DataPort(name, node, type), Port(node)
+{
+ _data = Py_None;
+ Py_INCREF(_data);
+}
+OutputPyPort::~OutputPyPort()
+{
+ PyGILState_STATE gstate = PyGILState_Ensure();
+ DEBTRACE( "_data refcnt: " << _data->ob_refcnt );
+ Py_XDECREF(_data);
+ PyGILState_Release(gstate);
+}
+
+OutputPyPort::OutputPyPort(const OutputPyPort& other, Node *newHelder):OutputPort(other,newHelder),DataPort(other,newHelder),Port(other,newHelder),
+ _data(Py_None)
{
- _impl = "Python";
}
void OutputPyPort::put(const void *data) throw(ConversionException)
void OutputPyPort::put(PyObject *data) throw(ConversionException)
{
- cerr << "OutputPyPort::put" << endl;
InputPort *p;
- cerr << "ob refcnt: " << data->ob_refcnt << endl;
- PyObject_Print(data,stdout,Py_PRINT_RAW);
+ DEBTRACE( "OutputPyPort::put.ob refcnt: " << data->ob_refcnt );
+#ifdef _DEVDEBUG_
+ PyObject_Print(data,stderr,Py_PRINT_RAW);
cerr << endl;
+#endif
+ Py_XDECREF(_data);
_data = data;
- set<InputPort *>::iterator iter;
- for(iter = _setOfInputPort.begin(); iter != _setOfInputPort.end(); iter++)
- {
- p = *iter;
- p->put(data);
- }
+ Py_INCREF(_data);
+ DEBTRACE( "OutputPyPort::put.ob refcnt: " << data->ob_refcnt );
+ OutputPort::put(data);
+}
+
+OutputPort *OutputPyPort::clone(Node *newHelder) const
+{
+ return new OutputPyPort(*this,newHelder);
}
-PyObject * OutputPyPort:: get() const
+PyObject * OutputPyPort::get() const
{
return _data;
}
+std::string OutputPyPort::dump()
+{
+ if( _data == Py_None)
+ return "<value>None</value>";
+ InterpreterUnlocker l;
+ string xmldump = convertPyObjectXml(edGetType(), _data);
+ return xmldump;
+}
+
