services/histserv/app/Application.h

Go to the documentation of this file.

/* Copyright (C) 2023 Facility for Antiproton and Ion Research in Europe, Darmstadt
   SPDX-License-Identifier: GPL-3.0-only
   Authors: Pierre-Alain Loizeau [committer] */
 
#ifndef CBM_SERVICES_HISTSERV_APP_APPLICATION_H
#define CBM_SERVICES_HISTSERV_APP_APPLICATION_H 1
 
#include "Histogram.h"
#include "ProgramOptions.h"
#include "THttpServer.h"
#include "TObjArray.h"
#include "ui_callbacks.h"
 
#include <csignal>
#include <forward_list>
#include <memory>
#include <string>
#include <string_view>
#include <thread>
#include <zmq.hpp>
 
class TCanvas;
class TNamed;
 
namespace cbm::services::histserv
{
  struct AppConfig {
    int fNofTsToStore = 400;  
  };
 
  class Application {
 
   public:
    explicit Application(ProgramOptions const& opt, volatile sig_atomic_t* signalStatus);
 
    Application(const Application&) = delete;
 
    void operator=(const Application&) = delete;
 
    ~Application();
 
    void Exec();
 
    void UpdateHttpServer();
 
   private:
    //template<class HistoSrc>
    //bool CollectHistograms(const std::forward_list<HistoSrc>& container);
 
    //const std::string& ConfigFile() const;
    int FindHistogram(const std::string& name);
 
    bool ResetHistograms();
 
    template<class HistoDst, class HistoSrc>
    bool ReadHistogram(const HistoSrc& rHist);
 
    template<class HistoSrc>
    bool ReadHistogramExtendedTsId(const HistoSrc& pHistSrc, uint64_t tsIndex);
 
    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);
 
    bool RegisterHistoConfig(const std::pair<std::string, std::string>& config);
 
    bool RegisterHistogram(const TNamed* hist);
 
    bool PrepareCanvas(uint32_t uCanvIdx);
 
    bool SaveHistograms();
 
    //static void SignalHandler(int signal);
 
   private:
    ProgramOptions const& fOpt;      
    volatile sig_atomic_t* fSignalStatus;  
    THttpServer* fServer = nullptr;  
    std::thread fThread;
    bool fStopThread = false;
 
    std::unique_ptr<UiCmdActor> fUiCmdActor;
 
    zmq::context_t fZmqContext {1};
    zmq::socket_t fZmqSocket {fZmqContext, ZMQ_PULL};
 
    TObjArray fArrayHisto;
    std::vector<std::pair<std::string, std::string>> fvpsHistosFolder = {};
    std::vector<std::pair<std::string, std::string>> fvpsCanvasConfig = {};
    std::vector<bool> fvbCanvasReady                                  = {};
    bool fbAllCanvasReady                                             = false;
    AppConfig fConfig;
 
    std::vector<std::pair<TNamed*, std::string>> fvHistos  = {};  
    std::vector<bool> fvbHistoRegistered                   = {};
    bool fbAllHistosRegistered                             = false;
    std::vector<std::pair<TCanvas*, std::string>> fvCanvas = {};  
    std::vector<bool> fvbCanvasRegistered                  = {};
    bool fbAllCanvasRegistered                             = false;
 
    uint32_t fNMessages = 0;
  };
 
}  // namespace cbm::services::histserv
 
#endif /* CBM_SERVICES_HISTSERV_APP_APPLICATION_H */