Inheritance diagram for CbmMQTsaMultiSampler:

Collaboration diagram for CbmMQTsaMultiSampler:

Protected Attributes
uint64_t	fMaxTimeslices

std::string	fFileName

std::string	fDirName

std::vector< std::string >	fInputFileList
	List of input files.

uint64_t	fFileCounter

std::string	fHost

uint64_t	fPort

uint64_t	fHighWaterMark

bool	fbNoSplitTs = false

bool	fbSendTsPerSysId = false

bool	fbSendTsPerChannel = false

std::string	fsChannelNameHistosInput = "histogram-in"

std::string	fsChannelNameHistosConfig = "histo-conf"

std::string	fsChannelNameCanvasConfig = "canvas-conf"

uint32_t	fuPublishFreqTs = 0

double_t	fdMinPublishTime = 0.5

double_t	fdMaxPublishTime = 5

uint64_t	fuPrevTsIndex = 0

uint64_t	fTSCounter

uint64_t	fMessageCounter

int	fMaxMemory = 0

Private Member Functions
bool	InitHistograms ()

bool	CheckTimeslice (const fles::Timeslice &ts)

void	PrintMicroSliceDescriptor (const fles::MicrosliceDescriptor &mdsc)

void	CalcRuntime ()

bool	IsChannelNameAllowed (std::string)

bool	CreateAndSendComponent (const fles::Timeslice &, int)

bool	CreateAndCombineComponentsPerSysId (const fles::Timeslice &)

bool	CreateAndCombineComponentsPerChannel (const fles::Timeslice &)

bool	CreateAndSendFullTs (const fles::Timeslice &)

bool	SendData (const fles::StorableTimeslice &, int)

bool	SendData (const fles::StorableTimeslice &, std::string)

bool	SendMissedTsIdx (std::vector< uint64_t > vIndices)

bool	SendCommand (std::string sCommand)

bool	SendHistograms ()

bool	ResetHistograms ()

Private Attributes
fles::TimesliceSource *	fSource

std::chrono::steady_clock::time_point	fTime

std::chrono::system_clock::time_point	fLastPublishTime

std::vector< std::string >	fAllowedChannels

std::vector< int >	fSysId = {0x10, 0x30, 0x40, 0x50, 0x60, 0x90, 0x80}

std::vector< int >	fComponentsToSend = {0, 0, 0, 0, 0, 0, 0}

std::vector< std::vector< std::string > >	fChannelsToSend = {{}, {}, {}, {}, {}, {}, {}}

bool	fbListCompPerSysIdReady = false

std::vector< std::vector< uint32_t > >	fvvCompPerSysId = {{}, {}, {}, {}, {}, {}, {}}

bool	fbListCompPerChannelReady = false

std::vector< std::string >	fvChannelsToSend = {}

std::vector< std::vector< uint32_t > >	fvvCompPerChannel = {}

std::string	fsChannelNameMissedTs = ""

std::string	fsChannelNameCommands = ""

TObjArray	fArrayHisto = {}
	Array of histograms to send to the histogram server.

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::pair< std::string, std::string > >	fvpsCanvasConfig = {}

TH1I *	fhTsRate = nullptr
	Histograms.

TH1I *	fhTsSize = nullptr

TProfile *	fhTsSizeEvo = nullptr

TH1F *	fhTsMaxSizeEvo = nullptr

TH1I *	fhMissedTS = nullptr

TProfile *	fhMissedTSEvo = nullptr

TCanvas *	fcSummary = nullptr

uint64_t	fuStartTime = 0

double_t	fdTimeToStart = 0.

double_t	fdLastMaxTime = 0.

double_t	fdTsMaxSize = 0.

Detailed Description

Definition at line 34 of file CbmMQTsaMultiSampler.h.

Constructor & Destructor Documentation

CbmMQTsaMultiSampler::CbmMQTsaMultiSampler ( )

Definition at line 61 of file CbmMQTsaMultiSampler.cxx.

CbmMQTsaMultiSampler::~CbmMQTsaMultiSampler ( )

virtual

Definition at line 989 of file CbmMQTsaMultiSampler.cxx.

void CbmMQTsaMultiSampler::CalcRuntime ( )

private

Definition at line 991 of file CbmMQTsaMultiSampler.cxx.

References fTime.

bool CbmMQTsaMultiSampler::CheckTimeslice ( const fles::Timeslice & ts )

private

Definition at line 1014 of file CbmMQTsaMultiSampler.cxx.

bool CbmMQTsaMultiSampler::ConditionalRun ( )

protectedvirtual

initialize the source (connect to emitter, ...)

Fill max size per s (assumes the histo binning is 1 second!)

Missed TS detection (only if output channel name defined by user)

Add missing TS indices to a vector and send it in appropriate channel