#include <CbmMQTsaMultiSamplerTof.h>

Inheritance diagram for CbmMQTsaMultiSamplerTof:

Collaboration diagram for CbmMQTsaMultiSamplerTof:

Public Member Functions
	CbmMQTsaMultiSamplerTof ()

virtual	~CbmMQTsaMultiSamplerTof ()

Protected Member Functions
virtual void	InitTask ()

virtual bool	ConditionalRun ()

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

uint64_t	fTSNumber

uint64_t	fTSCounter

uint64_t	fMessageCounter

int	fMaxMemory = 0

Private Member Functions
bool	OpenNextFile ()

bool	CheckTimeslice (const fles::Timeslice &ts)

void	PrintMicroSliceDescriptor (const fles::MicrosliceDescriptor &mdsc)

bool	SendData (const fles::StorableTimeslice &component)

void	CalcRuntime ()

bool	IsChannelNameAllowed (std::string)

bool	IsChannelUp (std::string)

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

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

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

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

bool	SendTs ()

void	SendSysCmdStop ()

Private Attributes
fles::TimesliceSource *	fSource

std::chrono::steady_clock::time_point	fTime

std::vector< std::string >	fAllowedChannels = {"stscomponent", "trdcomponent", "tofcomponent", "syscmd", "syscmdin"}

std::vector< int >	fSysId = {16, 64, 96}

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

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

Detailed Description

CbmMQTsaMultiSamplerTof.h

Since: 2018-09-14

Author: N. Herrmann

Definition at line 27 of file CbmMQTsaMultiSamplerTof.h.

Constructor & Destructor Documentation

◆ CbmMQTsaMultiSamplerTof()

CbmMQTsaMultiSamplerTof::CbmMQTsaMultiSamplerTof ( )

Definition at line 50 of file CbmMQTsaMultiSamplerTof.cxx.

References fDirName, fFileCounter, fFileName, fHighWaterMark, fHost, fInputFileList, fMaxTimeslices, fMessageCounter, fPort, fSource, fTime, fTSCounter, and fTSNumber.

◆ ~CbmMQTsaMultiSamplerTof()

CbmMQTsaMultiSamplerTof::~CbmMQTsaMultiSamplerTof ( )

virtual

Definition at line 487 of file CbmMQTsaMultiSamplerTof.cxx.

Member Function Documentation

◆ AppendData()

bool CbmMQTsaMultiSamplerTof::AppendData	(	const fles::StorableTimeslice &	,
		int	)

private

Definition at line 385 of file CbmMQTsaMultiSamplerTof.cxx.

◆ CalcRuntime()

void CbmMQTsaMultiSamplerTof::CalcRuntime ( )

private

Definition at line 489 of file CbmMQTsaMultiSamplerTof.cxx.

References fTime.

◆ CheckTimeslice()

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

private

Definition at line 512 of file CbmMQTsaMultiSamplerTof.cxx.

Referenced by ConditionalRun().

◆ ConditionalRun()

bool CbmMQTsaMultiSamplerTof::ConditionalRun ( )

protectedvirtual

Definition at line 220 of file CbmMQTsaMultiSamplerTof.cxx.

References CheckTimeslice(), fChannelsToSend, fComponentsToSend, fiSelectComponents, fMaxTimeslices, fMessageCounter, fSource, fSysId, fTSCounter, pos, and SendSysCmdStop().

◆ CreateAndCombineComponents()

bool CbmMQTsaMultiSamplerTof::CreateAndCombineComponents	(	const fles::Timeslice &	,
		int	)

private

Definition at line 352 of file CbmMQTsaMultiSamplerTof.cxx.

◆ CreateAndSendComponent()

bool CbmMQTsaMultiSamplerTof::CreateAndSendComponent	(	const fles::Timeslice &	ts,
		int	nrComp )

private

Definition at line 423 of file CbmMQTsaMultiSamplerTof.cxx.

References fComponentsToSend, fSysId, pos, and SendData().

◆ InitTask()

void CbmMQTsaMultiSamplerTof::InitTask ( )

protectedvirtual

