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

Adjust modules to use the template version of RingBuffer

Browse Source
This commit is contained in:
babic_a
2020-04-15 10:43:57 +02:00
parent 22e0af6200
commit 98da2ec0de
4 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/include/H5WriteModule.hpp
+2 -2
View File
@@ -9,7 +9,7 @@
class H5WriteModule {
typedef std::unordered_map<std::string, HeaderDataType> header_map;
RingBuffer& ring_buffer_;
RingBuffer<FrameMetadata>& ring_buffer_;
const header_map& header_values_;
const H5Format& format_;
std::atomic_bool is_writing_;
@@ -23,7 +23,7 @@ protected:
public:
H5WriteModule(
RingBuffer& ring_buffer,
RingBuffer<FrameMetadata>& ring_buffer,
const header_map& header_values,
const H5Format& format);
core-writer/include/ZmqRecvModule.hpp
+2 -2
View File
@@ -9,7 +9,7 @@ class ZmqRecvModule
{
typedef std::unordered_map<std::string, HeaderDataType> header_map;
RingBuffer& ring_buffer_;
RingBuffer<FrameMetadata>& ring_buffer_;
const header_map& header_values_;
std::atomic_bool is_receiving_;
std::atomic_bool is_saving_;
@@ -21,7 +21,7 @@ protected:
public:
ZmqRecvModule(
RingBuffer& ring_buffer,
RingBuffer<FrameMetadata>& ring_buffer,
const header_map& header_values);
virtual ~ZmqRecvModule();
core-writer/src/module/H5WriteModule.cpp
+1 -1
View File
@@ -7,7 +7,7 @@
using namespace std;
H5WriteModule::H5WriteModule(
RingBuffer& ring_buffer,
RingBuffer<FrameMetadata>& ring_buffer,
const header_map& header_values,
const H5Format& format) :
ring_buffer_(ring_buffer),
core-writer/src/module/ZmqRecvModule.cpp
+3 -1
View File
@@ -7,7 +7,7 @@
using namespace std;
ZmqRecvModule::ZmqRecvModule(
RingBuffer &ring_buffer,
RingBuffer<FrameMetadata> &ring_buffer,
const header_map &header_values) :
ring_buffer_(ring_buffer),
header_values_(header_values),
@@ -144,6 +144,8 @@ void ZmqRecvModule::receive_thread(const string& connect_address)
continue;
}
cout <<" Something!!!"<< endl;
if (!is_saving_) {
continue;
}