Added Cbm2021EventBuilder files.

reco/eventbuilder/digis/Cbm2021EventBuilderAlgo.h

+/********************************************************************************
+ *    Copyright (C) 2014 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH    *
+ *                                                                              *
+ *              This software is distributed under the terms of the             *
+ *              GNU Lesser General Public Licence (LGPL) version 3,             *
+ *                  copied verbatim in the file "LICENSE"                       *
+ ********************************************************************************/
+#ifndef CBM2021EVENTBUILDERALGO_H
+#define CBM2021EVENTBUILDERALGO_H
+
+/// CBM headers
+#include "CbmMuchBeamTimeDigi.h"
+#include "CbmMuchDigi.h"
+#include "CbmPsdDigi.h"
+#include "CbmRichDigi.h"
+#include "CbmStsDigi.h"
+#include "CbmTofDigi.h"
+#include "CbmTrdDigi.h"
+
+/// FAIRROOT headers
+#include "FairTask.h"
+
+/// FAIRSOFT headers (geant, boost, ...)
+
+/// C/C++ headers
+#include <array>
+#include <map>
+#include <set>
+#include <tuple>
+#include <vector>
+
+#include <boost/any.hpp> 
+
+class TimesliceMetaData;
+class CbmEvent;
+class TClonesArray;
+class TH1;
+class TH2;
+class TNamed;
+class TCanvas;
+
+enum class EOverlapMode { NoOverlap, MergeOverlap, AllowOverlap };
+
+class EventBuilderDetector {
+public:
+  EventBuilderDetector() { ; }
+  EventBuilderDetector(ECbmModuleId detIdIn,
+                       ECbmDataType dataTypeIn,
+                       std::string sNameIn) {
+    detId    = detIdIn;
+    dataType = dataTypeIn;
+    sName    = sNameIn;
+  }
+  EventBuilderDetector(ECbmModuleId detIdIn,
+                       ECbmDataType dataTypeIn,
+                       std::string sNameIn,
+                       UInt_t uTriggerMinDigisIn,
+                       Int_t iTriggerMaxDigisIn,
+                       Double_t fdTimeWinBegIn,
+                       Double_t fdTimeWinEndIn)
+    : EventBuilderDetector(detIdIn, dataTypeIn, sNameIn) {
+    fuTriggerMinDigis = uTriggerMinDigisIn;
+    fiTriggerMaxDigis = iTriggerMaxDigisIn;
+
+    fdTimeWinBeg = fdTimeWinBegIn;
+    fdTimeWinEnd = fdTimeWinEndIn;
+  }
+
+  bool operator==(const EventBuilderDetector& other) const {
+    return (other.detId == this->detId);
+  }
+  bool operator!=(const EventBuilderDetector& other) const {
+    return (other.detId != this->detId);
+  }
+
+  Double_t GetTimeWinRange() { return fdTimeWinEnd - fdTimeWinBeg; }
+
+  /// Settings
+  ECbmModuleId detId    = ECbmModuleId::kNotExist;
+  ECbmDataType dataType = ECbmDataType::kUnknown;
+  std::string sName     = "Invalid";
+  /// Minimum number of T0 digis needed to generate a trigger, 0 means don't use for trigger generation
+  UInt_t fuTriggerMinDigis = 0;
+  /// Maximum number of digis per detector to generate an event, -1 means no cut, 0 means anti-coinc trigger
+  Int_t fiTriggerMaxDigis = -1;
+  /// Selection Window
+  Double_t fdTimeWinBeg = -100;
+  Double_t fdTimeWinEnd = 100;
+
+  /// Book-keeping variables
+  UInt_t fuStartIndex = 0;
+  UInt_t fuEndIndex   = 0;
+};
+
+/// Pre-defined detector types
+static const EventBuilderDetector kEventBuilderDetSts =
+  EventBuilderDetector(ECbmModuleId::kSts, ECbmDataType::kStsDigi, "Sts");
+static const EventBuilderDetector kEventBuilderDetMuch =
+  EventBuilderDetector(ECbmModuleId::kMuch, ECbmDataType::kMuchDigi, "Much");
+static const EventBuilderDetector kEventBuilderDetTrd =
+  EventBuilderDetector(ECbmModuleId::kTrd, ECbmDataType::kTrdDigi, "Trd");
+static const EventBuilderDetector kEventBuilderDetTof =
+  EventBuilderDetector(ECbmModuleId::kTof, ECbmDataType::kTofDigi, "Tof");
+static const EventBuilderDetector kEventBuilderDetRich =
+  EventBuilderDetector(ECbmModuleId::kRich, ECbmDataType::kRichDigi, "Rich");
+static const EventBuilderDetector kEventBuilderDetPsd =
+  EventBuilderDetector(ECbmModuleId::kPsd, ECbmDataType::kPsdDigi, "Psd");
+static const EventBuilderDetector kEventBuilderDetT0 =
+  EventBuilderDetector(ECbmModuleId::kT0, ECbmDataType::kT0Digi, "T0");
+static const EventBuilderDetector kEventBuilderDetUndef =
+  EventBuilderDetector();
+
+class Cbm2021EventBuilderAlgo {
+public:
+  /** Default constructor **/
+  Cbm2021EventBuilderAlgo();
+
+  Cbm2021EventBuilderAlgo(
+    const Cbm2021EventBuilderAlgo&) = delete;
+  Cbm2021EventBuilderAlgo
+  operator=(const Cbm2021EventBuilderAlgo&) = delete;
+
+  /** Destructor **/
+  ~Cbm2021EventBuilderAlgo();
+
+  /** Initiliazation at the beginning of a run **/
+  Bool_t InitAlgo();
+
+  /** Executed for each TS. **/
+  void ProcessTs();
+
+  /** Finish called at the end of the run **/
+  void Finish();
+
+  void SetFillHistos(Bool_t var) { fbFillHistos = var; }
+  void ResetHistograms(Bool_t bResetTime = kTRUE);
+
+  void SetReferenceDetector(ECbmModuleId refDet,
+                            ECbmDataType dataTypeIn,
+                            std::string sNameIn,
+                            UInt_t uTriggerMinDigisIn = 0,
+                            Int_t iTriggerMaxDigisIn  = -1,
+                            Double_t fdTimeWinBegIn   = -100,
+                            Double_t fdTimeWinEndIn   = 100);
+  void AddDetector(ECbmModuleId selDet,
+                   ECbmDataType dataTypeIn,
+                   std::string sNameIn,
+                   UInt_t uTriggerMinDigisIn = 0,
+                   Int_t iTriggerMaxDigisIn  = -1,
+                   Double_t fdTimeWinBegIn   = -100,
+                   Double_t fdTimeWinEndIn   = 100);
+
+  void SetReferenceDetector(EventBuilderDetector refDetIn);
+  void AddDetector(EventBuilderDetector selDet);
+  void RemoveDetector(EventBuilderDetector selDet);
+
+  void SetTriggerMinNumber(ECbmModuleId selDet, UInt_t uVal);
+  void SetTriggerMaxNumber(ECbmModuleId selDet, Int_t iVal);
+
+  void
+  SetTriggerWindow(ECbmModuleId selDet, Double_t dWinBeg, Double_t dWinEnd);
+
+  void SetTsParameters(Double_t dTsStartTime,
+                       Double_t dTsLength,
+                       Double_t dTsOverLength) {
+    fdTsStartTime  = dTsStartTime;
+    fdTsLength     = dTsLength;
+    fdTsOverLength = dTsOverLength;
+  }
+
+  /// Control flags
+  void SetEventOverlapMode(EOverlapMode mode) { fOverMode = mode; }
+  void SetIgnoreTsOverlap(Bool_t bFlagIn = kTRUE) {
+    fbIgnoreTsOverlap = bFlagIn;
+  }
+
+  void ChangeMuchBeamtimeDigiFlag(Bool_t bFlagIn = kFALSE) {
+    fbUseMuchBeamtimeDigi = bFlagIn;
+  }
+
+  /// For monitor algos
+  void AddHistoToVector(TNamed* pointer, std::string sFolder = "") {
+    fvpAllHistoPointers.push_back(
+      std::pair<TNamed*, std::string>(pointer, sFolder));
+  }
+  std::vector<std::pair<TNamed*, std::string>> GetHistoVector() {
+    return fvpAllHistoPointers;
+  }
+  void AddCanvasToVector(TCanvas* pointer, std::string sFolder = "") {
+    fvpAllCanvasPointers.push_back(
+      std::pair<TCanvas*, std::string>(pointer, sFolder));
+  }
+  std::vector<std::pair<TCanvas*, std::string>> GetCanvasVector() {
+    return fvpAllCanvasPointers;
+  }
+
+  /// Set digi containers
+  void SetStsDigis( std::vector<CbmStsDigi>* StsDigis ){
+    fStsDigis = StsDigis;
+  }
+  void SetMuchDigis( std::vector<CbmMuchDigi>* MuchDigis ){
+    fMuchDigis = MuchDigis;
+  }
+  void SetTrdDigis( std::vector<CbmTrdDigi>* TrdDigis ){
+    fTrdDigis = TrdDigis;
+  }
+  void SetTofDigis( std::vector<CbmTofDigi>* TofDigis ){
+    fTofDigis = TofDigis;
+  }
+  void SetRichDigis( std::vector<CbmRichDigi>* RichDigis ){
+    fRichDigis = RichDigis;
+  }
+  void SetPsdDigis( std::vector<CbmPsdDigi>* PsdDigis ){
+    fPsdDigis = PsdDigis;
+  }
+  void SetMuchBeamTimeDigis( std::vector<CbmMuchBeamTimeDigi>* MuchBeamTimeDigis ){
+    fMuchBeamTimeDigis = MuchBeamTimeDigis;
+  }
+
+  /// Data output access
+  std::vector<CbmEvent*>& GetEventVector() { return fEventVector; }
+  void ClearEventVector();
+
+private:
+  /// Internal methods
+  Bool_t CheckDataAvailable(EventBuilderDetector& det);
+  void InitTs();
+  void BuildEvents();
+
+  void CreateHistograms();
+  void FillHistos();
+
+  template<class DigiSeed>
+  void LoopOnSeeds();
+  void CheckSeed(Double_t dSeedTime, UInt_t uSeedDigiIdx);
+  template<class DigiCheck>
+  void SearchMatches(Double_t dSeedTime, EventBuilderDetector& detMatch);
+  void AddDigiToEvent(EventBuilderDetector& det, Int_t uIdx);
+  Bool_t HasTrigger(CbmEvent*);
+  Bool_t CheckTriggerConditions(CbmEvent* event, EventBuilderDetector& det);
+
+  void UpdateTimeWinBoundariesExtrema();
+  void UpdateWidestTimeWinRange();
+
+  /// Constants
+  static constexpr Double_t kdDefaultTimeWinBeg = -100.0;
+  static constexpr Double_t kdDefaultTimeWinEnd = 100.0;
+
+  /// User parameters
+  /// Control flags
+  Bool_t fbIgnoreTsOverlap = kFALSE;  //! Ignore data in Overlap part of the TS
+  Bool_t fbFillHistos {kTRUE};        //! Switch ON/OFF filling of histograms
+  Bool_t fbUseMuchBeamtimeDigi = kTRUE;  //! Switch between MUCH digi classes
+    /// Event building mode and detectors selection
+  EOverlapMode fOverMode {EOverlapMode::AllowOverlap};
+
+  EventBuilderDetector fRefDet =
+    EventBuilderDetector(ECbmModuleId::kT0, ECbmDataType::kT0Digi, "T0");
+  std::vector<EventBuilderDetector> fvDets = {
+    EventBuilderDetector(ECbmModuleId::kSts, ECbmDataType::kStsDigi, "kSts"),
+    EventBuilderDetector(ECbmModuleId::kMuch, ECbmDataType::kMuchDigi, "kMuch"),
+    EventBuilderDetector(ECbmModuleId::kTrd, ECbmDataType::kTrdDigi, "kTrd"),
+    EventBuilderDetector(ECbmModuleId::kTof, ECbmDataType::kTofDigi, "kTof"),
+    EventBuilderDetector(ECbmModuleId::kRich, ECbmDataType::kRichDigi, "kRich"),
+    EventBuilderDetector(ECbmModuleId::kPsd, ECbmDataType::kPsdDigi, "kPsd")};
+
+  Double_t fdEarliestTimeWinBeg = kdDefaultTimeWinBeg;
+  Double_t fdLatestTimeWinEnd   = kdDefaultTimeWinEnd;
+  Double_t fdWidestTimeWinRange = kdDefaultTimeWinEnd - kdDefaultTimeWinBeg;
+
+  Double_t fdTsStartTime  = -1;
+  Double_t fdTsLength     = -1;
+  Double_t fdTsOverLength = -1;
+
+  /// Data input
+  /// FIXME: usage of CbmDigiManager in FairMq context?!?
+  ///        => Maybe by registering vector (or vector reference) to ioman in Device?
+  //CbmDigiManager* fDigiMan                  = nullptr;  //!
+  const std::vector<CbmTofDigi>* fT0DigiVec = nullptr;  //!
+  TClonesArray* fTimeSliceMetaDataArray     = nullptr;  //!
+  const TimesliceMetaData* pTsMetaData      = nullptr;
+
+  const std::vector<CbmMuchDigi>* fMuchDigis = nullptr;
+  const std::vector<CbmMuchBeamTimeDigi>* fMuchBeamTimeDigis = nullptr;
+  const std::vector<CbmStsDigi>* fStsDigis = nullptr;
+  const std::vector<CbmTrdDigi>* fTrdDigis = nullptr;
+  const std::vector<CbmTofDigi>* fTofDigis = nullptr;
+  const std::vector<CbmRichDigi>* fRichDigis = nullptr;
+  const std::vector<CbmPsdDigi>* fPsdDigis = nullptr;
+
+  bool DetIsPresent( ECbmModuleId detId ); 
+  UInt_t GetNofDigis( ECbmModuleId detId ); 
+  template <class Digi> const Digi* GetDigi( UInt_t uDigi );
+
+  /// Data ouptut
+  CbmEvent* fCurrentEvent =
+    nullptr;  //! pointer to the event which is currently build
+  std::vector<CbmEvent*> fEventVector = {};  //! vector with all created events
+
+  /// Monitoring histograms
+  /// => Pointers should be filled with TH1*, TH2*, TProfile*, ...
+  /// ==> To check if object N is of type T, use "T ObjectPointer = dynamic_cast<T>( fvpAllHistoPointers[N].first );" and check for nullptr
+  /// ==> To get back the original class name use "fvpAllHistoPointers[N].first->ClassName()" which returns a const char * (e.g. "TH1I")
+  /// ===> Usage example with feeding a THttpServer:
+  /// ===> #include "TH2.h"
+  /// ===> std::string sClassName = vHistos[ uHisto ].first.ClassName();
+  /// ===> if( !strncmp( sClassName, "TH1", 3 ) )
+  /// ===>    server->Register( vHistos[ uHisto ].second.data(), dynamic_cast< TH1 * >(vHistos[ uHisto ].first) );
+  /// ===> else if( !strncmp( sClassName, "TH2", 3 ) )
+  /// ===>    server->Register( vHistos[ uHisto ].second.data(), dynamic_cast< TH2 * >(vHistos[ uHisto ].first) );
+  std::vector<std::pair<TNamed*, std::string>>
+    fvpAllHistoPointers;  //! Vector of pointers to histograms + optional folder name
+  std::vector<std::pair<TCanvas*, std::string>>
+    fvpAllCanvasPointers;  //! Vector of pointers to canvases + optional folder name
+
+  TH1* fhEventTime = nullptr;  //! histogram with the seed time of the events
+  TH1* fhEventDt =
+    nullptr;  //! histogram with the interval in seed time of consecutive events
+  TH1* fhEventSize =
+    nullptr;  //! histogram with the nb of all  digis in the event
+  TH2* fhNbDigiPerEvtTime =
+    nullptr;  //! histogram with the nb of all  digis per event vs seed time of the events
+  std::vector<TH2*> fvhNbDigiPerEvtTimeDet =
+    {};  //! histograms with the nb of digis in each detector per event vs seed time of the events
+
+  /// Internal state variables
+  UInt_t fuCurEv         = 0;   //! Event Counter
+  UInt_t fuErrors        = 0;   //! Error Counter
+  UInt_t fuNrTs          = 0;   //! Timeslice Counter
+  Double_t fdPrevEvtTime = 0.;  //! Save previous time information
+  Double_t fdPrevEvtEndTime =
+    0.;  //! Save previous event last digi time information
+
+  ClassDefNV(Cbm2021EventBuilderAlgo, 1);
+};
+
+#endif  //  CBM2021EVENTBUILDERALGO_H

