diff options
author | Jan Holthuis <jan.holthuis@ruhr-uni-bochum.de> | 2020-01-07 15:41:11 +0100 |
---|---|---|
committer | Jan Holthuis <jan.holthuis@ruhr-uni-bochum.de> | 2020-01-07 15:41:11 +0100 |
commit | 1b5ab66726aa649151be793f83b128848e6cb9c7 (patch) | |
tree | ffc38b2fb22f65f7bf7efdb54b56541ccf428198 /src/engine/cachingreader | |
parent | b591fc2f3b212ee2f866182d3afabb0c72c66f04 (diff) |
Use loadAcquire() for certain atomic load calls
Diffstat (limited to 'src/engine/cachingreader')
-rw-r--r-- | src/engine/cachingreader/cachingreader.cpp | 2 | ||||
-rw-r--r-- | src/engine/cachingreader/cachingreaderworker.cpp | 2 |
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) { |