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

Fix syntactic problems with RingBuffer

Browse Source
This commit is contained in:
babic_a
2019-04-26 15:33:01 +02:00
parent b8803b1e04
commit 32a025f0fc
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/src/RingBuffer.cpp
+5 -5
View File
@@ -36,7 +36,7 @@ void RingBuffer::initialize(size_t slot_size)
using namespace chrono;
error_message << "[" << system_clock::now() << "]";
error_message << "[RingBuffer::initialize] Ring buffer";
error_message << already initialized." << endl;
error_message << " already initialized." << endl;
throw runtime_error(error_message.str());
}
@@ -262,13 +262,13 @@ bool RingBuffer::is_empty()
return buffer_used_slots == 0;
}
bool RingBuffer::clear()
void RingBuffer::clear()
{
lock_guard<mutex> lock(ringbuffer_slots_mutex);
lock_guard<mutex> lock(frame_metadata_queue_mutex);
lock_guard<mutex> lock_slots(ringbuffer_slots_mutex);
lock_guard<mutex> lock_metadata(frame_metadata_queue_mutex);
write_index = 0;
buffer_used_slots == 0;
buffer_used_slots = 0;
ringbuffer_slots = vector<bool>(n_slots, 0);
frame_metadata_queue.clear();
}