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
|
/* BEGIN_COMMON_COPYRIGHT_HEADER
* (c)LGPL2+
*
* LXQt - a lightweight, Qt based, desktop toolset
* https://lxqt.org
*
* Copyright: 2021 LXQt team
*
* This program or library is free software; you can redistribute it
* and/or modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General
* Public License along with this library; if not, write to the
* Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
* Boston, MA 02110-1301 USA
*
* END_COMMON_COPYRIGHT_HEADER */
#include "statusnotifierproxy.h"
#include "statusnotifierwatcher.h"
#include <QApplication>
#include <QFutureWatcher>
#include <QtConcurrent>
#include <QDBusConnectionInterface>
#include <QDebug>
Q_GLOBAL_STATIC(StatusNotifierProxy, statusNotifierProxy)
StatusNotifierProxy::StatusNotifierProxy()
: mWatcher{nullptr},
mUsersCount{0}
{
}
void StatusNotifierProxy::createWatcher()
{
QFutureWatcher<StatusNotifierWatcher *> * future_watcher = new QFutureWatcher<StatusNotifierWatcher *>;
connect(future_watcher, &QFutureWatcher<StatusNotifierWatcher *>::finished, this, [this, future_watcher]
{
mWatcher.reset(future_watcher->future().result());
connect(mWatcher.get(), &StatusNotifierWatcher::StatusNotifierItemRegistered,
this, &StatusNotifierProxy::StatusNotifierItemRegistered);
connect(mWatcher.get(), &StatusNotifierWatcher::StatusNotifierItemUnregistered,
this, &StatusNotifierProxy::StatusNotifierItemUnregistered);
qDebug() << "StatusNotifierProxy, services:" << mWatcher->RegisteredStatusNotifierItems();
future_watcher->deleteLater();
});
QFuture<StatusNotifierWatcher *> future = QtConcurrent::run([]
{
QString dbusName = QStringLiteral("org.kde.StatusNotifierHost-%1-%2").arg(QApplication::applicationPid()).arg(1);
if (QDBusConnectionInterface::ServiceNotRegistered == QDBusConnection::sessionBus().interface()->registerService(dbusName, QDBusConnectionInterface::DontQueueService))
qDebug() << "unable to register service for " << dbusName;
StatusNotifierWatcher * watcher = new StatusNotifierWatcher;
watcher->RegisterStatusNotifierHost(dbusName);
watcher->moveToThread(QApplication::instance()->thread());
return watcher;
});
future_watcher->setFuture(future);
}
QStringList StatusNotifierProxy::RegisteredStatusNotifierItems() const
{
Q_ASSERT(mUsersCount > 0);
return mWatcher ? mWatcher->RegisteredStatusNotifierItems() : QStringList{};
}
StatusNotifierProxy & StatusNotifierProxy::registerLifetimeUsage(QObject * obj)
{
StatusNotifierProxy & p = *statusNotifierProxy();
p.registerUsage(obj);
return p;
}
void StatusNotifierProxy::registerUsage(QObject * obj)
{
connect(obj, &QObject::destroyed, this, &StatusNotifierProxy::unregisterUsage);
if (mUsersCount <= 0)
createWatcher();
++mUsersCount;
}
void StatusNotifierProxy::unregisterUsage()
{
--mUsersCount;
if (mUsersCount <= 0) {
mWatcher.reset();
}
}
|
