CbmRoot
CbmTsaComponentSink.h
Go to the documentation of this file.
1 
8 #ifndef CBMTSACOMPONENTSINK_H_
9 #define CBMTSACOMPONENTSINK_H_
10 
11 #include "FairMQDevice.h"
12 
13 #include "MicrosliceDescriptor.hpp"
14 #include "Timeslice.hpp"
15 
16 class CbmTsaComponentSink : public FairMQDevice {
17 public:
19  virtual ~CbmTsaComponentSink();
20 
21 protected:
22  virtual void InitTask();
23  bool HandleData(FairMQMessagePtr&, int);
24 
25 private:
26  uint64_t fNumMessages;
27 
28  std::vector<std::string> fAllowedChannels = {"stscomponent",
29  "tofcomponent",
30  "trdcomponent"};
31 
32  bool CheckTimeslice(const fles::Timeslice& ts);
33  void PrintMicroSliceDescriptor(const fles::MicrosliceDescriptor& mdsc);
34  bool IsChannelNameAllowed(std::string channelName);
35 };
36 
37 #endif /* CBMTSACOMPONENTSINK_H_ */
CbmTsaComponentSink::CheckTimeslice
bool CheckTimeslice(const fles::Timeslice &ts)
Definition: CbmTsaComponentSink.cxx:115
CbmTsaComponentSink::IsChannelNameAllowed
bool IsChannelNameAllowed(std::string channelName)
Definition: CbmTsaComponentSink.cxx:52
CbmTsaComponentSink::fNumMessages
uint64_t fNumMessages
Definition: CbmTsaComponentSink.h:26
CbmTsaComponentSink::fAllowedChannels
std::vector< std::string > fAllowedChannels
Definition: CbmTsaComponentSink.h:28
CbmTsaComponentSink
Definition: CbmTsaComponentSink.h:16
CbmTsaComponentSink::~CbmTsaComponentSink
virtual ~CbmTsaComponentSink()
Definition: CbmTsaComponentSink.cxx:95
CbmTsaComponentSink::PrintMicroSliceDescriptor
void PrintMicroSliceDescriptor(const fles::MicrosliceDescriptor &mdsc)
Definition: CbmTsaComponentSink.cxx:97
CbmTsaComponentSink::CbmTsaComponentSink
CbmTsaComponentSink()
Definition: CbmTsaComponentSink.cxx:27
CbmTsaComponentSink::HandleData
bool HandleData(FairMQMessagePtr &, int)
Definition: CbmTsaComponentSink.cxx:75
CbmTsaComponentSink::InitTask
virtual void InitTask()
Definition: CbmTsaComponentSink.cxx:29