Squeeze memory of process hosting YACS graph

[modules/yacs.git] / src / runtime / CORBAPorts.hxx

diff --git a/src/runtime/CORBAPorts.hxx b/src/runtime/CORBAPorts.hxx
index 7d13244f7e399b7e18bf36cfbd1c1a3e4babd763..ddf2976058bda63dad0e0a27a4b2779233114e9d 100644 (file)
--- a/src/runtime/CORBAPorts.hxx
+++ b/src/runtime/CORBAPorts.hxx
@@ -1,10 +1,34 @@
+// Copyright (C) 2006-2019  CEA/DEN, EDF R&D
+//
+// This library is free software; you can redistribute it and/or
+// modify it under the terms of the GNU Lesser General Public
+// License as published by the Free Software Foundation; either
+// version 2.1 of the License, or (at your option) any later version.
+//
+// This library is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+// Lesser General Public License for more details.
+//
+// You should have received a copy of the GNU Lesser General Public
+// License along with this library; if not, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
+//
+// See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
+//
+
 #ifndef _CORBAPORTS_HXX_
 #define _CORBAPORTS_HXX_
 
 #include <omniORB4/CORBA.h>
 
+#include "YACSRuntimeSALOMEExport.hxx"
 #include "InputPort.hxx"
 #include "OutputPort.hxx"
+#include "Mutex.hxx"
+
+#include <Python.h>
+
 #include <string>
 
 namespace YACS
@@ -17,7 +41,7 @@ namespace YACS
  *
  * \see CORBANode
  */
-    class InputCorbaPort : public InputPort
+    class YACSRUNTIMESALOME_EXPORT InputCorbaPort : public InputPort
     {
     public:
       InputCorbaPort(const std::string& name, Node *node, TypeCode * type);
@@ -27,21 +51,36 @@ namespace YACS
       void edRemoveManInit();
       virtual void put(const void *data) throw(ConversionException);
       void put(CORBA::Any *data) throw (ConversionException);
+      void releaseData() override;
       InputPort *clone(Node *newHelder) const;
       void *get() const throw(Exception);
       virtual bool isEmpty();
       virtual CORBA::Any * getAny();
+      virtual std::string getAsString();
+      virtual PyObject* getPyObj();
       virtual void exSaveInit();
       virtual void exRestoreInit();
       virtual std::string dump();
+      virtual std::string typeName() {return "YACS__ENGINE__InputCorbaPort";}
+      virtual std::string valToStr();
+      virtual void valFromStr(std::string valstr);
     protected:
       CORBA::Any  _data;
       CORBA::Any *  _initData;
       CORBA::ORB_ptr _orb;
+    private:
+      YACS::BASES::Mutex _mutex;
     };
 
-    class OutputCorbaPort : public OutputPort
+    class OutputCorbaPort;
+
+    YACSRUNTIMESALOME_EXPORT std::ostream & operator<<(std::ostream &os,
+                                                       const YACS::ENGINE::OutputCorbaPort& p);
+
+    class YACSRUNTIMESALOME_EXPORT OutputCorbaPort : public OutputPort
     {
+      friend std::ostream &operator<< ( std::ostream &os,
+                                        const OutputCorbaPort& p);
     public:
       OutputCorbaPort(const std::string& name, Node *node, TypeCode * type);
       OutputCorbaPort(const OutputCorbaPort& other, Node *newHelder);
@@ -51,12 +90,17 @@ namespace YACS
       OutputPort *clone(Node *newHelder) const;
       virtual CORBA::Any * getAny();
       virtual CORBA::Any * getAnyOut();
+      virtual std::string getAsString();
+      virtual PyObject* getPyObj();
       virtual std::string dump();
-      friend std::ostream & operator<< ( std::ostream &os,
-                                         const OutputCorbaPort& p);
+      virtual std::string typeName() {return "YACS__ENGINE__OutputCorbaPort";}
+      virtual std::string valToStr();
+      virtual void valFromStr(std::string valstr);
     protected:
       CORBA::Any  _data;
       CORBA::ORB_ptr _orb;
+    private:
+      YACS::BASES::Mutex _mutex;
     };