diff --git a/core-writer/include/H5WriteModule.hpp b/core-writer/include/H5WriteModule.hpp index 07430fa..1cc8fd1 100644 --- a/core-writer/include/H5WriteModule.hpp +++ b/core-writer/include/H5WriteModule.hpp @@ -9,7 +9,7 @@ class H5WriteModule { typedef std::unordered_map header_map; - RingBuffer& ring_buffer_; + RingBuffer& 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& ring_buffer, const header_map& header_values, const H5Format& format); diff --git a/core-writer/include/ZmqRecvModule.hpp b/core-writer/include/ZmqRecvModule.hpp index 36f1b64..f414926 100644 --- a/core-writer/include/ZmqRecvModule.hpp +++ b/core-writer/include/ZmqRecvModule.hpp @@ -9,7 +9,7 @@ class ZmqRecvModule { typedef std::unordered_map header_map; - RingBuffer& ring_buffer_; + RingBuffer& 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& ring_buffer, const header_map& header_values); virtual ~ZmqRecvModule(); diff --git a/core-writer/src/module/H5WriteModule.cpp b/core-writer/src/module/H5WriteModule.cpp index 5fa6ba2..0ef1c2d 100644 --- a/core-writer/src/module/H5WriteModule.cpp +++ b/core-writer/src/module/H5WriteModule.cpp @@ -7,7 +7,7 @@ using namespace std; H5WriteModule::H5WriteModule( - RingBuffer& ring_buffer, + RingBuffer& ring_buffer, const header_map& header_values, const H5Format& format) : ring_buffer_(ring_buffer), diff --git a/core-writer/src/module/ZmqRecvModule.cpp b/core-writer/src/module/ZmqRecvModule.cpp index 1ced3a7..a168c59 100644 --- a/core-writer/src/module/ZmqRecvModule.cpp +++ b/core-writer/src/module/ZmqRecvModule.cpp @@ -7,7 +7,7 @@ using namespace std; ZmqRecvModule::ZmqRecvModule( - RingBuffer &ring_buffer, + RingBuffer &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; }