CbmDaq.h

Go to the documentation of this file.

/* Copyright (C) 2012-2020 GSI Helmholtzzentrum fuer Schwerionenforschung, Darmstadt
   SPDX-License-Identifier: GPL-3.0-only
   Authors: Volker Friese [committer] */
 
#ifndef CBMDAQ_H
#define CBMDAQ_H 1
 
#include "CbmDefs.h"         // for ECbmModuleId
#include "CbmMCEventList.h"  // for CbmMCEventList
 
#include <FairTask.h>  // for FairTask, InitStatus
 
#include <Rtypes.h>      // for THashConsistencyHolder, ClassDef
#include <RtypesCore.h>  // for Int_t, Double_t, Bool_t, kFALSE, ULong64_t
#include <TStopwatch.h>  // for TStopwatch
 
#include <map>      // for map
#include <string>   // for string
#include <utility>  // for pair
class CbmDigi;
class CbmDigitizeBase;
class CbmTimeSlice;
class TClonesArray;
 
 
class CbmDaq : public FairTask {
 
 public:
  CbmDaq(Bool_t eventMode = kFALSE);
 
 
  CbmDaq(Double_t tsLength);
 
 
  ~CbmDaq();
 
 
  virtual void Exec(Option_t* opt);
 
 
  virtual InitStatus Init();
 
 
  void SetLatency(Double_t time);
 
  void SetDigitizer(ECbmModuleId system, CbmDigitizeBase* digitizer);
 
 
  void SetTimeSliceLength(Double_t length) { fTimeSliceLength = length; }
 
 
  void StoreAllTimeSlices(Bool_t choice = kTRUE) { fStoreEmptySlices = choice; }
 
 
 private:
  Bool_t fIsEventByEvent;       
  Double_t fTimeSliceLength;    
  Double_t fLatency = 5000.;    
  Bool_t fStoreEmptySlices;     
  Double_t fTimeEventPrevious;  
 
  Int_t fNofEvents;           
  Int_t fNofDigis;            
  Int_t fNofDigisIgnored;     
  Int_t fNofTimeSlices;       
  Int_t fNofTimeSlicesEmpty;  
  Double_t fTimeDigiFirst;    
  Double_t fTimeDigiLast;     
  Double_t fTimeSliceFirst;   
  Double_t fTimeSliceLast;    
 
  TStopwatch fTimer;                                     
  std::map<ECbmModuleId, TClonesArray*> fDigis;          
  std::map<ECbmModuleId, CbmDigitizeBase*> fDigitizers;  
  CbmTimeSlice* fTimeSlice;                              
  CbmMCEventList fEventList;                             
  CbmMCEventList* fEventsCurrent;                        
 
 
  std::map<Int_t, std::pair<Int_t, Int_t>> fEventRange;  
 
 
  Bool_t CheckOutput() const;
 
 
  void CloseTimeSlice();
 
 
  Int_t CopyEventList();
 
 
  void FillData(CbmDigi* digi);
  //TODO: Obsolete, remove
 
 
  ULong64_t FillTimeSlice(Bool_t timeLimit, Double_t fillTime = -1.);
 
 
  ULong64_t GetBufferSize() const;
 
 
  std::string GetBufferStatus(Bool_t verbose = kFALSE) const;
 
 
  Double_t GetBufferTimeFirst() const;
 
 
  Double_t GetBufferTimeLast() const;
 
 
  Bool_t IsDaqBufferEmpty() const;
 
 
  void PrintCurrentEventRange() const;
 
 
  void StartNextTimeSlice();
 
 
  virtual void Finish();
 
 
  CbmDaq(const CbmDaq&) = delete;
  CbmDaq& operator=(const CbmDaq&) = delete;
 
  ClassDef(CbmDaq, 4);
};
 
#endif /* CBMDAQ_H */