CbmTaskTriggerDigi.cxx

Go to the documentation of this file.

/* Copyright (C) 2021 GSI Helmholtzzentrum fuer Schwerionenforschung, Darmstadt
   SPDX-License-Identifier: GPL-3.0-only
   Authors: Volker Friese [committer] */
 
#include "CbmTaskTriggerDigi.h"
 
#include "CbmDefs.h"
#include "CbmDigiManager.h"
#include "CbmDigiTimeslice.h"
#include "CbmModuleList.h"
#include "CbmMuchDigi.h"
#include "CbmPsdDigi.h"
#include "CbmRichDigi.h"
#include "CbmStsDigi.h"
#include "CbmTofDigi.h"
#include "CbmTrdDigi.h"
#include "TimeClusterTrigger.h"
 
#include <FairRootManager.h>
#include <Logger.h>
 
#include <algorithm>
#include <cassert>
#include <iomanip>
#include <vector>
 
// -----   Constructor   -----------------------------------------------------
CbmTaskTriggerDigi::CbmTaskTriggerDigi() : FairTask("TriggerDigi") {}
// ---------------------------------------------------------------------------
 
// -----   Destructor   ------------------------------------------------------
CbmTaskTriggerDigi::~CbmTaskTriggerDigi()
{
  if (fTriggers) delete fTriggers;
}
// ---------------------------------------------------------------------------
 