Definition at line 68 of file CbmMQTsaMultiSamplerTof.cxx.

References fComponentsToSend, fDirName, fFileName, fHighWaterMark, fHost, fInputFileList, fiSelectComponents, fMaxTimeslices, fPort, fSource, fTime, and IsChannelNameAllowed().

◆ IsChannelNameAllowed()

bool CbmMQTsaMultiSamplerTof::IsChannelNameAllowed ( std::string channelName )

private

Definition at line 181 of file CbmMQTsaMultiSamplerTof.cxx.

References fAllowedChannels, fChannelsToSend, fComponentsToSend, and pos.

Referenced by InitTask().

◆ IsChannelUp()

bool CbmMQTsaMultiSamplerTof::IsChannelUp ( std::string channelName )

private

Definition at line 205 of file CbmMQTsaMultiSamplerTof.cxx.

Referenced by SendSysCmdStop().

◆ OpenNextFile()

bool CbmMQTsaMultiSamplerTof::OpenNextFile ( )

private

◆ PrintMicroSliceDescriptor()

void CbmMQTsaMultiSamplerTof::PrintMicroSliceDescriptor ( const fles::MicrosliceDescriptor & mdsc )

private

Definition at line 498 of file CbmMQTsaMultiSamplerTof.cxx.

◆ SendData() [1/2]

bool CbmMQTsaMultiSamplerTof::SendData	(	const fles::StorableTimeslice &	component,
		int	idx )

private

Definition at line 451 of file CbmMQTsaMultiSamplerTof.cxx.

References fChannelsToSend, fComponentsToSend, and fMessageCounter.

◆ SendData() [2/2]

bool CbmMQTsaMultiSamplerTof::SendData ( const fles::StorableTimeslice & component )

private

Referenced by CreateAndSendComponent().

◆ SendSysCmdStop()

void CbmMQTsaMultiSamplerTof::SendSysCmdStop ( )

private

Definition at line 544 of file CbmMQTsaMultiSamplerTof.cxx.

References IsChannelUp().

Referenced by ConditionalRun().

◆ SendTs()

bool CbmMQTsaMultiSamplerTof::SendTs ( )

private

Definition at line 404 of file CbmMQTsaMultiSamplerTof.cxx.

Member Data Documentation

◆ fAllowedChannels

std::vector<std::string> CbmMQTsaMultiSamplerTof::fAllowedChannels = {"stscomponent", "trdcomponent", "tofcomponent", "syscmd", "syscmdin"}

private

Definition at line 84 of file CbmMQTsaMultiSamplerTof.h.

Referenced by IsChannelNameAllowed().

◆ fChannelsToSend

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

private

Definition at line 89 of file CbmMQTsaMultiSamplerTof.h.

Referenced by ConditionalRun(), IsChannelNameAllowed(), and SendData().

◆ fComponentsToSend

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

private

Definition at line 88 of file CbmMQTsaMultiSamplerTof.h.

Referenced by ConditionalRun(), CreateAndSendComponent(), InitTask(), IsChannelNameAllowed(), and SendData().

◆ fDirName

std::string CbmMQTsaMultiSamplerTof::fDirName

protected

Definition at line 36 of file CbmMQTsaMultiSamplerTof.h.

Referenced by CbmMQTsaMultiSamplerTof(), and InitTask().

◆ fFileCounter

uint64_t CbmMQTsaMultiSamplerTof::fFileCounter

protected

Definition at line 39 of file CbmMQTsaMultiSamplerTof.h.

Referenced by CbmMQTsaMultiSamplerTof().

◆ fFileName

std::string CbmMQTsaMultiSamplerTof::fFileName

protected

Definition at line 35 of file CbmMQTsaMultiSamplerTof.h.

Referenced by CbmMQTsaMultiSamplerTof(), and InitTask().

◆ fHighWaterMark

uint64_t CbmMQTsaMultiSamplerTof::fHighWaterMark

protected

Definition at line 42 of file CbmMQTsaMultiSamplerTof.h.

Referenced by CbmMQTsaMultiSamplerTof(), and InitTask().

◆ fHost

