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

Encapsulate is_writing_ flag

Browse Source
This commit is contained in:
babic_a
2020-04-01 16:00:05 +02:00
parent 69fb522efd
commit 5d5fde82f8
2 changed files with 18 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/include/ZmqRecvModule.hpp
+5 -3
View File
@@ -11,8 +11,8 @@ class ZmqRecvModule
RingBuffer& ring_buffer_;
const header_map& header_values_;
const std::atomic_bool& is_writing_;
std::atomic_bool is_receiving_;
std::atomic_bool is_writing_;
std::vector<std::thread> receiving_threads_;
protected:
@@ -22,13 +22,15 @@ protected:
public:
ZmqRecvModule(
RingBuffer& ring_buffer,
const header_map& header_values,
const std::atomic_bool& is_writing);
const header_map& header_values);
void start_recv(const std::string& connect_address,
const uint8_t n_receiving_threads);
void stop_recv();
void start_writing();
void stop_writing();
};
core-writer/src/ZmqRecvModule.cpp
+13 -4
View File
@@ -8,12 +8,11 @@ using namespace std;
ZmqRecvModule::ZmqRecvModule(
RingBuffer &ringBuffer,
const header_map &header_values,
const std::atomic_bool& is_writing) :
const header_map &header_values) :
ring_buffer_(ring_buffer_),
header_values_(header_values),
is_writing_(is_writing),
is_receiving_(false)
is_receiving_(false),
is_writing_(false)
{}
void ZmqRecvModule::start_recv(
@@ -69,6 +68,16 @@ void ZmqRecvModule::stop_recv()
receiving_threads_.clear();
}
void ZmqRecvModule::start_writing()
{
is_writing_ = true;
}
void ZmqRecvModule::stop_writing()
{
is_writing_ = false;
}
void ZmqRecvModule::receive_thread(const string& connect_address)
{
ZmqReceiver receiver(