CbmDeviceMonitorReqBmon.h

Go to the documentation of this file.

/* Copyright (C) 2021 Facility for Antiproton and Ion Research in Europe, Darmstadt
   SPDX-License-Identifier: GPL-3.0-only
   Authors: Pierre-Alain Loizeau [committer] */
 
#ifndef CBMDEVICEMONITORREQBmon_H_
#define CBMDEVICEMONITORREQBmon_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 CbmMcbm2018MonitorAlgoBmon;
 
class CbmDeviceMonitorReqBmon : public FairMQDevice {
public:
  CbmDeviceMonitorReqBmon();
  virtual ~CbmDeviceMonitorReqBmon();
 
protected:
  virtual void InitTask();
  virtual bool ConditionalRun();
 
private:
  static const uint16_t kusSysId = 0x90;
 
  Bool_t fbIgnoreOverlapMs       = kFALSE;  
  Bool_t fbComponentsAddedToList = kFALSE;
 
  std::string fsChannelNameDataInput     = "ts-request";
  std::string fsTsBlockName              = "t0block";
  std::string fsChannelNameHistosInput   = "histogram-in";
  uint32_t fuHistoryHistoSize            = 3600;
  uint32_t fuMinTotPulser                = 185;
  uint32_t fuMaxTotPulser                = 195;
  uint32_t fuOffSpillCountLimit          = 25;
  uint32_t fuOffSpillCountLimitNonPulser = 10;
  double fdSpillCheckInterval            = 0.0128;
  std::vector<uint32_t> fvuChanMap       = {0, 1, 2, 3, 4, 5, 6, 7};
  uint32_t fuPublishFreqTs               = 100;
  double_t fdMinPublishTime              = 0.5;
  double_t fdMaxPublishTime              = 5.0;
 
  TList* fParCList = nullptr;
 
  uint64_t fulNumMessages                                = 0;
  uint64_t fulTsCounter                                  = 0;
  std::chrono::system_clock::time_point fLastPublishTime = std::chrono::system_clock::now();
 
  CbmMcbm2018MonitorAlgoBmon* fMonitorAlgo;
 
  TObjArray fArrayHisto = {};
  std::vector<std::pair<std::string, std::string>> fvpsHistosFolder = {};
  std::vector<std::pair<std::string, std::string>> fvpsCanvasConfig = {};
  bool fbConfigSent = false;
 
  bool InitContainers();
  bool InitHistograms();
  bool DoUnpack(const fles::Timeslice& ts, size_t component);
  void Finish();
  bool SendHistoConfAndData();
  bool SendHistograms();
};
 
#endif /* CBMDEVICEMONITORREQBmon_H_ */