CbmDeviceBuildDigiEvents.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 CBMDEVICEBUILDDIGIEVENTS_H_
#define CBMDEVICEBUILDDIGIEVENTS_H_
 
#include "CbmAlgoBuildRawEvents.h"
#include "CbmBmonDigi.h"
#include "CbmMuchDigi.h"
#include "CbmPsdDigi.h"
#include "CbmRichDigi.h"
#include "CbmStsDigi.h"
#include "CbmTofDigi.h"
#include "CbmTrdDigi.h"
 
#include "FairMQDevice.h"
 
#include "Rtypes.h"
#include "TObjArray.h"
 
#include <chrono>
#include <map>
#include <vector>
 
class TList;
class TClonesArray;
class FairRunOnline;
class CbmTsEventHeader;
 
class CbmDeviceBuildDigiEvents : public FairMQDevice {
public:
  CbmDeviceBuildDigiEvents();
  virtual ~CbmDeviceBuildDigiEvents();
 
protected:
  virtual void InitTask();
  bool HandleData(FairMQParts&, int);
  bool HandleCommand(FairMQMessagePtr&, int);
 
private:
 
  Bool_t fbIgnoreTsOverlap = kFALSE;  
  Bool_t fbFillHistos      = kTRUE;   
 
  std::string fsEvtOverMode                      = "NoOverlap";
  std::string fsRefDet                           = "kBmon";
  std::vector<std::string> fvsAddDet             = {};
  std::vector<std::string> fvsDelDet             = {};
  std::vector<std::string> fvsSetTrigWin         = {};
  std::vector<std::string> fvsSetTrigMinNb       = {};
  std::vector<std::string> fvsSetTrigMaxNb       = {};
  std::vector<std::string> fvsSetTrigMinLayersNb = {};
  std::vector<std::string> fvsSetHistMaxDigiNb   = {};
  bool fbDoNotSend       = false;
  bool fbDigiEventOutput = false;
  std::string fsChannelNameDataInput   = "unpts_0";
  std::string fsChannelNameDataOutput  = "events";
  std::string fsChannelNameCommands    = "commands";
  std::string fsChannelNameHistosInput = "histogram-in";
  uint32_t fuPublishFreqTs  = 100;
  double_t fdMinPublishTime = 0.5;
  double_t fdMaxPublishTime = 5.0;
 
  std::vector<std::string> fsAllowedChannels = {fsChannelNameDataInput};
 
  uint64_t fulNumMessages                                = 0;
  uint64_t fulTsCounter                                  = 0;
  std::chrono::system_clock::time_point fLastPublishTime = std::chrono::system_clock::now();
 
  CbmAlgoBuildRawEvents* fpAlgo = nullptr;
 
  size_t fuNbCoreMsPerTs    = 0;        
  size_t fuNbOverMsPerTs    = 0;        
  Double_t fdMsSizeInNs     = 1280000;  
  Double_t fdTsCoreSizeInNs = -1.0;     
  Double_t fdTsOverSizeInNs = -1.0;     
  Double_t fdTsFullSizeInNs = -1.0;     
 
  CbmTsEventHeader* fCbmTsEventHeader = nullptr;
  std::vector<CbmBmonDigi>* fvDigiBmon = nullptr;
  std::vector<CbmStsDigi>* fvDigiSts   = nullptr;
  std::vector<CbmMuchDigi>* fvDigiMuch = nullptr;
  std::vector<CbmTrdDigi>* fvDigiTrd   = nullptr;
  std::vector<CbmTofDigi>* fvDigiTof   = nullptr;
  std::vector<CbmRichDigi>* fvDigiRich = nullptr;
  std::vector<CbmPsdDigi>* fvDigiPsd   = nullptr;
  TClonesArray* fTimeSliceMetaDataArray = nullptr;  
  TimesliceMetaData* fTsMetaData        = nullptr;
 
  TObjArray fArrayHisto = {};
  std::vector<std::pair<std::string, std::string>> fvpsHistosFolder = {};
  std::vector<std::pair<std::string, std::string>> fvpsCanvasConfig = {};
  bool fbConfigSent = false;
 
  bool IsChannelNameAllowed(std::string channelName);
  RawEventBuilderDetector GetDetectorBuilderCfg(std::string detName);
  ECbmModuleId GetDetectorId(std::string detName);
 
  bool InitHistograms();
  void Finish();
  bool SendEvents(FairMQParts& partsIn);
  bool SendDigiEvents(FairMQParts& partsIn);
  bool SendHistoConfAndData();
  bool SendHistograms();
};
 
#endif /* CBMDEVICEBUILDDIGIEVENTS_H_ */