1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
// Copyright (C) 2018 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only OR GPL-2.0-only OR GPL-3.0-only
#include "qxcbeventdispatcher.h"
#include "qxcbconnection.h"
#include <QtCore/QCoreApplication>
#include <qpa/qwindowsysteminterface.h>
QT_BEGIN_NAMESPACE
QXcbUnixEventDispatcher::QXcbUnixEventDispatcher(QXcbConnection *connection, QObject *parent)
: QEventDispatcherUNIX(parent)
, m_connection(connection)
{
}
QXcbUnixEventDispatcher::~QXcbUnixEventDispatcher()
{
}
bool QXcbUnixEventDispatcher::processEvents(QEventLoop::ProcessEventsFlags flags)
{
const bool didSendEvents = QEventDispatcherUNIX::processEvents(flags);
m_connection->processXcbEvents(flags);
// The following line should not be necessary after QTBUG-70095
return QWindowSystemInterface::sendWindowSystemEvents(flags) || didSendEvents;
}
#if QT_CONFIG(glib)
struct XcbEventSource
{
GSource source;
QXcbGlibEventDispatcher *dispatcher;
QXcbGlibEventDispatcherPrivate *dispatcher_p;
QXcbConnection *connection = nullptr;
};
static gboolean xcbSourcePrepare(GSource *source, gint *timeout)
{
Q_UNUSED(timeout);
auto xcbEventSource = reinterpret_cast<XcbEventSource *>(source);
return xcbEventSource->dispatcher_p->wakeUpCalled;
}
static gboolean xcbSourceCheck(GSource *source)
{
return xcbSourcePrepare(source, nullptr);
}
static gboolean xcbSourceDispatch(GSource *source, GSourceFunc, gpointer)
{
auto xcbEventSource = reinterpret_cast<XcbEventSource *>(source);
QEventLoop::ProcessEventsFlags flags = xcbEventSource->dispatcher->flags();
xcbEventSource->connection->processXcbEvents(flags);
// The following line should not be necessary after QTBUG-70095
QWindowSystemInterface::sendWindowSystemEvents(flags);
return true;
}
QXcbGlibEventDispatcher::QXcbGlibEventDispatcher(QXcbConnection *connection, QObject *parent)
: QEventDispatcherGlib(*new QXcbGlibEventDispatcherPrivate(), parent)
{
Q_D(QXcbGlibEventDispatcher);
m_xcbEventSourceFuncs.prepare = xcbSourcePrepare;
m_xcbEventSourceFuncs.check = xcbSourceCheck;
m_xcbEventSourceFuncs.dispatch = xcbSourceDispatch;
m_xcbEventSourceFuncs.finalize = nullptr;
GSource *source = g_source_new(&m_xcbEventSourceFuncs, sizeof(XcbEventSource));
g_source_set_name(source, "[Qt] XcbEventSource");
m_xcbEventSource = reinterpret_cast<XcbEventSource *>(source);
m_xcbEventSource->dispatcher = this;
m_xcbEventSource->dispatcher_p = d_func();
m_xcbEventSource->connection = connection;
g_source_set_can_recurse(&m_xcbEventSource->source, true);
g_source_attach(&m_xcbEventSource->source, d->mainContext);
}
QXcbGlibEventDispatcherPrivate::QXcbGlibEventDispatcherPrivate()
{
}
QXcbGlibEventDispatcher::~QXcbGlibEventDispatcher()
{
g_source_destroy(&m_xcbEventSource->source);
g_source_unref(&m_xcbEventSource->source);
}
bool QXcbGlibEventDispatcher::processEvents(QEventLoop::ProcessEventsFlags flags)
{
m_flags = flags;
return QEventDispatcherGlib::processEvents(m_flags);
}
#endif // QT_CONFIG(glib)
QAbstractEventDispatcher *QXcbEventDispatcher::createEventDispatcher(QXcbConnection *connection)
{
#if QT_CONFIG(glib)
if (qEnvironmentVariableIsEmpty("QT_NO_GLIB") && QEventDispatcherGlib::versionSupported()) {
qCDebug(lcQpaXcb, "using glib dispatcher");
return new QXcbGlibEventDispatcher(connection);
} else
#endif
{
qCDebug(lcQpaXcb, "using unix dispatcher");
return new QXcbUnixEventDispatcher(connection);
}
}
QT_END_NAMESPACE
#include "moc_qxcbeventdispatcher.cpp"
|
