Fixed bug in queue slot allocation

(Of course it can really happen!)
2026-04-30 12:12:23 +02:00 · 2020-05-06 10:29:33 +02:00
parent 7b524501c0
commit b31b6cddf9
1 changed files with 1 additions and 1 deletions
@@ -103,7 +103,7 @@ void LiveRecvModule::receive_thread(const size_t n_modules, void* ctx_)
        }

        uint64_t current_pulse_id = 0;
-        auto slot_id = queue_.read();
+        auto slot_id = queue_.reserve();
        if (slot_id == -1) throw runtime_error("This cannot really happen");

        auto metadata = queue_.get_metadata_buffer(slot_id);