CbmDeviceEventBuilderEtofStar2019.h

Go to the documentation of this file.

/* Copyright (C) 2019 PI-UHd, GSI
   SPDX-License-Identifier: GPL-3.0-only
   Authors: Norbert Herrmann [committer] */
 
#ifndef CBMDEVICEEVENTBUILDERETOFSTAR2019_H_
#define CBMDEVICEEVENTBUILDERETOFSTAR2019_H_
 
#include "CbmMqTMessage.h"
 
#include "Timeslice.hpp"
 
#include "FairMQDevice.h"
 
#include "TMessage.h"
#include "TStopwatch.h"
 
class CbmStar2019EventBuilderEtofAlgo;
class CbmStar2019TofPar;
 
class CbmDeviceEventBuilderEtofStar2019 : public FairMQDevice {
public:
  CbmDeviceEventBuilderEtofStar2019();
  virtual ~CbmDeviceEventBuilderEtofStar2019();
 
  virtual Bool_t DoUnpack(const fles::Timeslice& ts, size_t component);
  virtual void Reset();
  virtual void Finish();
 
  void SetParContainers();
 
  Bool_t InitContainers();
 
  Bool_t ReInitContainers();
 
  void SetSandboxMode(Bool_t bSandboxMode = kTRUE) { fbSandboxMode = bSandboxMode; }
  void SetEventDumpEnable(Bool_t bDumpEna = kTRUE);
 
  void AddMsComponentToList(size_t component, UShort_t usDetectorId);
  void SetNbMsInTs(size_t /*uCoreMsNb*/, size_t /*uOverlapMsNb*/) {};
 
  CbmDeviceEventBuilderEtofStar2019(const CbmDeviceEventBuilderEtofStar2019&) = delete;
  CbmDeviceEventBuilderEtofStar2019 operator=(const CbmDeviceEventBuilderEtofStar2019&) = delete;
 
protected:
  virtual void InitTask();
  bool HandleData(FairMQMessagePtr&, int);
  bool HandleParts(FairMQParts&, int);
  bool HandleMessage(FairMQMessagePtr&, int);
  virtual bool SendEvent(std::vector<Int_t>, int);
  virtual bool SendSubevent(uint, char*, int, int);
 
private:
  uint64_t fNumMessages;
  Bool_t fbMonitorMode;       
  Bool_t fbDebugMonitorMode;  
  Bool_t fbSandboxMode;       
  Bool_t fbEventDumpEna;      
 
  TList* fParCList;
 
  uint64_t fulTsCounter;
  uint64_t fNumEvt;
 
  bool CheckTimeslice(const fles::Timeslice& ts);
  bool IsChannelNameAllowed(std::string channelName);
 
  std::vector<std::string> fAllowedChannels             = {"tofcomponent", "parameters", "etofevts", "syscmd"};
  std::vector<std::vector<std::string>> fChannelsToSend = {{}, {}, {}};
 
  CbmStar2019EventBuilderEtofAlgo* fEventBuilderAlgo;
  TStopwatch fTimer;
 
  CbmStar2019TofPar* fUnpackPar;  
 
  std::fstream* fpBinDumpFile;
  const UInt_t kuBinDumpBegWord = 0xFEEDBEAF;
  const UInt_t kuBinDumpEndWord = 0xFAEBDEEF;
};
 
#endif /* CBMDEVICEEVENTBUILDERETOFSTAR2019_H_ */