// -----   Execution   -------------------------------------------------------
void CbmTaskTriggerDigi::Exec(Option_t*)
{
 
  // --- Timer and counters
  TStopwatch timerStep;
  TStopwatch timerTot;
  timerTot.Start();
 
  // --- Get digi times
  std::vector<double> digiTimes;
 
  // --- Case: input CbmDigiTimeslice
  if (fTimeslice) {
    for (const auto& system : fSystems) {
      std::vector<double> systemDigiTimes = GetDigiTimes(system);
      digiTimes.insert(digiTimes.end(), systemDigiTimes.begin(), systemDigiTimes.end());
    }
    if (fSystems.size() > 1) {
      std::sort(digiTimes.begin(), digiTimes.end());
    }
  }
 
  // --- Case: input digi branches
  else {
    for (const auto& system : fSystems) {
      CbmDigiBranchBase* digiBranch = fDigiMan->GetBranch(system);
      std::vector<double> locDigiTimes;
      switch (system) {
        case ECbmModuleId::kMuch: {  //we do not support the "MuchBeamTimeDigi"
          locDigiTimes = GetDigiTimes<CbmMuchDigi>(digiBranch);
          break;
        }
        case ECbmModuleId::kSts: {
          locDigiTimes = GetDigiTimes<CbmStsDigi>(digiBranch);
          break;
        }
        case ECbmModuleId::kTof: {
          locDigiTimes = GetDigiTimes<CbmTofDigi>(digiBranch);
          break;
        }
        case ECbmModuleId::kTrd: {
          locDigiTimes = GetDigiTimes<CbmTrdDigi>(digiBranch);
          break;
        }
        case ECbmModuleId::kRich: {
          locDigiTimes = GetDigiTimes<CbmRichDigi>(digiBranch);
          break;
        }
        case ECbmModuleId::kPsd: {
          locDigiTimes = GetDigiTimes<CbmPsdDigi>(digiBranch);
          break;
        }
        case ECbmModuleId::kBmon: {  //Bmon has Tof digis
          locDigiTimes = GetDigiTimes<CbmTofDigi>(digiBranch);
          break;
        }
        default: {
          LOG(error) << GetName() << ": Unknown detector type!";
          break;
        }
      }
      digiTimes.insert(digiTimes.end(), locDigiTimes.begin(), locDigiTimes.end());
    }
    if (fSystems.size() > 1) {
      std::sort(digiTimes.begin(), digiTimes.end());
    }
  }
 
  // --- Call the trigger algorithm
  timerStep.Start();
  *fTriggers = (*fAlgo)(digiTimes).first;
  timerStep.Stop();
  fTimeFind += timerStep.RealTime();
 
  // --- Timeslice statistics
  size_t numDigis    = digiTimes.size();
  size_t numTriggers = fTriggers->size();
 
  // --- Timeslice log
  timerTot.Stop();
  fTimeTot += timerTot.RealTime();
  stringstream logOut;
  logOut << setw(15) << left << GetName() << " [";
  logOut << fixed << setw(8) << setprecision(1) << right << timerTot.RealTime() * 1000. << " ms] ";
  logOut << "TS " << fNumTs << ", digis " << numDigis << ", triggers " << numTriggers;
  LOG(info) << logOut.str();
 
  // --- Run statistics
  fNumTs++;
  fNumDigis += numDigis;
  fNumTriggers += numTriggers;
}
// ----------------------------------------------------------------------------
 
 
// -----   Get digi times from CbmDigiTimeslice   -----------------------------
std::vector<double> CbmTaskTriggerDigi::GetDigiTimes(ECbmModuleId system)
{
  assert(fTimeslice);
  std::vector<double> result;
  switch (system) {
    case ECbmModuleId::kSts: {
      result.resize(fTimeslice->fData.fSts.fDigis.size());
      auto it1 = fTimeslice->fData.fSts.fDigis.begin();
      auto it2 = fTimeslice->fData.fSts.fDigis.end();
      std::transform(it1, it2, result.begin(), [](const CbmStsDigi& digi) { return digi.GetTime(); });
      break;
    }
    case ECbmModuleId::kRich: {
      result.resize(fTimeslice->fData.fRich.fDigis.size());
      auto it1 = fTimeslice->fData.fRich.fDigis.begin();
      auto it2 = fTimeslice->fData.fRich.fDigis.end();
      std::transform(it1, it2, result.begin(), [](const CbmRichDigi& digi) { return digi.GetTime(); });
      break;
    }
    case ECbmModuleId::kMuch: {
      result.resize(fTimeslice->fData.fMuch.fDigis.size());
      auto it1 = fTimeslice->fData.fMuch.fDigis.begin();
      auto it2 = fTimeslice->fData.fMuch.fDigis.end();
      std::transform(it1, it2, result.begin(), [](const CbmMuchDigi& digi) { return digi.GetTime(); });
      break;
    }
    case ECbmModuleId::kTrd: {
      result.resize(fTimeslice->fData.fTrd.fDigis.size());
      auto it1 = fTimeslice->fData.fTrd.fDigis.begin();
      auto it2 = fTimeslice->fData.fTrd.fDigis.end();
      std::transform(it1, it2, result.begin(), [](const CbmTrdDigi& digi) { return digi.GetTime(); });
      break;
    }
    case ECbmModuleId::kTof: {
      result.resize(fTimeslice->fData.fTof.fDigis.size());
      auto it1 = fTimeslice->fData.fTof.fDigis.begin();
      auto it2 = fTimeslice->fData.fTof.fDigis.end();
      std::transform(it1, it2, result.begin(), [](const CbmTofDigi& digi) { return digi.GetTime(); });
      break;
    }
    case ECbmModuleId::kPsd: {
      result.resize(fTimeslice->fData.fPsd.fDigis.size());
      auto it1 = fTimeslice->fData.fPsd.fDigis.begin();
      auto it2 = fTimeslice->fData.fPsd.fDigis.end();
      std::transform(it1, it2, result.begin(), [](const CbmPsdDigi& digi) { return digi.GetTime(); });
      break;
    }
    case ECbmModuleId::kBmon: {
      result.resize(fTimeslice->fData.fBmon.fDigis.size());
      auto it1 = fTimeslice->fData.fBmon.fDigis.begin();
      auto it2 = fTimeslice->fData.fBmon.fDigis.end();
      std::transform(it1, it2, result.begin(), [](const CbmTofDigi& digi) { return digi.GetTime(); });
      break;
    }
    default: {
      LOG(error) << GetName() << ": Unknown system " << system;
      break;
    }
  }  //? system
 
  return result;
}
// ----------------------------------------------------------------------------
 
 
// -----   End-of-timeslice action   ------------------------------------------
void CbmTaskTriggerDigi::Finish()
{
  LOG(info) << "=====================================";
  LOG(info) << GetName() << ": Run summary";
  LOG(info) << "Timeslices         : " << fNumTs;
  LOG(info) << "Digis              : " << fNumDigis;
  LOG(info) << "Triggers           : " << fNumTriggers;
  LOG(info) << "Time  / TS         : " << fixed << setprecision(2) << 1000. * fTimeTot / double(fNumTs) << " ms";
  LOG(info) << "Time extract       : " << fixed << setprecision(2) << 1000. * fTimeExtract / double(fNumTs)
            << " ms = " << 100. * fTimeExtract / fTimeTot << " %";
  LOG(info) << "Time find trigger  : " << fixed << setprecision(2) << 1000. * fTimeFind / double(fNumTs)
            << " ms = " << 100. * fTimeFind / fTimeTot << " %";
  LOG(info) << "=====================================";
}
// ----------------------------------------------------------------------------
 
 
// -----   Initialisation   ---------------------------------------------------
InitStatus CbmTaskTriggerDigi::Init()
{
 
  // --- Get FairRootManager instance
  FairRootManager* ioman = FairRootManager::Instance();
  assert(ioman);
 
  LOG(info) << "==================================================";
  LOG(info) << GetName() << ": Initialising...";
 
  // --- Check input data
  // --- DigiTimeslice: Unpacked data from FLES
  fTimeslice = ioman->InitObjectAs<const CbmDigiTimeslice*>("DigiTimeslice.");
  if (fTimeslice) {
    LOG(info) << "--- Found branch DigiTimeslice.";
  }
  // --- DigiManager: Simulated digi data
  else {
    fDigiMan = CbmDigiManager::Instance();
    fDigiMan->Init();
    for (const auto& system : fSystems) {
      if (!fDigiMan->IsPresent(system)) {
        LOG(fatal) << GetName() << ": No digi branch for " << CbmModuleList::GetModuleNameCaps(system);
        return kFATAL;
      }
      LOG(info) << "--- Found digi branch for " << CbmModuleList::GetModuleNameCaps(system);
    }
  }
 
  // --- Register output array (Triggers)
  if (ioman->GetObject("Trigger")) {
    LOG(fatal) << GetName() << ": Branch Trigger already exists!";
    return kFATAL;
  }
  fTriggers = new vector<double>;
  ioman->RegisterAny("Trigger", fTriggers, IsOutputBranchPersistent("Trigger"));
  if (!fTriggers) {
    LOG(fatal) << GetName() << ": Output branch could not be created!";
    return kFATAL;
  }
  LOG(info) << "--- Registered branch Trigger";
 
  // --- Configure algorithm
  fAlgo.reset(new cbm::algo::evbuild::TimeClusterTrigger(fConfig->Window(), fConfig->Threshold(), fConfig->DeadTime()));
  LOG(info) << "--- Using trigger detector " << ::ToString(fConfig->Detector());
  LOG(info) << fAlgo->ToString();
 
  LOG(info) << "==================================================";
  return kSUCCESS;
}
// ----------------------------------------------------------------------------
 
ClassImp(CbmTaskTriggerDigi)