CbmDevBuildEvents.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: Dominik Smith[committer] */
 
#ifndef CBMDEVICEEVENTBUILDER_H_
#define CBMDEVICEEVENTBUILDER_H_
 
#include "EventBuilder.h"
 
#include "FairMQDevice.h"
 
#include "Rtypes.h"
#include "TObjArray.h"
 
#include <vector>
 
class FairRunOnline;
class FairRootManager;
 
class TClonesArray;
class TimesliceMetaData;
 
class CbmDevBuildEvents : public FairMQDevice {
 public:
  CbmDevBuildEvents();
  virtual ~CbmDevBuildEvents();
 
 protected:
  virtual void InitTask();
  bool HandleData(FairMQParts&, int);
 
 private:
  Bool_t fbFinishDone = false;  
 
  std::string fsChannelNameDataInput  = "trigger";
  std::string fsChannelNameDataOutput = "events";
 
  std::vector<std::string> fsAllowedChannels = {fsChannelNameDataInput};
 
  uint64_t fulNumMessages = 0;
  //  uint64_t fulTsCounter   = 0;
 
  std::unique_ptr<cbm::algo::evbuild::EventBuilder> fEvbuildAlgo;
 
  std::string fsOutputFileName             = "";
  FairRunOnline* fpRun                     = nullptr;
  FairRootManager* fpFairRootMgr           = nullptr;
  std::vector<CbmDigiEvent>* fEventsSelOut = nullptr;  // output container of CbmDigiEvents
  TClonesArray* fTimeSliceMetaDataArrayOut = nullptr;  // output container of meta data
 
  bool IsChannelNameAllowed(std::string channelName);
  bool SendEvents(const std::vector<CbmDigiEvent>& vEvents, const TimesliceMetaData* tsMetaData);
 
  // Get detector type from string containing name
  ECbmModuleId GetDetectorId(std::string detName);
 
  void DumpTreeEntry();
  void Finish();
};
 
#endif /* CBMDEVICEEVENTBUILDER_H_ */