| /**************************************************************************** |
| ** |
| ** Copyright (C) 2016 The Qt Company Ltd. |
| ** Copyright (C) 2016 Intel Corporation. |
| ** Contact: https://www.qt.io/licensing/ |
| ** |
| ** This file is part of the QtDBus module of the Qt Toolkit. |
| ** |
| ** $QT_BEGIN_LICENSE:LGPL$ |
| ** Commercial License Usage |
| ** Licensees holding valid commercial Qt licenses may use this file in |
| ** accordance with the commercial license agreement provided with the |
| ** Software or, alternatively, in accordance with the terms contained in |
| ** a written agreement between you and The Qt Company. For licensing terms |
| ** and conditions see https://www.qt.io/terms-conditions. For further |
| ** information use the contact form at https://www.qt.io/contact-us. |
| ** |
| ** GNU Lesser General Public License Usage |
| ** Alternatively, this file may be used under the terms of the GNU Lesser |
| ** General Public License version 3 as published by the Free Software |
| ** Foundation and appearing in the file LICENSE.LGPL3 included in the |
| ** packaging of this file. Please review the following information to |
| ** ensure the GNU Lesser General Public License version 3 requirements |
| ** will be met: https://www.gnu.org/licenses/lgpl-3.0.html. |
| ** |
| ** GNU General Public License Usage |
| ** Alternatively, this file may be used under the terms of the GNU |
| ** General Public License version 2.0 or (at your option) the GNU General |
| ** Public license version 3 or any later version approved by the KDE Free |
| ** Qt Foundation. The licenses are as published by the Free Software |
| ** Foundation and appearing in the file LICENSE.GPL2 and LICENSE.GPL3 |
| ** included in the packaging of this file. Please review the following |
| ** information to ensure the GNU General Public License requirements will |
| ** be met: https://www.gnu.org/licenses/gpl-2.0.html and |
| ** https://www.gnu.org/licenses/gpl-3.0.html. |
| ** |
| ** $QT_END_LICENSE$ |
| ** |
| ****************************************************************************/ |
| #ifndef QDBUSTHREADDEBUG_P_H |
| #define QDBUSTHREADDEBUG_P_H |
| |
| // |
| // W A R N I N G |
| // ------------- |
| // |
| // This file is not part of the Qt API. It exists purely as an |
| // implementation detail. This header file may change from version to |
| // version without notice, or even be removed. |
| // |
| // We mean it. |
| // |
| |
| #include <QtDBus/private/qtdbusglobal_p.h> |
| |
| #ifndef QT_NO_DBUS |
| |
| #if !defined(QDBUS_THREAD_DEBUG) && defined(QT_BUILD_INTERNAL) |
| # define QDBUS_THREAD_DEBUG 1 |
| #endif |
| |
| #if QDBUS_THREAD_DEBUG |
| QT_BEGIN_NAMESPACE |
| typedef void (*qdbusThreadDebugFunc)(int, int, QDBusConnectionPrivate *); |
| Q_DBUS_EXPORT void qdbusDefaultThreadDebug(int, int, QDBusConnectionPrivate *); |
| extern Q_DBUS_EXPORT qdbusThreadDebugFunc qdbusThreadDebug; |
| QT_END_NAMESPACE |
| #endif |
| |
| enum ThreadAction { |
| ConnectAction = 0, |
| DisconnectAction = 1, |
| RegisterObjectAction = 2, |
| UnregisterObjectAction = 3, |
| ObjectRegisteredAtAction = 4, |
| |
| CloseConnectionAction = 10, |
| ObjectDestroyedAction = 11, |
| RelaySignalAction = 12, |
| HandleObjectCallAction = 13, |
| HandleSignalAction = 14, |
| ConnectRelayAction = 15, |
| DisconnectRelayAction = 16, |
| FindMetaObject1Action = 17, |
| FindMetaObject2Action = 18, |
| RegisterServiceAction = 19, |
| UnregisterServiceAction = 20, |
| UpdateSignalHookOwnerAction = 21, |
| HandleObjectCallPostEventAction = 22, |
| HandleObjectCallSemaphoreAction = 23, |
| DoDispatchAction = 24, |
| SetDispatchEnabledAction = 25, |
| MessageResultReceivedAction = 26, |
| ActivateSignalAction = 27, |
| PendingCallBlockAction = 28, |
| SendMessageAction = 29, |
| HuntAndEmitAction = 30, |
| }; |
| |
| struct QDBusLockerBase |
| { |
| enum Condition |
| { |
| BeforeLock, |
| AfterLock, |
| BeforeUnlock, |
| AfterUnlock, |
| |
| BeforePost, |
| AfterPost, |
| BeforeDeliver, |
| AfterDeliver, |
| |
| BeforeAcquire, |
| AfterAcquire, |
| BeforeRelease, |
| AfterRelease |
| }; |
| |
| #if QDBUS_THREAD_DEBUG |
| static inline void reportThreadAction(int action, int condition, QDBusConnectionPrivate *ptr) |
| { if (qdbusThreadDebug) qdbusThreadDebug(action, condition, ptr); } |
| #else |
| static inline void reportThreadAction(int, int, QDBusConnectionPrivate *) { } |
| #endif |
| }; |
| |
| struct QDBusReadLocker: QDBusLockerBase |
| { |
| QDBusConnectionPrivate *self; |
| ThreadAction action; |
| inline QDBusReadLocker(ThreadAction a, QDBusConnectionPrivate *s) |
| : self(s), action(a) |
| { |
| reportThreadAction(action, BeforeLock, self); |
| self->lock.lockForRead(); |
| reportThreadAction(action, AfterLock, self); |
| } |
| |
| inline ~QDBusReadLocker() |
| { |
| reportThreadAction(action, BeforeUnlock, self); |
| self->lock.unlock(); |
| reportThreadAction(action, AfterUnlock, self); |
| } |
| }; |
| |
| struct QDBusWriteLocker: QDBusLockerBase |
| { |
| QDBusConnectionPrivate *self; |
| ThreadAction action; |
| inline QDBusWriteLocker(ThreadAction a, QDBusConnectionPrivate *s) |
| : self(s), action(a) |
| { |
| reportThreadAction(action, BeforeLock, self); |
| self->lock.lockForWrite(); |
| reportThreadAction(action, AfterLock, self); |
| } |
| |
| inline ~QDBusWriteLocker() |
| { |
| reportThreadAction(action, BeforeUnlock, self); |
| self->lock.unlock(); |
| reportThreadAction(action, AfterUnlock, self); |
| } |
| }; |
| |
| #if QDBUS_THREAD_DEBUG |
| # define SEM_ACQUIRE(action, sem) \ |
| do { \ |
| QDBusLockerBase::reportThreadAction(action, QDBusLockerBase::BeforeAcquire, this); \ |
| sem.acquire(); \ |
| QDBusLockerBase::reportThreadAction(action, QDBusLockerBase::AfterAcquire, this); \ |
| } while (false) |
| |
| # define SEM_RELEASE(action, sem) \ |
| do { \ |
| QDBusLockerBase::reportThreadAction(action, QDBusLockerBase::BeforeRelease, that); \ |
| sem.release(); \ |
| QDBusLockerBase::reportThreadAction(action, QDBusLockerBase::AfterRelease, that); \ |
| } while (false) |
| |
| #else |
| # define SEM_ACQUIRE(action, sem) sem.acquire() |
| # define SEM_RELEASE(action, sem) sem.release() |
| #endif |
| |
| #endif // QT_NO_DBUS |
| #endif |