CbmDeviceMonitorPsd.h

Go to the documentation of this file.

/* Copyright (C) 2021 Institute for Nuclear Research, Moscow
   SPDX-License-Identifier: GPL-3.0-only
   Authors: Nikolay Karpushkin [committer] */
 
#ifndef CBMDEVICEMONITORPSD_H_
#define CBMDEVICEMONITORPSD_H_
 
#include "CbmMqTMessage.h"
 
#include "Timeslice.hpp"
 
#include "FairMQDevice.h"
 
#include "Rtypes.h"
#include "TObjArray.h"
 
#include <chrono>
#include <map>
#include <vector>
 
class TList;
class CbmMcbm2018MonitorAlgoPsd;
 
class CbmDeviceMonitorPsd : public FairMQDevice {
public:
  CbmDeviceMonitorPsd();
  virtual ~CbmDeviceMonitorPsd();
 
protected:
  virtual void InitTask();
  bool HandleData(FairMQMessagePtr&, int);
 
private:
  static const uint16_t kusSysId = 0x80;
  Bool_t fbComponentsAddedToList = kFALSE;
 
  Bool_t fbMonitorMode;      
  Bool_t fbIgnoreOverlapMs;  
  Bool_t fbMonitorChanMode;  
  Bool_t fbMonitorWfmMode;   
  Bool_t fbMonitorFitMode;   
                             //  Bool_t fbDebugMonitorMode;  //! Switch ON the filling of a additional set of histograms
 
  std::string fsChannelNameDataInput;
  std::string fsChannelNameHistosInput;
  std::string fsChannelNameHistosConfig;
  std::string fsChannelNameCanvasConfig;
  uint32_t fuPublishFreqTs;
  double_t fdMinPublishTime;
  double_t fdMaxPublishTime;
 
  UInt_t fuHistoryHistoSize;
  std::vector<Int_t> fviHistoChargeArgs; 
  std::vector<Int_t> fviHistoAmplArgs;   
  std::vector<Int_t> fviHistoZLArgs;     
  std::vector<std::string> fsAllowedChannels;
 
  TList* fParCList;
 
  uint64_t fulNumMessages;
  uint64_t fulTsCounter;
  std::chrono::system_clock::time_point fLastPublishTime;
 
  CbmMcbm2018MonitorAlgoPsd* 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();
};
 
#endif /* CBMDEVICEMONITORPSD_H_ */