TDE
/
tqt3
mirror of https://mirror.git.trinitydesktop.org/gitea/TDE/tqt3
0
0
Fork 0
Code Issues Releases Wiki Activity

Added safety harness for currentThreadObject() usage.

Browse Source 
currentThreadObject() returns a null pointer if the
current thread was not started using the TQThread API.
This relates to bug 1748.

Signed-off-by: Michele Calgaro <michele.calgaro@yahoo.it>
pull/1/head
Michele Calgaro 10 years ago
parent 42dcb07b26
commit caab7b3557
2 changed files with 25 additions and 7 deletions
Show Stats Download Patch File Download Diff File

8
src/kernel/qeventloop_unix_glib.cpp
Unescape View File

@ -688,7 +688,9 @@ int TQEventLoop::activateTimers()
TQTimerEvent e( t->id ); TQTimerEvent e( t->id );
#if defined(QT_THREAD_SUPPORT) #if defined(QT_THREAD_SUPPORT)
// Be careful...the current thread may not be the target object's thread! // Be careful...the current thread may not be the target object's thread!
if ((!t->obj) || (TQThread::currentThreadObject()->threadPostedEventsDisabled()) || (t->obj && (t->obj->contextThreadObject() == TQThread::currentThreadObject()))) { if ((!t->obj) ||
(TQThread::currentThreadObject() && TQThread::currentThreadObject()->threadPostedEventsDisabled()) ||
(t->obj && t->obj->contextThreadObject() == TQThread::currentThreadObject())) {
TQApplication::sendEvent( t->obj, &e ); // send event TQApplication::sendEvent( t->obj, &e ); // send event
} }
else { else {
@ -731,7 +733,9 @@ int TQEventLoop::activateSocketNotifiers()
sn->pending = FALSE; sn->pending = FALSE;
#if defined(QT_THREAD_SUPPORT) #if defined(QT_THREAD_SUPPORT)
// Be careful...the current thread may not be the target object's thread! // Be careful...the current thread may not be the target object's thread!
if ((!sn->obj) || (TQThread::currentThreadObject()->threadPostedEventsDisabled()) || (sn->obj && (sn->obj->contextThreadObject() == TQThread::currentThreadObject()))) { if ((!sn->obj) ||
(TQThread::currentThreadObject() && TQThread::currentThreadObject()->threadPostedEventsDisabled()) ||
(sn->obj && sn->obj->contextThreadObject() == TQThread::currentThreadObject())) {
TQApplication::sendEvent( sn->obj, &event ); // send event TQApplication::sendEvent( sn->obj, &event ); // send event
} }
else { else {

24
src/kernel/qobject.cpp
Unescape View File

@ -203,9 +203,10 @@ void TQObject::moveToThread(TQThread *targetThread)
} }
TQThread *objectThread = contextThreadObject(); TQThread *objectThread = contextThreadObject();
// NOTE currentThread could be NULL if the current thread was not started using the TQThread API
TQThread *currentThread = TQThread::currentThreadObject(); TQThread *currentThread = TQThread::currentThreadObject();
if (objectThread != currentThread) { if (currentThread && objectThread != currentThread) {
#if defined(QT_DEBUG) #if defined(QT_DEBUG)
tqWarning( "TQObject::moveToThread: Current thread is not the object's thread" ); tqWarning( "TQObject::moveToThread: Current thread is not the object's thread" );
#endif #endif
@ -2760,6 +2761,7 @@ void TQObject::activate_signal( TQConnectionList *clist, TQUObject *o )
} }
#endif #endif
// NOTE currentThread could be NULL if the current thread was not started using the TQThread API
const TQThread *currentThread = TQThread::currentThreadObject(); const TQThread *currentThread = TQThread::currentThreadObject();
TQObject *object; TQObject *object;
@ -2779,7 +2781,10 @@ void TQObject::activate_signal( TQConnectionList *clist, TQUObject *o )
sol->currentSender = this; sol->currentSender = this;
} }
if ( c->memberType() == TQSIGNAL_CODE ) { if ( c->memberType() == TQSIGNAL_CODE ) {
if ((d->disableThreadPostedEvents) || (object->d->disableThreadPostedEvents) || (currentThread->threadPostedEventsDisabled()) || (object->d->ownThread == currentThread)) { if ((d->disableThreadPostedEvents) ||
(object->d->disableThreadPostedEvents) ||
(currentThread && currentThread->threadPostedEventsDisabled()) ||
(currentThread && object->d->ownThread == currentThread)) {
#ifdef QT_THREAD_SUPPORT #ifdef QT_THREAD_SUPPORT
sol->listMutex->unlock(); sol->listMutex->unlock();
#endif // QT_THREAD_SUPPORT #endif // QT_THREAD_SUPPORT
@ -2798,7 +2803,10 @@ void TQObject::activate_signal( TQConnectionList *clist, TQUObject *o )
} }
} }
else { else {
if ((d->disableThreadPostedEvents) || (object->d->disableThreadPostedEvents) || (currentThread->threadPostedEventsDisabled()) || (object->d->ownThread == currentThread)) { if ((d->disableThreadPostedEvents) ||
(object->d->disableThreadPostedEvents) ||
(currentThread && currentThread->threadPostedEventsDisabled()) ||
(currentThread && object->d->ownThread == currentThread)) {
#ifdef QT_THREAD_SUPPORT #ifdef QT_THREAD_SUPPORT
sol->listMutex->unlock(); sol->listMutex->unlock();
#endif // QT_THREAD_SUPPORT #endif // QT_THREAD_SUPPORT
@ -2846,7 +2854,10 @@ void TQObject::activate_signal( TQConnectionList *clist, TQUObject *o )
sol->currentSender = this; sol->currentSender = this;
} }
if ( c->memberType() == TQSIGNAL_CODE ) { if ( c->memberType() == TQSIGNAL_CODE ) {
if ((d->disableThreadPostedEvents) || (object->d->disableThreadPostedEvents) || (currentThread->threadPostedEventsDisabled()) || (object->d->ownThread == currentThread)) { if ((d->disableThreadPostedEvents) ||
(object->d->disableThreadPostedEvents) ||
(currentThread && currentThread->threadPostedEventsDisabled()) ||
(currentThread && object->d->ownThread == currentThread)) {
#ifdef QT_THREAD_SUPPORT #ifdef QT_THREAD_SUPPORT
sol->listMutex->unlock(); sol->listMutex->unlock();
#endif // QT_THREAD_SUPPORT #endif // QT_THREAD_SUPPORT
@ -2865,7 +2876,10 @@ void TQObject::activate_signal( TQConnectionList *clist, TQUObject *o )
} }
} }
else { else {
if ((d->disableThreadPostedEvents) || (object->d->disableThreadPostedEvents) || (currentThread->threadPostedEventsDisabled()) || (object->d->ownThread == currentThread)) { if ((d->disableThreadPostedEvents) ||
(object->d->disableThreadPostedEvents) ||
(currentThread && currentThread->threadPostedEventsDisabled()) ||
(currentThread && object->d->ownThread == currentThread)) {
#ifdef QT_THREAD_SUPPORT #ifdef QT_THREAD_SUPPORT
sol->listMutex->unlock(); sol->listMutex->unlock();
#endif // QT_THREAD_SUPPORT #endif // QT_THREAD_SUPPORT

Write Preview
Loading…
Cancel
Save