sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-05-03 23:34:14 +02:00
Code Issues Packages Projects Releases Wiki Activity

Revert "Add counter for frames to save instead of just flag"

Browse Source 
This reverts commit 16612a2d
This commit is contained in:
babic_a
2020-04-08 15:04:56 +02:00
parent 2e9568da8d
commit 9518f03deb
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/include/ZmqRecvModule.hpp
+4 -6
View File
@@ -12,7 +12,7 @@ class ZmqRecvModule
RingBuffer& ring_buffer_;
const header_map& header_values_;
std::atomic_bool is_receiving_;
std::atomic_int n_frames_to_save_;
std::atomic_bool is_saving_;
std::vector<std::thread> receiving_threads_;
protected:
@@ -24,14 +24,12 @@ public:
RingBuffer& ring_buffer,
const header_map& header_values);
void start_recv(
const std::string& connect_address,
const uint8_t n_receiving_threads);
void start_recv(const std::string& connect_address,
const uint8_t n_receiving_threads);
void stop_recv();
void start_saving(const int n_frames = -1);
void start_saving();
void stop_saving();
bool is_saving();
};
#endif