Add ZMQ to Cbmroot deps + ZMQ iface & boost deser. example to histserv_nofairmq

CMakeLists.txt

@@ -129,6 +129,13 @@ if(FAIRROOT_FOUND)
 endif()
 
 
+#Searching for Boost Package
+find_package(ZeroMQ)
+if(ZeroMQ_FOUND)
+  list(APPEND packages ZeroMQ)
+endif()
+
+
 #Searching for Boost Package
 find_package(Boost COMPONENTS serialization regex filesystem log log_setup container program_options thread)
 if(Boost_FOUND)

services/histserv/Roadmap.md

+Histo source: class/lib + EventBuildChain
+
+- Members: hostname, port, ZMQ socket, list of known histo names
+
+- Interface method/constructor: init socket
+  => Type? PUB or PUSH?
+- Interface function: new entry <histo name, histo, (folder)>
+  => Check if histo already known
+     => No = add config part to message with <histo name, folder>
+  => Add part to message with <histo name, histo>
+     -> How do we stream the Histo1D object? boost streamer call?
+
+- Message format
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
+Histo consummer: histserv
+
+- Members: ZMQ socket
+- Interface function: init socket
+  => Type? SUB or PULL?
+  => PULL
+- Exec method: ZMQ poll/get loop
+  => Blocking?
+  => Exit condition?
+- Config deserialization: boost?
+- Histos deserialization: boost?
+- Message processing: parts + calls to deserialization methods for Config and histo depending on size

services/histserv/app/Application.h

@@ -8,9 +8,9 @@
 #include "THttpServer.h"
 #include "TObjArray.h"
 
-#include <memory>
 #include <string>
 #include <thread>
+#include <zmq.hpp>
 
 #include "ProgramOptions.h"
 
@@ -43,15 +43,12 @@ namespace cbm::services::histserv
     void UpdateHttpServer();
 
   private:
-    const std::string& OutputFile() const;
-    const std::string& ParamFile() const;
-    const std::string& SetupTag() const;
     //const std::string& ConfigFile() const;
 
-    bool ReceiveData(/*FIXME_SOMETHING_To_Replace_FairMQ& parts*/);
-    bool ReceiveHistoConfig(/*FIXME_SOMETHING_To_Replace_FairMQ& parts*/);
-    bool ReceiveCanvasConfig(/*FIXME_SOMETHING_To_Replace_FairMQ& parts*/);
-    bool ReceiveConfigAndData(/*FIXME_SOMETHING_To_Replace_FairMQ& parts*/);
+    bool ReceiveData(zmq::message_t& msg);
+    bool ReceiveHistoConfig(zmq::message_t& msg);
+    bool ReceiveCanvasConfig(zmq::message_t& msg);
+    bool ReceiveConfigAndData(std::vector<zmq::message_t>& vMsg);
 
     template<class HistoT>
     bool ReadHistogram(HistoT* pHist);
@@ -67,6 +64,10 @@ namespace cbm::services::histserv
     std::thread fThread;
     bool fStopThread = false;
 
+    /// Interface
+    zmq::context_t fZmqContext {1};
+    zmq::socket_t fZmqSocket {fZmqContext, ZMQ_PULL};
+
     /// Array of histograms with unique names
     TObjArray fArrayHisto;
     /// Vector of string with ( HistoName, FolderPath ) to configure the histogram

services/histserv/app/CMakeLists.txt

@@ -38,6 +38,8 @@ target_link_libraries(histserv_nofairmq
     ROOT::Hist
     ROOT::RIO
     ROOT::RHTTP
+    libzmq
+    cppzmq
   )
 
 install(TARGETS histserv_nofairmq DESTINATION bin)

services/histserv/app/ProgramOptions.cxx

@@ -34,8 +34,9 @@ namespace cbm::services::histserv
     // --- Define configuration options
     po::options_description config("Configuration");
     auto config_add = config.add_options();
-    config_add("input,i", po::value<string>(&fsChanHistosIn)->value_name("<???????>"),
-               "name or host:port or whatever is needed for input channel (histos/canvases config and data)");
+    config_add("input,i", po::value<string>(&fsChanHistosIn)->value_name("<protocol://xxxxxx>"),
+               "name or host:port or whatever is needed for input channel (histos/canvases config and data), "
+               " cf http://api.zeromq.org/2-1:zmq-bind");
     config_add("port,p", po::value<uint32_t>(&fuHttpServerPort)->default_value(8080),
                "port on which the http ROOT server (JSroot) will be available");
     config_add("output,o", po::value<string>(&fsHistoFileName)->value_name("<file name>"),