From 9512dd1522506eebf0c02d39f75b9ff360c967cd Mon Sep 17 00:00:00 2001
From: Andrej Babic <andrej.babic@psi.ch>
Date: Wed, 8 Apr 2020 15:38:27 +0200
Subject: [PATCH] Add is_receiving function to ZmqRecvModule

---
 core-writer/include/ZmqRecvModule.hpp    | 1 +
 core-writer/src/module/ZmqRecvModule.cpp | 5 +++++
 2 files changed, 6 insertions(+)

diff --git a/core-writer/include/ZmqRecvModule.hpp b/core-writer/include/ZmqRecvModule.hpp
index 7f861b7..6355516 100644
--- a/core-writer/include/ZmqRecvModule.hpp
+++ b/core-writer/include/ZmqRecvModule.hpp
@@ -27,6 +27,7 @@ public:
     void start_recv(const std::string& connect_address,
                const uint8_t n_receiving_threads);
     void stop_recv();
+    bool is_receiving();
 
     void start_saving();
     void stop_saving_and_clear_buffer();
diff --git a/core-writer/src/module/ZmqRecvModule.cpp b/core-writer/src/module/ZmqRecvModule.cpp
index 1bcb143..11491a9 100644
--- a/core-writer/src/module/ZmqRecvModule.cpp
+++ b/core-writer/src/module/ZmqRecvModule.cpp
@@ -84,6 +84,11 @@ void ZmqRecvModule::stop_recv()
     receiving_threads_.clear();
 }
 
+bool ZmqRecvModule::is_receiving()
+{
+    return is_receiving_;
+}
+
 void ZmqRecvModule::start_saving()
 {
     #ifdef DEBUG_OUTPUT