CbmTsaComponentSink.h

Go to the documentation of this file.

/* Copyright (C) 2018 GSI Helmholtzzentrum fuer Schwerionenforschung, Darmstadt
   SPDX-License-Identifier: GPL-3.0-only
   Authors: Florian Uhlig [committer] */
 
#ifndef CBMTSACOMPONENTSINK_H_
#define CBMTSACOMPONENTSINK_H_
 
#include "MicrosliceDescriptor.hpp"
#include "Timeslice.hpp"
 
#include "FairMQDevice.h"
 
class CbmTsaComponentSink : public FairMQDevice {
public:
  CbmTsaComponentSink();
  virtual ~CbmTsaComponentSink();
 
protected:
  virtual void InitTask();
  bool HandleData(FairMQMessagePtr&, int);
 
private:
  uint64_t fNumMessages;
 
  std::vector<std::string> fAllowedChannels = {"stscomponent", "tofcomponent", "trdcomponent"};
 
  bool CheckTimeslice(const fles::Timeslice& ts);
  void PrintMicroSliceDescriptor(const fles::MicrosliceDescriptor& mdsc);
  bool IsChannelNameAllowed(std::string channelName);
};
 
#endif /* CBMTSACOMPONENTSINK_H_ */