reco/eventbuilder/digis/Cbm2021EventBuilderTask.cxx

+/********************************************************************************
+ *    Copyright (C) 2014 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH    *
+ *                                                                              *
+ *              This software is distributed under the terms of the             *
+ *              GNU Lesser General Public Licence (LGPL) version 3,             *
+ *                  copied verbatim in the file "LICENSE"                       *
+ ********************************************************************************/
+#include "Cbm2021EventBuilderAlgo.h"
+#include "Cbm2021EventBuilderTask.h"
+
+#include "CbmEvent.h"
+#include "CbmDigiManager.h"
+
+#include "FairLogger.h"
+#include "FairRootManager.h"
+#include "FairRunOnline.h"
+
+#include "TClonesArray.h"
+#include "TH1.h"
+#include "TH2.h"
+#include "THttpServer.h"
+#include <TFile.h>
+
+// ---- Default constructor -------------------------------------------
+Cbm2021EventBuilderTask::Cbm2021EventBuilderTask()
+  : FairTask("Cbm2021EventBuilderTask") {
+  /// Create Algo. To be made generic/switchable when more event building algo are available!
+  fpAlgo = new Cbm2021EventBuilderAlgo();
+}
+
+// ---- Destructor ----------------------------------------------------
+Cbm2021EventBuilderTask::~Cbm2021EventBuilderTask() {
+}
+
+// ----  Initialisation  ----------------------------------------------
+void Cbm2021EventBuilderTask::SetParContainers() {
+  /// Nothing to do
+}
+
+// ---- Init ----------------------------------------------------------
+InitStatus Cbm2021EventBuilderTask::Init() {
+  /// Get a handle from the IO manager
+  FairRootManager* ioman = FairRootManager::Instance();
+
+  // Get a pointer to the previous already existing data level
+  fDigiMan = CbmDigiManager::Instance();
+  if (fbUseMuchBeamtimeDigi) {
+    fDigiMan->UseMuchBeamTimeDigi();
+  }  
+  fDigiMan->Init();
+
+  //Init STS digis
+  if (!fDigiMan->IsPresent(ECbmModuleId::kSts)) {
+    LOG(info) << "No STS digi input.";
+  }else{
+    LOG(info) << "STS digi input.";
+    fStsDigis = new std::vector<CbmStsDigi>;
+    fpAlgo->SetStsDigis(fStsDigis);
+  }
+
+  //Init MUCH digis
+  if (!fDigiMan->IsPresent(ECbmModuleId::kMuch)) {
+    LOG(info) << "No MUCH digi input.";
+  }else{
+    LOG(info) << "MUCH digi input.";
+    if( fbUseMuchBeamtimeDigi ){
+      fMuchBeamTimeDigis = new std::vector<CbmMuchBeamTimeDigi>;
+      fpAlgo->SetMuchBeamTimeDigis(fMuchBeamTimeDigis);
+    }else{
+      fMuchDigis = new std::vector<CbmMuchDigi>;
+      fpAlgo->SetMuchDigis(fMuchDigis);
+    }
+  }
+
+  //Init TRD digis
+  if (!fDigiMan->IsPresent(ECbmModuleId::kTrd)) {
+    LOG(info) << "No TRD digi input.";
+  }else{
+    LOG(info) << "TRD digi input.";
+    fTrdDigis = new std::vector<CbmTrdDigi>;
+    fpAlgo->SetTrdDigis(fTrdDigis);
+  }
+
+  //Init TOF digis
+  if (!fDigiMan->IsPresent(ECbmModuleId::kTof)) {
+    LOG(info) << "No TOF digi input.";
+  }else{
+    LOG(info) << "TOF digi input.";
+    fTofDigis = new std::vector<CbmTofDigi>;
+    fpAlgo->SetTofDigis(fTofDigis);
+  }
+
+  //Init RICH digis
+  if (!fDigiMan->IsPresent(ECbmModuleId::kRich)) {
+    LOG(info) << "No RICH digi input.";
+  }else{
+    LOG(info) << "RICH digi input.";
+    fRichDigis = new std::vector<CbmRichDigi>;
+    fpAlgo->SetRichDigis(fRichDigis);
+  }
+
+  //Init PSD digis
+  if (!fDigiMan->IsPresent(ECbmModuleId::kPsd)) {
+    LOG(info) << "No PSD digi input.";
+  }else{
+    LOG(info) << "PSD digi input.";
+    fPsdDigis = new std::vector<CbmPsdDigi>;
+    fpAlgo->SetPsdDigis(fPsdDigis);
+  }
+
+  /// Register output array (CbmEvent)
+  fEvents = new TClonesArray("CbmEvent", 100);
+  ioman->Register(
+    "CbmEvent", "Cbm_Event", fEvents, IsOutputBranchPersistent("CbmEvent"));
+
+  if (!fEvents) LOG(fatal) << "Output branch was not created";
+
+  /// Call Algo Init method
+  if (kTRUE == fpAlgo->InitAlgo())
+    return kSUCCESS;
+  else
+    return kFATAL;
+}
+
+// ---- ReInit  -------------------------------------------------------
+InitStatus Cbm2021EventBuilderTask::ReInit() { return kSUCCESS; }
+
+// ---- Exec ----------------------------------------------------------
+void Cbm2021EventBuilderTask::Exec(Option_t* /*option*/) {
+  LOG(debug2)
+    << "Cbm2021EventBuilderTask::Exec => Starting sequence";
+
+  //Read STS digis
+  if (fDigiMan->IsPresent(ECbmModuleId::kSts)) {
+    fStsDigis->clear();
+    for( Int_t i=0; i<fDigiMan->GetNofDigis(ECbmModuleId::kSts); i++){
+	const CbmStsDigi* Digi = fDigiMan->Get<CbmStsDigi>(i);
+	fStsDigis->insert( fStsDigis->begin()+i, *Digi );
+    }
+    LOG(debug) << "Read: "<< fStsDigis->size() << " STS digis.";
+    LOG(debug) << "In DigiManager: "<< fDigiMan->GetNofDigis(ECbmModuleId::kSts) << " STS digis.";
+  }
+
+  //Read MUCH digis
+  if (fDigiMan->IsPresent(ECbmModuleId::kMuch)) {
+    if( fbUseMuchBeamtimeDigi ){
+      fMuchBeamTimeDigis->clear();
+      for( Int_t i=0; i<fDigiMan->GetNofDigis(ECbmModuleId::kMuch); i++){
+  	const CbmMuchBeamTimeDigi* Digi = fDigiMan->Get<CbmMuchBeamTimeDigi>(i);
+  	fMuchBeamTimeDigis->insert( fMuchBeamTimeDigis->begin()+i, *Digi );
+      }
+      LOG(debug) << "Read: "<< fDigiMan->GetNofDigis(ECbmModuleId::kMuch) << " MUCH digis.";
+      LOG(debug) << "In DigiManager: "<< fMuchBeamTimeDigis->size() << " MUCH digis.";
+    }else{
+      fMuchDigis->clear();
+      for( Int_t i=0; i<fDigiMan->GetNofDigis(ECbmModuleId::kMuch); i++){
+  	const CbmMuchDigi* Digi = fDigiMan->Get<CbmMuchDigi>(i);
+  	fMuchDigis->insert( fMuchDigis->begin()+i, *Digi );
+      }
+      LOG(debug) << "Read: "<< fDigiMan->GetNofDigis(ECbmModuleId::kMuch) << " MUCH digis.";
+      LOG(debug) << "In DigiManager: "<< fMuchDigis->size() << " MUCH digis.";
+    }
+  }
+
+  //Read TRD digis
+  if (fDigiMan->IsPresent(ECbmModuleId::kTrd)) {
+    fTrdDigis->clear();
+    for( Int_t i=0; i<fDigiMan->GetNofDigis(ECbmModuleId::kTrd); i++){
+	const CbmTrdDigi* Digi = fDigiMan->Get<CbmTrdDigi>(i);
+	fTrdDigis->insert( fTrdDigis->begin()+i, *Digi );
+    }
+    LOG(debug) << "Read: "<< fDigiMan->GetNofDigis(ECbmModuleId::kTrd) << " TRD digis.";
+    LOG(debug) << "In DigiManager: "<< fTrdDigis->size() << " TRD digis.";
+  }
+
+  //Read TOF digis
+  if (fDigiMan->IsPresent(ECbmModuleId::kTof)) {
+    fTofDigis->clear();
+    for( Int_t i=0; i<fDigiMan->GetNofDigis(ECbmModuleId::kTof); i++){
+	const CbmTofDigi* Digi = fDigiMan->Get<CbmTofDigi>(i);
+	fTofDigis->insert( fTofDigis->begin()+i, *Digi );
+    }
+    LOG(debug) << "Read: "<< fDigiMan->GetNofDigis(ECbmModuleId::kTof) << " TOF digis.";
+    LOG(debug) << "In DigiManager: "<< fTofDigis->size() << " TOF digis.";
+  }
+
+  //Read RICH digis
+  if (fDigiMan->IsPresent(ECbmModuleId::kRich)) {
+    fRichDigis->clear();
+    for( Int_t i=0; i<fDigiMan->GetNofDigis(ECbmModuleId::kRich); i++){
+	const CbmRichDigi* Digi = fDigiMan->Get<CbmRichDigi>(i);
+	fRichDigis->insert( fRichDigis->begin()+i, *Digi );
+    }
+    LOG(debug) << "Read: "<< fDigiMan->GetNofDigis(ECbmModuleId::kRich) << " RICH digis.";
+    LOG(debug) << "In DigiManager: "<< fRichDigis->size() << " RICH digis.";
+  }
+
+  //Read PSD digis
+  if (fDigiMan->IsPresent(ECbmModuleId::kPsd)) {
+    fPsdDigis->clear();
+    for( Int_t i=0; i<fDigiMan->GetNofDigis(ECbmModuleId::kPsd); i++){
+	const CbmPsdDigi* Digi = fDigiMan->Get<CbmPsdDigi>(i);
+	fPsdDigis->insert( fPsdDigis->begin()+i, *Digi );
+    }
+    LOG(debug) << "Read: "<< fDigiMan->GetNofDigis(ECbmModuleId::kPsd) << " PSD digis.";
+    LOG(debug) << "In DigiManager: "<< fPsdDigis->size() << " PSD digis.";
+  }
+
+  /// Call Algo ProcessTs method
+  fpAlgo->ProcessTs();
+
+  /// Save the resulting vector of events in TClonesArray
+  FillOutput();
+  LOG(debug2) << "Cbm2021EventBuilderTask::Exec => Done";
+}
+
+
+// ---- Finish --------------------------------------------------------
+void Cbm2021EventBuilderTask::Finish() {
+  if (fbFillHistos) { SaveHistos(); }  // if( fbFillHistos )
+
+  /// Call Algo finish method
+  fpAlgo->Finish();
+}
+
+//----------------------------------------------------------------------
+void Cbm2021EventBuilderTask::FillOutput() {
+  /// Clear TClonesArray before usage.
+  fEvents->Delete();
+
+  /// Get vector reference from algo
+  std::vector<CbmEvent*> vEvents = fpAlgo->GetEventVector();
+
+  /// Move CbmEvent from temporary vector to TClonesArray
+  for (CbmEvent* event : vEvents) {
+    LOG(debug) << "Vector: " << event->ToString();
+    new ((*fEvents)[fEvents->GetEntriesFast()]) CbmEvent(std::move(*event));
+    LOG(debug) << "TClonesArray: "
+               << static_cast<CbmEvent*>(
+                    fEvents->At(fEvents->GetEntriesFast() - 1))
+                    ->ToString();
+  }  // for( CbmEvent* event: vEvents )
+
+  /// Clear event vector after usage
+  fpAlgo->ClearEventVector();
+}
+//----------------------------------------------------------------------
+void Cbm2021EventBuilderTask::SaveHistos() {
+  /// Obtain vector of pointers on each histo from the algo (+ optionally desired folder)