py/modules/IcePy/ThreadNotification.cpp

   1 // **********************************************************************
   2 //
   3 // Copyright (c) 2003-2011 ZeroC, Inc. All rights reserved.
   4 //
   5 // This copy of Ice is licensed to you under the terms described in the
   6 // ICE_LICENSE file included in this distribution.
   7 //
   8 // **********************************************************************
   9
  10 #ifdef _WIN32
  11 #   include <IceUtil/Config.h>
  12 #endif
  13 #include <ThreadNotification.h>
  14
  15 using namespace std;
  16 using namespace IcePy;
  17
  18 IcePy::ThreadNotificationWrapper::ThreadNotificationWrapper(PyObject* threadNotification) :
  19     _threadNotification(threadNotification)
  20 {
  21     Py_INCREF(threadNotification);
  22 }
  23
  24 void
  25 IcePy::ThreadNotificationWrapper::start()
  26 {
  27     AdoptThread adoptThread; // Ensure the current thread is able to call into Python.
  28
  29     PyObjectHandle tmp = PyObject_CallMethod(_threadNotification.get(), STRCAST("start"), 0);
  30     if(!tmp.get())
  31     {
  32         throwPythonException();
  33     }
  34 }
  35
  36 void
  37 IcePy::ThreadNotificationWrapper::stop()
  38 {
  39     AdoptThread adoptThread; // Ensure the current thread is able to call into Python.
  40
  41     PyObjectHandle tmp = PyObject_CallMethod(_threadNotification.get(), STRCAST("stop"), 0);
  42     if(!tmp.get())
  43     {
  44         throwPythonException();
  45     }
  46 }
  47
  48 PyObject*
  49 IcePy::ThreadNotificationWrapper::getObject()
  50 {
  51     return _threadNotification.get();
  52 }