Go to the documentation of this file.
8 #ifndef CBMDEVICEMCBMUNPACK_H_
9 #define CBMDEVICEMCBMUNPACK_H_
11 #include "FairMQDevice.h"
13 #include "Timeslice.hpp"
17 #include "TObjArray.h"
99 Bool_t
DoUnpack(
const fles::Timeslice& ts,
size_t component);
bool HandleCommand(FairMQMessagePtr &, int)
CbmMcbm2018UnpackerAlgoMuch * fUnpAlgoMuch
static const uint16_t kusSysIdPsd
Double_t fdTsCoreSizeInNs
Size of a single MS, [nanoseconds].
uint64_t fulNumMessages
Statistics & first TS rejection.
std::vector< std::string > fsAllowedChannels
List of MQ channels names.
std::string fsChannelNameCommands
static const uint16_t kusSysIdTof
TimesliceMetaData * fTsMetaData
Total size of all MS in a TS, [nanoseconds].
static const uint16_t kusSysIdTrd
Bool_t InitParameters(TList *fParCList)
Parameters management.
CbmMcbm2018UnpackerAlgoPsd * fUnpAlgoPsd
CbmMQTMessage(void *buf, Int_t len)
std::vector< std::string > fvsSetTimeOffs
Time offsets.
bool HandleData(FairMQMessagePtr &, int)
static const uint16_t kusSysIdRich
Double_t fdTsFullSizeInNs
Total size of the overlap MS in a TS, [nanoseconds].
CbmMcbm2018UnpackerAlgoRich * fUnpAlgoRich
CbmMcbm2018UnpackerAlgoSts * fUnpAlgoSts
Processing algos.
std::string fsChannelNameDataOutput
CbmMcbm2018UnpackerAlgoTrdR * fUnpAlgoTrd
Bool_t fbIgnoreOverlapMs
Control flags.
size_t fuNbCoreMsPerTs
TS MetaData storage.
bool IsChannelNameAllowed(std::string channelName)
CbmMcbm2018UnpackerAlgoTof * fUnpAlgoTof
Bool_t fbComponentsAddedToList
Ignore Overlap Ms: all fuOverlapMsNb MS at the end of timeslice.
virtual ~CbmDeviceMcbmUnpack()
static const uint16_t kusSysIdT0
static const uint16_t kusSysIdMuch
static const uint16_t kusSysIdSts
Constants.
std::string fsChannelNameDataInput
User settings parameters.
Double_t fdTsOverSizeInNs
Total size of the core MS in a TS, [nanoseconds].
Bool_t DoUnpack(const fles::Timeslice &ts, size_t component)
Timeslice unpacker algorithm for Spadic v.2.2 .