qdbusintegrator.cpp

Source codeSwitch to Preprocessed file
LineSource CodeCoverage
1/****************************************************************************-
**
** Copyright (C) 2012 Digia Plc and/or its subsidiary(-ies).
** Contact: http://www.qt-project.org/legal
**
** 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 Digia. For licensing terms and
** conditions see http://qt.digia.com/licensing. For further information
** use the contact form at http://qt.digia.com/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 2.1 as published by the Free Software
** Foundation and appearing in the file LICENSE.LGPL included in the
** packaging of this file. Please review the following information to
** ensure the GNU Lesser General Public License version 2.1 requirements
** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html.
**
** In addition, as a special exception, Digia gives you certain additional
** rights. These rights are described in the Digia Qt LGPL Exception
** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.
**
** GNU General Public License Usage
** Alternatively, this file may be used under the terms of the GNU
** General Public License version 3.0 as published by the Free Software
** Foundation and appearing in the file LICENSE.GPL included in the
** packaging of this file. Please review the following information to
** ensure the GNU General Public License version 3.0 requirements will be
** met: http://www.gnu.org/copyleft/gpl.html.
**
**
** $QT_END_LICENSE$
**
****************************************************************************/****************************************************************************
2** -
3** Copyright (C) 2013 Digia Plc and/or its subsidiary(-ies). -
4** Contact: http://www.qt-project.org/legal -
5** -
6** This file is part of the QtDBus module of the Qt Toolkit. -
7** -
8** $QT_BEGIN_LICENSE:LGPL$ -
9** Commercial License Usage -
10** Licensees holding valid commercial Qt licenses may use this file in -
11** accordance with the commercial license agreement provided with the -
12** Software or, alternatively, in accordance with the terms contained in -
13** a written agreement between you and Digia. For licensing terms and -
14** conditions see http://qt.digia.com/licensing. For further information -
15** use the contact form at http://qt.digia.com/contact-us. -
16** -
17** GNU Lesser General Public License Usage -
18** Alternatively, this file may be used under the terms of the GNU Lesser -
19** General Public License version 2.1 as published by the Free Software -
20** Foundation and appearing in the file LICENSE.LGPL included in the -
21** packaging of this file. Please review the following information to -
22** ensure the GNU Lesser General Public License version 2.1 requirements -
23** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html. -
24** -
25** In addition, as a special exception, Digia gives you certain additional -
26** rights. These rights are described in the Digia Qt LGPL Exception -
27** version 1.1, included in the file LGPL_EXCEPTION.txt in this package. -
28** -
29** GNU General Public License Usage -
30** Alternatively, this file may be used under the terms of the GNU -
31** General Public License version 3.0 as published by the Free Software -
32** Foundation and appearing in the file LICENSE.GPL included in the -
33** packaging of this file. Please review the following information to -
34** ensure the GNU General Public License version 3.0 requirements will be -
35** met: http://www.gnu.org/copyleft/gpl.html. -
36** -
37** -
38** $QT_END_LICENSE$ -
39** -
40****************************************************************************/ -
41 -
42#include "qdbusintegrator_p.h" -
43 -
44#include <qcoreapplication.h> -
45#include <qdebug.h> -
46#include <qmetaobject.h> -
47#include <qobject.h> -
48#include <qsocketnotifier.h> -
49#include <qstringlist.h> -
50#include <qtimer.h> -
51#include <qthread.h> -
52 -
53#include "qdbusargument.h" -
54#include "qdbusconnection_p.h" -
55#include "qdbusconnectionmanager_p.h" -
56#include "qdbusinterface_p.h" -
57#include "qdbusmessage.h" -
58#include "qdbusmetatype.h" -
59#include "qdbusmetatype_p.h" -
60#include "qdbusabstractadaptor.h" -
61#include "qdbusabstractadaptor_p.h" -
62#include "qdbusutil_p.h" -
63#include "qdbusvirtualobject.h" -
64#include "qdbusmessage_p.h" -
65#include "qdbuscontext_p.h" -
66#include "qdbuspendingcall_p.h" -
67 -
68#include "qdbusthreaddebug_p.h" -
69 -
70#include <algorithm> -
71 -
72#ifndef QT_NO_DBUS -
73 -
74QT_BEGIN_NAMESPACE -
75 -
76static bool isDebugging; -
77#define qDBusDebug if (!::isDebugging); else qDebug -
78 -
79Q_GLOBAL_STATIC_WITH_ARGS(const QString, orgFreedesktopDBusString, (QLatin1String(DBUS_SERVICE_DBUS))) -
80 -
81static inline QString dbusServiceString() -
82{ return *orgFreedesktopDBusString(); } -
83static inline QString dbusInterfaceString() -
84{ -
85 // it's the same string, but just be sure -
86 Q_ASSERT(*orgFreedesktopDBusString() == QLatin1String(DBUS_INTERFACE_DBUS)); -
87 return *orgFreedesktopDBusString(); -
88} -
89 -
90static inline QDebug operator<<(QDebug dbg, const QThread *th) -
91{ -
92 dbg.nospace() << "QThread(ptr=" << (void*)th; -
93 if (th && !th->objectName().isEmpty()) -
94 dbg.nospace() << ", name=" << th->objectName(); -
95 dbg.nospace() << ')'; -
96 return dbg.space(); -
97} -
98 -
99#if QDBUS_THREAD_DEBUG -
100static inline QDebug operator<<(QDebug dbg, const QDBusConnectionPrivate *conn) -
101{ -
102 dbg.nospace() << "QDBusConnection(" -
103 << "ptr=" << (void*)conn -
104 << ", name=" << conn->name -
105 << ", baseService=" << conn->baseService -
106 << ", thread="; -
107 if (conn->thread() == QThread::currentThread()) -
108 dbg.nospace() << "same thread"; -
109 else -
110 dbg.nospace() << conn->thread(); -
111 dbg.nospace() << ')'; -
112 return dbg.space(); -
113} -
114 -
115void qdbusDefaultThreadDebug(int action, int condition, QDBusConnectionPrivate *conn) -
116{ -
117 qDBusDebug() << QThread::currentThread() -
118 << "QtDBus"Qt D-Bus threading action" << action -
119 << (condition == QDBusLockerBase::BeforeLock ? "before lock" : -
120 condition == QDBusLockerBase::AfterLock ? "after lock" : -
121 condition == QDBusLockerBase::BeforeUnlock ? "before unlock" : -
122 condition == QDBusLockerBase::AfterUnlock ? "after unlock" : -
123 condition == QDBusLockerBase::BeforePost ? "before event posting" : -
124 condition == QDBusLockerBase::AfterPost ? "after event posting" : -
125 condition == QDBusLockerBase::BeforeDeliver ? "before event delivery" : -
126 condition == QDBusLockerBase::AfterDeliver ? "after event delivery" : -
127 condition == QDBusLockerBase::BeforeAcquire ? "before acquire" : -
128 condition == QDBusLockerBase::AfterAcquire ? "after acquire" : -
129 condition == QDBusLockerBase::BeforeRelease ? "before release" : -
130 condition == QDBusLockerBase::AfterRelease ? "after release" : -
131 "condition unknown") -
132 << "in connection" << conn; -
133} -
134qdbusThreadDebugFunc qdbusThreadDebug = 0; -
135#endif -
136 -
137typedef void (*QDBusSpyHook)(const QDBusMessage&); -
138typedef QVarLengthArray<QDBusSpyHook, 4> QDBusSpyHookList; -
139Q_GLOBAL_STATIC(QDBusSpyHookList, qDBusSpyHookList) -
140 -
141extern "C" { -
142 -
143 // libdbus-1 callbacks -
144 -
145static bool qDBusRealAddTimeout(QDBusConnectionPrivate *d, DBusTimeout *timeout, int ms); -
146static dbus_bool_t qDBusAddTimeout(DBusTimeout *timeout, void *data) -
147{ -
148 Q_ASSERT(timeout); -
149 Q_ASSERT(data); -
150 -
151 // qDebug("addTimeout %d", q_dbus_timeout_get_interval(timeout)); -
152 -
153 QDBusConnectionPrivate *d = static_cast<QDBusConnectionPrivate *>(data); -
154 -
155 if (!q_dbus_timeout_get_enabled(timeout)) -
156 return true; -
157 -
158 QDBusWatchAndTimeoutLocker locker(AddTimeoutAction, d); -
159 if (QCoreApplication::instance() && QThread::currentThread() == d->thread()) { -
160 // correct thread -
161 return qDBusRealAddTimeout(d, timeout, q_dbus_timeout_get_interval(timeout)); -
162 } else { -
163 // wrong thread: sync back -
164 QDBusConnectionCallbackEvent *ev = new QDBusConnectionCallbackEvent; -
165 ev->subtype = QDBusConnectionCallbackEvent::AddTimeout; -
166 d->timeoutsPendingAdd.append(qMakePair(timeout, q_dbus_timeout_get_interval(timeout))); -
167 d->postEventToThread(AddTimeoutAction, d, ev); -
168 return true; -
169 } -
170} -
171 -
172static bool qDBusRealAddTimeout(QDBusConnectionPrivate *d, DBusTimeout *timeout, int ms) -
173{ -
174 Q_ASSERT(d->timeouts.keys(timeout).isEmpty()); -
175 -
176 int timerId = d->startTimer(ms); -
177 if (!timerId) -
178 return false; -
179 -
180 d->timeouts[timerId] = timeout; -
181 return true; -
182} -
183 -
184static void qDBusRemoveTimeout(DBusTimeout *timeout, void *data) -
185{ -
186 Q_ASSERT(timeout); -
187 Q_ASSERT(data); -
188 -
189 // qDebug("removeTimeout"); -
190 -
191 QDBusConnectionPrivate *d = static_cast<QDBusConnectionPrivate *>(data); -
192 -
193 QDBusWatchAndTimeoutLocker locker(RemoveTimeoutAction, d); -
194 -
195 // is it pending addition? -
196 QDBusConnectionPrivate::PendingTimeoutList::iterator pit = d->timeoutsPendingAdd.begin(); -
197 while (pit != d->timeoutsPendingAdd.end()) { -
198 if (pit->first == timeout) -
199 pit = d->timeoutsPendingAdd.erase(pit); -
200 else -
201 ++pit; -
202 } -
203 -
204 // is it a running timer? -
205 bool correctThread = QCoreApplication::instance() && QThread::currentThread() == d->thread(); -
206 QDBusConnectionPrivate::TimeoutHash::iterator it = d->timeouts.begin(); -
207 while (it != d->timeouts.end()) { -
208 if (it.value() == timeout) { -
209 if (correctThread) { -
210 // correct thread -
211 d->killTimer(it.key()); -
212 } else { -
213 // incorrect thread or no application, post an event for later -
214 QDBusConnectionCallbackEvent *ev = new QDBusConnectionCallbackEvent; -
215 ev->subtype = QDBusConnectionCallbackEvent::KillTimer; -
216 ev->timerId = it.key(); -
217 d->postEventToThread(KillTimerAction, d, ev); -
218 } -
219 it = d->timeouts.erase(it); -
220 break; -
221 } else { -
222 ++it; -
223 } -
224 } -
225} -
226 -
227static void qDBusToggleTimeout(DBusTimeout *timeout, void *data) -
228{ -
229 Q_ASSERT(timeout); -
230 Q_ASSERT(data); -
231 -
232 //qDebug("ToggleTimeout"); -
233 -
234 qDBusRemoveTimeout(timeout, data); -
235 qDBusAddTimeout(timeout, data); -
236} -
237 -
238static bool qDBusRealAddWatch(QDBusConnectionPrivate *d, DBusWatch *watch, int flags, int fd); -
239static dbus_bool_t qDBusAddWatch(DBusWatch *watch, void *data) -
240{ -
241 Q_ASSERT(watch); -
242 Q_ASSERT(data); -
243 -
244 QDBusConnectionPrivate *d = static_cast<QDBusConnectionPrivate *>(data); -
245 -
246 int flags = q_dbus_watch_get_flags(watch); -
247 int fd = q_dbus_watch_get_fd(watch); -
248 -
249 if (QCoreApplication::instance() && QThread::currentThread() == d->thread()) { -
250 return qDBusRealAddWatch(d, watch, flags, fd); -
251 } else { -
252 QDBusConnectionCallbackEvent *ev = new QDBusConnectionCallbackEvent; -
253 ev->subtype = QDBusConnectionCallbackEvent::AddWatch; -
254 ev->watch = watch; -
255 ev->fd = fd; -
256 ev->extra = flags; -
257 d->postEventToThread(AddWatchAction, d, ev); -
258 return true; -
259 } -
260} -
261 -
262static bool qDBusRealAddWatch(QDBusConnectionPrivate *d, DBusWatch *watch, int flags, int fd) -
263{ -
264 QDBusConnectionPrivate::Watcher watcher; -
265 -
266 QDBusWatchAndTimeoutLocker locker(AddWatchAction, d); -
267 if (flags & DBUS_WATCH_READABLE) { -
268 //qDebug("addReadWatch %d", fd); -
269 watcher.watch = watch; -
270 if (QCoreApplication::instance()) { -
271 watcher.read = new QSocketNotifier(fd, QSocketNotifier::Read, d); -
272 watcher.read->setEnabled(q_dbus_watch_get_enabled(watch)); -
273 d->connect(watcher.read, SIGNAL(activated(int)), SLOT(socketRead(int))); -
274 } -
275 } -
276 if (flags & DBUS_WATCH_WRITABLE) { -
277 //qDebug("addWriteWatch %d", fd); -
278 watcher.watch = watch; -
279 if (QCoreApplication::instance()) { -
280 watcher.write = new QSocketNotifier(fd, QSocketNotifier::Write, d); -
281 watcher.write->setEnabled(q_dbus_watch_get_enabled(watch)); -
282 d->connect(watcher.write, SIGNAL(activated(int)), SLOT(socketWrite(int))); -
283 } -
284 } -
285 d->watchers.insertMulti(fd, watcher); -
286 -
287 return true; -
288} -
289 -
290static void qDBusRemoveWatch(DBusWatch *watch, void *data) -
291{ -
292 Q_ASSERT(watch); -
293 Q_ASSERT(data); -
294 -
295 //qDebug("remove watch"); -
296 -
297 QDBusConnectionPrivate *d = static_cast<QDBusConnectionPrivate *>(data); -
298 int fd = q_dbus_watch_get_fd(watch); -
299 -
300 QDBusWatchAndTimeoutLocker locker(RemoveWatchAction, d); -
301 QDBusConnectionPrivate::WatcherHash::iterator i = d->watchers.find(fd); -
302 while (i != d->watchers.end() && i.key() == fd) { -
303 if (i.value().watch == watch) { -
304 if (QCoreApplication::instance() && QThread::currentThread() == d->thread()) { -
305 // correct thread, delete the socket notifiers -
306 delete i.value().read; -
307 delete i.value().write; -
308 } else { -
309 // incorrect thread or no application, use delete later -
310 if (i->read) -
311 i->read->deleteLater(); -
312 if (i->write) -
313 i->write->deleteLater(); -
314 } -
315 i = d->watchers.erase(i); -
316 } else { -
317 ++i; -
318 } -
319 } -
320} -
321 -
322static void qDBusRealToggleWatch(QDBusConnectionPrivate *d, DBusWatch *watch, int fd); -
323static void qDBusToggleWatch(DBusWatch *watch, void *data) -
324{ -
325 Q_ASSERT(watch); -
326 Q_ASSERT(data); -
327 -
328 QDBusConnectionPrivate *d = static_cast<QDBusConnectionPrivate *>(data); -
329 int fd = q_dbus_watch_get_fd(watch); -
330 -
331 if (QCoreApplication::instance() && QThread::currentThread() == d->thread()) { -
332 qDBusRealToggleWatch(d, watch, fd); -
333 } else { -
334 QDBusConnectionCallbackEvent *ev = new QDBusConnectionCallbackEvent; -
335 ev->subtype = QDBusConnectionCallbackEvent::ToggleWatch; -
336 ev->watch = watch; -
337 ev->fd = fd; -
338 d->postEventToThread(ToggleWatchAction, d, ev); -
339 } -
340} -
341 -
342static void qDBusRealToggleWatch(QDBusConnectionPrivate *d, DBusWatch *watch, int fd) -
343{ -
344 QDBusWatchAndTimeoutLocker locker(ToggleWatchAction, d); -
345 -
346 QDBusConnectionPrivate::WatcherHash::iterator i = d->watchers.find(fd); -
347 while (i != d->watchers.end() && i.key() == fd) { -
348 if (i.value().watch == watch) { -
349 bool enabled = q_dbus_watch_get_enabled(watch); -
350 int flags = q_dbus_watch_get_flags(watch); -
351 -
352 //qDebug("toggle watch %d to %d (write: %d, read: %d)", q_dbus_watch_get_fd(watch), enabled, flags & DBUS_WATCH_WRITABLE, flags & DBUS_WATCH_READABLE); -
353 -
354 if (flags & DBUS_WATCH_READABLE && i.value().read) -
355 i.value().read->setEnabled(enabled); -
356 if (flags & DBUS_WATCH_WRITABLE && i.value().write) -
357 i.value().write->setEnabled(enabled); -
358 return; -
359 } -
360 ++i; -
361 } -
362} -
363 -
364static void qDBusUpdateDispatchStatus(DBusConnection *connection, DBusDispatchStatus new_status, void *data) -
365{ -
366 Q_ASSERT(connection); -
367 Q_UNUSED(connection); -
368 QDBusConnectionPrivate *d = static_cast<QDBusConnectionPrivate *>(data); -
369 -
370 static int slotId; // 0 is QObject::deleteLater() -
371 if (!slotId) { -
372 // it's ok to do this: there's no race condition because the store is atomic -
373 // and we always set to the same value -
374 slotId = QDBusConnectionPrivate::staticMetaObject.indexOfSlot("doDispatch()"); -
375 } -
376 -
377 //qDBusDebug() << "Updating dispatcher status" << slotId; -
378 if (new_status == DBUS_DISPATCH_DATA_REMAINS) -
379 QDBusConnectionPrivate::staticMetaObject.method(slotId). -
380 invoke(d, Qt::QueuedConnection); -
381} -
382 -
383static void qDBusNewConnection(DBusServer *server, DBusConnection *connection, void *data) -
384{ -
385 // ### We may want to separate the server from the QDBusConnectionPrivate -
386 Q_ASSERT(server); Q_UNUSED(server); -
387 Q_ASSERT(connection); -
388 Q_ASSERT(data); -
389 -
390 // keep the connection alive -
391 q_dbus_connection_ref(connection); -
392 QDBusConnectionPrivate *serverConnection = static_cast<QDBusConnectionPrivate *>(data); -
393 -
394 QDBusConnectionPrivate *newConnection = new QDBusConnectionPrivate(serverConnection->parent()); -
395 QMutexLocker locker(&QDBusConnectionManager::instance()->mutex); -
396 QDBusConnectionManager::instance()->setConnection(QLatin1String("QDBusServer-") + QString::number(reinterpret_cast<qulonglong>(newConnection)), newConnection); -
397 serverConnection->serverConnectionNames << newConnection->name; -
398 -
399 // setPeer does the error handling for us -
400 QDBusErrorInternal error; -
401 newConnection->setPeer(connection, error); -
402 -
403 QDBusConnection retval = QDBusConnectionPrivate::q(newConnection); -
404 -
405 // make QDBusServer emit the newConnection signal -
406 serverConnection->serverConnection(retval); -
407} -
408 -
409} // extern "C" -
410 -
411static QByteArray buildMatchRule(const QString &service, -
412 const QString &objectPath, const QString &interface, -
413 const QString &member, const QStringList &argMatch, const QString & /*signature*/) -
414{ -
415 QString result = QLatin1String("type='signal',"); -
416 QString keyValue = QLatin1String("%1='%2',"); -
417 -
418 if (!service.isEmpty()) -
419 result += keyValue.arg(QLatin1String("sender"), service); -
420 if (!objectPath.isEmpty()) -
421 result += keyValue.arg(QLatin1String("path"), objectPath); -
422 if (!interface.isEmpty()) -
423 result += keyValue.arg(QLatin1String("interface"), interface); -
424 if (!member.isEmpty()) -
425 result += keyValue.arg(QLatin1String("member"), member); -
426 -
427 // add the argument string-matching now -
428 if (!argMatch.isEmpty()) { -
429 keyValue = QLatin1String("arg%1='%2',"); -
430 for (int i = 0; i < argMatch.count(); ++i) -
431 if (!argMatch.at(i).isNull()) -
432 result += keyValue.arg(i).arg(argMatch.at(i)); -
433 } -
434 -
435 result.chop(1); // remove ending comma -
436 return result.toLatin1(); -
437} -
438 -
439static bool findObject(const QDBusConnectionPrivate::ObjectTreeNode *root, -
440 const QString &fullpath, int &usedLength, -
441 QDBusConnectionPrivate::ObjectTreeNode &result) -
442{ -
443 if (!fullpath.compare(QLatin1String("/")) && root->obj) { -
444 usedLength = 1; -
445 result = *root; -
446 return root; -
447 } -
448 int start = 0; -
449 int length = fullpath.length(); -
450 if (fullpath.at(0) == QLatin1Char('/')) -
451 start = 1; -
452 -
453 // walk the object tree -
454 QDBusConnectionPrivate::ObjectTreeNode::DataList::ConstIterator node = root; -
455 while (start < length && node) { -
456 if (node->flags & QDBusConnection::ExportChildObjects) -
457 break; -
458 if ((node->flags & QDBusConnectionPrivate::VirtualObject) && (node->flags & QDBusConnection::SubPath)) -
459 break; -
460 int end = fullpath.indexOf(QLatin1Char('/'), start); -
461 end = (end == -1 ? length : end); -
462 QStringRef pathComponent(&fullpath, start, end - start); -
463 -
464 QDBusConnectionPrivate::ObjectTreeNode::DataList::ConstIterator it = -
465 std::lower_bound(node->children.constBegin(), node->children.constEnd(), pathComponent); -
466 if (it != node->children.constEnd() && it->name == pathComponent) -
467 // match -
468 node = it; -
469 else -
470 node = 0; -
471 -
472 start = end + 1; -
473 } -
474 -
475 // found our object -
476 usedLength = (start > length ? length : start); -
477 if (node) { -
478 if (node->obj || !node->children.isEmpty()) -
479 result = *node; -
480 else -
481 // there really is no object here -
482 // we're just looking at an unused space in the QVector -
483 node = 0; -
484 } -
485 return node; -
486} -
487 -
488static QObject *findChildObject(const QDBusConnectionPrivate::ObjectTreeNode *root, -
489 const QString &fullpath, int start) -
490{ -
491 int length = fullpath.length(); -
492 -
493 // any object in the tree can tell us to switch to its own object tree: -
494 const QDBusConnectionPrivate::ObjectTreeNode *node = root; -
495 if (node && node->flags & QDBusConnection::ExportChildObjects) { -
496 QObject *obj = node->obj; -
497 -
498 while (obj) { -
499 if (start >= length) -
500 // we're at the correct level -
501 return obj; -
502 -
503 int pos = fullpath.indexOf(QLatin1Char('/'), start); -
504 pos = (pos == -1 ? length : pos); -
505 QStringRef pathComponent(&fullpath, start, pos - start); -
506 -
507 const QObjectList children = obj->children(); -
508 -
509 // find a child with the proper name -
510 QObject *next = 0; -
511 QObjectList::ConstIterator it = children.constBegin(); -
512 QObjectList::ConstIterator end = children.constEnd(); -
513 for ( ; it != end; ++it) -
514 if ((*it)->objectName() == pathComponent) { -
515 next = *it; -
516 break; -
517 } -
518 -
519 if (!next) -
520 break; -
521 -
522 obj = next; -
523 start = pos + 1; -
524 } -
525 } -
526 -
527 // object not found -
528 return 0; -
529} -
530 -
531static bool shouldWatchService(const QString &service) -
532{ -
533 return !service.isEmpty() && !service.startsWith(QLatin1Char(':')); -
534} -
535 -
536extern Q_DBUS_EXPORT void qDBusAddSpyHook(QDBusSpyHook); -
537void qDBusAddSpyHook(QDBusSpyHook hook) -
538{ -
539 qDBusSpyHookList()->append(hook); -
540} -
541 -
542extern "C" { -
543static DBusHandlerResult -
544qDBusSignalFilter(DBusConnection *connection, DBusMessage *message, void *data) -
545{ -
546 Q_ASSERT(data); -
547 Q_UNUSED(connection); -
548 QDBusConnectionPrivate *d = static_cast<QDBusConnectionPrivate *>(data); -
549 if (d->mode == QDBusConnectionPrivate::InvalidMode) -
550 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED; -
551 -
552 QDBusMessage amsg = QDBusMessagePrivate::fromDBusMessage(message, d->capabilities); -
553 qDBusDebug() << d << "got message (signal):" << amsg; -
554 -
555 return d->handleMessage(amsg) ? -
556 DBUS_HANDLER_RESULT_HANDLED : -
557 DBUS_HANDLER_RESULT_NOT_YET_HANDLED; -
558} -
559} -
560 -
561bool QDBusConnectionPrivate::handleMessage(const QDBusMessage &amsg) -
562{ -
563 const QDBusSpyHookList *list = qDBusSpyHookList(); -
564 for (int i = 0; i < list->size(); ++i) { -
565 qDBusDebug() << "calling the message spy hook"; -
566 (*(*list)[i])(amsg); -
567 } -
568 -
569 if (!ref.load()) -
570 return false; -
571 -
572 switch (amsg.type()) { -
573 case QDBusMessage::SignalMessage: -
574 handleSignal(amsg); -
575 // if there are any other filters in this DBusConnection, -
576 // let them see the signal too -
577 return false; -
578 case QDBusMessage::MethodCallMessage: -
579 handleObjectCall(amsg); -
580 return true; -
581 case QDBusMessage::ReplyMessage: -
582 case QDBusMessage::ErrorMessage: -
583 case QDBusMessage::InvalidMessage: -
584 return false; // we don't handle those here -
585 } -
586 -
587 return false; -
588} -
589 -
590static void huntAndDestroy(QObject *needle, QDBusConnectionPrivate::ObjectTreeNode &haystack) -
591{ -
592 QDBusConnectionPrivate::ObjectTreeNode::DataList::Iterator it = haystack.children.begin(); -
593 QDBusConnectionPrivate::ObjectTreeNode::DataList::Iterator end = haystack.children.end(); -
594 for ( ; it != end; ++it) -
595 huntAndDestroy(needle, *it); -
596 -
597 if (needle == haystack.obj) { -
598 haystack.obj = 0; -
599 haystack.flags = 0; -
600 } -
601} -
602 -
603static void huntAndEmit(DBusConnection *connection, DBusMessage *msg, -
604 QObject *needle, const QDBusConnectionPrivate::ObjectTreeNode &haystack, -
605 bool isScriptable, bool isAdaptor, const QString &path = QString()) -
606{ -
607 QDBusConnectionPrivate::ObjectTreeNode::DataList::ConstIterator it = haystack.children.constBegin(); -
608 QDBusConnectionPrivate::ObjectTreeNode::DataList::ConstIterator end = haystack.children.constEnd(); -
609 for ( ; it != end; ++it) -
610 huntAndEmit(connection, msg, needle, *it, isScriptable, isAdaptor, path + QLatin1Char('/') + it->name); -
611 -
612 if (needle == haystack.obj) { -
613 // is this a signal we should relay? -
614 if (isAdaptor && (haystack.flags & QDBusConnection::ExportAdaptors) == 0) -
615 return; // no: it comes from an adaptor and we're not exporting adaptors -
616 else if (!isAdaptor) { -
617 int mask = isScriptable -
618 ? QDBusConnection::ExportScriptableSignals -
619 : QDBusConnection::ExportNonScriptableSignals; -
620 if ((haystack.flags & mask) == 0) -
621 return; // signal was not exported -
622 } -
623 -
624 QByteArray p = path.toLatin1(); -
625 if (p.isEmpty()) -
626 p = "/"; -
627 qDBusDebug() << QThread::currentThread() << "emitting signal at" << p; -
628 DBusMessage *msg2 = q_dbus_message_copy(msg); -
629 q_dbus_message_set_path(msg2, p); -
630 q_dbus_connection_send(connection, msg2, 0); -
631 q_dbus_message_unref(msg2); -
632 } -
633} -
634 -
635static int findSlot(const QMetaObject *mo, const QByteArray &name, int flags, -
636 const QString &signature_, QVector<int> &metaTypes) -
637{ -
638 QByteArray msgSignature = signature_.toLatin1(); -
639 -
640 for (int idx = mo->methodCount() - 1 ; idx >= QObject::staticMetaObject.methodCount(); --idx) { -
641 QMetaMethod mm = mo->method(idx); -
642 -
643 // check access: -
644 if (mm.access() != QMetaMethod::Public) -
645 continue; -
646 -
647 // check type: -
648 if (mm.methodType() != QMetaMethod::Slot && mm.methodType() != QMetaMethod::Method) -
649 continue; -
650 -
651 // check name: -
652 if (mm.name() != name) -
653 continue; -
654 -
655 int returnType = mm.returnType(); -
656 bool isAsync = qDBusCheckAsyncTag(mm.tag()); -
657 bool isScriptable = mm.attributes() & QMetaMethod::Scriptable; -
658 -
659 // consistency check: -
660 if (isAsync && returnType != QMetaType::Void) -
661 continue; -
662 -
663 int inputCount = qDBusParametersForMethod(mm, metaTypes); -
664 if (inputCount == -1) -
665 continue; // problem parsing -
666 -
667 metaTypes[0] = returnType; -
668 bool hasMessage = false; -
669 if (inputCount > 0 && -
670 metaTypes.at(inputCount) == QDBusMetaTypeId::message()) { -
671 // "no input parameters" is allowed as long as the message meta type is there -
672 hasMessage = true; -
673 --inputCount; -
674 } -
675 -
676 // try to match the parameters -
677 int i; -
678 QByteArray reconstructedSignature; -
679 for (i = 1; i <= inputCount; ++i) { -
680 const char *typeSignature = QDBusMetaType::typeToSignature( metaTypes.at(i) ); -
681 if (!typeSignature) -
682 break; // invalid -
683 -
684 reconstructedSignature += typeSignature; -
685 if (!msgSignature.startsWith(reconstructedSignature)) -
686 break; -
687 } -
688 -
689 if (reconstructedSignature != msgSignature) -
690 continue; // we didn't match them all -
691 -
692 if (hasMessage) -
693 ++i; -
694 -
695 // make sure that the output parameters have signatures too -
696 if (returnType != QMetaType::UnknownType && returnType != QMetaType::Void && QDBusMetaType::typeToSignature(returnType) == 0) -
697 continue; -
698 -
699 bool ok = true; -
700 for (int j = i; ok && j < metaTypes.count(); ++j) -
701 if (QDBusMetaType::typeToSignature(metaTypes.at(i)) == 0) -
702 ok = false; -
703 if (!ok) -
704 continue; -
705 -
706 // consistency check: -
707 if (isAsync && metaTypes.count() > i + 1) -
708 continue; -
709 -
710 if (mm.methodType() == QMetaMethod::Slot) { -
711 if (isScriptable && (flags & QDBusConnection::ExportScriptableSlots) == 0) -
712 continue; // scriptable slots not exported -
713 if (!isScriptable && (flags & QDBusConnection::ExportNonScriptableSlots) == 0) -
714 continue; // non-scriptable slots not exported -
715 } else { -
716 if (isScriptable && (flags & QDBusConnection::ExportScriptableInvokables) == 0) -
717 continue; // scriptable invokables not exported -
718 if (!isScriptable && (flags & QDBusConnection::ExportNonScriptableInvokables) == 0) -
719 continue; // non-scriptable invokables not exported -
720 } -
721 -
722 // if we got here, this slot matched -
723 return idx; -
724 } -
725 -
726 // no slot matched -
727 return -1; -
728} -
729 -
730static QDBusCallDeliveryEvent * const DIRECT_DELIVERY = (QDBusCallDeliveryEvent *)1; -
731 -
732QDBusCallDeliveryEvent* QDBusConnectionPrivate::prepareReply(QDBusConnectionPrivate *target, -
733 QObject *object, int idx, -
734 const QVector<int> &metaTypes, -
735 const QDBusMessage &msg) -
736{ -
737 Q_ASSERT(object); -
738 Q_UNUSED(object); -
739 -
740 int n = metaTypes.count() - 1; -
741 if (metaTypes[n] == QDBusMetaTypeId::message()) -
742 --n; -
743 -
744 if (msg.arguments().count() < n) -
745 return 0; // too few arguments -
746 -
747 // check that types match -
748 for (int i = 0; i < n; ++i) -
749 if (metaTypes.at(i + 1) != msg.arguments().at(i).userType() && -
750 msg.arguments().at(i).userType() != qMetaTypeId<QDBusArgument>()) -
751 return 0; // no match -
752 -
753 // we can deliver -
754 // prepare for the call -
755 if (target == object) -
756 return DIRECT_DELIVERY; -
757 return new QDBusCallDeliveryEvent(QDBusConnection(target), idx, target, msg, metaTypes); -
758} -
759 -
760void QDBusConnectionPrivate::activateSignal(const QDBusConnectionPrivate::SignalHook& hook, -
761 const QDBusMessage &msg) -
762{ -
763 // This is called by QDBusConnectionPrivate::handleSignal to deliver a signal -
764 // that was received from D-Bus -
765 // -
766 // Signals are delivered to slots if the parameters match -
767 // Slots can have less parameters than there are on the message -
768 // Slots can optionally have one final parameter that is a QDBusMessage -
769 // Slots receive read-only copies of the message (i.e., pass by value or by const-ref) -
770 QDBusCallDeliveryEvent *call = prepareReply(this, hook.obj, hook.midx, hook.params, msg); -
771 if (call == DIRECT_DELIVERY) { -
772 // short-circuit delivery -
773 Q_ASSERT(this == hook.obj); -
774 deliverCall(this, 0, msg, hook.params, hook.midx); -
775 return; -
776 } -
777 if (call) -
778 postEventToThread(ActivateSignalAction, hook.obj, call); -
779} -
780 -
781bool QDBusConnectionPrivate::activateCall(QObject* object, int flags, const QDBusMessage &msg) -
782{ -
783 // This is called by QDBusConnectionPrivate::handleObjectCall to place a call -
784 // to a slot on the object. -
785 // -
786 // The call is delivered to the first slot that matches the following conditions: -
787 // - has the same name as the message's target member -
788 // - ALL of the message's types are found in slot's parameter list -
789 // - optionally has one more parameter of type QDBusMessage -
790 // If none match, then the slot of the same name as the message target and with -
791 // the first type of QDBusMessage is delivered. -
792 // -
793 // The D-Bus specification requires that all MethodCall messages be replied to, unless the -
794 // caller specifically waived this requirement. This means that we inspect if the user slot -
795 // generated a reply and, if it didn't, we will. Obviously, if the user slot doesn't take a -
796 // QDBusMessage parameter, it cannot generate a reply. -
797 // -
798 // When a return message is generated, the slot's return type, if any, will be placed -
799 // in the message's first position. If there are non-const reference parameters to the -
800 // slot, they must appear at the end and will be placed in the subsequent message -
801 // positions. -
802 -
803 static const char cachePropertyName[] = "_qdbus_slotCache"; -
804 -
805 if (!object) -
806 return false; -
807 -
808#ifndef QT_NO_PROPERTIES -
809 Q_ASSERT_X(QThread::currentThread() == object->thread(), -
810 "QDBusConnection: internal threading error", -
811 "function called for an object that is in another thread!!"); -
812 -
813 QDBusSlotCache slotCache = -
814 qvariant_cast<QDBusSlotCache>(object->property(cachePropertyName)); -
815 QString cacheKey = msg.member(), signature = msg.signature(); -
816 if (!signature.isEmpty()) { -
817 cacheKey.reserve(cacheKey.length() + 1 + signature.length()); -
818 cacheKey += QLatin1Char('.'); -
819 cacheKey += signature; -
820 } -
821 -
822 QDBusSlotCache::Hash::ConstIterator cacheIt = slotCache.hash.constFind(cacheKey); -
823 while (cacheIt != slotCache.hash.constEnd() && cacheIt->flags != flags && -
824 cacheIt.key() == cacheKey) -
825 ++cacheIt; -
826 if (cacheIt == slotCache.hash.constEnd() || cacheIt.key() != cacheKey) -
827 { -
828 // not cached, analyze the meta object -
829 const QMetaObject *mo = object->metaObject(); -
830 QByteArray memberName = msg.member().toUtf8(); -
831 -
832 // find a slot that matches according to the rules above -
833 QDBusSlotCache::Data slotData; -
834 slotData.flags = flags; -
835 slotData.slotIdx = ::findSlot(mo, memberName, flags, msg.signature(), slotData.metaTypes); -
836 if (slotData.slotIdx == -1) { -
837 // ### this is where we want to add the connection as an arg too -
838 // try with no parameters, but with a QDBusMessage -
839 slotData.slotIdx = ::findSlot(mo, memberName, flags, QString(), slotData.metaTypes); -
840 if (slotData.metaTypes.count() != 2 || -
841 slotData.metaTypes.at(1) != QDBusMetaTypeId::message()) { -
842 // not found -
843 // save the negative lookup -
844 slotData.slotIdx = -1; -
845 slotData.metaTypes.clear(); -
846 slotCache.hash.insert(cacheKey, slotData); -
847 object->setProperty(cachePropertyName, QVariant::fromValue(slotCache)); -
848 return false; -
849 } -
850 } -
851 -
852 // save to the cache -
853 slotCache.hash.insert(cacheKey, slotData); -
854 object->setProperty(cachePropertyName, QVariant::fromValue(slotCache)); -
855 -
856 // found the slot to be called -
857 deliverCall(object, flags, msg, slotData.metaTypes, slotData.slotIdx); -
858 return true; -
859 } else if (cacheIt->slotIdx == -1) { -
860 // negative cache -
861 return false; -
862 } else { -
863 // use the cache -
864 deliverCall(object, flags, msg, cacheIt->metaTypes, cacheIt->slotIdx); -
865 return true; -
866 } -
867#endif // QT_NO_PROPERTIES -
868 return false;
dead code: return false;
-
869} -
870 -
871void QDBusConnectionPrivate::deliverCall(QObject *object, int /*flags*/, const QDBusMessage &msg, -
872 const QVector<int> &metaTypes, int slotIdx) -
873{ -
874 Q_ASSERT_X(!object || QThread::currentThread() == object->thread(), -
875 "QDBusConnection: internal threading error", -
876 "function called for an object that is in another thread!!"); -
877 -
878 QVarLengthArray<void *, 10> params; -
879 params.reserve(metaTypes.count()); -
880 -
881 QVariantList auxParameters; -
882 // let's create the parameter list -
883 -
884 // first one is the return type -- add it below -
885 params.append(0); -
886 -
887 // add the input parameters -
888 int i; -
889 int pCount = qMin(msg.arguments().count(), metaTypes.count() - 1); -
890 for (i = 1; i <= pCount; ++i) { -
891 int id = metaTypes[i]; -
892 if (id == QDBusMetaTypeId::message()) -
893 break; -
894 -
895 const QVariant &arg = msg.arguments().at(i - 1); -
896 if (arg.userType() == id) -
897 // no conversion needed -
898 params.append(const_cast<void *>(arg.constData())); -
899 else if (arg.userType() == qMetaTypeId<QDBusArgument>()) { -
900 // convert to what the function expects -
901 void *null = 0; -
902 auxParameters.append(QVariant(id, null)); -
903 -
904 const QDBusArgument &in = -
905 *reinterpret_cast<const QDBusArgument *>(arg.constData()); -
906 QVariant &out = auxParameters[auxParameters.count() - 1]; -
907 -
908 if (!QDBusMetaType::demarshall(in, out.userType(), out.data())) -
909 qFatal("Internal error: demarshalling function for type '%s' (%d) failed!", -
910 out.typeName(), out.userType()); -
911 -
912 params.append(const_cast<void *>(out.constData())); -
913 } else { -
914 qFatal("Internal error: got invalid meta type %d (%s) " -
915 "when trying to convert to meta type %d (%s)", -
916 arg.userType(), QMetaType::typeName(arg.userType()), -
917 id, QMetaType::typeName(id)); -
918 } -
919 } -
920 -
921 if (metaTypes.count() > i && metaTypes[i] == QDBusMetaTypeId::message()) { -
922 params.append(const_cast<void*>(static_cast<const void*>(&msg))); -
923 ++i; -
924 } -
925 -
926 // output arguments -
927 QVariantList outputArgs; -
928 void *null = 0; -
929 if (metaTypes[0] != QMetaType::Void && metaTypes[0] != QMetaType::UnknownType) { -
930 QVariant arg(metaTypes[0], null); -
931 outputArgs.append( arg ); -
932 params[0] = const_cast<void*>(outputArgs.at( outputArgs.count() - 1 ).constData()); -
933 } -
934 for ( ; i < metaTypes.count(); ++i) { -
935 QVariant arg(metaTypes[i], null); -
936 outputArgs.append( arg ); -
937 params.append(const_cast<void*>(outputArgs.at( outputArgs.count() - 1 ).constData())); -
938 } -
939 -
940 // make call: -
941 bool fail; -
942 if (!object) { -
943 fail = true; -
944 } else { -
945 // FIXME: save the old sender! -
946 QDBusContextPrivate context(QDBusConnection(this), msg); -
947 QDBusContextPrivate *old = QDBusContextPrivate::set(object, &context); -
948 QDBusConnectionPrivate::setSender(this); -
949 -
950 QPointer<QObject> ptr = object; -
951 fail = object->qt_metacall(QMetaObject::InvokeMetaMethod, -
952 slotIdx, params.data()) >= 0; -
953 QDBusConnectionPrivate::setSender(0); -
954 // the object might be deleted in the slot -
955 if (!ptr.isNull()) -
956 QDBusContextPrivate::set(object, old); -
957 } -
958 -
959 // do we create a reply? Only if the caller is waiting for a reply and one hasn't been sent -
960 // yet. -
961 if (msg.isReplyRequired() && !msg.isDelayedReply()) { -
962 if (!fail) { -
963 // normal reply -
964 qDBusDebug() << this << "Automatically sending reply:" << outputArgs; -
965 send(msg.createReply(outputArgs)); -
966 } else { -
967 // generate internal error -
968 qWarning("Internal error: Failed to deliver message"); -
969 send(msg.createErrorReply(QDBusError::InternalError, -
970 QLatin1String("Failed to deliver message"))); -
971 } -
972 } -
973 -
974 return; -
975} -
976 -
977extern bool qDBusInitThreads(); -
978 -
979QDBusConnectionPrivate::QDBusConnectionPrivate(QObject *p) -
980 : QObject(p), ref(1), capabilities(0), mode(InvalidMode), connection(0), server(0), busService(0), -
981 watchAndTimeoutLock(QMutex::Recursive), -
982 rootNode(QString(QLatin1Char('/'))) -
983{ -
984 static const bool threads = q_dbus_threads_init_default(); -
985 static const int debugging = qgetenv("QDBUS_DEBUG").toInt(); -
986 ::isDebugging = debugging; -
987 Q_UNUSED(threads) -
988 Q_UNUSED(debugging) -
989 -
990#ifdef QDBUS_THREAD_DEBUG -
991 if (debugging > 1) -
992 qdbusThreadDebug = qdbusDefaultThreadDebug; -
993#endif -
994 -
995 QDBusMetaTypeId::init(); -
996 -
997 rootNode.flags = 0; -
998 -
999 // prepopulate watchedServices: -
1000 // we know that the owner of org.freedesktop.DBus is itself -
1001 watchedServices.insert(dbusServiceString(), WatchedServiceData(dbusServiceString(), 1)); -
1002 -
1003 // prepopulate matchRefCounts: -
1004 // we know that org.freedesktop.DBus will never change owners -
1005 matchRefCounts.insert("type='signal',sender='org.freedesktop.DBus',interface='org.freedesktop.DBus',member='NameOwnerChanged',arg0='org.freedesktop.DBus'", 1); -
1006} -
1007 -
1008QDBusConnectionPrivate::~QDBusConnectionPrivate() -
1009{ -
1010 if (thread() && thread() != QThread::currentThread()) -
1011 qWarning("QDBusConnection(name=\"%s\")'s last reference in not in its creation thread! " -
1012 "Timer and socket errors will follow and the program will probably crash", -
1013 qPrintable(name)); -
1014 -
1015 closeConnection(); -
1016 rootNode.children.clear(); // free resources -
1017 qDeleteAll(cachedMetaObjects); -
1018 -
1019 if (server) -
1020 q_dbus_server_unref(server); -
1021 if (connection) -
1022 q_dbus_connection_unref(connection); -
1023 -
1024 connection = 0; -
1025 server = 0; -
1026} -
1027 -
1028void QDBusConnectionPrivate::deleteYourself() -
1029{ -
1030 if (thread() && thread() != QThread::currentThread()) { -
1031 // last reference dropped while not in the correct thread -
1032 // ask the correct thread to delete -
1033 -
1034 // note: since we're posting an event to another thread, we -
1035 // must consider deleteLater() to take effect immediately -
1036 deleteLater(); -
1037 } else { -
1038 delete this; -
1039 } -
1040} -
1041 -
1042void QDBusConnectionPrivate::closeConnection() -
1043{ -
1044 QDBusWriteLocker locker(CloseConnectionAction, this); -
1045 ConnectionMode oldMode = mode; -
1046 mode = InvalidMode; // prevent reentrancy -
1047 baseService.clear(); -
1048 -
1049 if (server) -
1050 q_dbus_server_disconnect(server); -
1051 -
1052 if (oldMode == ClientMode || oldMode == PeerMode) { -
1053 if (connection) { -
1054 q_dbus_connection_close(connection); -
1055 // send the "close" message -
1056 while (q_dbus_connection_dispatch(connection) == DBUS_DISPATCH_DATA_REMAINS) -
1057 ; -
1058 } -
1059 } -
1060 qDBusDebug() << this << "Disconnected"; -
1061} -
1062 -
1063void QDBusConnectionPrivate::checkThread() -
1064{ -
1065 if (!thread()) { -
1066 if (QCoreApplication::instance()) -
1067 moveToThread(QCoreApplication::instance()->thread()); -
1068 else -
1069 qWarning("The thread that had QDBusConnection('%s') has died and there is no main thread", -
1070 qPrintable(name)); -
1071 } -
1072} -
1073 -
1074bool QDBusConnectionPrivate::handleError(const QDBusErrorInternal &error) -
1075{ -
1076 if (!error) -
1077 return false; // no error -
1078 -
1079 //lock.lockForWrite(); -
1080 lastError = error; -
1081 //lock.unlock(); -
1082 return true; -
1083} -
1084 -
1085void QDBusConnectionPrivate::timerEvent(QTimerEvent *e) -
1086{ -
1087 { -
1088 QDBusWatchAndTimeoutLocker locker(TimerEventAction, this); -
1089 DBusTimeout *timeout = timeouts.value(e->timerId(), 0); -
1090 if (timeout) -
1091 q_dbus_timeout_handle(timeout); -
1092 } -
1093 -
1094 doDispatch(); -
1095} -
1096 -
1097void QDBusConnectionPrivate::customEvent(QEvent *e) -
1098{ -
1099 Q_ASSERT(e->type() == QEvent::User); -
1100 -
1101 QDBusConnectionCallbackEvent *ev = static_cast<QDBusConnectionCallbackEvent *>(e); -
1102 QDBusLockerBase::reportThreadAction(int(AddTimeoutAction) + int(ev->subtype), -
1103 QDBusLockerBase::BeforeDeliver, this); -
1104 switch (ev->subtype) -
1105 { -
1106 case QDBusConnectionCallbackEvent::AddTimeout: { -
1107 QDBusWatchAndTimeoutLocker locker(RealAddTimeoutAction, this); -
1108 while (!timeoutsPendingAdd.isEmpty()) { -
1109 QPair<DBusTimeout *, int> entry = timeoutsPendingAdd.takeFirst(); -
1110 qDBusRealAddTimeout(this, entry.first, entry.second); -
1111 } -
1112 break; -
1113 } -
1114 -
1115 case QDBusConnectionCallbackEvent::KillTimer: -
1116 killTimer(ev->timerId); -
1117 break; -
1118 -
1119 case QDBusConnectionCallbackEvent::AddWatch: -
1120 qDBusRealAddWatch(this, ev->watch, ev->extra, ev->fd); -
1121 break; -
1122 -
1123 case QDBusConnectionCallbackEvent::ToggleWatch: -
1124 qDBusRealToggleWatch(this, ev->watch, ev->fd); -
1125 break; -
1126 } -
1127 QDBusLockerBase::reportThreadAction(int(AddTimeoutAction) + int(ev->subtype), -
1128 QDBusLockerBase::AfterDeliver, this); -
1129} -
1130 -
1131void QDBusConnectionPrivate::doDispatch() -
1132{ -
1133 QDBusDispatchLocker locker(DoDispatchAction, this); -
1134 if (mode == ClientMode || mode == PeerMode) -
1135 while (q_dbus_connection_dispatch(connection) == DBUS_DISPATCH_DATA_REMAINS) ; -
1136} -
1137 -
1138void QDBusConnectionPrivate::socketRead(int fd) -
1139{ -
1140 QVarLengthArray<DBusWatch *, 2> pendingWatches; -
1141 -
1142 { -
1143 QDBusWatchAndTimeoutLocker locker(SocketReadAction, this); -
1144 WatcherHash::ConstIterator it = watchers.constFind(fd); -
1145 while (it != watchers.constEnd() && it.key() == fd) { -
1146 if (it->watch && it->read && it->read->isEnabled()) -
1147 pendingWatches.append(it.value().watch); -
1148 ++it; -
1149 } -
1150 } -
1151 -
1152 for (int i = 0; i < pendingWatches.size(); ++i) -
1153 if (!q_dbus_watch_handle(pendingWatches[i], DBUS_WATCH_READABLE)) -
1154 qDebug("OUT OF MEM"); -
1155 doDispatch(); -
1156} -
1157 -
1158void QDBusConnectionPrivate::socketWrite(int fd) -
1159{ -
1160 QVarLengthArray<DBusWatch *, 2> pendingWatches; -
1161 -
1162 { -
1163 QDBusWatchAndTimeoutLocker locker(SocketWriteAction, this); -
1164 WatcherHash::ConstIterator it = watchers.constFind(fd); -
1165 while (it != watchers.constEnd() && it.key() == fd) { -
1166 if (it->watch && it->write && it->write->isEnabled()) -
1167 pendingWatches.append(it.value().watch); -
1168 ++it; -
1169 } -
1170 } -
1171 -
1172 for (int i = 0; i < pendingWatches.size(); ++i) -
1173 if (!q_dbus_watch_handle(pendingWatches[i], DBUS_WATCH_WRITABLE)) -
1174 qDebug("OUT OF MEM"); -
1175} -
1176 -
1177void QDBusConnectionPrivate::objectDestroyed(QObject *obj) -
1178{ -
1179 QDBusWriteLocker locker(ObjectDestroyedAction, this); -
1180 huntAndDestroy(obj, rootNode); -
1181 -
1182 SignalHookHash::iterator sit = signalHooks.begin(); -
1183 while (sit != signalHooks.end()) { -
1184 if (static_cast<QObject *>(sit.value().obj) == obj) -
1185 sit = disconnectSignal(sit); -
1186 else -
1187 ++sit; -
1188 } -
1189 -
1190 obj->disconnect(this); -
1191} -
1192 -
1193void QDBusConnectionPrivate::relaySignal(QObject *obj, const QMetaObject *mo, int signalId, -
1194 const QVariantList &args) -
1195{ -
1196 QString interface = qDBusInterfaceFromMetaObject(mo); -
1197 -
1198 QMetaMethod mm = mo->method(signalId); -
1199 QByteArray memberName = mm.name(); -
1200 -
1201 // check if it's scriptable -
1202 bool isScriptable = mm.attributes() & QMetaMethod::Scriptable; -
1203 bool isAdaptor = false; -
1204 for ( ; mo; mo = mo->superClass()) -
1205 if (mo == &QDBusAbstractAdaptor::staticMetaObject) { -
1206 isAdaptor = true; -
1207 break; -
1208 } -
1209 -
1210 QDBusReadLocker locker(RelaySignalAction, this); -
1211 QDBusMessage message = QDBusMessage::createSignal(QLatin1String("/"), interface, -
1212 QLatin1String(memberName)); -
1213 QDBusMessagePrivate::setParametersValidated(message, true); -
1214 message.setArguments(args); -
1215 QDBusError error; -
1216 DBusMessage *msg = QDBusMessagePrivate::toDBusMessage(message, capabilities, &error); -
1217 if (!msg) { -
1218 qWarning("QDBusConnection: Could not emit signal %s.%s: %s", qPrintable(interface), memberName.constData(), -
1219 qPrintable(error.message())); -
1220 lastError = error; -
1221 return; -
1222 } -
1223 -
1224 //qDBusDebug() << "Emitting signal" << message; -
1225 //qDBusDebug() << "for paths:"; -
1226 q_dbus_message_set_no_reply(msg, true); // the reply would not be delivered to anything -
1227 huntAndEmit(connection, msg, obj, rootNode, isScriptable, isAdaptor); -
1228 q_dbus_message_unref(msg); -
1229} -
1230 -
1231void QDBusConnectionPrivate::serviceOwnerChangedNoLock(const QString &name, -
1232 const QString &oldOwner, const QString &newOwner) -
1233{ -
1234 Q_UNUSED(oldOwner); -
1235// QDBusWriteLocker locker(UpdateSignalHookOwnerAction, this); -
1236 WatchedServicesHash::Iterator it = watchedServices.find(name); -
1237 if (it == watchedServices.end()) -
1238 return; -
1239 if (oldOwner != it->owner) -
1240 qWarning("QDBusConnection: name '%s' had owner '%s' but we thought it was '%s'", -
1241 qPrintable(name), qPrintable(oldOwner), qPrintable(it->owner)); -
1242 -
1243 qDBusDebug() << this << "Updating name" << name << "from" << oldOwner << "to" << newOwner; -
1244 it->owner = newOwner; -
1245} -
1246 -
1247int QDBusConnectionPrivate::findSlot(QObject* obj, const QByteArray &normalizedName, -
1248 QVector<int> &params) -
1249{ -
1250 int midx = obj->metaObject()->indexOfMethod(normalizedName); -
1251 if (midx == -1) -
1252 return -1; -
1253 -
1254 int inputCount = qDBusParametersForMethod(obj->metaObject()->method(midx), params); -
1255 if ( inputCount == -1 || inputCount + 1 != params.count() ) -
1256 return -1; // failed to parse or invalid arguments or output arguments -
1257 -
1258 return midx; -
1259} -
1260 -
1261bool QDBusConnectionPrivate::prepareHook(QDBusConnectionPrivate::SignalHook &hook, QString &key, -
1262 const QString &service, -
1263 const QString &path, const QString &interface, const QString &name, -
1264 const QStringList &argMatch, -
1265 QObject *receiver, const char *signal, int minMIdx, -
1266 bool buildSignature) -
1267{ -
1268 QByteArray normalizedName = signal + 1; -
1269 hook.midx = findSlot(receiver, signal + 1, hook.params); -
1270 if (hook.midx == -1) { -
1271 normalizedName = QMetaObject::normalizedSignature(signal + 1); -
1272 hook.midx = findSlot(receiver, normalizedName, hook.params); -
1273 } -
1274 if (hook.midx < minMIdx) { -
1275 if (hook.midx == -1) -
1276 {} -
1277 return false; -
1278 } -
1279 -
1280 hook.service = service; -
1281 hook.path = path; -
1282 hook.obj = receiver; -
1283 hook.argumentMatch = argMatch; -
1284 -
1285 // build the D-Bus signal name and signature -
1286 // This should not happen for QDBusConnection::connect, use buildSignature here, since -
1287 // QDBusConnection::connect passes false and everything else uses true -
1288 QString mname = name; -
1289 if (buildSignature && mname.isNull()) { -
1290 normalizedName.truncate(normalizedName.indexOf('(')); -
1291 mname = QString::fromUtf8(normalizedName); -
1292 } -
1293 key = mname; -
1294 key.reserve(interface.length() + 1 + mname.length()); -
1295 key += QLatin1Char(':'); -
1296 key += interface; -
1297 -
1298 if (buildSignature) { -
1299 hook.signature.clear(); -
1300 for (int i = 1; i < hook.params.count(); ++i) -
1301 if (hook.params.at(i) != QDBusMetaTypeId::message()) -
1302 hook.signature += QLatin1String( QDBusMetaType::typeToSignature( hook.params.at(i) ) ); -
1303 } -
1304 -
1305 hook.matchRule = buildMatchRule(service, path, interface, mname, argMatch, hook.signature); -
1306 return true; // connect to this signal -
1307} -
1308 -
1309void QDBusConnectionPrivate::sendError(const QDBusMessage &msg, QDBusError::ErrorType code) -
1310{ -
1311 if (code == QDBusError::UnknownMethod) { -
1312 QString interfaceMsg; -
1313 if (msg.interface().isEmpty()) -
1314 interfaceMsg = QLatin1String("any interface"); -
1315 else -
1316 interfaceMsg = QString::fromLatin1("interface '%1'").arg(msg.interface()); -
1317 -
1318 send(msg.createErrorReply(code, -
1319 QString::fromLatin1("No such method '%1' in %2 at object path '%3' " -
1320 "(signature '%4')") -
1321 .arg(msg.member(), interfaceMsg, msg.path(), msg.signature()))); -
1322 } else if (code == QDBusError::UnknownInterface) { -
1323 send(msg.createErrorReply(QDBusError::UnknownInterface, -
1324 QString::fromLatin1("No such interface '%1' at object path '%2'") -
1325 .arg(msg.interface(), msg.path()))); -
1326 } else if (code == QDBusError::UnknownObject) { -
1327 send(msg.createErrorReply(QDBusError::UnknownObject, -
1328 QString::fromLatin1("No such object path '%1'").arg(msg.path()))); -
1329 } -
1330} -
1331 -
1332bool QDBusConnectionPrivate::activateInternalFilters(const ObjectTreeNode &node, -
1333 const QDBusMessage &msg) -
1334{ -
1335 // object may be null -
1336 const QString interface = msg.interface(); -
1337 -
1338 if (interface.isEmpty() || interface == QLatin1String(DBUS_INTERFACE_INTROSPECTABLE)) { -
1339 if (msg.member() == QLatin1String("Introspect") && msg.signature().isEmpty()) { -
1340 //qDebug() << "QDBusConnectionPrivate::activateInternalFilters introspect" << msg.d_ptr->msg; -
1341 QDBusMessage reply = msg.createReply(qDBusIntrospectObject(node, msg.path())); -
1342 send(reply); -
1343 return true; -
1344 } -
1345 -
1346 if (!interface.isEmpty()) { -
1347 sendError(msg, QDBusError::UnknownMethod); -
1348 return true; -
1349 } -
1350 } -
1351 -
1352 if (node.obj && (interface.isEmpty() || -
1353 interface == QLatin1String(DBUS_INTERFACE_PROPERTIES))) { -
1354 //qDebug() << "QDBusConnectionPrivate::activateInternalFilters properties" << msg.d_ptr->msg; -
1355 if (msg.member() == QLatin1String("Get") && msg.signature() == QLatin1String("ss")) { -
1356 QDBusMessage reply = qDBusPropertyGet(node, msg); -
1357 send(reply); -
1358 return true; -
1359 } else if (msg.member() == QLatin1String("Set") && msg.signature() == QLatin1String("ssv")) { -
1360 QDBusMessage reply = qDBusPropertySet(node, msg); -
1361 send(reply); -
1362 return true; -
1363 } else if (msg.member() == QLatin1String("GetAll") && msg.signature() == QLatin1String("s")) { -
1364 QDBusMessage reply = qDBusPropertyGetAll(node, msg); -
1365 send(reply); -
1366 return true; -
1367 } -
1368 -
1369 if (!interface.isEmpty()) { -
1370 sendError(msg, QDBusError::UnknownMethod); -
1371 return true; -
1372 } -
1373 } -
1374 -
1375 return false; -
1376} -
1377 -
1378void QDBusConnectionPrivate::activateObject(ObjectTreeNode &node, const QDBusMessage &msg, -
1379 int pathStartPos) -
1380{ -
1381 // This is called by QDBusConnectionPrivate::handleObjectCall to place a call to a slot -
1382 // on the object. -
1383 // -
1384 // The call is routed through the adaptor sub-objects if we have any -
1385 -
1386 // object may be null -
1387 -
1388 if (node.flags & QDBusConnectionPrivate::VirtualObject) { -
1389 if (node.treeNode->handleMessage(msg, q(this))) { -
1390 return; -
1391 } else { -
1392 if (activateInternalFilters(node, msg)) -
1393 return; -
1394 } -
1395 } -
1396 -
1397 if (pathStartPos != msg.path().length()) { -
1398 node.flags &= ~QDBusConnection::ExportAllSignals; -
1399 node.obj = findChildObject(&node, msg.path(), pathStartPos); -
1400 if (!node.obj) { -
1401 sendError(msg, QDBusError::UnknownObject); -
1402 return; -
1403 } -
1404 } -
1405 -
1406 QDBusAdaptorConnector *connector; -
1407 if (node.flags & QDBusConnection::ExportAdaptors && -
1408 (connector = qDBusFindAdaptorConnector(node.obj))) { -
1409 int newflags = node.flags | QDBusConnection::ExportAllSlots; -
1410 -
1411 if (msg.interface().isEmpty()) { -
1412 // place the call in all interfaces -
1413 // let the first one that handles it to work -
1414 QDBusAdaptorConnector::AdaptorMap::ConstIterator it = -
1415 connector->adaptors.constBegin(); -
1416 QDBusAdaptorConnector::AdaptorMap::ConstIterator end = -
1417 connector->adaptors.constEnd(); -
1418 -
1419 for ( ; it != end; ++it) -
1420 if (activateCall(it->adaptor, newflags, msg)) -
1421 return; -
1422 } else { -
1423 // check if we have an interface matching the name that was asked: -
1424 QDBusAdaptorConnector::AdaptorMap::ConstIterator it; -
1425 it = std::lower_bound(connector->adaptors.constBegin(), connector->adaptors.constEnd(), -
1426 msg.interface()); -
1427 if (it != connector->adaptors.constEnd() && msg.interface() == QLatin1String(it->interface)) { -
1428 if (!activateCall(it->adaptor, newflags, msg)) -
1429 sendError(msg, QDBusError::UnknownMethod); -
1430 return; -
1431 } -
1432 } -
1433 } -
1434 -
1435 // no adaptors matched or were exported -
1436 // try our standard filters -
1437 if (activateInternalFilters(node, msg)) -
1438 return; // internal filters have already run or an error has been sent -
1439 -
1440 // try the object itself: -
1441 if (node.flags & (QDBusConnection::ExportScriptableSlots|QDBusConnection::ExportNonScriptableSlots) || -
1442 node.flags & (QDBusConnection::ExportScriptableInvokables|QDBusConnection::ExportNonScriptableInvokables)) { -
1443 bool interfaceFound = true; -
1444 if (!msg.interface().isEmpty()) -
1445 interfaceFound = qDBusInterfaceInObject(node.obj, msg.interface()); -
1446 -
1447 if (interfaceFound) { -
1448 if (!activateCall(node.obj, node.flags, msg)) -
1449 sendError(msg, QDBusError::UnknownMethod); -
1450 return; -
1451 } -
1452 } -
1453 -
1454 // nothing matched, send an error code -
1455 if (msg.interface().isEmpty()) -
1456 sendError(msg, QDBusError::UnknownMethod); -
1457 else -
1458 sendError(msg, QDBusError::UnknownInterface); -
1459} -
1460 -
1461void QDBusConnectionPrivate::handleObjectCall(const QDBusMessage &msg) -
1462{ -
1463 // if the msg is external, we were called from inside doDispatch -
1464 // that means the dispatchLock mutex is locked -
1465 // must not call out to user code in that case -
1466 // -
1467 // however, if the message is internal, handleMessage was called -
1468 // directly and no lock is in place. We can therefore call out to -
1469 // user code, if necessary -
1470 ObjectTreeNode result; -
1471 int usedLength; -
1472 QThread *objThread = 0; -
1473 QSemaphore sem; -
1474 bool semWait; -
1475 -
1476 { -
1477 QDBusReadLocker locker(HandleObjectCallAction, this); -
1478 if (!findObject(&rootNode, msg.path(), usedLength, result)) { -
1479 // qDebug("Call failed: no object found at %s", qPrintable(msg.path())); -
1480 sendError(msg, QDBusError::UnknownObject); -
1481 return; -
1482 } -
1483 -
1484 if (!result.obj) { -
1485 // no object -> no threading issues -
1486 // it's either going to be an error, or an internal filter -
1487 activateObject(result, msg, usedLength); -
1488 return; -
1489 } -
1490 -
1491 objThread = result.obj->thread(); -
1492 if (!objThread) { -
1493 send(msg.createErrorReply(QDBusError::InternalError, -
1494 QString::fromLatin1("Object '%1' (at path '%2')" -
1495 " has no thread. Cannot deliver message.") -
1496 .arg(result.obj->objectName(), msg.path()))); -
1497 return; -
1498 } -
1499 -
1500 if (!QDBusMessagePrivate::isLocal(msg)) { -
1501 // external incoming message -
1502 // post it and forget -
1503 postEventToThread(HandleObjectCallPostEventAction, result.obj, -
1504 new QDBusActivateObjectEvent(QDBusConnection(this), this, result, -
1505 usedLength, msg)); -
1506 return; -
1507 } else if (objThread != QThread::currentThread()) { -
1508 // synchronize with other thread -
1509 postEventToThread(HandleObjectCallPostEventAction, result.obj, -
1510 new QDBusActivateObjectEvent(QDBusConnection(this), this, result, -
1511 usedLength, msg, &sem)); -
1512 semWait = true; -
1513 } else { -
1514 semWait = false; -
1515 } -
1516 } // release the lock -
1517 -
1518 if (semWait) -
1519 SEM_ACQUIRE(HandleObjectCallSemaphoreAction, sem); -
1520 else -
1521 activateObject(result, msg, usedLength); -
1522} -
1523 -
1524QDBusActivateObjectEvent::~QDBusActivateObjectEvent() -
1525{ -
1526 if (!handled) { -
1527 // we're being destroyed without delivering -
1528 // it means the object was deleted between posting and delivering -
1529 QDBusConnectionPrivate *that = QDBusConnectionPrivate::d(connection); -
1530 that->sendError(message, QDBusError::UnknownObject); -
1531 } -
1532 -
1533 // semaphore releasing happens in ~QMetaCallEvent -
1534} -
1535 -
1536void QDBusActivateObjectEvent::placeMetaCall(QObject *) -
1537{ -
1538 QDBusConnectionPrivate *that = QDBusConnectionPrivate::d(connection); -
1539 -
1540 QDBusLockerBase::reportThreadAction(HandleObjectCallPostEventAction, -
1541 QDBusLockerBase::BeforeDeliver, that); -
1542 that->activateObject(node, message, pathStartPos); -
1543 QDBusLockerBase::reportThreadAction(HandleObjectCallPostEventAction, -
1544 QDBusLockerBase::AfterDeliver, that); -
1545 -
1546 handled = true; -
1547} -
1548 -
1549void QDBusConnectionPrivate::handleSignal(const QString &key, const QDBusMessage& msg) -
1550{ -
1551 SignalHookHash::const_iterator it = signalHooks.constFind(key); -
1552 SignalHookHash::const_iterator end = signalHooks.constEnd(); -
1553 //qDebug("looking for: %s", path.toLocal8Bit().constData()); -
1554 //qDBusDebug() << signalHooks.keys(); -
1555 for ( ; it != end && it.key() == key; ++it) { -
1556 const SignalHook &hook = it.value(); -
1557 if (!hook.service.isEmpty()) { -
1558 const QString owner = -
1559 shouldWatchService(hook.service) ? -
1560 watchedServices.value(hook.service).owner : -
1561 hook.service; -
1562 if (owner != msg.service()) -
1563 continue; -
1564 } -
1565 if (!hook.path.isEmpty() && hook.path != msg.path()) -
1566 continue; -
1567 if (!hook.signature.isEmpty() && hook.signature != msg.signature()) -
1568 continue; -
1569 if (hook.signature.isEmpty() && !hook.signature.isNull() && !msg.signature().isEmpty()) -
1570 continue; -
1571 if (!hook.argumentMatch.isEmpty()) { -
1572 const QVariantList arguments = msg.arguments(); -
1573 if (hook.argumentMatch.size() > arguments.size()) -
1574 continue; -
1575 -
1576 bool matched = true; -
1577 for (int i = 0; i < hook.argumentMatch.size(); ++i) { -
1578 const QString &param = hook.argumentMatch.at(i); -
1579 if (param.isNull()) -
1580 continue; // don't try to match against this -
1581 if (param == arguments.at(i).toString()) -
1582 continue; // matched -
1583 matched = false; -
1584 break; -
1585 } -
1586 if (!matched) -
1587 continue; -
1588 } -
1589 -
1590 activateSignal(hook, msg); -
1591 } -
1592} -
1593 -
1594void QDBusConnectionPrivate::handleSignal(const QDBusMessage& msg) -
1595{ -
1596 // We call handlesignal(QString, QDBusMessage) three times: -
1597 // one with member:interface -
1598 // one with member: -
1599 // one with :interface -
1600 // This allows us to match signals with wildcards on member or interface -
1601 // (but not both) -
1602 -
1603 QString key = msg.member(); -
1604 key.reserve(key.length() + 1 + msg.interface().length()); -
1605 key += QLatin1Char(':'); -
1606 key += msg.interface(); -
1607 -
1608 QDBusReadLocker locker(HandleSignalAction, this); -
1609 handleSignal(key, msg); // one try -
1610 -
1611 key.truncate(msg.member().length() + 1); // keep the ':' -
1612 handleSignal(key, msg); // second try -
1613 -
1614 key = QLatin1Char(':'); -
1615 key += msg.interface(); -
1616 handleSignal(key, msg); // third try -
1617} -
1618 -
1619static dbus_int32_t server_slot = -1; -
1620 -
1621void QDBusConnectionPrivate::setServer(DBusServer *s, const QDBusErrorInternal &error) -
1622{ -
1623 if (!s) { -
1624 handleError(error); -
1625 return; -
1626 } -
1627 -
1628 server = s; -
1629 mode = ServerMode; -
1630 -
1631 dbus_bool_t data_allocated = q_dbus_server_allocate_data_slot(&server_slot); -
1632 if (data_allocated && server_slot < 0) -
1633 return; -
1634 -
1635 dbus_bool_t watch_functions_set = q_dbus_server_set_watch_functions(server, -
1636 qDBusAddWatch, -
1637 qDBusRemoveWatch, -
1638 qDBusToggleWatch, -
1639 this, 0); -
1640 //qDebug() << "watch_functions_set" << watch_functions_set; -
1641 Q_UNUSED(watch_functions_set); -
1642 -
1643 dbus_bool_t time_functions_set = q_dbus_server_set_timeout_functions(server, -
1644 qDBusAddTimeout, -
1645 qDBusRemoveTimeout, -
1646 qDBusToggleTimeout, -
1647 this, 0); -
1648 //qDebug() << "time_functions_set" << time_functions_set; -
1649 Q_UNUSED(time_functions_set); -
1650 -
1651 q_dbus_server_set_new_connection_function(server, qDBusNewConnection, this, 0); -
1652 -
1653 dbus_bool_t data_set = q_dbus_server_set_data(server, server_slot, this, 0); -
1654 //qDebug() << "data_set" << data_set; -
1655 Q_UNUSED(data_set); -
1656} -
1657 -
1658void QDBusConnectionPrivate::setPeer(DBusConnection *c, const QDBusErrorInternal &error) -
1659{ -
1660 if (!c) { -
1661 handleError(error); -
1662 return; -
1663 } -
1664 -
1665 connection = c; -
1666 mode = PeerMode; -
1667 -
1668 q_dbus_connection_set_exit_on_disconnect(connection, false); -
1669 q_dbus_connection_set_watch_functions(connection, -
1670 qDBusAddWatch, -
1671 qDBusRemoveWatch, -
1672 qDBusToggleWatch, -
1673 this, 0); -
1674 q_dbus_connection_set_timeout_functions(connection, -
1675 qDBusAddTimeout, -
1676 qDBusRemoveTimeout, -
1677 qDBusToggleTimeout, -
1678 this, 0); -
1679 q_dbus_connection_set_dispatch_status_function(connection, qDBusUpdateDispatchStatus, this, 0); -
1680 q_dbus_connection_add_filter(connection, -
1681 qDBusSignalFilter, -
1682 this, 0); -
1683 -
1684 QMetaObject::invokeMethod(this, "doDispatch", Qt::QueuedConnection); -
1685} -
1686 -
1687static QDBusConnection::ConnectionCapabilities connectionCapabilies(DBusConnection *connection) -
1688{ -
1689 QDBusConnection::ConnectionCapabilities result = 0; -
1690 typedef dbus_bool_t (*can_send_type_t)(DBusConnection *, int); -
1691 static can_send_type_t can_send_type = 0; -
1692 -
1693#if defined(QT_LINKED_LIBDBUS) -
1694# if DBUS_VERSION-0 >= 0x010400 -
1695 can_send_type = dbus_connection_can_send_type; -
1696# endif -
1697#else -
1698 // run-time check if the next functions are available -
1699 can_send_type = (can_send_type_t)qdbus_resolve_conditionally("dbus_connection_can_send_type"); -
1700#endif -
1701 -
1702#ifndef DBUS_TYPE_UNIX_FD -
1703# define DBUS_TYPE_UNIX_FD int('h') -
1704#endif -
1705 if (can_send_type && can_send_type(connection, DBUS_TYPE_UNIX_FD)) -
1706 result |= QDBusConnection::UnixFileDescriptorPassing; -
1707 -
1708 return result; -
1709} -
1710 -
1711void QDBusConnectionPrivate::setConnection(DBusConnection *dbc, const QDBusErrorInternal &error) -
1712{ -
1713 if (!dbc) { -
1714 handleError(error); -
1715 return; -
1716 } -
1717 -
1718 connection = dbc; -
1719 mode = ClientMode; -
1720 -
1721 const char *service = q_dbus_bus_get_unique_name(connection); -
1722 Q_ASSERT(service); -
1723 baseService = QString::fromUtf8(service); -
1724 capabilities = connectionCapabilies(connection); -
1725 -
1726 q_dbus_connection_set_exit_on_disconnect(connection, false); -
1727 q_dbus_connection_set_watch_functions(connection, qDBusAddWatch, qDBusRemoveWatch, -
1728 qDBusToggleWatch, this, 0); -
1729 q_dbus_connection_set_timeout_functions(connection, qDBusAddTimeout, qDBusRemoveTimeout, -
1730 qDBusToggleTimeout, this, 0); -
1731 q_dbus_connection_set_dispatch_status_function(connection, qDBusUpdateDispatchStatus, this, 0); -
1732 q_dbus_connection_add_filter(connection, qDBusSignalFilter, this, 0); -
1733 -
1734 // Initialize the hooks for the NameAcquired and NameLost signals -
1735 // we don't use connectSignal here because we don't need the rules to be sent to the bus -
1736 // the bus will always send us these two signals -
1737 SignalHook hook; -
1738 hook.service = dbusServiceString(); -
1739 hook.path.clear(); // no matching -
1740 hook.obj = this; -
1741 hook.params << QMetaType::Void << QVariant::String; // both functions take a QString as parameter and return void -
1742 -
1743 hook.midx = staticMetaObject.indexOfSlot("registerServiceNoLock(QString)"); -
1744 Q_ASSERT(hook.midx != -1); -
1745 signalHooks.insert(QLatin1String("NameAcquired:" DBUS_INTERFACE_DBUS), hook); -
1746 -
1747 hook.midx = staticMetaObject.indexOfSlot("unregisterServiceNoLock(QString)"); -
1748 Q_ASSERT(hook.midx != -1); -
1749 signalHooks.insert(QLatin1String("NameLost:" DBUS_INTERFACE_DBUS), hook); -
1750 -
1751 qDBusDebug() << this << ": connected successfully"; -
1752 -
1753 // schedule a dispatch: -
1754 QMetaObject::invokeMethod(this, "doDispatch", Qt::QueuedConnection); -
1755} -
1756 -
1757extern "C"{ -
1758static void qDBusResultReceived(DBusPendingCall *pending, void *user_data) -
1759{ -
1760 QDBusPendingCallPrivate *call = reinterpret_cast<QDBusPendingCallPrivate *>(user_data); -
1761 Q_ASSERT(call->pending == pending); -
1762 Q_UNUSED(pending); -
1763 QDBusConnectionPrivate::processFinishedCall(call); -
1764} -
1765} -
1766 -
1767void QDBusConnectionPrivate::waitForFinished(QDBusPendingCallPrivate *pcall) -
1768{ -
1769 Q_ASSERT(pcall->pending); -
1770 Q_ASSERT(!pcall->autoDelete); -
1771 //Q_ASSERT(pcall->mutex.isLocked()); // there's no such function -
1772 -
1773 if (pcall->waitingForFinished) { -
1774 // another thread is already waiting -
1775 pcall->waitForFinishedCondition.wait(&pcall->mutex); -
1776 } else { -
1777 pcall->waitingForFinished = true; -
1778 pcall->mutex.unlock(); -
1779 -
1780 { -
1781 QDBusDispatchLocker locker(PendingCallBlockAction, this); -
1782 q_dbus_pending_call_block(pcall->pending); -
1783 // QDBusConnectionPrivate::processFinishedCall() is called automatically -
1784 } -
1785 pcall->mutex.lock(); -
1786 pcall->waitForFinishedCondition.wakeAll(); -
1787 } -
1788} -
1789 -
1790static inline bool waitingForFinishedIsSet(QDBusPendingCallPrivate *call) -
1791{ -
1792 const QMutexLocker locker(&call->mutex); -
1793 return call->waitingForFinished; -
1794} -
1795 -
1796void QDBusConnectionPrivate::processFinishedCall(QDBusPendingCallPrivate *call) -
1797{ -
1798 QDBusConnectionPrivate *connection = const_cast<QDBusConnectionPrivate *>(call->connection); -
1799 -
1800 QMutexLocker locker(&call->mutex); -
1801 -
1802 QDBusMessage &msg = call->replyMessage; -
1803 if (call->pending) { -
1804 // decode the message -
1805 DBusMessage *reply = q_dbus_pending_call_steal_reply(call->pending); -
1806 msg = QDBusMessagePrivate::fromDBusMessage(reply, connection->capabilities); -
1807 q_dbus_message_unref(reply); -
1808 } -
1809 qDBusDebug() << connection << "got message reply (async):" << msg; -
1810 -
1811 // Check if the reply has the expected signature -
1812 call->checkReceivedSignature(); -
1813 -
1814 if (!call->receiver.isNull() && call->methodIdx != -1 && msg.type() == QDBusMessage::ReplyMessage) { -
1815 // Deliver the return values of a remote function call. -
1816 // -
1817 // There is only one connection and it is specified by idx -
1818 // The slot must have the same parameter types that the message does -
1819 // The slot may have less parameters than the message -
1820 // The slot may optionally have one final parameter that is QDBusMessage -
1821 // The slot receives read-only copies of the message (i.e., pass by value or by const-ref) -
1822 -
1823 QDBusCallDeliveryEvent *e = prepareReply(connection, call->receiver, call->methodIdx, -
1824 call->metaTypes, msg); -
1825 if (e) -
1826 connection->postEventToThread(MessageResultReceivedAction, call->receiver, e); -
1827 else -
1828 qDBusDebug() << "Deliver failed!"; -
1829 } -
1830 -
1831 if (call->pending) -
1832 q_dbus_pending_call_unref(call->pending); -
1833 call->pending = 0; -
1834 -
1835 locker.unlock(); -
1836 -
1837 // Are there any watchers? -
1838 if (call->watcherHelper) -
1839 call->watcherHelper->emitSignals(msg, call->sentMessage); -
1840 -
1841 if (msg.type() == QDBusMessage::ErrorMessage) -
1842 emit connection->callWithCallbackFailed(QDBusError(msg), call->sentMessage); -
1843 -
1844 if (call->autoDelete) { -
1845 Q_ASSERT(!waitingForFinishedIsSet(call)); // can't wait on a call with autoDelete! -
1846 delete call; -
1847 } -
1848} -
1849 -
1850int QDBusConnectionPrivate::send(const QDBusMessage& message) -
1851{ -
1852 if (QDBusMessagePrivate::isLocal(message)) -
1853 return -1; // don't send; the reply will be retrieved by the caller -
1854 // through the d_ptr->localReply link -
1855 -
1856 QDBusError error; -
1857 DBusMessage *msg = QDBusMessagePrivate::toDBusMessage(message, capabilities, &error); -
1858 if (!msg) { -
1859 if (message.type() == QDBusMessage::MethodCallMessage) -
1860 qWarning("QDBusConnection: error: could not send message to service \"%s\" path \"%s\" interface \"%s\" member \"%s\": %s", -
1861 qPrintable(message.service()), qPrintable(message.path()), -
1862 qPrintable(message.interface()), qPrintable(message.member()), -
1863 qPrintable(error.message())); -
1864 else if (message.type() == QDBusMessage::SignalMessage) -
1865 qWarning("QDBusConnection: error: could not send signal path \"%s\" interface \"%s\" member \"%s\": %s", -
1866 qPrintable(message.path()), qPrintable(message.interface()), -
1867 qPrintable(message.member()), -
1868 qPrintable(error.message())); -
1869 else -
1870 qWarning("QDBusConnection: error: could not send %s message to service \"%s\": %s", -
1871 message.type() == QDBusMessage::ReplyMessage ? "reply" : -
1872 message.type() == QDBusMessage::ErrorMessage ? "error" : -
1873 "invalid", qPrintable(message.service()), -
1874 qPrintable(error.message())); -
1875 lastError = error; -
1876 return 0; -
1877 } -
1878 -
1879 q_dbus_message_set_no_reply(msg, true); // the reply would not be delivered to anything -
1880 -
1881 qDBusDebug() << this << "sending message (no reply):" << message; -
1882 checkThread(); -
1883 bool isOk = q_dbus_connection_send(connection, msg, 0); -
1884 int serial = 0; -
1885 if (isOk) -
1886 serial = q_dbus_message_get_serial(msg); -
1887 -
1888 q_dbus_message_unref(msg); -
1889 return serial; -
1890} -
1891 -
1892QDBusMessage QDBusConnectionPrivate::sendWithReply(const QDBusMessage &message, -
1893 int sendMode, int timeout) -
1894{ -
1895 checkThread(); -
1896 if ((sendMode == QDBus::BlockWithGui || sendMode == QDBus::Block) -
1897 && isServiceRegisteredByThread(message.service())) -
1898 // special case for synchronous local calls -
1899 return sendWithReplyLocal(message); -
1900 -
1901 if (!QCoreApplication::instance() || sendMode == QDBus::Block) { -
1902 QDBusError err; -
1903 DBusMessage *msg = QDBusMessagePrivate::toDBusMessage(message, capabilities, &err); -
1904 if (!msg) { -
1905 qWarning("QDBusConnection: error: could not send message to service \"%s\" path \"%s\" interface \"%s\" member \"%s\": %s", -
1906 qPrintable(message.service()), qPrintable(message.path()), -
1907 qPrintable(message.interface()), qPrintable(message.member()), -
1908 qPrintable(err.message())); -
1909 lastError = err; -
1910 return QDBusMessage::createError(err); -
1911 } -
1912 -
1913 qDBusDebug() << this << "sending message (blocking):" << message; -
1914 QDBusErrorInternal error; -
1915 DBusMessage *reply = q_dbus_connection_send_with_reply_and_block(connection, msg, timeout, error); -
1916 -
1917 q_dbus_message_unref(msg); -
1918 -
1919 if (!!error) { -
1920 lastError = err = error; -
1921 return QDBusMessage::createError(err); -
1922 } -
1923 -
1924 QDBusMessage amsg = QDBusMessagePrivate::fromDBusMessage(reply, capabilities); -
1925 q_dbus_message_unref(reply); -
1926 qDBusDebug() << this << "got message reply (blocking):" << amsg; -
1927 -
1928 return amsg; -
1929 } else { // use the event loop -
1930 QDBusPendingCallPrivate *pcall = sendWithReplyAsync(message, timeout); -
1931 Q_ASSERT(pcall); -
1932 -
1933 if (pcall->replyMessage.type() == QDBusMessage::InvalidMessage) { -
1934 pcall->watcherHelper = new QDBusPendingCallWatcherHelper; -
1935 QEventLoop loop; -
1936 loop.connect(pcall->watcherHelper, SIGNAL(reply(QDBusMessage)), SLOT(quit())); -
1937 loop.connect(pcall->watcherHelper, SIGNAL(error(QDBusError,QDBusMessage)), SLOT(quit())); -
1938 -
1939 // enter the event loop and wait for a reply -
1940 loop.exec(QEventLoop::ExcludeUserInputEvents | QEventLoop::WaitForMoreEvents); -
1941 } -
1942 -
1943 QDBusMessage reply = pcall->replyMessage; -
1944 lastError = QDBusError(reply); // set or clear error -
1945 -
1946 delete pcall; -
1947 return reply; -
1948 } -
1949} -
1950 -
1951QDBusMessage QDBusConnectionPrivate::sendWithReplyLocal(const QDBusMessage &message) -
1952{ -
1953 qDBusDebug() << this << "sending message via local-loop:" << message; -
1954 -
1955 QDBusMessage localCallMsg = QDBusMessagePrivate::makeLocal(*this, message); -
1956 bool handled = handleMessage(localCallMsg); -
1957 -
1958 if (!handled) { -
1959 QString interface = message.interface(); -
1960 if (interface.isEmpty()) -
1961 interface = QLatin1String("<no-interface>"); -
1962 return QDBusMessage::createError(QDBusError::InternalError, -
1963 QString::fromLatin1("Internal error trying to call %1.%2 at %3 (signature '%4'") -
1964 .arg(interface, message.member(), -
1965 message.path(), message.signature())); -
1966 } -
1967 -
1968 // if the message was handled, there might be a reply -
1969 QDBusMessage localReplyMsg = QDBusMessagePrivate::makeLocalReply(*this, localCallMsg); -
1970 if (localReplyMsg.type() == QDBusMessage::InvalidMessage) { -
1971 qWarning("QDBusConnection: cannot call local method '%s' at object %s (with signature '%s') " -
1972 "on blocking mode", qPrintable(message.member()), qPrintable(message.path()), -
1973 qPrintable(message.signature())); -
1974 return QDBusMessage::createError( -
1975 QDBusError(QDBusError::InternalError, -
1976 QLatin1String("local-loop message cannot have delayed replies"))); -
1977 } -
1978 -
1979 // there is a reply -
1980 qDBusDebug() << this << "got message via local-loop:" << localReplyMsg; -
1981 return localReplyMsg; -
1982} -
1983 -
1984QDBusPendingCallPrivate *QDBusConnectionPrivate::sendWithReplyAsync(const QDBusMessage &message, -
1985 int timeout) -
1986{ -
1987 if (isServiceRegisteredByThread(message.service())) { -
1988 // special case for local calls -
1989 QDBusPendingCallPrivate *pcall = new QDBusPendingCallPrivate(message, this); -
1990 pcall->replyMessage = sendWithReplyLocal(message); -
1991 -
1992 return pcall; -
1993 } -
1994 -
1995 checkThread(); -
1996 QDBusPendingCallPrivate *pcall = new QDBusPendingCallPrivate(message, this); -
1997 pcall->ref.store(0); -
1998 -
1999 QDBusError error; -
2000 DBusMessage *msg = QDBusMessagePrivate::toDBusMessage(message, capabilities, &error); -
2001 if (!msg) { -
2002 qWarning("QDBusConnection: error: could not send message to service \"%s\" path \"%s\" interface \"%s\" member \"%s\": %s", -
2003 qPrintable(message.service()), qPrintable(message.path()), -
2004 qPrintable(message.interface()), qPrintable(message.member()), -
2005 qPrintable(error.message())); -
2006 pcall->replyMessage = QDBusMessage::createError(error); -
2007 lastError = error; -
2008 return pcall; -
2009 } -
2010 -
2011 qDBusDebug() << this << "sending message (async):" << message; -
2012 DBusPendingCall *pending = 0; -
2013 -
2014 QDBusDispatchLocker locker(SendWithReplyAsyncAction, this); -
2015 if (q_dbus_connection_send_with_reply(connection, msg, &pending, timeout)) { -
2016 if (pending) { -
2017 q_dbus_message_unref(msg); -
2018 -
2019 pcall->pending = pending; -
2020 q_dbus_pending_call_set_notify(pending, qDBusResultReceived, pcall, 0); -
2021 -
2022 return pcall; -
2023 } else { -
2024 // we're probably disconnected at this point -
2025 lastError = error = QDBusError(QDBusError::Disconnected, QLatin1String("Not connected to server")); -
2026 } -
2027 } else { -
2028 lastError = error = QDBusError(QDBusError::NoMemory, QLatin1String("Out of memory")); -
2029 } -
2030 -
2031 q_dbus_message_unref(msg); -
2032 pcall->replyMessage = QDBusMessage::createError(error); -
2033 return pcall; -
2034} -
2035 -
2036int QDBusConnectionPrivate::sendWithReplyAsync(const QDBusMessage &message, QObject *receiver, -
2037 const char *returnMethod, const char *errorMethod, -
2038 int timeout) -
2039{ -
2040 QDBusPendingCallPrivate *pcall = sendWithReplyAsync(message, timeout); -
2041 Q_ASSERT(pcall); -
2042 -
2043 // has it already finished with success (dispatched locally)? -
2044 if (pcall->replyMessage.type() == QDBusMessage::ReplyMessage) { -
2045 pcall->setReplyCallback(receiver, returnMethod); -
2046 processFinishedCall(pcall); -
2047 delete pcall; -
2048 return 1; -
2049 } -
2050 -
2051 // either it hasn't finished or it has finished with error -
2052 if (errorMethod) { -
2053 pcall->watcherHelper = new QDBusPendingCallWatcherHelper; -
2054 connect(pcall->watcherHelper, SIGNAL(error(QDBusError,QDBusMessage)), receiver, errorMethod, -
2055 Qt::QueuedConnection); -
2056 pcall->watcherHelper->moveToThread(thread()); -
2057 } -
2058 -
2059 // has it already finished and is an error reply message? -
2060 if (pcall->replyMessage.type() == QDBusMessage::ErrorMessage) { -
2061 processFinishedCall(pcall); -
2062 delete pcall; -
2063 return 1; -
2064 } -
2065 -
2066 pcall->autoDelete = true; -
2067 pcall->ref.ref(); -
2068 pcall->setReplyCallback(receiver, returnMethod); -
2069 -
2070 return 1; -
2071} -
2072 -
2073bool QDBusConnectionPrivate::connectSignal(const QString &service, -
2074 const QString &path, const QString &interface, const QString &name, -
2075 const QStringList &argumentMatch, const QString &signature, -
2076 QObject *receiver, const char *slot) -
2077{ -
2078 // check the slot -
2079 QDBusConnectionPrivate::SignalHook hook; -
2080 QString key; -
2081 QString name2 = name; -
2082 if (name2.isNull()) -
2083 name2.detach(); -
2084 -
2085 hook.signature = signature; -
2086 if (!prepareHook(hook, key, service, path, interface, name, argumentMatch, receiver, slot, 0, false)) -
2087 return false; // don't connect -
2088 -
2089 // avoid duplicating: -
2090 QDBusConnectionPrivate::SignalHookHash::ConstIterator it = signalHooks.constFind(key); -
2091 QDBusConnectionPrivate::SignalHookHash::ConstIterator end = signalHooks.constEnd(); -
2092 for ( ; it != end && it.key() == key; ++it) { -
2093 const QDBusConnectionPrivate::SignalHook &entry = it.value(); -
2094 if (entry.service == hook.service && -
2095 entry.path == hook.path && -
2096 entry.signature == hook.signature && -
2097 entry.obj == hook.obj && -
2098 entry.midx == hook.midx && -
2099 entry.argumentMatch == hook.argumentMatch) { -
2100 // no need to compare the parameters if it's the same slot -
2101 return true; // already there -
2102 } -
2103 } -
2104 -
2105 connectSignal(key, hook); -
2106 return true; -
2107} -
2108 -
2109void QDBusConnectionPrivate::connectSignal(const QString &key, const SignalHook &hook) -
2110{ -
2111 signalHooks.insertMulti(key, hook); -
2112 connect(hook.obj, SIGNAL(destroyed(QObject*)), SLOT(objectDestroyed(QObject*)), -
2113 Qt::ConnectionType(Qt::DirectConnection | Qt::UniqueConnection)); -
2114 -
2115 MatchRefCountHash::iterator it = matchRefCounts.find(hook.matchRule); -
2116 -
2117 if (it != matchRefCounts.end()) { // Match already present -
2118 it.value() = it.value() + 1; -
2119 return; -
2120 } -
2121 -
2122 matchRefCounts.insert(hook.matchRule, 1); -
2123 -
2124 if (connection) { -
2125 if (mode != QDBusConnectionPrivate::PeerMode) { -
2126 qDBusDebug("Adding rule: %s", hook.matchRule.constData()); -
2127 q_dbus_bus_add_match(connection, hook.matchRule, NULL); -
2128 -
2129 // Successfully connected the signal -
2130 // Do we need to watch for this name? -
2131 if (shouldWatchService(hook.service)) { -
2132 WatchedServicesHash::mapped_type &data = watchedServices[hook.service]; -
2133 if (++data.refcount == 1) { -
2134 // we need to watch for this service changing -
2135 connectSignal(dbusServiceString(), QString(), dbusInterfaceString(), -
2136 QLatin1String("NameOwnerChanged"), QStringList() << hook.service, QString(), -
2137 this, SLOT(serviceOwnerChangedNoLock(QString,QString,QString))); -
2138 data.owner = getNameOwnerNoCache(hook.service); -
2139 qDBusDebug() << this << "Watching service" << hook.service << "for owner changes (current owner:" -
2140 << data.owner << ")"; -
2141 } -
2142 } -
2143 } -
2144 } -
2145} -
2146 -
2147bool QDBusConnectionPrivate::disconnectSignal(const QString &service, -
2148 const QString &path, const QString &interface, const QString &name, -
2149 const QStringList &argumentMatch, const QString &signature, -
2150 QObject *receiver, const char *slot) -
2151{ -
2152 // check the slot -
2153 QDBusConnectionPrivate::SignalHook hook; -
2154 QString key; -
2155 QString name2 = name; -
2156 if (name2.isNull()) -
2157 name2.detach(); -
2158 -
2159 hook.signature = signature; -
2160 if (!prepareHook(hook, key, service, path, interface, name, argumentMatch, receiver, slot, 0, false)) -
2161 return false; // don't disconnect -
2162 -
2163 // avoid duplicating: -
2164 QDBusConnectionPrivate::SignalHookHash::Iterator it = signalHooks.find(key); -
2165 QDBusConnectionPrivate::SignalHookHash::Iterator end = signalHooks.end(); -
2166 for ( ; it != end && it.key() == key; ++it) { -
2167 const QDBusConnectionPrivate::SignalHook &entry = it.value(); -
2168 if (entry.service == hook.service && -
2169 entry.path == hook.path && -
2170 entry.signature == hook.signature && -
2171 entry.obj == hook.obj && -
2172 entry.midx == hook.midx && -
2173 entry.argumentMatch == hook.argumentMatch) { -
2174 // no need to compare the parameters if it's the same slot -
2175 disconnectSignal(it); -
2176 return true; // it was there -
2177 } -
2178 } -
2179 -
2180 // the slot was not found -
2181 return false; -
2182} -
2183 -
2184QDBusConnectionPrivate::SignalHookHash::Iterator -
2185QDBusConnectionPrivate::disconnectSignal(SignalHookHash::Iterator &it) -
2186{ -
2187 const SignalHook &hook = it.value(); -
2188 -
2189 bool erase = false; -
2190 MatchRefCountHash::iterator i = matchRefCounts.find(hook.matchRule); -
2191 if (i == matchRefCounts.end()) { -
2192 qWarning("QDBusConnectionPrivate::disconnectSignal: MatchRule not found in matchRefCounts!!"); -
2193 } else { -
2194 if (i.value() == 1) { -
2195 erase = true; -
2196 matchRefCounts.erase(i); -
2197 } -
2198 else { -
2199 i.value() = i.value() - 1; -
2200 } -
2201 } -
2202 -
2203 // we don't care about errors here -
2204 if (connection && erase) { -
2205 if (mode != QDBusConnectionPrivate::PeerMode) { -
2206 qDBusDebug("Removing rule: %s", hook.matchRule.constData()); -
2207 q_dbus_bus_remove_match(connection, hook.matchRule, NULL); -
2208 -
2209 // Successfully disconnected the signal -
2210 // Were we watching for this name? -
2211 WatchedServicesHash::Iterator sit = watchedServices.find(hook.service); -
2212 if (sit != watchedServices.end()) { -
2213 if (--sit.value().refcount == 0) { -
2214 watchedServices.erase(sit); -
2215 disconnectSignal(dbusServiceString(), QString(), dbusInterfaceString(), -
2216 QLatin1String("NameOwnerChanged"), QStringList() << hook.service, QString(), -
2217 this, SLOT(_q_serviceOwnerChanged(QString,QString,QString))); -
2218 } -
2219 } -
2220 } -
2221 -
2222 } -
2223 -
2224 return signalHooks.erase(it); -
2225} -
2226 -
2227void QDBusConnectionPrivate::registerObject(const ObjectTreeNode *node) -
2228{ -
2229 connect(node->obj, SIGNAL(destroyed(QObject*)), SLOT(objectDestroyed(QObject*)), -
2230 Qt::DirectConnection); -
2231 -
2232 if (node->flags & (QDBusConnection::ExportAdaptors -
2233 | QDBusConnection::ExportScriptableSignals -
2234 | QDBusConnection::ExportNonScriptableSignals)) { -
2235 QDBusAdaptorConnector *connector = qDBusCreateAdaptorConnector(node->obj); -
2236 -
2237 if (node->flags & (QDBusConnection::ExportScriptableSignals -
2238 | QDBusConnection::ExportNonScriptableSignals)) { -
2239 connector->disconnectAllSignals(node->obj); -
2240 connector->connectAllSignals(node->obj); -
2241 } -
2242 -
2243 // disconnect and reconnect to avoid duplicates -
2244 connector->disconnect(SIGNAL(relaySignal(QObject*,const QMetaObject*,int,QVariantList)), -
2245 this, SLOT(relaySignal(QObject*,const QMetaObject*,int,QVariantList))); -
2246 connect(connector, SIGNAL(relaySignal(QObject*,const QMetaObject*,int,QVariantList)), -
2247 this, SLOT(relaySignal(QObject*,const QMetaObject*,int,QVariantList)), -
2248 Qt::DirectConnection); -
2249 } -
2250} -
2251 -
2252void QDBusConnectionPrivate::connectRelay(const QString &service, -
2253 const QString &path, const QString &interface, -
2254 QDBusAbstractInterface *receiver, -
2255 const QMetaMethod &signal) -
2256{ -
2257 // this function is called by QDBusAbstractInterface when one of its signals is connected -
2258 // we set up a relay from D-Bus into it -
2259 SignalHook hook; -
2260 QString key; -
2261 -
2262 QByteArray sig; -
2263 sig.append(QSIGNAL_CODE + '0'); -
2264 sig.append(signal.methodSignature()); -
2265 if (!prepareHook(hook, key, service, path, interface, QString(), QStringList(), receiver, sig, -
2266 QDBusAbstractInterface::staticMetaObject.methodCount(), true)) -
2267 return; // don't connect -
2268 -
2269 // add it to our list: -
2270 QDBusWriteLocker locker(ConnectRelayAction, this); -
2271 SignalHookHash::ConstIterator it = signalHooks.constFind(key); -
2272 SignalHookHash::ConstIterator end = signalHooks.constEnd(); -
2273 for ( ; it != end && it.key() == key; ++it) { -
2274 const SignalHook &entry = it.value(); -
2275 if (entry.service == hook.service && -
2276 entry.path == hook.path && -
2277 entry.signature == hook.signature && -
2278 entry.obj == hook.obj && -
2279 entry.midx == hook.midx) -
2280 return; // already there, no need to re-add -
2281 } -
2282 -
2283 connectSignal(key, hook); -
2284} -
2285 -
2286void QDBusConnectionPrivate::disconnectRelay(const QString &service, -
2287 const QString &path, const QString &interface, -
2288 QDBusAbstractInterface *receiver, -
2289 const QMetaMethod &signal) -
2290{ -
2291 // this function is called by QDBusAbstractInterface when one of its signals is disconnected -
2292 // we remove relay from D-Bus into it -
2293 SignalHook hook; -
2294 QString key; -
2295 -
2296 QByteArray sig; -
2297 sig.append(QSIGNAL_CODE + '0'); -
2298 sig.append(signal.methodSignature()); -
2299 if (!prepareHook(hook, key, service, path, interface, QString(), QStringList(), receiver, sig, -
2300 QDBusAbstractInterface::staticMetaObject.methodCount(), true)) -
2301 return; // don't connect -
2302 -
2303 // remove it from our list: -
2304 QDBusWriteLocker locker(DisconnectRelayAction, this); -
2305 SignalHookHash::Iterator it = signalHooks.find(key); -
2306 SignalHookHash::Iterator end = signalHooks.end(); -
2307 for ( ; it != end && it.key() == key; ++it) { -
2308 const SignalHook &entry = it.value(); -
2309 if (entry.service == hook.service && -
2310 entry.path == hook.path && -
2311 entry.signature == hook.signature && -
2312 entry.obj == hook.obj && -
2313 entry.midx == hook.midx) { -
2314 // found it -
2315 disconnectSignal(it); -
2316 return; -
2317 } -
2318 } -
2319 -
2320 qWarning("QDBusConnectionPrivate::disconnectRelay called for a signal that was not found"); -
2321} -
2322 -
2323QString QDBusConnectionPrivate::getNameOwner(const QString& serviceName) -
2324{ -
2325 if (QDBusUtil::isValidUniqueConnectionName(serviceName)) -
2326 return serviceName; -
2327 if (!connection) -
2328 return QString(); -
2329 -
2330 { -
2331 // acquire a read lock for the cache -
2332 QReadLocker locker(&lock); -
2333 WatchedServicesHash::ConstIterator it = watchedServices.constFind(serviceName); -
2334 if (it != watchedServices.constEnd()) -
2335 return it->owner; -
2336 } -
2337 -
2338 // not cached -
2339 return getNameOwnerNoCache(serviceName); -
2340} -
2341 -
2342QString QDBusConnectionPrivate::getNameOwnerNoCache(const QString &serviceName) -
2343{ -
2344 QDBusMessage msg = QDBusMessage::createMethodCall(dbusServiceString(), -
2345 QLatin1String(DBUS_PATH_DBUS), dbusInterfaceString(), -
2346 QLatin1String("GetNameOwner")); -
2347 QDBusMessagePrivate::setParametersValidated(msg, true); -
2348 msg << serviceName; -
2349 QDBusMessage reply = sendWithReply(msg, QDBus::Block); -
2350 if (reply.type() == QDBusMessage::ReplyMessage) -
2351 return reply.arguments().at(0).toString(); -
2352 return QString(); -
2353} -
2354 -
2355QDBusMetaObject * -
2356QDBusConnectionPrivate::findMetaObject(const QString &service, const QString &path, -
2357 const QString &interface, QDBusError &error) -
2358{ -
2359 // service must be a unique connection name -
2360 if (!interface.isEmpty()) { -
2361 QDBusReadLocker locker(FindMetaObject1Action, this); -
2362 QDBusMetaObject *mo = cachedMetaObjects.value(interface, 0); -
2363 if (mo) -
2364 return mo; -
2365 } -
2366 -
2367 // introspect the target object -
2368 QDBusMessage msg = QDBusMessage::createMethodCall(service, path, -
2369 QLatin1String(DBUS_INTERFACE_INTROSPECTABLE), -
2370 QLatin1String("Introspect")); -
2371 QDBusMessagePrivate::setParametersValidated(msg, true); -
2372 -
2373 QDBusMessage reply = sendWithReply(msg, QDBus::Block); -
2374 -
2375 // it doesn't exist yet, we have to create it -
2376 QDBusWriteLocker locker(FindMetaObject2Action, this); -
2377 QDBusMetaObject *mo = 0; -
2378 if (!interface.isEmpty()) -
2379 mo = cachedMetaObjects.value(interface, 0); -
2380 if (mo) -
2381 // maybe it got created when we switched from read to write lock -
2382 return mo; -
2383 -
2384 QString xml; -
2385 if (reply.type() == QDBusMessage::ReplyMessage) { -
2386 if (reply.signature() == QLatin1String("s")) -
2387 // fetch the XML description -
2388 xml = reply.arguments().at(0).toString(); -
2389 } else { -
2390 error = QDBusError(reply); -
2391 lastError = error; -
2392 if (reply.type() != QDBusMessage::ErrorMessage || error.type() != QDBusError::UnknownMethod) -
2393 return 0; // error -
2394 } -
2395 -
2396 // release the lock and return -
2397 QDBusMetaObject *result = QDBusMetaObject::createMetaObject(interface, xml, -
2398 cachedMetaObjects, error); -
2399 lastError = error; -
2400 return result; -
2401} -
2402 -
2403void QDBusConnectionPrivate::registerService(const QString &serviceName) -
2404{ -
2405 QDBusWriteLocker locker(RegisterServiceAction, this); -
2406 registerServiceNoLock(serviceName); -
2407} -
2408 -
2409void QDBusConnectionPrivate::registerServiceNoLock(const QString &serviceName) -
2410{ -
2411 serviceNames.append(serviceName); -
2412} -
2413 -
2414void QDBusConnectionPrivate::unregisterService(const QString &serviceName) -
2415{ -
2416 QDBusWriteLocker locker(UnregisterServiceAction, this); -
2417 unregisterServiceNoLock(serviceName); -
2418} -
2419 -
2420void QDBusConnectionPrivate::unregisterServiceNoLock(const QString &serviceName) -
2421{ -
2422 serviceNames.removeAll(serviceName); -
2423} -
2424 -
2425bool QDBusConnectionPrivate::isServiceRegisteredByThread(const QString &serviceName) const -
2426{ -
2427 if (!serviceName.isEmpty() && serviceName == baseService) -
2428 return true; -
2429 QStringList copy = serviceNames; -
2430 return copy.contains(serviceName); -
2431} -
2432 -
2433void QDBusConnectionPrivate::postEventToThread(int action, QObject *object, QEvent *ev) -
2434{ -
2435 QDBusLockerBase::reportThreadAction(action, QDBusLockerBase::BeforePost, this); -
2436 QCoreApplication::postEvent(object, ev); -
2437 QDBusLockerBase::reportThreadAction(action, QDBusLockerBase::AfterPost, this); -
2438} -
2439 -
2440QT_END_NAMESPACE -
2441 -
2442#endif // QT_NO_DBUS -
2443 -
Source codeSwitch to Preprocessed file
Generated by Squish Coco Non-Commercial