fix(core-clp): Resolve lost wake-up issue in NetworkReader after a …

…download is aborted. (#663)
y-scope · Jan 14, 2025 · 1ecd9c7 · 1ecd9c7
1 parent 57bc265
commit 1ecd9c7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/components/core/src/clp/NetworkReader.cpp b/components/core/src/clp/NetworkReader.cpp
@@ -252,10 +252,10 @@ auto NetworkReader::acquire_empty_buffer() -> void {
     }
     std::unique_lock<std::mutex> buffer_resource_lock{m_buffer_resource_mutex};
     while (m_filled_buffer_queue.size() == m_buffer_pool_size) {
-        m_downloader_cv.wait(buffer_resource_lock);
         if (is_abort_download_requested()) {
             return;
         }
+        m_downloader_cv.wait(buffer_resource_lock);
     }
     m_curr_downloader_buf.emplace(
             m_buffer_pool.at(m_curr_downloader_buf_idx).data(),