CbmDeviceMonitorTof.h

Go to the documentation of this file.

 
#ifndef CBMDEVICEMONITORTOF_H_
#define CBMDEVICEMONITORTOF_H_
 
#include "FairMQDevice.h"
 
#include "Timeslice.hpp"
 
#include "Rtypes.h"
#include "TMessage.h"
#include "TObjArray.h"
 
#include <chrono>
#include <map>
#include <vector>
 
class TList;
class CbmMcbm2018MonitorAlgoTof;
 
class CbmDeviceMonitorTof : public FairMQDevice {
public:
  CbmDeviceMonitorTof();
  virtual ~CbmDeviceMonitorTof();
 
protected:
  virtual void InitTask();
  bool HandleData(FairMQMessagePtr&, int);
 
private:
  static const uint16_t kusSysIdTof = 0x60;
  static const uint16_t kusSysIdT0  = 0x90;
 
  Bool_t fbIgnoreOverlapMs =
    kFALSE;  
  Bool_t fbDebugMonitorMode =
    kFALSE;  
  Bool_t fbIgnoreCriticalErrors =
    kTRUE;  
  Bool_t fbComponentsAddedToList = kFALSE;
 
  std::string fsChannelNameDataInput    = "tofcomponent";
  std::string fsChannelNameHistosInput  = "histogram-in";
  std::string fsChannelNameHistosConfig = "histo-conf";
  std::string fsChannelNameCanvasConfig = "canvas-conf";
  uint32_t fuHistoryHistoSize           = 3600;
  uint32_t fuMinTotPulser               = 185;
  uint32_t fuMaxTotPulser               = 195;
  int32_t fiGdpbIndex                   = -1;
  uint32_t fuPublishFreqTs              = 100;
  double_t fdMinPublishTime             = 0.5;
  double_t fdMaxPublishTime             = 5.0;
 
  std::vector<std::string> fsAllowedChannels = {fsChannelNameDataInput};
 
  TList* fParCList = nullptr;
 
  uint64_t fulNumMessages = 0;
  uint64_t fulTsCounter   = 0;
  std::chrono::system_clock::time_point fLastPublishTime =
    std::chrono::system_clock::now();
 
  CbmMcbm2018MonitorAlgoTof* fMonitorAlgo;
 
  TObjArray fArrayHisto = {};
  std::vector<std::pair<std::string, std::string>> fvpsHistosFolder = {};
  std::vector<std::pair<std::string, std::string>> fvpsCanvasConfig = {};
 
  bool IsChannelNameAllowed(std::string channelName);
  Bool_t InitContainers();
  Bool_t DoUnpack(const fles::Timeslice& ts, size_t component);
  void Finish();
  bool SendHistograms();
};
 
// special class to expose protected TMessage constructor
class CbmMQTMessage : public TMessage {
public:
  CbmMQTMessage(void* buf, Int_t len) : TMessage(buf, len) {
    ResetBit(kIsOwner);
  }
};
 
 
#endif /* CBMDEVICEMONITORTOF_H_ */