Absolute File Name: | /home/qt/qt5_coco/qt5/qtbase/src/corelib/thread/qthread_unix.cpp |
Source code | Switch to Preprocessed file |
Line | Source | Count | ||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
1 | /**************************************************************************** | - | ||||||||||||||||||
2 | ** | - | ||||||||||||||||||
3 | ** Copyright (C) 2016 The Qt Company Ltd. | - | ||||||||||||||||||
4 | ** Copyright (C) 2016 Intel Corporation. | - | ||||||||||||||||||
5 | ** Contact: https://www.qt.io/licensing/ | - | ||||||||||||||||||
6 | ** | - | ||||||||||||||||||
7 | ** This file is part of the QtCore module of the Qt Toolkit. | - | ||||||||||||||||||
8 | ** | - | ||||||||||||||||||
9 | ** $QT_BEGIN_LICENSE:LGPL$ | - | ||||||||||||||||||
10 | ** Commercial License Usage | - | ||||||||||||||||||
11 | ** Licensees holding valid commercial Qt licenses may use this file in | - | ||||||||||||||||||
12 | ** accordance with the commercial license agreement provided with the | - | ||||||||||||||||||
13 | ** Software or, alternatively, in accordance with the terms contained in | - | ||||||||||||||||||
14 | ** a written agreement between you and The Qt Company. For licensing terms | - | ||||||||||||||||||
15 | ** and conditions see https://www.qt.io/terms-conditions. For further | - | ||||||||||||||||||
16 | ** information use the contact form at https://www.qt.io/contact-us. | - | ||||||||||||||||||
17 | ** | - | ||||||||||||||||||
18 | ** GNU Lesser General Public License Usage | - | ||||||||||||||||||
19 | ** Alternatively, this file may be used under the terms of the GNU Lesser | - | ||||||||||||||||||
20 | ** General Public License version 3 as published by the Free Software | - | ||||||||||||||||||
21 | ** Foundation and appearing in the file LICENSE.LGPL3 included in the | - | ||||||||||||||||||
22 | ** packaging of this file. Please review the following information to | - | ||||||||||||||||||
23 | ** ensure the GNU Lesser General Public License version 3 requirements | - | ||||||||||||||||||
24 | ** will be met: https://www.gnu.org/licenses/lgpl-3.0.html. | - | ||||||||||||||||||
25 | ** | - | ||||||||||||||||||
26 | ** GNU General Public License Usage | - | ||||||||||||||||||
27 | ** Alternatively, this file may be used under the terms of the GNU | - | ||||||||||||||||||
28 | ** General Public License version 2.0 or (at your option) the GNU General | - | ||||||||||||||||||
29 | ** Public license version 3 or any later version approved by the KDE Free | - | ||||||||||||||||||
30 | ** Qt Foundation. The licenses are as published by the Free Software | - | ||||||||||||||||||
31 | ** Foundation and appearing in the file LICENSE.GPL2 and LICENSE.GPL3 | - | ||||||||||||||||||
32 | ** included in the packaging of this file. Please review the following | - | ||||||||||||||||||
33 | ** information to ensure the GNU General Public License requirements will | - | ||||||||||||||||||
34 | ** be met: https://www.gnu.org/licenses/gpl-2.0.html and | - | ||||||||||||||||||
35 | ** https://www.gnu.org/licenses/gpl-3.0.html. | - | ||||||||||||||||||
36 | ** | - | ||||||||||||||||||
37 | ** $QT_END_LICENSE$ | - | ||||||||||||||||||
38 | ** | - | ||||||||||||||||||
39 | ****************************************************************************/ | - | ||||||||||||||||||
40 | - | |||||||||||||||||||
41 | #include "qthread.h" | - | ||||||||||||||||||
42 | - | |||||||||||||||||||
43 | #include "qplatformdefs.h" | - | ||||||||||||||||||
44 | - | |||||||||||||||||||
45 | #include <private/qcoreapplication_p.h> | - | ||||||||||||||||||
46 | #include <private/qcore_unix_p.h> | - | ||||||||||||||||||
47 | - | |||||||||||||||||||
48 | #if defined(Q_OS_OSX) | - | ||||||||||||||||||
49 | # include <private/qeventdispatcher_cf_p.h> | - | ||||||||||||||||||
50 | #else | - | ||||||||||||||||||
51 | # if !defined(QT_NO_GLIB) | - | ||||||||||||||||||
52 | # include "../kernel/qeventdispatcher_glib_p.h" | - | ||||||||||||||||||
53 | # endif | - | ||||||||||||||||||
54 | #endif | - | ||||||||||||||||||
55 | - | |||||||||||||||||||
56 | #include <private/qeventdispatcher_unix_p.h> | - | ||||||||||||||||||
57 | - | |||||||||||||||||||
58 | #include "qthreadstorage.h" | - | ||||||||||||||||||
59 | - | |||||||||||||||||||
60 | #include "qthread_p.h" | - | ||||||||||||||||||
61 | - | |||||||||||||||||||
62 | #include "qdebug.h" | - | ||||||||||||||||||
63 | - | |||||||||||||||||||
64 | #include <sched.h> | - | ||||||||||||||||||
65 | #include <errno.h> | - | ||||||||||||||||||
66 | - | |||||||||||||||||||
67 | #ifdef Q_OS_BSD4 | - | ||||||||||||||||||
68 | #include <sys/sysctl.h> | - | ||||||||||||||||||
69 | #endif | - | ||||||||||||||||||
70 | #ifdef Q_OS_VXWORKS | - | ||||||||||||||||||
71 | # if (_WRS_VXWORKS_MAJOR > 6) || ((_WRS_VXWORKS_MAJOR == 6) && (_WRS_VXWORKS_MINOR >= 6)) | - | ||||||||||||||||||
72 | # include <vxCpuLib.h> | - | ||||||||||||||||||
73 | # include <cpuset.h> | - | ||||||||||||||||||
74 | # define QT_VXWORKS_HAS_CPUSET | - | ||||||||||||||||||
75 | # endif | - | ||||||||||||||||||
76 | #endif | - | ||||||||||||||||||
77 | - | |||||||||||||||||||
78 | #ifdef Q_OS_HPUX | - | ||||||||||||||||||
79 | #include <sys/pstat.h> | - | ||||||||||||||||||
80 | #endif | - | ||||||||||||||||||
81 | - | |||||||||||||||||||
82 | #if defined(Q_OS_MAC) | - | ||||||||||||||||||
83 | # ifdef qDebug | - | ||||||||||||||||||
84 | # define old_qDebug qDebug | - | ||||||||||||||||||
85 | # undef qDebug | - | ||||||||||||||||||
86 | # endif | - | ||||||||||||||||||
87 | - | |||||||||||||||||||
88 | # ifdef old_qDebug | - | ||||||||||||||||||
89 | # undef qDebug | - | ||||||||||||||||||
90 | # define qDebug QT_NO_QDEBUG_MACRO | - | ||||||||||||||||||
91 | # undef old_qDebug | - | ||||||||||||||||||
92 | # endif | - | ||||||||||||||||||
93 | #endif | - | ||||||||||||||||||
94 | - | |||||||||||||||||||
95 | #if defined(Q_OS_LINUX) && !defined(QT_LINUXBASE) | - | ||||||||||||||||||
96 | #include <sys/prctl.h> | - | ||||||||||||||||||
97 | #endif | - | ||||||||||||||||||
98 | - | |||||||||||||||||||
99 | #if defined(Q_OS_LINUX) && !defined(SCHED_IDLE) | - | ||||||||||||||||||
100 | // from linux/sched.h | - | ||||||||||||||||||
101 | # define SCHED_IDLE 5 | - | ||||||||||||||||||
102 | #endif | - | ||||||||||||||||||
103 | - | |||||||||||||||||||
104 | #if defined(Q_OS_DARWIN) || !defined(Q_OS_OPENBSD) && defined(_POSIX_THREAD_PRIORITY_SCHEDULING) && (_POSIX_THREAD_PRIORITY_SCHEDULING-0 >= 0) | - | ||||||||||||||||||
105 | #define QT_HAS_THREAD_PRIORITY_SCHEDULING | - | ||||||||||||||||||
106 | #endif | - | ||||||||||||||||||
107 | - | |||||||||||||||||||
108 | - | |||||||||||||||||||
109 | QT_BEGIN_NAMESPACE | - | ||||||||||||||||||
110 | - | |||||||||||||||||||
111 | #ifndef QT_NO_THREAD | - | ||||||||||||||||||
112 | - | |||||||||||||||||||
113 | Q_STATIC_ASSERT(sizeof(pthread_t) <= sizeof(Qt::HANDLE)); | - | ||||||||||||||||||
114 | - | |||||||||||||||||||
115 | enum { ThreadPriorityResetFlag = 0x80000000 }; | - | ||||||||||||||||||
116 | - | |||||||||||||||||||
117 | #if defined(Q_OS_LINUX) && defined(__GLIBC__) && (defined(Q_CC_GNU) || defined(Q_CC_INTEL)) && !defined(QT_LINUXBASE) | - | ||||||||||||||||||
118 | /* LSB doesn't have __thread, https://lsbbugs.linuxfoundation.org/show_bug.cgi?id=993 */ | - | ||||||||||||||||||
119 | #define HAVE_TLS | - | ||||||||||||||||||
120 | #endif | - | ||||||||||||||||||
121 | #if defined(Q_CC_XLC) || defined (Q_CC_SUN) | - | ||||||||||||||||||
122 | #define HAVE_TLS | - | ||||||||||||||||||
123 | #endif | - | ||||||||||||||||||
124 | - | |||||||||||||||||||
125 | #ifdef HAVE_TLS | - | ||||||||||||||||||
126 | static __thread QThreadData *currentThreadData = 0; | - | ||||||||||||||||||
127 | #endif | - | ||||||||||||||||||
128 | - | |||||||||||||||||||
129 | static pthread_once_t current_thread_data_once = PTHREAD_ONCE_INIT; | - | ||||||||||||||||||
130 | static pthread_key_t current_thread_data_key; | - | ||||||||||||||||||
131 | - | |||||||||||||||||||
132 | static void destroy_current_thread_data(void *p) | - | ||||||||||||||||||
133 | { | - | ||||||||||||||||||
134 | #if defined(Q_OS_VXWORKS) | - | ||||||||||||||||||
135 | // Calling setspecific(..., 0) sets the value to 0 for ALL threads. | - | ||||||||||||||||||
136 | // The 'set to 1' workaround adds a bit of an overhead though, | - | ||||||||||||||||||
137 | // since this function is called twice now. | - | ||||||||||||||||||
138 | if (p == (void *)1) | - | ||||||||||||||||||
139 | return; | - | ||||||||||||||||||
140 | #endif | - | ||||||||||||||||||
141 | // POSIX says the value in our key is set to zero before calling | - | ||||||||||||||||||
142 | // this destructor function, so we need to set it back to the | - | ||||||||||||||||||
143 | // right value... | - | ||||||||||||||||||
144 | pthread_setspecific(current_thread_data_key, p); | - | ||||||||||||||||||
145 | QThreadData *data = static_cast<QThreadData *>(p); | - | ||||||||||||||||||
146 | if (data->isAdopted) {
| 17-620183 | ||||||||||||||||||
147 | QThread *thread = data->thread; | - | ||||||||||||||||||
148 | Q_ASSERT(thread); | - | ||||||||||||||||||
149 | QThreadPrivate *thread_p = static_cast<QThreadPrivate *>(QObjectPrivate::get(thread)); | - | ||||||||||||||||||
150 | Q_ASSERT(!thread_p->finished); | - | ||||||||||||||||||
151 | thread_p->finish(thread); | - | ||||||||||||||||||
152 | } executed 17 times by 1 test: end of block Executed by:
| 17 | ||||||||||||||||||
153 | data->deref(); | - | ||||||||||||||||||
154 | - | |||||||||||||||||||
155 | // ... but we must reset it to zero before returning so we aren't | - | ||||||||||||||||||
156 | // called again (POSIX allows implementations to call destructor | - | ||||||||||||||||||
157 | // functions repeatedly until all values are zero) | - | ||||||||||||||||||
158 | pthread_setspecific(current_thread_data_key, | - | ||||||||||||||||||
159 | #if defined(Q_OS_VXWORKS) | - | ||||||||||||||||||
160 | (void *)1); | - | ||||||||||||||||||
161 | #else | - | ||||||||||||||||||
162 | 0); | - | ||||||||||||||||||
163 | #endif | - | ||||||||||||||||||
164 | } executed 620200 times by 512 tests: end of block Executed by:
| 620200 | ||||||||||||||||||
165 | - | |||||||||||||||||||
166 | static void create_current_thread_data_key() | - | ||||||||||||||||||
167 | { | - | ||||||||||||||||||
168 | pthread_key_create(¤t_thread_data_key, destroy_current_thread_data); | - | ||||||||||||||||||
169 | } executed 1104 times by 15 tests: end of block Executed by:
| 1104 | ||||||||||||||||||
170 | - | |||||||||||||||||||
171 | static void destroy_current_thread_data_key() | - | ||||||||||||||||||
172 | { | - | ||||||||||||||||||
173 | pthread_once(¤t_thread_data_once, create_current_thread_data_key); | - | ||||||||||||||||||
174 | pthread_key_delete(current_thread_data_key); | - | ||||||||||||||||||
175 | - | |||||||||||||||||||
176 | // Reset current_thread_data_once in case we end up recreating | - | ||||||||||||||||||
177 | // the thread-data in the rare case of QObject construction | - | ||||||||||||||||||
178 | // after destroying the QThreadData. | - | ||||||||||||||||||
179 | pthread_once_t pthread_once_init = PTHREAD_ONCE_INIT; | - | ||||||||||||||||||
180 | current_thread_data_once = pthread_once_init; | - | ||||||||||||||||||
181 | } never executed: end of block | 0 | ||||||||||||||||||
182 | Q_DESTRUCTOR_FUNCTION(destroy_current_thread_data_key) never executed: end of block | 0 | ||||||||||||||||||
183 | - | |||||||||||||||||||
184 | - | |||||||||||||||||||
185 | // Utility functions for getting, setting and clearing thread specific data. | - | ||||||||||||||||||
186 | static QThreadData *get_thread_data() | - | ||||||||||||||||||
187 | { | - | ||||||||||||||||||
188 | #ifdef HAVE_TLS | - | ||||||||||||||||||
189 | return currentThreadData; executed 43687172 times by 1014 tests: return currentThreadData; Executed by:
| 43687172 | ||||||||||||||||||
190 | #else | - | ||||||||||||||||||
191 | pthread_once(¤t_thread_data_once, create_current_thread_data_key); | - | ||||||||||||||||||
192 | return reinterpret_cast<QThreadData *>(pthread_getspecific(current_thread_data_key)); | - | ||||||||||||||||||
193 | #endif | - | ||||||||||||||||||
194 | } | - | ||||||||||||||||||
195 | - | |||||||||||||||||||
196 | static void set_thread_data(QThreadData *data) | - | ||||||||||||||||||
197 | { | - | ||||||||||||||||||
198 | #ifdef HAVE_TLS | - | ||||||||||||||||||
199 | currentThreadData = data; | - | ||||||||||||||||||
200 | #endif | - | ||||||||||||||||||
201 | pthread_once(¤t_thread_data_once, create_current_thread_data_key); | - | ||||||||||||||||||
202 | pthread_setspecific(current_thread_data_key, data); | - | ||||||||||||||||||
203 | } executed 621808 times by 523 tests: end of block Executed by:
| 621808 | ||||||||||||||||||
204 | - | |||||||||||||||||||
205 | static void clear_thread_data() | - | ||||||||||||||||||
206 | { | - | ||||||||||||||||||
207 | #ifdef HAVE_TLS | - | ||||||||||||||||||
208 | currentThreadData = 0; | - | ||||||||||||||||||
209 | #endif | - | ||||||||||||||||||
210 | pthread_setspecific(current_thread_data_key, 0); | - | ||||||||||||||||||
211 | } executed 1087 times by 346 tests: end of block Executed by:
| 1087 | ||||||||||||||||||
212 | - | |||||||||||||||||||
213 | template <typename T> | - | ||||||||||||||||||
214 | static typename QtPrivate::QEnableIf<QTypeInfo<T>::isIntegral, Qt::HANDLE>::Type to_HANDLE(T id) | - | ||||||||||||||||||
215 | { | - | ||||||||||||||||||
216 | return reinterpret_cast<Qt::HANDLE>(static_cast<intptr_t>(id)); executed 14588472 times by 801 tests: return reinterpret_cast<Qt::HANDLE>(static_cast<intptr_t>(id)); Executed by:
| 14588472 | ||||||||||||||||||
217 | } | - | ||||||||||||||||||
218 | - | |||||||||||||||||||
219 | template <typename T> | - | ||||||||||||||||||
220 | static typename QtPrivate::QEnableIf<QTypeInfo<T>::isIntegral, T>::Type from_HANDLE(Qt::HANDLE id) | - | ||||||||||||||||||
221 | { | - | ||||||||||||||||||
222 | return static_cast<T>(reinterpret_cast<intptr_t>(id)); executed 1240826 times by 1012 tests: return static_cast<T>(reinterpret_cast<intptr_t>(id)); Executed by:
| 1240826 | ||||||||||||||||||
223 | } | - | ||||||||||||||||||
224 | - | |||||||||||||||||||
225 | template <typename T> | - | ||||||||||||||||||
226 | static typename QtPrivate::QEnableIf<QTypeInfo<T>::isPointer, Qt::HANDLE>::Type to_HANDLE(T id) | - | ||||||||||||||||||
227 | { | - | ||||||||||||||||||
228 | return id; never executed: return id; | 0 | ||||||||||||||||||
229 | } | - | ||||||||||||||||||
230 | - | |||||||||||||||||||
231 | template <typename T> | - | ||||||||||||||||||
232 | static typename QtPrivate::QEnableIf<QTypeInfo<T>::isPointer, T>::Type from_HANDLE(Qt::HANDLE id) | - | ||||||||||||||||||
233 | { | - | ||||||||||||||||||
234 | return static_cast<T>(id); never executed: return static_cast<T>(id); | 0 | ||||||||||||||||||
235 | } | - | ||||||||||||||||||
236 | - | |||||||||||||||||||
237 | void QThreadData::clearCurrentThreadData() | - | ||||||||||||||||||
238 | { | - | ||||||||||||||||||
239 | clear_thread_data(); | - | ||||||||||||||||||
240 | } executed 1087 times by 346 tests: end of block Executed by:
| 1087 | ||||||||||||||||||
241 | - | |||||||||||||||||||
242 | QThreadData *QThreadData::current(bool createIfNecessary) | - | ||||||||||||||||||
243 | { | - | ||||||||||||||||||
244 | QThreadData *data = get_thread_data(); | - | ||||||||||||||||||
245 | if (!data && createIfNecessary) {
| 0-43686044 | ||||||||||||||||||
246 | data = new QThreadData; | - | ||||||||||||||||||
247 | QT_TRY { | - | ||||||||||||||||||
248 | set_thread_data(data); | - | ||||||||||||||||||
249 | data->thread = new QAdoptedThread(data); | - | ||||||||||||||||||
250 | } QT_CATCH(...) { executed 1125 times by 19 tests: end of block Executed by:
| 1125 | ||||||||||||||||||
251 | clear_thread_data(); | - | ||||||||||||||||||
252 | data->deref(); | - | ||||||||||||||||||
253 | data = 0; | - | ||||||||||||||||||
254 | QT_RETHROW; never executed: throw; | 0 | ||||||||||||||||||
255 | } | - | ||||||||||||||||||
256 | data->deref(); | - | ||||||||||||||||||
257 | data->isAdopted = true; | - | ||||||||||||||||||
258 | data->threadId = to_HANDLE(pthread_self()); | - | ||||||||||||||||||
259 | if (!QCoreApplicationPrivate::theMainThread)
| 17-1108 | ||||||||||||||||||
260 | QCoreApplicationPrivate::theMainThread = data->thread.load(); executed 1108 times by 18 tests: QCoreApplicationPrivate::theMainThread = data->thread.load(); Executed by:
| 1108 | ||||||||||||||||||
261 | } executed 1125 times by 19 tests: end of block Executed by:
| 1125 | ||||||||||||||||||
262 | return data; executed 43687169 times by 1014 tests: return data; Executed by:
| 43687169 | ||||||||||||||||||
263 | } | - | ||||||||||||||||||
264 | - | |||||||||||||||||||
265 | - | |||||||||||||||||||
266 | void QAdoptedThread::init() | - | ||||||||||||||||||
267 | { | - | ||||||||||||||||||
268 | } | - | ||||||||||||||||||
269 | - | |||||||||||||||||||
270 | /* | - | ||||||||||||||||||
271 | QThreadPrivate | - | ||||||||||||||||||
272 | */ | - | ||||||||||||||||||
273 | - | |||||||||||||||||||
274 | extern "C" { | - | ||||||||||||||||||
275 | typedef void*(*QtThreadCallback)(void*); | - | ||||||||||||||||||
276 | } | - | ||||||||||||||||||
277 | - | |||||||||||||||||||
278 | #endif // QT_NO_THREAD | - | ||||||||||||||||||
279 | - | |||||||||||||||||||
280 | void QThreadPrivate::createEventDispatcher(QThreadData *data) | - | ||||||||||||||||||
281 | { | - | ||||||||||||||||||
282 | #if defined(Q_OS_OSX) | - | ||||||||||||||||||
283 | bool ok = false; | - | ||||||||||||||||||
284 | int value = qEnvironmentVariableIntValue("QT_EVENT_DISPATCHER_CORE_FOUNDATION", &ok); | - | ||||||||||||||||||
285 | if (ok && value > 0) | - | ||||||||||||||||||
286 | data->eventDispatcher.storeRelease(new QEventDispatcherCoreFoundation); | - | ||||||||||||||||||
287 | else | - | ||||||||||||||||||
288 | data->eventDispatcher.storeRelease(new QEventDispatcherUNIX); | - | ||||||||||||||||||
289 | #elif !defined(QT_NO_GLIB) | - | ||||||||||||||||||
290 | if (qEnvironmentVariableIsEmpty("QT_NO_GLIB")
| 0-620684 | ||||||||||||||||||
291 | && qEnvironmentVariableIsEmpty("QT_NO_THREADED_GLIB")
| 0-620684 | ||||||||||||||||||
292 | && QEventDispatcherGlib::versionSupported())
| 0-620684 | ||||||||||||||||||
293 | data->eventDispatcher.storeRelease(new QEventDispatcherGlib); executed 620684 times by 512 tests: data->eventDispatcher.storeRelease(new QEventDispatcherGlib); Executed by:
| 620684 | ||||||||||||||||||
294 | else | - | ||||||||||||||||||
295 | data->eventDispatcher.storeRelease(new QEventDispatcherUNIX); never executed: data->eventDispatcher.storeRelease(new QEventDispatcherUNIX); | 0 | ||||||||||||||||||
296 | #else | - | ||||||||||||||||||
297 | data->eventDispatcher.storeRelease(new QEventDispatcherUNIX); | - | ||||||||||||||||||
298 | #endif | - | ||||||||||||||||||
299 | - | |||||||||||||||||||
300 | data->eventDispatcher.load()->startingUp(); | - | ||||||||||||||||||
301 | } executed 620684 times by 512 tests: end of block Executed by:
| 620684 | ||||||||||||||||||
302 | - | |||||||||||||||||||
303 | #ifndef QT_NO_THREAD | - | ||||||||||||||||||
304 | - | |||||||||||||||||||
305 | #if (defined(Q_OS_LINUX) || defined(Q_OS_MAC) || defined(Q_OS_QNX)) | - | ||||||||||||||||||
306 | static void setCurrentThreadName(pthread_t threadId, const char *name) | - | ||||||||||||||||||
307 | { | - | ||||||||||||||||||
308 | # if defined(Q_OS_LINUX) && !defined(QT_LINUXBASE) | - | ||||||||||||||||||
309 | Q_UNUSED(threadId); | - | ||||||||||||||||||
310 | prctl(PR_SET_NAME, (unsigned long)name, 0, 0, 0); | - | ||||||||||||||||||
311 | # elif defined(Q_OS_MAC) | - | ||||||||||||||||||
312 | Q_UNUSED(threadId); | - | ||||||||||||||||||
313 | pthread_setname_np(name); | - | ||||||||||||||||||
314 | # elif defined(Q_OS_QNX) | - | ||||||||||||||||||
315 | pthread_setname_np(threadId, name); | - | ||||||||||||||||||
316 | # endif | - | ||||||||||||||||||
317 | } executed 620683 times by 512 tests: end of block Executed by:
| 620683 | ||||||||||||||||||
318 | #endif | - | ||||||||||||||||||
319 | - | |||||||||||||||||||
320 | void *QThreadPrivate::start(void *arg) | - | ||||||||||||||||||
321 | { | - | ||||||||||||||||||
322 | #if !defined(Q_OS_ANDROID) | - | ||||||||||||||||||
323 | pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL); | - | ||||||||||||||||||
324 | #endif | - | ||||||||||||||||||
325 | pthread_cleanup_push(QThreadPrivate::finish, arg); | - | ||||||||||||||||||
326 | - | |||||||||||||||||||
327 | QThread *thr = reinterpret_cast<QThread *>(arg); | - | ||||||||||||||||||
328 | QThreadData *data = QThreadData::get2(thr); | - | ||||||||||||||||||
329 | - | |||||||||||||||||||
330 | { | - | ||||||||||||||||||
331 | QMutexLocker locker(&thr->d_func()->mutex); | - | ||||||||||||||||||
332 | - | |||||||||||||||||||
333 | // do we need to reset the thread priority? | - | ||||||||||||||||||
334 | if (int(thr->d_func()->priority) & ThreadPriorityResetFlag) {
| 3-620680 | ||||||||||||||||||
335 | thr->d_func()->setPriority(QThread::Priority(thr->d_func()->priority & ~ThreadPriorityResetFlag)); | - | ||||||||||||||||||
336 | } executed 3 times by 2 tests: end of block Executed by:
| 3 | ||||||||||||||||||
337 | - | |||||||||||||||||||
338 | data->threadId = to_HANDLE(pthread_self()); | - | ||||||||||||||||||
339 | set_thread_data(data); | - | ||||||||||||||||||
340 | - | |||||||||||||||||||
341 | data->ref(); | - | ||||||||||||||||||
342 | data->quitNow = thr->d_func()->exited; | - | ||||||||||||||||||
343 | } | - | ||||||||||||||||||
344 | - | |||||||||||||||||||
345 | if (data->eventDispatcher.load()) // custom event dispatcher set?
| 1-620682 | ||||||||||||||||||
346 | data->eventDispatcher.load()->startingUp(); executed 1 time by 1 test: data->eventDispatcher.load()->startingUp(); Executed by:
| 1 | ||||||||||||||||||
347 | else | - | ||||||||||||||||||
348 | createEventDispatcher(data); executed 620682 times by 512 tests: createEventDispatcher(data); Executed by:
| 620682 | ||||||||||||||||||
349 | - | |||||||||||||||||||
350 | #if (defined(Q_OS_LINUX) || defined(Q_OS_MAC) || defined(Q_OS_QNX)) | - | ||||||||||||||||||
351 | { | - | ||||||||||||||||||
352 | // sets the name of the current thread. | - | ||||||||||||||||||
353 | QString objectName = thr->objectName(); | - | ||||||||||||||||||
354 | - | |||||||||||||||||||
355 | pthread_t thread_id = from_HANDLE<pthread_t>(data->threadId); | - | ||||||||||||||||||
356 | if (Q_LIKELY(objectName.isEmpty()))
| 1935-618748 | ||||||||||||||||||
357 | setCurrentThreadName(thread_id, thr->metaObject()->className()); executed 618748 times by 512 tests: setCurrentThreadName(thread_id, thr->metaObject()->className()); Executed by:
| 618748 | ||||||||||||||||||
358 | else | - | ||||||||||||||||||
359 | setCurrentThreadName(thread_id, objectName.toLocal8Bit()); executed 1935 times by 45 tests: setCurrentThreadName(thread_id, objectName.toLocal8Bit()); Executed by:
| 1935 | ||||||||||||||||||
360 | } | - | ||||||||||||||||||
361 | #endif | - | ||||||||||||||||||
362 | - | |||||||||||||||||||
363 | emit thr->started(QThread::QPrivateSignal()); | - | ||||||||||||||||||
364 | #if !defined(Q_OS_ANDROID) | - | ||||||||||||||||||
365 | pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL); | - | ||||||||||||||||||
366 | pthread_testcancel(); | - | ||||||||||||||||||
367 | #endif | - | ||||||||||||||||||
368 | thr->run(); | - | ||||||||||||||||||
369 | - | |||||||||||||||||||
370 | pthread_cleanup_pop(1); | - | ||||||||||||||||||
371 | - | |||||||||||||||||||
372 | return 0; executed 620181 times by 512 tests: return 0; Executed by:
| 620181 | ||||||||||||||||||
373 | } | - | ||||||||||||||||||
374 | - | |||||||||||||||||||
375 | void QThreadPrivate::finish(void *arg) | - | ||||||||||||||||||
376 | { | - | ||||||||||||||||||
377 | QThread *thr = reinterpret_cast<QThread *>(arg); | - | ||||||||||||||||||
378 | QThreadPrivate *d = thr->d_func(); | - | ||||||||||||||||||
379 | - | |||||||||||||||||||
380 | QMutexLocker locker(&d->mutex); | - | ||||||||||||||||||
381 | - | |||||||||||||||||||
382 | d->isInFinish = true; | - | ||||||||||||||||||
383 | d->priority = QThread::InheritPriority; | - | ||||||||||||||||||
384 | void *data = &d->data->tls; | - | ||||||||||||||||||
385 | locker.unlock(); | - | ||||||||||||||||||
386 | emit thr->finished(QThread::QPrivateSignal()); | - | ||||||||||||||||||
387 | QCoreApplication::sendPostedEvents(0, QEvent::DeferredDelete); | - | ||||||||||||||||||
388 | QThreadStorageData::finish((void **)data); | - | ||||||||||||||||||
389 | locker.relock(); | - | ||||||||||||||||||
390 | - | |||||||||||||||||||
391 | QAbstractEventDispatcher *eventDispatcher = d->data->eventDispatcher.load(); | - | ||||||||||||||||||
392 | if (eventDispatcher) {
| 15-620844 | ||||||||||||||||||
393 | d->data->eventDispatcher = 0; | - | ||||||||||||||||||
394 | locker.unlock(); | - | ||||||||||||||||||
395 | eventDispatcher->closingDown(); | - | ||||||||||||||||||
396 | delete eventDispatcher; | - | ||||||||||||||||||
397 | locker.relock(); | - | ||||||||||||||||||
398 | } executed 620844 times by 578 tests: end of block Executed by:
| 620844 | ||||||||||||||||||
399 | - | |||||||||||||||||||
400 | d->running = false; | - | ||||||||||||||||||
401 | d->finished = true; | - | ||||||||||||||||||
402 | d->interruptionRequested = false; | - | ||||||||||||||||||
403 | - | |||||||||||||||||||
404 | d->isInFinish = false; | - | ||||||||||||||||||
405 | d->thread_done.wakeAll(); | - | ||||||||||||||||||
406 | } executed 620859 times by 578 tests: end of block Executed by:
| 620859 | ||||||||||||||||||
407 | - | |||||||||||||||||||
408 | - | |||||||||||||||||||
409 | - | |||||||||||||||||||
410 | - | |||||||||||||||||||
411 | /************************************************************************** | - | ||||||||||||||||||
412 | ** QThread | - | ||||||||||||||||||
413 | *************************************************************************/ | - | ||||||||||||||||||
414 | - | |||||||||||||||||||
415 | Qt::HANDLE QThread::currentThreadId() Q_DECL_NOTHROW | - | ||||||||||||||||||
416 | { | - | ||||||||||||||||||
417 | // requires a C cast here otherwise we run into trouble on AIX | - | ||||||||||||||||||
418 | return to_HANDLE(pthread_self()); executed 13345982 times by 599 tests: return to_HANDLE(pthread_self()); Executed by:
| 13345982 | ||||||||||||||||||
419 | } | - | ||||||||||||||||||
420 | - | |||||||||||||||||||
421 | #if defined(QT_LINUXBASE) && !defined(_SC_NPROCESSORS_ONLN) | - | ||||||||||||||||||
422 | // LSB doesn't define _SC_NPROCESSORS_ONLN. | - | ||||||||||||||||||
423 | # define _SC_NPROCESSORS_ONLN 84 | - | ||||||||||||||||||
424 | #endif | - | ||||||||||||||||||
425 | - | |||||||||||||||||||
426 | int QThread::idealThreadCount() Q_DECL_NOTHROW | - | ||||||||||||||||||
427 | { | - | ||||||||||||||||||
428 | int cores = 1; | - | ||||||||||||||||||
429 | - | |||||||||||||||||||
430 | #if defined(Q_OS_HPUX) | - | ||||||||||||||||||
431 | // HP-UX | - | ||||||||||||||||||
432 | struct pst_dynamic psd; | - | ||||||||||||||||||
433 | if (pstat_getdynamic(&psd, sizeof(psd), 1, 0) == -1) { | - | ||||||||||||||||||
434 | perror("pstat_getdynamic"); | - | ||||||||||||||||||
435 | } else { | - | ||||||||||||||||||
436 | cores = (int)psd.psd_proc_cnt; | - | ||||||||||||||||||
437 | } | - | ||||||||||||||||||
438 | #elif defined(Q_OS_BSD4) | - | ||||||||||||||||||
439 | // FreeBSD, OpenBSD, NetBSD, BSD/OS, OS X, iOS | - | ||||||||||||||||||
440 | size_t len = sizeof(cores); | - | ||||||||||||||||||
441 | int mib[2]; | - | ||||||||||||||||||
442 | mib[0] = CTL_HW; | - | ||||||||||||||||||
443 | mib[1] = HW_NCPU; | - | ||||||||||||||||||
444 | if (sysctl(mib, 2, &cores, &len, NULL, 0) != 0) { | - | ||||||||||||||||||
445 | perror("sysctl"); | - | ||||||||||||||||||
446 | } | - | ||||||||||||||||||
447 | #elif defined(Q_OS_IRIX) | - | ||||||||||||||||||
448 | // IRIX | - | ||||||||||||||||||
449 | cores = (int)sysconf(_SC_NPROC_ONLN); | - | ||||||||||||||||||
450 | #elif defined(Q_OS_INTEGRITY) | - | ||||||||||||||||||
451 | #if (__INTEGRITY_MAJOR_VERSION >= 10) | - | ||||||||||||||||||
452 | // Integrity V10+ does support multicore CPUs | - | ||||||||||||||||||
453 | Value processorCount; | - | ||||||||||||||||||
454 | if (GetProcessorCount(CurrentTask(), &processorCount) == 0) | - | ||||||||||||||||||
455 | cores = processorCount; | - | ||||||||||||||||||
456 | else | - | ||||||||||||||||||
457 | #endif | - | ||||||||||||||||||
458 | // as of aug 2008 Integrity only supports one single core CPU | - | ||||||||||||||||||
459 | cores = 1; | - | ||||||||||||||||||
460 | #elif defined(Q_OS_VXWORKS) | - | ||||||||||||||||||
461 | // VxWorks | - | ||||||||||||||||||
462 | # if defined(QT_VXWORKS_HAS_CPUSET) | - | ||||||||||||||||||
463 | cpuset_t cpus = vxCpuEnabledGet(); | - | ||||||||||||||||||
464 | cores = 0; | - | ||||||||||||||||||
465 | - | |||||||||||||||||||
466 | // 128 cores should be enough for everyone ;) | - | ||||||||||||||||||
467 | for (int i = 0; i < 128 && !CPUSET_ISZERO(cpus); ++i) { | - | ||||||||||||||||||
468 | if (CPUSET_ISSET(cpus, i)) { | - | ||||||||||||||||||
469 | CPUSET_CLR(cpus, i); | - | ||||||||||||||||||
470 | cores++; | - | ||||||||||||||||||
471 | } | - | ||||||||||||||||||
472 | } | - | ||||||||||||||||||
473 | # else | - | ||||||||||||||||||
474 | // as of aug 2008 VxWorks < 6.6 only supports one single core CPU | - | ||||||||||||||||||
475 | cores = 1; | - | ||||||||||||||||||
476 | # endif | - | ||||||||||||||||||
477 | #else | - | ||||||||||||||||||
478 | // the rest: Linux, Solaris, AIX, Tru64 | - | ||||||||||||||||||
479 | cores = (int)sysconf(_SC_NPROCESSORS_ONLN); | - | ||||||||||||||||||
480 | if (cores == -1)
| 0-1903 | ||||||||||||||||||
481 | return 1; never executed: return 1; | 0 | ||||||||||||||||||
482 | #endif | - | ||||||||||||||||||
483 | return cores; executed 1903 times by 447 tests: return cores; Executed by:
| 1903 | ||||||||||||||||||
484 | } | - | ||||||||||||||||||
485 | - | |||||||||||||||||||
486 | void QThread::yieldCurrentThread() | - | ||||||||||||||||||
487 | { | - | ||||||||||||||||||
488 | sched_yield(); | - | ||||||||||||||||||
489 | } executed 1556 times by 3 tests: end of block Executed by:
| 1556 | ||||||||||||||||||
490 | - | |||||||||||||||||||
491 | static timespec makeTimespec(time_t secs, long nsecs) | - | ||||||||||||||||||
492 | { | - | ||||||||||||||||||
493 | struct timespec ts; | - | ||||||||||||||||||
494 | ts.tv_sec = secs; | - | ||||||||||||||||||
495 | ts.tv_nsec = nsecs; | - | ||||||||||||||||||
496 | return ts; executed 325374 times by 11 tests: return ts; Executed by:
| 325374 | ||||||||||||||||||
497 | } | - | ||||||||||||||||||
498 | - | |||||||||||||||||||
499 | void QThread::sleep(unsigned long secs) | - | ||||||||||||||||||
500 | { | - | ||||||||||||||||||
501 | qt_nanosleep(makeTimespec(secs, 0)); | - | ||||||||||||||||||
502 | } executed 7 times by 3 tests: end of block Executed by:
| 7 | ||||||||||||||||||
503 | - | |||||||||||||||||||
504 | void QThread::msleep(unsigned long msecs) | - | ||||||||||||||||||
505 | { | - | ||||||||||||||||||
506 | qt_nanosleep(makeTimespec(msecs / 1000, msecs % 1000 * 1000 * 1000)); | - | ||||||||||||||||||
507 | } executed 295269 times by 8 tests: end of block Executed by:
| 295269 | ||||||||||||||||||
508 | - | |||||||||||||||||||
509 | void QThread::usleep(unsigned long usecs) | - | ||||||||||||||||||
510 | { | - | ||||||||||||||||||
511 | qt_nanosleep(makeTimespec(usecs / 1000 / 1000, usecs % (1000*1000) * 1000)); | - | ||||||||||||||||||
512 | } executed 30079 times by 3 tests: end of block Executed by:
| 30079 | ||||||||||||||||||
513 | - | |||||||||||||||||||
514 | #ifdef QT_HAS_THREAD_PRIORITY_SCHEDULING | - | ||||||||||||||||||
515 | // Does some magic and calculate the Unix scheduler priorities | - | ||||||||||||||||||
516 | // sched_policy is IN/OUT: it must be set to a valid policy before calling this function | - | ||||||||||||||||||
517 | // sched_priority is OUT only | - | ||||||||||||||||||
518 | static bool calculateUnixPriority(int priority, int *sched_policy, int *sched_priority) | - | ||||||||||||||||||
519 | { | - | ||||||||||||||||||
520 | #ifdef SCHED_IDLE | - | ||||||||||||||||||
521 | if (priority == QThread::IdlePriority) {
| 8-393 | ||||||||||||||||||
522 | *sched_policy = SCHED_IDLE; | - | ||||||||||||||||||
523 | *sched_priority = 0; | - | ||||||||||||||||||
524 | return true; executed 8 times by 2 tests: return true; Executed by:
| 8 | ||||||||||||||||||
525 | } | - | ||||||||||||||||||
526 | const int lowestPriority = QThread::LowestPriority; | - | ||||||||||||||||||
527 | #else | - | ||||||||||||||||||
528 | const int lowestPriority = QThread::IdlePriority; | - | ||||||||||||||||||
529 | #endif | - | ||||||||||||||||||
530 | const int highestPriority = QThread::TimeCriticalPriority; | - | ||||||||||||||||||
531 | - | |||||||||||||||||||
532 | int prio_min; | - | ||||||||||||||||||
533 | int prio_max; | - | ||||||||||||||||||
534 | #if defined(Q_OS_VXWORKS) && defined(VXWORKS_DKM) | - | ||||||||||||||||||
535 | // for other scheduling policies than SCHED_RR or SCHED_FIFO | - | ||||||||||||||||||
536 | prio_min = SCHED_FIFO_LOW_PRI; | - | ||||||||||||||||||
537 | prio_max = SCHED_FIFO_HIGH_PRI; | - | ||||||||||||||||||
538 | - | |||||||||||||||||||
539 | if ((*sched_policy == SCHED_RR) || (*sched_policy == SCHED_FIFO)) | - | ||||||||||||||||||
540 | #endif | - | ||||||||||||||||||
541 | { | - | ||||||||||||||||||
542 | prio_min = sched_get_priority_min(*sched_policy); | - | ||||||||||||||||||
543 | prio_max = sched_get_priority_max(*sched_policy); | - | ||||||||||||||||||
544 | } | - | ||||||||||||||||||
545 | - | |||||||||||||||||||
546 | if (prio_min == -1 || prio_max == -1)
| 0-393 | ||||||||||||||||||
547 | return false; never executed: return false; | 0 | ||||||||||||||||||
548 | - | |||||||||||||||||||
549 | int prio; | - | ||||||||||||||||||
550 | // crudely scale our priority enum values to the prio_min/prio_max | - | ||||||||||||||||||
551 | prio = ((priority - lowestPriority) * (prio_max - prio_min) / highestPriority) + prio_min; | - | ||||||||||||||||||
552 | prio = qMax(prio_min, qMin(prio_max, prio)); | - | ||||||||||||||||||
553 | - | |||||||||||||||||||
554 | *sched_priority = prio; | - | ||||||||||||||||||
555 | return true; executed 393 times by 10 tests: return true; Executed by:
| 393 | ||||||||||||||||||
556 | } | - | ||||||||||||||||||
557 | #endif | - | ||||||||||||||||||
558 | - | |||||||||||||||||||
559 | void QThread::start(Priority priority) | - | ||||||||||||||||||
560 | { | - | ||||||||||||||||||
561 | Q_D(QThread); | - | ||||||||||||||||||
562 | QMutexLocker locker(&d->mutex); | - | ||||||||||||||||||
563 | - | |||||||||||||||||||
564 | if (d->isInFinish)
| 0-620683 | ||||||||||||||||||
565 | d->thread_done.wait(locker.mutex()); never executed: d->thread_done.wait(locker.mutex()); | 0 | ||||||||||||||||||
566 | - | |||||||||||||||||||
567 | if (d->running)
| 1-620682 | ||||||||||||||||||
568 | return; executed 1 time by 1 test: return; Executed by:
| 1 | ||||||||||||||||||
569 | - | |||||||||||||||||||
570 | d->running = true; | - | ||||||||||||||||||
571 | d->finished = false; | - | ||||||||||||||||||
572 | d->returnCode = 0; | - | ||||||||||||||||||
573 | d->exited = false; | - | ||||||||||||||||||
574 | d->interruptionRequested = false; | - | ||||||||||||||||||
575 | - | |||||||||||||||||||
576 | pthread_attr_t attr; | - | ||||||||||||||||||
577 | pthread_attr_init(&attr); | - | ||||||||||||||||||
578 | pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); | - | ||||||||||||||||||
579 | - | |||||||||||||||||||
580 | d->priority = priority; | - | ||||||||||||||||||
581 | - | |||||||||||||||||||
582 | #if defined(QT_HAS_THREAD_PRIORITY_SCHEDULING) | - | ||||||||||||||||||
583 | switch (priority) { | - | ||||||||||||||||||
584 | case InheritPriority: executed 620298 times by 512 tests: case InheritPriority: Executed by:
| 620298 | ||||||||||||||||||
585 | { | - | ||||||||||||||||||
586 | pthread_attr_setinheritsched(&attr, PTHREAD_INHERIT_SCHED); | - | ||||||||||||||||||
587 | break; executed 620298 times by 512 tests: break; Executed by:
| 620298 | ||||||||||||||||||
588 | } | - | ||||||||||||||||||
589 | - | |||||||||||||||||||
590 | default: executed 384 times by 10 tests: default: Executed by:
| 384 | ||||||||||||||||||
591 | { | - | ||||||||||||||||||
592 | int sched_policy; | - | ||||||||||||||||||
593 | if (pthread_attr_getschedpolicy(&attr, &sched_policy) != 0) {
| 0-384 | ||||||||||||||||||
594 | // failed to get the scheduling policy, don't bother | - | ||||||||||||||||||
595 | // setting the priority | - | ||||||||||||||||||
596 | qWarning("QThread::start: Cannot determine default scheduler policy"); | - | ||||||||||||||||||
597 | break; never executed: break; | 0 | ||||||||||||||||||
598 | } | - | ||||||||||||||||||
599 | - | |||||||||||||||||||
600 | int prio; | - | ||||||||||||||||||
601 | if (!calculateUnixPriority(priority, &sched_policy, &prio)) {
| 0-384 | ||||||||||||||||||
602 | // failed to get the scheduling parameters, don't | - | ||||||||||||||||||
603 | // bother setting the priority | - | ||||||||||||||||||
604 | qWarning("QThread::start: Cannot determine scheduler priority range"); | - | ||||||||||||||||||
605 | break; never executed: break; | 0 | ||||||||||||||||||
606 | } | - | ||||||||||||||||||
607 | - | |||||||||||||||||||
608 | sched_param sp; | - | ||||||||||||||||||
609 | sp.sched_priority = prio; | - | ||||||||||||||||||
610 | - | |||||||||||||||||||
611 | if (pthread_attr_setinheritsched(&attr, PTHREAD_EXPLICIT_SCHED) != 0
| 0-384 | ||||||||||||||||||
612 | || pthread_attr_setschedpolicy(&attr, sched_policy) != 0
| 3-381 | ||||||||||||||||||
613 | || pthread_attr_setschedparam(&attr, &sp) != 0) {
| 0-381 | ||||||||||||||||||
614 | // could not set scheduling hints, fallback to inheriting them | - | ||||||||||||||||||
615 | // we'll try again from inside the thread | - | ||||||||||||||||||
616 | pthread_attr_setinheritsched(&attr, PTHREAD_INHERIT_SCHED); | - | ||||||||||||||||||
617 | d->priority = Priority(priority | ThreadPriorityResetFlag); | - | ||||||||||||||||||
618 | } executed 3 times by 2 tests: end of block Executed by:
| 3 | ||||||||||||||||||
619 | break; executed 384 times by 10 tests: break; Executed by:
| 384 | ||||||||||||||||||
620 | } | - | ||||||||||||||||||
621 | } | - | ||||||||||||||||||
622 | #endif // QT_HAS_THREAD_PRIORITY_SCHEDULING | - | ||||||||||||||||||
623 | - | |||||||||||||||||||
624 | - | |||||||||||||||||||
625 | if (d->stackSize > 0) {
| 0-620682 | ||||||||||||||||||
626 | #if defined(_POSIX_THREAD_ATTR_STACKSIZE) && (_POSIX_THREAD_ATTR_STACKSIZE-0 > 0) | - | ||||||||||||||||||
627 | int code = pthread_attr_setstacksize(&attr, d->stackSize); | - | ||||||||||||||||||
628 | #else | - | ||||||||||||||||||
629 | int code = ENOSYS; // stack size not supported, automatically fail | - | ||||||||||||||||||
630 | #endif // _POSIX_THREAD_ATTR_STACKSIZE | - | ||||||||||||||||||
631 | - | |||||||||||||||||||
632 | if (code) {
| 0 | ||||||||||||||||||
633 | qWarning("QThread::start: Thread stack size error: %s", | - | ||||||||||||||||||
634 | qPrintable(qt_error_string(code))); | - | ||||||||||||||||||
635 | - | |||||||||||||||||||
636 | // we failed to set the stacksize, and as the documentation states, | - | ||||||||||||||||||
637 | // the thread will fail to run... | - | ||||||||||||||||||
638 | d->running = false; | - | ||||||||||||||||||
639 | d->finished = false; | - | ||||||||||||||||||
640 | return; never executed: return; | 0 | ||||||||||||||||||
641 | } | - | ||||||||||||||||||
642 | } never executed: end of block | 0 | ||||||||||||||||||
643 | - | |||||||||||||||||||
644 | pthread_t threadId; | - | ||||||||||||||||||
645 | int code = pthread_create(&threadId, &attr, QThreadPrivate::start, this); | - | ||||||||||||||||||
646 | if (code == EPERM) {
| 0-620682 | ||||||||||||||||||
647 | // caller does not have permission to set the scheduling | - | ||||||||||||||||||
648 | // parameters/policy | - | ||||||||||||||||||
649 | #if defined(QT_HAS_THREAD_PRIORITY_SCHEDULING) | - | ||||||||||||||||||
650 | pthread_attr_setinheritsched(&attr, PTHREAD_INHERIT_SCHED); | - | ||||||||||||||||||
651 | #endif | - | ||||||||||||||||||
652 | code = pthread_create(&threadId, &attr, QThreadPrivate::start, this); | - | ||||||||||||||||||
653 | } never executed: end of block | 0 | ||||||||||||||||||
654 | d->data->threadId = to_HANDLE(threadId); | - | ||||||||||||||||||
655 | - | |||||||||||||||||||
656 | pthread_attr_destroy(&attr); | - | ||||||||||||||||||
657 | - | |||||||||||||||||||
658 | if (code) {
| 0-620682 | ||||||||||||||||||
659 | qWarning("QThread::start: Thread creation error: %s", qPrintable(qt_error_string(code))); | - | ||||||||||||||||||
660 | - | |||||||||||||||||||
661 | d->running = false; | - | ||||||||||||||||||
662 | d->finished = false; | - | ||||||||||||||||||
663 | d->data->threadId = 0; | - | ||||||||||||||||||
664 | } never executed: end of block | 0 | ||||||||||||||||||
665 | } executed 620682 times by 512 tests: end of block Executed by:
| 620682 | ||||||||||||||||||
666 | - | |||||||||||||||||||
667 | void QThread::terminate() | - | ||||||||||||||||||
668 | { | - | ||||||||||||||||||
669 | #if !defined(Q_OS_ANDROID) | - | ||||||||||||||||||
670 | Q_D(QThread); | - | ||||||||||||||||||
671 | QMutexLocker locker(&d->mutex); | - | ||||||||||||||||||
672 | - | |||||||||||||||||||
673 | if (!d->data->threadId)
| 0-2 | ||||||||||||||||||
674 | return; never executed: return; | 0 | ||||||||||||||||||
675 | - | |||||||||||||||||||
676 | int code = pthread_cancel(from_HANDLE<pthread_t>(d->data->threadId)); | - | ||||||||||||||||||
677 | if (code) {
| 0-2 | ||||||||||||||||||
678 | qWarning("QThread::start: Thread termination error: %s", | - | ||||||||||||||||||
679 | qPrintable(qt_error_string((code)))); | - | ||||||||||||||||||
680 | } never executed: end of block | 0 | ||||||||||||||||||
681 | #endif | - | ||||||||||||||||||
682 | } executed 2 times by 1 test: end of block Executed by:
| 2 | ||||||||||||||||||
683 | - | |||||||||||||||||||
684 | bool QThread::wait(unsigned long time) | - | ||||||||||||||||||
685 | { | - | ||||||||||||||||||
686 | Q_D(QThread); | - | ||||||||||||||||||
687 | QMutexLocker locker(&d->mutex); | - | ||||||||||||||||||
688 | - | |||||||||||||||||||
689 | if (from_HANDLE<pthread_t>(d->data->threadId) == pthread_self()) {
| 0-620107 | ||||||||||||||||||
690 | qWarning("QThread::wait: Thread tried to wait on itself"); | - | ||||||||||||||||||
691 | return false; never executed: return false; | 0 | ||||||||||||||||||
692 | } | - | ||||||||||||||||||
693 | - | |||||||||||||||||||
694 | if (d->finished || !d->running)
| 10-613390 | ||||||||||||||||||
695 | return true; executed 6727 times by 428 tests: return true; Executed by:
| 6727 | ||||||||||||||||||
696 | - | |||||||||||||||||||
697 | while (d->running) {
| 613307-613380 | ||||||||||||||||||
698 | if (!d->thread_done.wait(locker.mutex(), time))
| 73-613307 | ||||||||||||||||||
699 | return false; executed 73 times by 4 tests: return false; Executed by:
| 73 | ||||||||||||||||||
700 | } executed 613307 times by 252 tests: end of block Executed by:
| 613307 | ||||||||||||||||||
701 | return true; executed 613307 times by 252 tests: return true; Executed by:
| 613307 | ||||||||||||||||||
702 | } | - | ||||||||||||||||||
703 | - | |||||||||||||||||||
704 | void QThread::setTerminationEnabled(bool enabled) | - | ||||||||||||||||||
705 | { | - | ||||||||||||||||||
706 | QThread *thr = currentThread(); | - | ||||||||||||||||||
707 | Q_ASSERT_X(thr != 0, "QThread::setTerminationEnabled()", | - | ||||||||||||||||||
708 | "Current thread was not started with QThread."); | - | ||||||||||||||||||
709 | - | |||||||||||||||||||
710 | Q_UNUSED(thr) | - | ||||||||||||||||||
711 | #if defined(Q_OS_ANDROID) | - | ||||||||||||||||||
712 | Q_UNUSED(enabled); | - | ||||||||||||||||||
713 | #else | - | ||||||||||||||||||
714 | pthread_setcancelstate(enabled ? PTHREAD_CANCEL_ENABLE : PTHREAD_CANCEL_DISABLE, NULL); | - | ||||||||||||||||||
715 | if (enabled)
| 2-166 | ||||||||||||||||||
716 | pthread_testcancel(); executed 166 times by 2 tests: pthread_testcancel(); Executed by:
| 166 | ||||||||||||||||||
717 | #endif | - | ||||||||||||||||||
718 | } executed 166 times by 2 tests: end of block Executed by:
| 166 | ||||||||||||||||||
719 | - | |||||||||||||||||||
720 | // Caller must lock the mutex | - | ||||||||||||||||||
721 | void QThreadPrivate::setPriority(QThread::Priority threadPriority) | - | ||||||||||||||||||
722 | { | - | ||||||||||||||||||
723 | priority = threadPriority; | - | ||||||||||||||||||
724 | - | |||||||||||||||||||
725 | // copied from start() with a few modifications: | - | ||||||||||||||||||
726 | - | |||||||||||||||||||
727 | #ifdef QT_HAS_THREAD_PRIORITY_SCHEDULING | - | ||||||||||||||||||
728 | int sched_policy; | - | ||||||||||||||||||
729 | sched_param param; | - | ||||||||||||||||||
730 | - | |||||||||||||||||||
731 | if (pthread_getschedparam(from_HANDLE<pthread_t>(data->threadId), &sched_policy, ¶m) != 0) {
| 0-17 | ||||||||||||||||||
732 | // failed to get the scheduling policy, don't bother setting | - | ||||||||||||||||||
733 | // the priority | - | ||||||||||||||||||
734 | qWarning("QThread::setPriority: Cannot get scheduler parameters"); | - | ||||||||||||||||||
735 | return; never executed: return; | 0 | ||||||||||||||||||
736 | } | - | ||||||||||||||||||
737 | - | |||||||||||||||||||
738 | int prio; | - | ||||||||||||||||||
739 | if (!calculateUnixPriority(priority, &sched_policy, &prio)) {
| 0-17 | ||||||||||||||||||
740 | // failed to get the scheduling parameters, don't | - | ||||||||||||||||||
741 | // bother setting the priority | - | ||||||||||||||||||
742 | qWarning("QThread::setPriority: Cannot determine scheduler priority range"); | - | ||||||||||||||||||
743 | return; never executed: return; | 0 | ||||||||||||||||||
744 | } | - | ||||||||||||||||||
745 | - | |||||||||||||||||||
746 | param.sched_priority = prio; | - | ||||||||||||||||||
747 | int status = pthread_setschedparam(from_HANDLE<pthread_t>(data->threadId), sched_policy, ¶m); | - | ||||||||||||||||||
748 | - | |||||||||||||||||||
749 | # ifdef SCHED_IDLE | - | ||||||||||||||||||
750 | // were we trying to set to idle priority and failed? | - | ||||||||||||||||||
751 | if (status == -1 && sched_policy == SCHED_IDLE && errno == EINVAL) {
| 0-17 | ||||||||||||||||||
752 | // reset to lowest priority possible | - | ||||||||||||||||||
753 | pthread_getschedparam(from_HANDLE<pthread_t>(data->threadId), &sched_policy, ¶m); | - | ||||||||||||||||||
754 | param.sched_priority = sched_get_priority_min(sched_policy); | - | ||||||||||||||||||
755 | pthread_setschedparam(from_HANDLE<pthread_t>(data->threadId), sched_policy, ¶m); | - | ||||||||||||||||||
756 | } never executed: end of block | 0 | ||||||||||||||||||
757 | # else | - | ||||||||||||||||||
758 | Q_UNUSED(status); | - | ||||||||||||||||||
759 | # endif // SCHED_IDLE | - | ||||||||||||||||||
760 | #endif | - | ||||||||||||||||||
761 | } executed 17 times by 2 tests: end of block Executed by:
| 17 | ||||||||||||||||||
762 | - | |||||||||||||||||||
763 | #endif // QT_NO_THREAD | - | ||||||||||||||||||
764 | - | |||||||||||||||||||
765 | QT_END_NAMESPACE | - | ||||||||||||||||||
766 | - | |||||||||||||||||||
Source code | Switch to Preprocessed file |