CbmDevEventSink.h

Go to the documentation of this file.

/* Copyright (C) 2022 Facility for Antiproton and Ion Research in Europe, Darmstadt
   SPDX-License-Identifier: GPL-3.0-only
   Authors: Dominik Smith [committer], Pierre-Alain Loizeau, Volker Friese */
 
#ifndef CBMDEVICEEVTSINK_H_
#define CBMDEVICEEVTSINK_H_
 
#include "CbmDigiEvent.h"
#include "FairMQDevice.h"
 
#include <vector>
 
class TimesliceMetaData;
class FairRunOnline;
class FairRootManager;
 
 
class CbmDevEventSink : public FairMQDevice {
 public:
  CbmDevEventSink(){};
 
  virtual ~CbmDevEventSink();
 
 
 protected:
  bool HandleCommand(FairMQMessagePtr&, int flag);
 
  bool HandleData(FairMQParts& parts, int flag);
 
  virtual void InitTask();
 
 
 private:  // methods
  void Finish();
 
 
 private:  // members
  // --- Counters and status flags
  size_t fNumMessages                  = 0;        
  size_t fNumTs                        = 0;        
  uint64_t fPrevTsIndex                = 0;        
  bool fFinishDone                     = false;    
  TimesliceMetaData* fTsMetaData       = nullptr;  
  std::vector<CbmDigiEvent>* fEventVec = nullptr;  
  FairRunOnline* fFairRun              = nullptr;  
  FairRootManager* fFairRootMgr        = nullptr;  
};
 
#endif /* CBMDEVICEEVTSINK_H_ */