Version: 8.3.0
PythonPorts.hxx
Go to the documentation of this file.
1 // Copyright (C) 2006-2016 CEA/DEN, EDF R&D
2 //
3 // This library is free software; you can redistribute it and/or
4 // modify it under the terms of the GNU Lesser General Public
5 // License as published by the Free Software Foundation; either
6 // version 2.1 of the License, or (at your option) any later version.
7 //
8 // This library is distributed in the hope that it will be useful,
9 // but WITHOUT ANY WARRANTY; without even the implied warranty of
10 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
11 // Lesser General Public License for more details.
12 //
13 // You should have received a copy of the GNU Lesser General Public
14 // License along with this library; if not, write to the Free Software
15 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
16 //
17 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
18 //
19 
20 #ifndef _PYTHONPORTS_HXX_
21 #define _PYTHONPORTS_HXX_
22 
23 #include <Python.h>
24 
25 #include "YACSRuntimeSALOMEExport.hxx"
26 #include "InputPort.hxx"
27 #include "OutputPort.hxx"
28 
29 namespace YACS
30 {
31  namespace ENGINE
32  {
33  class InterpreterUnlocker
34  {
35  public:
36  InterpreterUnlocker() {
37  gstate_ = PyGILState_Ensure();
38  }
39  ~InterpreterUnlocker() {
40  PyGILState_Release(gstate_);
41  }
42  private:
43  PyGILState_STATE gstate_;
44  };
45 
46  class InterpreterSaveThread {
47  public:
48  inline InterpreterSaveThread() {
49  tstate_ = PyEval_SaveThread();
50  }
51  inline ~InterpreterSaveThread() {
52  PyEval_RestoreThread(tstate_);
53  }
54  inline void lock() {
55  PyEval_RestoreThread(tstate_);
56  }
57  inline void unlock() {
58  tstate_ = PyEval_SaveThread();
59  }
60  private:
61  PyThreadState* tstate_;
62  };
63 
64 
65  typedef PyObject PyObj;
66 
73  class YACSRUNTIMESALOME_EXPORT InputPyPort : public InputPort
74  {
75  public:
76  InputPyPort(const std::string& name, Node * node, TypeCode * type);
77  InputPyPort(const InputPyPort& other, Node *newHelder);
78  ~InputPyPort();
79  bool edIsManuallyInitialized() const;
80  void edRemoveManInit();
81  virtual void put(const void *data) throw(ConversionException);
82  void put(PyObject *data) throw(ConversionException);
83  InputPort *clone(Node *newHelder) const;
84  //special typedef PyObj used in SWIG to increment ref count on output
85  virtual PyObj * getPyObj() const;
86  virtual std::string getAsString();
87  void *get() const throw(Exception);
88  virtual std::string getHumanRepr();
89  virtual bool isEmpty();
90  virtual void exSaveInit();
91  virtual void exRestoreInit();
92  virtual std::string dump();
93  virtual std::string typeName() {return "YACS__ENGINE__InputPyPort";}
94  virtual std::string valToStr();
95  virtual void valFromStr(std::string valstr);
96 
97  protected:
98  PyObject* _data;
99  PyObject* _initData;
100  };
101 
102  class YACSRUNTIMESALOME_EXPORT OutputPyPort : public OutputPort
103  {
104  public:
105  OutputPyPort(const std::string& name, Node * node, TypeCode * type);
106  OutputPyPort(const OutputPyPort& other, Node *newHelder);
107  ~OutputPyPort();
108  virtual void put(const void *data) throw(ConversionException);
109  void put(PyObject *data) throw(ConversionException);
110  OutputPort *clone(Node *newHelder) const;
111  virtual PyObject * get() const;
112  //special typedef PyObj used in SWIG to increment ref count on output
113  virtual PyObj * getPyObj() const;
114  virtual std::string getAsString();
115  virtual std::string dump();
116  virtual std::string typeName() {return "YACS__ENGINE__OutputPyPort";}
117  virtual std::string valToStr();
118  virtual void valFromStr(std::string valstr);
119  protected:
120  PyObject* _data;
121  };
122 
123 
124 
125  }
126 }
127 
128 #endif