CbmRoot
|
#include <CbmDevBuildEvents.h>
Public Member Functions | |
CbmDevBuildEvents () | |
virtual | ~CbmDevBuildEvents () |
Protected Member Functions | |
virtual void | InitTask () |
bool | HandleData (FairMQParts &, int) |
Private Member Functions | |
bool | IsChannelNameAllowed (std::string channelName) |
bool | SendEvents (const std::vector< CbmDigiEvent > &vEvents, const TimesliceMetaData *tsMetaData) |
ECbmModuleId | GetDetectorId (std::string detName) |
void | DumpTreeEntry () |
void | Finish () |
Private Attributes | |
Bool_t | fbFinishDone = false |
std::string | fsChannelNameDataInput = "trigger" |
Keep track of whether the Finish was already called. | |
std::string | fsChannelNameDataOutput = "events" |
std::vector< std::string > | fsAllowedChannels = {fsChannelNameDataInput} |
List of MQ channels names. | |
uint64_t | fulNumMessages = 0 |
Statistics & first TS rejection. | |
std::unique_ptr< cbm::algo::evbuild::EventBuilder > | fEvbuildAlgo |
Processing algos. | |
std::string | fsOutputFileName = "" |
Data storage. | |
FairRunOnline * | fpRun = nullptr |
FairRootManager * | fpFairRootMgr = nullptr |
std::vector< CbmDigiEvent > * | fEventsSelOut = nullptr |
TClonesArray * | fTimeSliceMetaDataArrayOut = nullptr |
Definition at line 34 of file CbmDevBuildEvents.h.
CbmDevBuildEvents::CbmDevBuildEvents | ( | ) |
Definition at line 37 of file CbmDevBuildEvents.cxx.
|
virtual |
Close things properly if not alredy done
Definition at line 303 of file CbmDevBuildEvents.cxx.
References fbFinishDone, fEventsSelOut, Finish(), fpRun, and fTimeSliceMetaDataArrayOut.
|
private |
FairRunOnline style
Definition at line 253 of file CbmDevBuildEvents.cxx.
References fpFairRootMgr.
Referenced by HandleData().
|
private |
Definition at line 293 of file CbmDevBuildEvents.cxx.
References fbFinishDone, fpFairRootMgr, and fsOutputFileName.
Referenced by ~CbmDevBuildEvents().
|
private |
|
protected |
Extract unpacked data from input message
TS
TS metadata
Triggers
First message received (do TS metadata stuff here)
Create events
Send output message
Write events to file
with FairMq messages ownership and memory managment
Definition at line 177 of file CbmDevBuildEvents.cxx.
References DumpTreeEntry(), CbmDigiData::fBmon, CbmDigiTimeslice::fData, CbmBmonDigiData::fDigis, CbmFsdDigiData::fDigis, CbmMuchDigiData::fDigis, CbmPsdDigiData::fDigis, CbmRichDigiData::fDigis, CbmStsDigiData::fDigis, CbmTofDigiData::fDigis, CbmTrdDigiData::fDigis, fEventsSelOut, CbmDigiData::fFsd, first, CbmDigiData::fMuch, CbmDigiData::fPsd, CbmDigiData::fRich, fsOutputFileName, CbmDigiData::fSts, fTimeSliceMetaDataArrayOut, CbmDigiData::fTof, CbmDigiData::fTrd, fulNumMessages, and SendEvents().
Referenced by InitTask().
|
protectedvirtual |
Read options from executable
Prepare root output
Create storage objects
Extract event builder window to add if any
Detector Enum Tag
Window beginning
Window end
Definition at line 39 of file CbmDevBuildEvents.cxx.
References fEvbuildAlgo, fEventsSelOut, fpFairRootMgr, fpRun, fsAllowedChannels, fsChannelNameDataInput, fsChannelNameDataOutput, fsOutputFileName, fTimeSliceMetaDataArrayOut, GetDetectorId(), HandleData(), IsChannelNameAllowed(), and kNotExist.
|
private |
Definition at line 158 of file CbmDevBuildEvents.cxx.
References fsAllowedChannels, and pos.
Referenced by InitTask().
|
private |
Definition at line 263 of file CbmDevBuildEvents.cxx.
References fsChannelNameDataOutput.
Referenced by HandleData().
|
private |
Definition at line 44 of file CbmDevBuildEvents.h.
Referenced by Finish(), and ~CbmDevBuildEvents().
|
private |
|
private |
Definition at line 65 of file CbmDevBuildEvents.h.
Referenced by HandleData(), InitTask(), and ~CbmDevBuildEvents().
|
private |
Definition at line 64 of file CbmDevBuildEvents.h.
Referenced by DumpTreeEntry(), Finish(), and InitTask().
|
private |
Definition at line 63 of file CbmDevBuildEvents.h.
Referenced by InitTask(), and ~CbmDevBuildEvents().
|
private |
List of MQ channels names.
Definition at line 52 of file CbmDevBuildEvents.h.
Referenced by InitTask(), and IsChannelNameAllowed().
|
private |
Keep track of whether the Finish was already called.
User settings parameters message queues
Definition at line 48 of file CbmDevBuildEvents.h.
Referenced by InitTask().
|
private |
Definition at line 49 of file CbmDevBuildEvents.h.
Referenced by InitTask(), and SendEvents().
|
private |
Data storage.
Definition at line 62 of file CbmDevBuildEvents.h.
Referenced by Finish(), HandleData(), and InitTask().
|
private |
Definition at line 66 of file CbmDevBuildEvents.h.
Referenced by HandleData(), InitTask(), and ~CbmDevBuildEvents().
|
private |
Statistics & first TS rejection.
Definition at line 55 of file CbmDevBuildEvents.h.
Referenced by HandleData().