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