CbmMqHistoServer.h

Go to the documentation of this file.

/********************************************************************************
 *    Copyright (C) 2014 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH    *
 *                                                                              *
 *              This software is distributed under the terms of the             *
 *              GNU Lesser General Public Licence (LGPL) version 3,             *
 *                  copied verbatim in the file "LICENSE"                       *
 ********************************************************************************/
#ifndef CBMMQHISTOSERVER_H
#define CBMMQHISTOSERVER_H
 
#include "FairMQDevice.h"
 
#include "THttpServer.h"
#include "TObjArray.h"
 
#include <memory>
#include <string>
#include <thread>
 
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);
 
  virtual void PreRun();
 
  virtual void PostRun();
 
private:
  std::string fsChannelNameHistosInput;
  std::string fsChannelNameHistosConfig;
  std::string fsChannelNameCanvasConfig;
  std::string fsHistoFileName;
  uint32_t fuHttpServerPort;
 
  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;
 
  std::vector<std::pair<TNamed*, std::string>>
    fvHistos;  
  std::vector<bool> fvbHistoRegistered;
  bool fbAllHistosRegistered;
  std::vector<std::pair<TCanvas*, std::string>>
    fvCanvas;  
  std::vector<bool> fvbCanvasRegistered;
  bool fbAllCanvasRegistered;
 
  int fNMessages;
 
  THttpServer* fServer;
 
  std::thread fThread;
  bool fStopThread;
 
  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