Detailed Description

The TTdrDataParser is the DAQ dependent part of GRSISort. It takes a "DAQ-dependent"-flavoured MIDAS 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 44 of file TTdrDataParser.h.

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

enum class	EDataParserState { kGood , kBadHeader , kMissingWords , kBadScalerLowTS , kBadScalerValue , kBadScalerHighTS , kBadScalerType , kBadTriggerId , kBadLowTS , kBadHighTS , kSecondHeader , kWrongNofWords , kNotSingleCfd , kSizeMismatch , kBadFooter , kFault , kMissingPsd , kMissingCfd , kMissingCharge , kBadBank , kBadModuleType , kEndOfData , kUndefined }

Public Member Functions
	TTdrDataParser ()

	~TTdrDataParser ()

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 (std::vector< std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TFragment > > > > &queues, const std::shared_ptr< TFragment > &frag)

void	Push (ThreadsafeQueue< std::shared_ptr< const TBadFragment > > &queue, const std::shared_ptr< TBadFragment > &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 Member Functions
TChannel *	Channel () const

bool	FragmentHasWaveform () const

void	FragmentHasWaveform (const bool &val)

TFragmentMap	FragmentMap () const

std::vector< std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TFragment > > > > &	GoodOutputQueues ()

uint64_t	LastDaqId () const

uint64_t	LastNetworkPacket () const

std::map< UInt_t, Long64_t >	LastTimeStampMap () const

uint64_t	LastTriggerId () const

void	LastTriggerId (const uint64_t &val)

uint64_t	MaxTriggerId () const

bool	NoWaveforms () const

bool	RecordDiag () const

Static Protected Member Functions
static TGRSIOptions *	Options ()

static void	Options (TGRSIOptions *val)

Private Member Functions
int	TdrToFragment (char *data, uint32_t size)

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

TChannel *	fChannel

bool	fFragmentHasWaveform

std::map< Long_t, 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

uint64_t	fLastDaqId

uint64_t	fLastNetworkPacket

std::map< UInt_t, Long64_t >	fLastTimeStampMap

uint64_t	fLastTriggerId

const uint64_t	fMaxTriggerId

bool	fNoWaveforms

bool	fRecordDiag

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

EDataParserState	fState

Static Private Attributes
static TGRSIOptions *	fOptions = nullptr

Inheritance diagram for TTdrDataParser:

Collaboration diagram for TTdrDataParser:

Member Enumeration Documentation

◆ EBank

enum class TTdrDataParser::EBank

strong

Enumerator
kWFDN
kGRF1
kGRF2
kGRF3
kGRF4
kFME0
kFME1
kFME2
kFME3

Definition at line 50 of file TTdrDataParser.h.

◆ EDataParserState

enum class TTdrDataParser::EDataParserState

strong

Enumerator
kGood
kBadHeader
kMissingWords
kBadScalerLowTS
kBadScalerValue
kBadScalerHighTS
kBadScalerType
kBadTriggerId
kBadLowTS
kBadHighTS
kSecondHeader
kWrongNofWords
kNotSingleCfd
kSizeMismatch
kBadFooter
kFault
kMissingPsd
kMissingCfd
kMissingCharge
kBadBank
kBadModuleType
kEndOfData
kUndefined

Definition at line 52 of file TTdrDataParser.h.

Constructor & Destructor Documentation

◆ TTdrDataParser()

TTdrDataParser::TTdrDataParser ( )

Definition at line 17 of file TTdrDataParser.cxx.

References fState, and kGood.

◆ ~TTdrDataParser()

TTdrDataParser::~TTdrDataParser ( )

Definition at line 23 of file TTdrDataParser.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 65 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 73 of file TDataParser.h.

References TDataParser::fBadOutputQueue.

Referenced by TUnpackingLoop::BadOutputQueue(), TGRSIDataParser::EmmaTdcDataToFragment(), TGRSIDataParser::GriffinDataToFragment(), and TGRSIDataParser::RFScalerToFragment().

◆ Channel()

TChannel * TDataParser::Channel ( ) const

inlineprotectedinherited

Definition at line 105 of file TDataParser.h.

References TDataParser::fChannel.

Referenced by TGRSIDataParser::EmmaMadcDataToFragment(), and TGRSIDataParser::SetTIGCharge().

◆ ClearQueue()

void TDataParser::ClearQueue ( )

virtualinherited

Definition at line 32 of file TDataParser.cxx.

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

Referenced by TUnpackingLoop::ClearQueue().

◆ FragmentHasWaveform() [1/2]

bool TDataParser::FragmentHasWaveform ( ) const

inlineprotectedinherited

Definition at line 112 of file TDataParser.h.

References TDataParser::fFragmentHasWaveform.

Referenced by TGRSIDataParser::GriffinDataToFragment(), and TGRSIDataParser::SetGRIFPrimaryFilterPattern().

◆ FragmentHasWaveform() [2/2]

void TDataParser::FragmentHasWaveform ( const bool & val )

inlineprotectedinherited

Definition at line 122 of file TDataParser.h.

References TDataParser::fFragmentHasWaveform.

◆ FragmentMap()

TFragmentMap TDataParser::FragmentMap ( ) const

inlineprotectedinherited

Definition at line 114 of file TDataParser.h.

References TDataParser::fFragmentMap.

Referenced by TGRSIDataParser::GriffinDataToFragment().

◆ GoodOutputQueues()

std::vector< std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TFragment > > > > & TDataParser::GoodOutputQueues ( )

inlineprotectedinherited

Definition at line 101 of file TDataParser.h.

References TDataParser::fGoodOutputQueues.

Referenced by TGRSIDataParser::CaenPhaToFragment(), TGRSIDataParser::CaenPsdToFragment(), TGRSIDataParser::EmmaMadcDataToFragment(), TGRSIDataParser::EmmaTdcDataToFragment(), TGRSIDataParser::GriffinDataToFragment(), TGRSIDataParser::RFScalerToFragment(), and TGRSIDataParser::TigressDataToFragment().

◆ ItemsPushed()

virtual size_t TDataParser::ItemsPushed ( )

inlinevirtualinherited

Definition at line 88 of file TDataParser.h.

References TDataParser::fGoodOutputQueues.

Referenced by TUnpackingLoop::GetItemsPushed().

◆ LastDaqId()

uint64_t TDataParser::LastDaqId ( ) const

inlineprotectedinherited

Definition at line 108 of file TDataParser.h.

References TDataParser::fLastDaqId.

◆ LastNetworkPacket()

uint64_t TDataParser::LastNetworkPacket ( ) const

inlineprotectedinherited

Definition at line 110 of file TDataParser.h.

References TDataParser::fLastNetworkPacket.

◆ LastTimeStampMap()

std::map< UInt_t, Long64_t > TDataParser::LastTimeStampMap ( ) const

inlineprotectedinherited

Definition at line 115 of file TDataParser.h.

References TDataParser::fLastTimeStampMap.

Referenced by TGRSIDataParser::GriffinDataToFragment().

◆ LastTriggerId() [1/2]

uint64_t TDataParser::LastTriggerId ( ) const

inlineprotectedinherited

Definition at line 109 of file TDataParser.h.

References TDataParser::fLastTriggerId.

Referenced by TGRSIDataParser::SetTIGTriggerID().

◆ LastTriggerId() [2/2]

void TDataParser::LastTriggerId ( const uint64_t & val )

inlineprotectedinherited

Definition at line 120 of file TDataParser.h.

References TDataParser::fLastTriggerId.

◆ MaxTriggerId()

uint64_t TDataParser::MaxTriggerId ( ) const

inlineprotectedinherited

Definition at line 107 of file TDataParser.h.

References TDataParser::fMaxTriggerId.

Referenced by TGRSIDataParser::SetTIGTriggerID().

◆ NoWaveforms()

bool TDataParser::NoWaveforms ( ) const

inlineprotectedinherited

Definition at line 103 of file TDataParser.h.

References TDataParser::fNoWaveforms.

Referenced by TGRSIDataParser::GriffinDataToFragment(), and TGRSIDataParser::TigressDataToFragment().

◆ Options() [1/2]

static TGRSIOptions * TDataParser::Options ( )

inlinestaticprotectedinherited

Definition at line 117 of file TDataParser.h.

References TDataParser::fOptions.

Referenced by TGRSIDataParser::CaenPhaToFragment(), TGRSIDataParser::CaenPsdToFragment(), and TGRSIDataParser::GriffinDataToFragment().

◆ Options() [2/2]

static void TDataParser::Options ( TGRSIOptions * val )

inlinestaticprotectedinherited

Definition at line 124 of file TDataParser.h.

References TDataParser::fOptions.

◆ OutputQueueStatus()

std::string TDataParser::OutputQueueStatus ( )

virtualinherited

Definition at line 78 of file TDataParser.cxx.

References TDataParser::fGoodOutputQueues.

Referenced by TUnpackingLoop::EndStatus().

◆ Process()

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

overridevirtual

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

Implements TDataParser.

Definition at line 27 of file TTdrDataParser.cxx.

References TdrToFragment().

◆ Push() [1/2]

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