sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-04-28 20:02:22 +02:00
Code Issues Packages Projects Releases Wiki Activity

Make RingBuffer initialization thread safe

Browse Source
This commit is contained in:
babic_a
2020-04-03 15:38:15 +02:00
parent d571cdfed7
commit 233c483fc7
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/src/RingBuffer.cpp
+7 -2
View File
@@ -69,9 +69,14 @@ void RingBuffer::initialize(size_t slot_size)
char* RingBuffer::reserve(shared_ptr<FrameMetadata> frame_metadata)
{
// TODO: Synchronize this as well.
if (!ring_buffer_initialized_) {
initialize(frame_metadata->frame_bytes_size);
{
lock_guard<mutex> lock(ringbuffer_slots_mutex_);
if (!ring_buffer_initialized_) {
initialize(frame_metadata->frame_bytes_size);
}
}
}
if (frame_metadata->frame_bytes_size > slot_size_) {