Go to the documentation of this file.
8 #ifndef CBMDEVICEMCBMEVTBUILDERWIN_H_
9 #define CBMDEVICEMCBMEVTBUILDERWIN_H_
21 #include "FairMQDevice.h"
26 #include "TObjArray.h"
86 std::chrono::system_clock::now();
CbmDeviceMcbmEventBuilderWin()
std::string fsChannelNameCanvasConfig
uint32_t fuPublishFreqTs
Histograms management.
Bool_t fbFillHistos
Ignore data in Overlap part of the TS.
std::vector< CbmMuchBeamTimeDigi > * fvDigiMuch
CbmMcbm2019TimeWinEventBuilderAlgo * fpAlgo
Processing algos.
FairRunOnline * fpRun
output container of CbmEvents
Bool_t fbIgnoreTsOverlap
Constants.
std::string fsEvtOverMode
Switch ON/OFF filling of histograms.
std::vector< std::string > fsAllowedChannels
List of MQ channels names.
uint64_t fulNumMessages
Parameters management.
std::string fsChannelNameHistosConfig
Double_t fdTsFullSizeInNs
Total size of the overlap MS in a TS, [nanoseconds].
Double_t fdTsOverSizeInNs
Total size of the core MS in a TS, [nanoseconds].
std::vector< CbmTrdDigi > * fvDigiTrd
std::vector< CbmStsDigi > * fvDigiSts
CbmMQTMessage(void *buf, Int_t len)
bool HandleCommand(FairMQMessagePtr &, int)
std::string fsChannelNameHistosInput
std::string fsChannelNameDataOutput
Double_t fdTsCoreSizeInNs
Size of a single MS, [nanoseconds].
std::vector< CbmTofDigi > * fvDigiTof
virtual ~CbmDeviceMcbmEventBuilderWin()
std::vector< std::string > fvsDelDet
TObjArray fArrayHisto
Array of histograms to send to the histogram server.
size_t fuNbCoreMsPerTs
TS MetaData stable values storage.
std::vector< CbmTofDigi > * fvDigiT0
Digis storage.
std::string fsChannelNameCommands
bool SendEvents(FairMQParts &partsIn)
std::vector< CbmPsdDigi > * fvDigiPsd
double_t fdMaxPublishTime
std::vector< std::string > fvsSetTrigWin
std::vector< CbmRichDigi > * fvDigiRich
std::string fsChannelNameDataInput
message queues
TClonesArray * fEvents
Data emission.
std::vector< std::pair< std::string, std::string > > fvpsHistosFolder
Vector of string pairs with ( HistoName, FolderPath ) to send to the histogram server.
std::vector< std::string > fvsSetTrigMinNb
std::vector< std::pair< std::string, std::string > > fvpsCanvasConfig
bool IsChannelNameAllowed(std::string channelName)
std::chrono::system_clock::time_point fLastPublishTime
TClonesArray * fTimeSliceMetaDataArray
Total size of all MS in a TS, [nanoseconds].
bool HandleData(FairMQParts &, int)
TimesliceMetaData * fTsMetaData
double_t fdMinPublishTime
std::vector< std::string > fvsAddDet