The THILDataParser is the DAQ dependent part of GRSISort. It takes a "DAQ-dependent"-flavoured LMD file and converts it into a generic TFragment that the rest of GRSISort can deal with. This is where event word masks are applied, and any changes to the event format must be implemented.

Definition at line 43 of file THILDataParser.h.

Public Types
enum	EBank { EBank::kWFDN = 0, EBank::kGRF1 = 1, EBank::kGRF2 = 2, EBank::kGRF3 = 3, EBank::kGRF4 = 4, EBank::kFME0 = 5, EBank::kFME1 = 6, EBank::kFME2 = 7, EBank::kFME3 = 8 }

enum	EDataParserState { EDataParserState::kGood, EDataParserState::kOddUsedLength, EDataParserState::kWrongBufferType, EDataParserState::kZeroEventLength, EDataParserState::kOddEventLength, EDataParserState::kWrongEventLength, EDataParserState::kWrongUsPattern, EDataParserState::kWrongGeHPPattern, EDataParserState::kWrongGeEnPattern, EDataParserState::kWrongGeTimePattern, EDataParserState::kWrongSi1HPPattern, EDataParserState::kWrongSi1EnPattern, EDataParserState::kWrongSi2HPPattern, EDataParserState::kWrongSi2EnPattern, EDataParserState::kWrongSi3HPPattern, EDataParserState::kWrongSi3EnPattern, EDataParserState::kWrongEventId, EDataParserState::kUndefined }

enum	EDigitizer { EDigitizer::kV1751 = 1, EDigitizer::kV1724 = 2, EDigitizer::kV1730_PSD = 3, EDigitizer::kV1730_PHA = 4, EDigitizer::kV1725_PHA = 7, EDigitizer::kV1725_PSD = 8 }

Public Member Functions
	THILDataParser ()

	~THILDataParser ()

virtual std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TFragment > > > &	AddGoodOutputQueue (size_t maxSize=50000)

virtual std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TBadFragment > > > &	BadOutputQueue ()

virtual void	ClearQueue ()

virtual size_t	ItemsPushed ()

virtual std::string	OutputQueueStatus ()

int	Process (std::shared_ptr< TRawEvent >) override

void	Push (ThreadsafeQueue< std::shared_ptr< const TBadFragment >> &queue, const std::shared_ptr< TBadFragment > &frag)

void	Push (std::vector< std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TFragment >>>> &queues, const std::shared_ptr< TFragment > &frag)

virtual std::shared_ptr< ThreadsafeQueue< std::shared_ptr< TEpicsFrag > > > &	ScalerOutputQueue ()

virtual void	SetFinished ()

virtual void	SetNoWaveForms (bool temp=true)

virtual void	SetRecordDiag (bool temp=true)

virtual void	SetStatusVariables (std::atomic_size_t itemsPopped, std::atomic_long inputSize)

Protected Attributes
std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TBadFragment > > >	fBadOutputQueue

TChannel *	fChannel

bool	fFragmentHasWaveform

std::map< int, int >	fFragmentIdMap

TFragmentMap	fFragmentMap

std::vector< std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TFragment > > > >	fGoodOutputQueues

std::atomic_long *	fInputSize

std::atomic_size_t *	fItemsPopped

unsigned long	fLastDaqId

unsigned long	fLastNetworkPacket

std::map< UInt_t, Long64_t >	fLastTimeStampMap

unsigned long	fLastTriggerId

const unsigned long	fMaxTriggerId

bool	fNoWaveforms

bool	fRecordDiag

std::shared_ptr< ThreadsafeQueue< std::shared_ptr< TEpicsFrag > > >	fScalerOutputQueue

Static Protected Attributes
static TGRSIOptions *	fOptions = nullptr

Private Member Functions
uint16_t	ByteSwap (const uint16_t &val)

int	EagleEventToFragment (uint32_t size, uint16_t *data)

Private Attributes
EDataParserState	fState

#include <THILDataParser.h>

Inheritance diagram for THILDataParser:

Collaboration diagram for THILDataParser:

Member Enumeration Documentation

◆ EBank

enum THILDataParser::EBank

strong

Enumerator
kWFDN
kGRF1
kGRF2
kGRF3
kGRF4
kFME0
kFME1
kFME2
kFME3

Definition at line 49 of file THILDataParser.h.

◆ EDataParserState

enum THILDataParser::EDataParserState

strong

Enumerator
kGood
kOddUsedLength
kWrongBufferType
kZeroEventLength
kOddEventLength
kWrongEventLength
kWrongUsPattern
kWrongGeHPPattern
kWrongGeEnPattern
kWrongGeTimePattern
kWrongSi1HPPattern
kWrongSi1EnPattern
kWrongSi2HPPattern
kWrongSi2EnPattern
kWrongSi3HPPattern
kWrongSi3EnPattern
kWrongEventId
kUndefined

Definition at line 60 of file THILDataParser.h.

◆ EDigitizer

enum THILDataParser::EDigitizer

strong

Enumerator
kV1751
kV1724
kV1730_PSD
kV1730_PHA
kV1725_PHA
kV1725_PSD

Definition at line 51 of file THILDataParser.h.

Constructor & Destructor Documentation

◆ THILDataParser()

THILDataParser::THILDataParser ( )

Definition at line 19 of file THILDataParser.cxx.

References fState, and kGood.

◆ ~THILDataParser()

THILDataParser::~THILDataParser ( )

Definition at line 25 of file THILDataParser.cxx.

Member Function Documentation

◆ AddGoodOutputQueue()

virtual std::shared_ptr<ThreadsafeQueue<std::shared_ptr<const TFragment> > >& TDataParser::AddGoodOutputQueue ( size_t maxSize = 50000 )

inlinevirtualinherited

Definition at line 53 of file TDataParser.h.

References TDataParser::fGoodOutputQueues.

Referenced by TUnpackingLoop::AddGoodOutputQueue().

◆ BadOutputQueue()

virtual std::shared_ptr<ThreadsafeQueue<std::shared_ptr<const TBadFragment> > >& TDataParser::BadOutputQueue ( )

inlinevirtualinherited

Definition at line 61 of file TDataParser.h.

References TDataParser::fBadOutputQueue.

Referenced by TUnpackingLoop::BadOutputQueue().

◆ ByteSwap()

uint16_t THILDataParser::ByteSwap ( const uint16_t & val )

inlineprivate

Definition at line 86 of file THILDataParser.h.

Referenced by EagleEventToFragment().

◆ ClearQueue()

void TDataParser::ClearQueue ( )

virtualinherited

Definition at line 34 of file TDataParser.cxx.

References TDataParser::fBadOutputQueue, TDataParser::fGoodOutputQueues, and TDataParser::fScalerOutputQueue.

Referenced by TUnpackingLoop::ClearQueue().

◆ EagleEventToFragment()

int THILDataParser::EagleEventToFragment	(	uint32_t	size,
		uint16_t *	data
	)

private

◆ ItemsPushed()

virtual size_t TDataParser::ItemsPushed ( )

inlinevirtualinherited

Definition at line 76 of file TDataParser.h.

References TDataParser::fGoodOutputQueues.

Referenced by TUnpackingLoop::GetItemsPushed().

◆ OutputQueueStatus()

std::string TDataParser::OutputQueueStatus ( )

virtualinherited

Definition at line 80 of file TDataParser.cxx.

References TDataParser::fGoodOutputQueues.

Referenced by TUnpackingLoop::EndStatus().

◆ Process()

int THILDataParser::Process ( std::shared_ptr< TRawEvent > rawEvent )

overridevirtual

Process this TRlmdEvent using the provided data parser. Returns the total number of fragments read (good and bad).

Implements TDataParser.

Definition at line 29 of file THILDataParser.cxx.

References EagleEventToFragment(), TDataParser::fInputSize, TDataParser::fItemsPopped, TGRSIOptions::Get(), TRlmdEvent::GetDataSize(), THILDataParserException::GetFailedWord(), and THILDataParserException::what().

◆ Push() [1/2]

void TDataParser::Push	(	ThreadsafeQueue< std::shared_ptr< const TBadFragment >> &	queue,
		const std::shared_ptr< TBadFragment > &	frag
	)

inherited

Definition at line 72 of file TDataParser.cxx.

References TDataParser::fFragmentIdMap.

Referenced by TGRSIDataParser::CaenPhaToFragment(), TGRSIDataParser::CaenPsdToFragment(), EagleEventToFragment(), TGRSIDataParser::EmmaMadcDataToFragment(), TGRSIDataParser::EmmaTdcDataToFragment(), TGRSIDataParser::GriffinDataToFragment(), TGRSIDataParser::RFScalerToFragment(), TTdrDataParser::TdrToFragment(), TGRSIDataParser::TigressDataToFragment(), TILLDataParser::V1SingleFippsEventToFragment(), and TILLDataParser::V2SingleFippsEventToFragment().

◆ Push() [2/2]

void TDataParser::Push	(	std::vector< std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TFragment >>>> &	queues,
		const std::shared_ptr< TFragment > &	frag
	)