summaryrefslogtreecommitdiffstats
path: root/src/engine/cachingreader
diff options
context:
space:
mode:
authorJan Holthuis <jan.holthuis@ruhr-uni-bochum.de>2020-01-07 15:41:11 +0100
committerJan Holthuis <jan.holthuis@ruhr-uni-bochum.de>2020-01-07 15:41:11 +0100
commit1b5ab66726aa649151be793f83b128848e6cb9c7 (patch)
treeffc38b2fb22f65f7bf7efdb54b56541ccf428198 /src/engine/cachingreader
parentb591fc2f3b212ee2f866182d3afabb0c72c66f04 (diff)
Use loadAcquire() for certain atomic load calls
Diffstat (limited to 'src/engine/cachingreader')
-rw-r--r--src/engine/cachingreader/cachingreader.cpp2
-rw-r--r--src/engine/cachingreader/cachingreaderworker.cpp2
2 files changed, 2 insertions, 2 deletions
diff --git a/src/engine/cachingreader/cachingreader.cpp b/src/engine/cachingreader/cachingreader.cpp
index 9a7a08d6f3..0ebc44b405 100644
--- a/src/engine/cachingreader/cachingreader.cpp
+++ b/src/engine/cachingreader/cachingreader.cpp
@@ -231,7 +231,7 @@ void CachingReader::process() {
update.status == CHUNK_READ_EOF ||
update.status == CHUNK_READ_INVALID ||
update.status == CHUNK_READ_DISCARDED);
- if (atomicLoadRelaxed(m_state) == STATE_TRACK_LOADING) {
+ if (atomicLoadAcquire(m_state) == STATE_TRACK_LOADING) {
// Discard all results from pending read requests for the
// previous track before the next track has been loaded.
freeChunk(pChunk);
diff --git a/src/engine/cachingreader/cachingreaderworker.cpp b/src/engine/cachingreader/cachingreaderworker.cpp
index 59734c40d2..5f2182acc4 100644
--- a/src/engine/cachingreader/cachingreaderworker.cpp
+++ b/src/engine/cachingreader/cachingreaderworker.cpp
@@ -89,7 +89,7 @@ void CachingReaderWorker::run() {
QThread::currentThread()->setObjectName(QString("CachingReaderWorker %1").arg(++id));
Event::start(m_tag);
- while (!atomicLoadRelaxed(m_stop)) {
+ while (!atomicLoadAcquire(m_stop)) {
// Request is initialized by reading from FIFO
CachingReaderChunkReadRequest request;
if (m_newTrackAvailable) {