diff options
author | Uwe Klotz <uklotz@mixxx.org> | 2020-06-07 16:14:41 +0200 |
---|---|---|
committer | Uwe Klotz <uklotz@mixxx.org> | 2020-06-07 16:14:41 +0200 |
commit | 54cd0e8e0be91888803635bf335a3b46bbe137cd (patch) | |
tree | 5ed321322ad24f24be86a30384fb036f7d4999ba /src/network | |
parent | 53873ee735b7cf8e9316a554b2bc67af3431839c (diff) | |
parent | 1fd6b1e2deee84ca45ffff7daf1eb988a403b4e3 (diff) |
Merge branch '2.3' of git@github.com:mixxxdj/mixxx.git
Diffstat (limited to 'src/network')
-rw-r--r-- | src/network/jsonwebtask.cpp | 10 | ||||
-rw-r--r-- | src/network/webtask.cpp | 14 |
2 files changed, 12 insertions, 12 deletions
diff --git a/src/network/jsonwebtask.cpp b/src/network/jsonwebtask.cpp index 6202a48759..74a30e5fbc 100644 --- a/src/network/jsonwebtask.cpp +++ b/src/network/jsonwebtask.cpp @@ -3,12 +3,12 @@ #include <QMetaMethod> #include <QMimeDatabase> #include <QNetworkRequest> -#include <QThread> #include <QTimerEvent> #include <mutex> // std::once_flag #include "util/counter.h" #include "util/logger.h" +#include "util/thread_affinity.h" namespace mixxx { @@ -222,7 +222,7 @@ bool JsonWebTask::doStart( QNetworkAccessManager* networkAccessManager, int parentTimeoutMillis) { Q_UNUSED(parentTimeoutMillis); - DEBUG_ASSERT(thread() == QThread::currentThread()); + DEBUG_ASSERT_QOBJECT_THREAD_AFFINITY(this); DEBUG_ASSERT(networkAccessManager); VERIFY_OR_DEBUG_ASSERT(!m_pendingNetworkReply) { kLogger.warning() @@ -269,7 +269,7 @@ bool JsonWebTask::doStart( } QUrl JsonWebTask::doAbort() { - DEBUG_ASSERT(thread() == QThread::currentThread()); + DEBUG_ASSERT_QOBJECT_THREAD_AFFINITY(this); QUrl requestUrl; if (m_pendingNetworkReply) { requestUrl = abortPendingNetworkReply(m_pendingNetworkReply); @@ -283,7 +283,7 @@ QUrl JsonWebTask::doAbort() { } QUrl JsonWebTask::doTimeOut() { - DEBUG_ASSERT(thread() == QThread::currentThread()); + DEBUG_ASSERT_QOBJECT_THREAD_AFFINITY(this); QUrl requestUrl; if (m_pendingNetworkReply) { requestUrl = timeOutPendingNetworkReply(m_pendingNetworkReply); @@ -295,7 +295,7 @@ QUrl JsonWebTask::doTimeOut() { } void JsonWebTask::slotNetworkReplyFinished() { - DEBUG_ASSERT(thread() == QThread::currentThread()); + DEBUG_ASSERT_QOBJECT_THREAD_AFFINITY(this); const QPair<QNetworkReply*, HttpStatusCode> networkReplyWithStatusCode = receiveNetworkReply(); auto* const networkReply = networkReplyWithStatusCode.first; diff --git a/src/network/webtask.cpp b/src/network/webtask.cpp index 1b0950b642..49cc3fc819 100644 --- a/src/network/webtask.cpp +++ b/src/network/webtask.cpp @@ -1,12 +1,12 @@ #include "network/webtask.h" -#include <QThread> #include <QTimerEvent> #include <mutex> // std::once_flag #include "util/assert.h" #include "util/counter.h" #include "util/logger.h" +#include "util/thread_affinity.h" namespace mixxx { @@ -166,7 +166,7 @@ void WebTask::invokeAbort() { } void WebTask::slotStart(int timeoutMillis) { - DEBUG_ASSERT(thread() == QThread::currentThread()); + DEBUG_ASSERT_QOBJECT_THREAD_AFFINITY(this); DEBUG_ASSERT(m_status != Status::Pending); VERIFY_OR_DEBUG_ASSERT(m_networkAccessManager) { onNetworkError( @@ -207,7 +207,7 @@ void WebTask::slotStart(int timeoutMillis) { QUrl WebTask::abortPendingNetworkReply( QNetworkReply* pendingNetworkReply) { - DEBUG_ASSERT(thread() == QThread::currentThread()); + DEBUG_ASSERT_QOBJECT_THREAD_AFFINITY(this); DEBUG_ASSERT(pendingNetworkReply); if (pendingNetworkReply->isRunning()) { pendingNetworkReply->abort(); @@ -219,7 +219,7 @@ QUrl WebTask::abortPendingNetworkReply( QUrl WebTask::timeOutPendingNetworkReply( QNetworkReply* pendingNetworkReply) { - DEBUG_ASSERT(thread() == QThread::currentThread()); + DEBUG_ASSERT_QOBJECT_THREAD_AFFINITY(this); DEBUG_ASSERT(pendingNetworkReply); if (pendingNetworkReply->isRunning()) { //pendingNetworkReply->abort(); @@ -230,7 +230,7 @@ QUrl WebTask::timeOutPendingNetworkReply( } QUrl WebTask::abort() { - DEBUG_ASSERT(thread() == QThread::currentThread()); + DEBUG_ASSERT_QOBJECT_THREAD_AFFINITY(this); if (m_status != Status::Pending) { DEBUG_ASSERT(m_timeoutTimerId == kInvalidTimerId); return QUrl(); @@ -252,7 +252,7 @@ void WebTask::slotAbort() { } void WebTask::timerEvent(QTimerEvent* event) { - DEBUG_ASSERT(thread() == QThread::currentThread()); + DEBUG_ASSERT_QOBJECT_THREAD_AFFINITY(this); const auto timerId = event->timerId(); DEBUG_ASSERT(timerId != kInvalidTimerId); if (timerId != m_timeoutTimerId) { @@ -270,7 +270,7 @@ void WebTask::timerEvent(QTimerEvent* event) { } QPair<QNetworkReply*, HttpStatusCode> WebTask::receiveNetworkReply() { - DEBUG_ASSERT(thread() == QThread::currentThread()); + DEBUG_ASSERT_QOBJECT_THREAD_AFFINITY(this); DEBUG_ASSERT(m_status != Status::Idle); auto* const networkReply = qobject_cast<QNetworkReply*>(sender()); HttpStatusCode statusCode = kHttpStatusCodeInvalid; |