std::string CbmMQTsaMultiSamplerTof::fHost

protected

Definition at line 40 of file CbmMQTsaMultiSamplerTof.h.

Referenced by CbmMQTsaMultiSamplerTof(), and InitTask().

◆ fInputFileList

std::vector<std::string> CbmMQTsaMultiSamplerTof::fInputFileList

protected

List of input files.

Definition at line 38 of file CbmMQTsaMultiSamplerTof.h.

Referenced by CbmMQTsaMultiSamplerTof(), and InitTask().

◆ fMaxMemory

int CbmMQTsaMultiSamplerTof::fMaxMemory = 0

protected

Definition at line 48 of file CbmMQTsaMultiSamplerTof.h.

◆ fMaxTimeslices

uint64_t CbmMQTsaMultiSamplerTof::fMaxTimeslices

protected

Definition at line 33 of file CbmMQTsaMultiSamplerTof.h.

Referenced by CbmMQTsaMultiSamplerTof(), ConditionalRun(), and InitTask().

◆ fMessageCounter

uint64_t CbmMQTsaMultiSamplerTof::fMessageCounter

protected

Definition at line 46 of file CbmMQTsaMultiSamplerTof.h.

Referenced by CbmMQTsaMultiSamplerTof(), ConditionalRun(), and SendData().

◆ fPort

uint64_t CbmMQTsaMultiSamplerTof::fPort

protected

Definition at line 41 of file CbmMQTsaMultiSamplerTof.h.

Referenced by CbmMQTsaMultiSamplerTof(), and InitTask().

◆ fSource

fles::TimesliceSource* CbmMQTsaMultiSamplerTof::fSource

private

Definition at line 69 of file CbmMQTsaMultiSamplerTof.h.

Referenced by CbmMQTsaMultiSamplerTof(), ConditionalRun(), and InitTask().

◆ fSysId

std::vector<int> CbmMQTsaMultiSamplerTof::fSysId = {16, 64, 96}

private

Definition at line 85 of file CbmMQTsaMultiSamplerTof.h.

Referenced by ConditionalRun(), and CreateAndSendComponent().

◆ fTime

std::chrono::steady_clock::time_point CbmMQTsaMultiSamplerTof::fTime

private

Definition at line 70 of file CbmMQTsaMultiSamplerTof.h.

Referenced by CalcRuntime(), CbmMQTsaMultiSamplerTof(), and InitTask().

◆ fTSCounter

uint64_t CbmMQTsaMultiSamplerTof::fTSCounter

protected

Definition at line 45 of file CbmMQTsaMultiSamplerTof.h.

Referenced by CbmMQTsaMultiSamplerTof(), and ConditionalRun().

◆ fTSNumber

uint64_t CbmMQTsaMultiSamplerTof::fTSNumber

protected

Definition at line 44 of file CbmMQTsaMultiSamplerTof.h.

Referenced by CbmMQTsaMultiSamplerTof().

The documentation for this class was generated from the following files:

Public Member Functions

Protected Member Functions

Protected Attributes

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ CbmMQTsaMultiSamplerTof()

◆ ~CbmMQTsaMultiSamplerTof()

Member Function Documentation

◆ AppendData()

◆ CalcRuntime()

◆ CheckTimeslice()

◆ ConditionalRun()

◆ CreateAndCombineComponents()

◆ CreateAndSendComponent()

◆ InitTask()

◆ IsChannelNameAllowed()

◆ IsChannelUp()

◆ OpenNextFile()

◆ PrintMicroSliceDescriptor()

◆ SendData() [1/2]

◆ SendData() [2/2]

◆ SendSysCmdStop()

◆ SendTs()

Member Data Documentation

◆ fAllowedChannels

◆ fChannelsToSend

◆ fComponentsToSend

◆ fDirName

◆ fFileCounter

◆ fFileName

◆ fHighWaterMark

◆ fHost

◆ fInputFileList

◆ fMaxMemory

◆ fMaxTimeslices

◆ fMessageCounter

◆ fPort

◆ fSource

◆ fSysId

◆ fTime

◆ fTSCounter

◆ fTSNumber