pyuno/source/module/pyuno_gc.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20 #include "pyuno_impl.hxx"
  21
  22 #include "sal/config.h"
  23
  24 #include "rtl/ref.hxx"
  25 #include "salhelper/thread.hxx"
  26
  27 namespace pyuno
  28 {
  29
  30 bool g_destructorsOfStaticObjectsHaveBeenCalled;
  31 class StaticDestructorGuard
  32 {
  33 public:
  34     ~StaticDestructorGuard()
  35     {
  36         g_destructorsOfStaticObjectsHaveBeenCalled = true;
  37     }
  38 };
  39 StaticDestructorGuard guard;
  40
  41 static bool isAfterUnloadOrPy_Finalize()
  42 {
  43     return g_destructorsOfStaticObjectsHaveBeenCalled ||
  44         !Py_IsInitialized();
  45 }
  46
  47 class GCThread: public salhelper::Thread {
  48 public:
  49     GCThread( PyInterpreterState *interpreter, PyObject * object );
  50
  51 private:
  52     virtual ~GCThread() {}
  53
  54     virtual void execute();
  55
  56     PyObject *mPyObject;
  57     PyInterpreterState *mPyInterpreter;
  58 };
  59
  60 GCThread::GCThread( PyInterpreterState *interpreter, PyObject * object ) :
  61     Thread( "pyunoGCThread" ), mPyObject( object ),
  62     mPyInterpreter( interpreter )
  63 {}
  64
  65 void GCThread::execute()
  66 {
  67     //  otherwise we crash here, when main has been left already
  68     if( isAfterUnloadOrPy_Finalize() )
  69         return;
  70     try
  71     {
  72         PyThreadAttach g( (PyInterpreterState*)mPyInterpreter );
  73         {
  74             Runtime runtime;
  75
  76             // remove the reference from the pythonobject2adapter map
  77             PyRef2Adapter::iterator ii =
  78                 runtime.getImpl()->cargo->mappedObjects.find( mPyObject );
  79             if( ii != runtime.getImpl()->cargo->mappedObjects.end() )
  80             {
  81                 runtime.getImpl()->cargo->mappedObjects.erase( ii );
  82             }
  83
  84             Py_XDECREF( mPyObject );
  85         }
  86     }
  87     catch( const com::sun::star::uno::RuntimeException & e )
  88     {
  89         OString msg;
  90         msg = OUStringToOString( e.Message, RTL_TEXTENCODING_ASCII_US );
  91         fprintf( stderr, "Leaking python objects bridged to UNO for reason %s\n",msg.getStr());
  92     }
  93 }
  94
  95 void decreaseRefCount( PyInterpreterState *interpreter, PyObject *object )
  96 {
  97     //  otherwise we crash in the last after main ...
  98     if( isAfterUnloadOrPy_Finalize() )
  99         return;
 100
 101     // delegate to a new thread, because there does not seem
 102     // to be a method, which tells, whether the global
 103     // interpreter lock is held or not
 104     // TODO: Look for a more efficient solution
 105     rtl::Reference< GCThread >(new GCThread(interpreter, object))->launch();
 106         //TODO: a protocol is missing how to join with the launched thread
 107         // before exit(3), to ensure the thread is no longer relying on any
 108         // infrastructure while that infrastructure is being shut down in
 109         // atexit handlers
 110 }
 111
 112 }
 113
 114 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */