Go to the documentation of this file.
8 #ifndef CBMMQTSASAMPLER_H_
9 #define CBMMQTSASAMPLER_H_
12 #include "MicrosliceDescriptor.hpp"
13 #include "StorableTimeslice.hpp"
14 #include "Timeslice.hpp"
15 #include "TimesliceSource.hpp"
18 #include "FairMQDevice.h"
54 bool SendData(
const fles::StorableTimeslice& component);
58 bool SendData(
const fles::StorableTimeslice&,
int);
61 std::chrono::steady_clock::time_point
fTime;
78 std::vector<int>
fSysId = {16, 64, 96};
std::chrono::steady_clock::time_point fTime
std::vector< std::string > fAllowedChannels
bool IsChannelNameAllowed(std::string)
std::vector< int > fSysId
bool SendData(const fles::StorableTimeslice &component)
std::vector< int > fComponentsToSend
bool CheckTimeslice(const fles::Timeslice &ts)
void PrintMicroSliceDescriptor(const fles::MicrosliceDescriptor &mdsc)
virtual ~CbmMQTsaSampler()
fles::TimesliceSource * fSource
std::vector< std::string > fInputFileList
List of input files.
virtual bool ConditionalRun()
std::vector< std::vector< std::string > > fChannelsToSend
bool CreateAndSendComponent(const fles::Timeslice &, int)