CbmMqHistoServer.h

Go to the documentation of this file.

/* Copyright (C) 2019-2021 GSI Helmholtzzentrum fuer Schwerionenforschung, Darmstadt
   SPDX-License-Identifier: GPL-3.0-only
   Authors: Pierre-Alain Loizeau [committer] */
 
#ifndef CBMMQHISTOSERVER_H
#define CBMMQHISTOSERVER_H
 
#include "FairMQDevice.h"
 
#include "THttpServer.h"
#include "TObjArray.h"
#include <thread>
 
#include <memory>
#include <string>
 
class TNamed;
class TCanvas;
 
class CbmMqHistoServer : public FairMQDevice {
public:
  CbmMqHistoServer();
 
  virtual ~CbmMqHistoServer();
 
  void UpdateHttpServer();
 
protected:
  virtual void InitTask();
 
  bool ReceiveData(FairMQMessagePtr& msg, int index);
 
  bool ReceiveHistoConfig(FairMQMessagePtr& msg, int index);
 
  bool ReceiveCanvasConfig(FairMQMessagePtr& msg, int index);
 
  bool ReceiveConfigAndData(FairMQParts& msg, int index);
 
  virtual void PreRun();
 
  virtual void PostRun();
 
private:
  std::string fsChannelNameHistosInput  = "histogram-in";
  std::string fsChannelNameHistosConfig = "histo-conf";
  std::string fsChannelNameCanvasConfig = "canvas-conf";
  std::string fsHistoFileName           = "MqHistos.root";
  uint32_t fuHttpServerPort             = 8098;
 
  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;
 
  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;
 
  int fNMessages = 0;
 
  THttpServer* fServer = nullptr;
 
  std::thread fThread;
  bool fStopThread = false;
 
  template<class HistoT>
  bool ReadHistogram(HistoT* pHist);
  int FindHistogram(const std::string& name);
  bool PrepareCanvas(uint32_t uCanvIdx);
 
  bool ResetHistograms();
  bool SaveHistograms();
};
 
#endif  // CBMMQHISTOSERVER_H