TTdrDataParser Class Reference

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	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::kBadHeader, EDataParserState::kMissingWords, EDataParserState::kBadScalerLowTS,   EDataParserState::kBadScalerValue, EDataParserState::kBadScalerHighTS, EDataParserState::kBadScalerType, EDataParserState::kBadTriggerId,   EDataParserState::kBadLowTS, EDataParserState::kBadHighTS, EDataParserState::kSecondHeader, EDataParserState::kWrongNofWords,   EDataParserState::kNotSingleCfd, EDataParserState::kSizeMismatch, EDataParserState::kBadFooter, EDataParserState::kFault,   EDataParserState::kMissingPsd, EDataParserState::kMissingCfd, EDataParserState::kMissingCharge, EDataParserState::kBadBank,   EDataParserState::kBadModuleType, EDataParserState::kEndOfData, EDataParserState::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 (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
int	TdrToFragment (char *data, uint32_t size)

Private Attributes
EDataParserState	fState

#include <TTdrDataParser.h>

Inheritance diagram for TTdrDataParser:

Collaboration diagram for TTdrDataParser:

Member Enumeration Documentation

EBank

enum TTdrDataParser::EBank

strong

Enumerator
kWFDN
kGRF1
kGRF2
kGRF3
kGRF4
kFME0
kFME1
kFME2
kFME3

Definition at line 50 of file TTdrDataParser.h.

EDataParserState

enum 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 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().

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().

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 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 ( 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(), THILDataParser::EagleEventToFragment(), TGRSIDataParser::EmmaMadcDataToFragment(), TGRSIDataParser::EmmaTdcDataToFragment(), TGRSIDataParser::GriffinDataToFragment(), TGRSIDataParser::RFScalerToFragment(), 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  )

inherited

Definition at line 61 of file TDataParser.cxx.

References TDataParser::fFragmentIdMap.

ScalerOutputQueue()

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

inlinevirtualinherited

Definition at line 63 of file TDataParser.h.

References TDataParser::fScalerOutputQueue.

Referenced by TUnpackingLoop::ScalerOutputQueue().

SetFinished()

void TDataParser::SetFinished ( )

virtualinherited

Definition at line 52 of file TDataParser.cxx.

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

Referenced by TUnpackingLoop::Iteration().

SetNoWaveForms()

virtual void TDataParser::SetNoWaveForms ( bool  temp = true )

inlinevirtualinherited

Definition at line 46 of file TDataParser.h.

References TDataParser::fNoWaveforms.

Referenced by TUnpackingLoop::SetNoWaveForms().

SetRecordDiag()

virtual void TDataParser::SetRecordDiag ( bool  temp = true )

inlinevirtualinherited

Definition at line 47 of file TDataParser.h.

References TDataParser::fRecordDiag.

Referenced by TUnpackingLoop::SetRecordDiag().

SetStatusVariables()

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

inlinevirtualinherited

Definition at line 65 of file TDataParser.h.

References TDataParser::fInputSize, and TDataParser::fItemsPopped.

Referenced by TUnpackingLoop::Iteration().

TdrToFragment()

int TTdrDataParser::TdrToFragment ( char *  data, uint32_t  size  )

private

Definition at line 37 of file TTdrDataParser.cxx.

References TPPG::AddData(), TParsingDiagnostics::BadFragment(), TDataParser::fBadOutputQueue, TDataParser::fGoodOutputQueues, TDataParser::fInputSize, TDataParser::fItemsPopped, TDataParser::fRecordDiag, TSingleton< TPPG >::Get(), TSingleton< TParsingDiagnostics >::Get(), TChannel::GetChannel(), TParsingDiagnostics::GoodFragment(), kBackground, kJunk, kPixieTapeMove, kTapeMove, TDataParser::Push(), and TPPGData::SetNewPPG().

Referenced by Process().

Member Data Documentation

fBadOutputQueue

std::shared_ptr<ThreadsafeQueue<std::shared_ptr<const TBadFragment> > > TDataParser::fBadOutputQueue

protectedinherited

Definition at line 89 of file TDataParser.h.

Referenced by TDataParser::BadOutputQueue(), TDataParser::ClearQueue(), THILDataParser::EagleEventToFragment(), TGRSIDataParser::EmmaTdcDataToFragment(), TGRSIDataParser::GriffinDataToFragment(), TGRSIDataParser::RFScalerToFragment(), TDataParser::SetFinished(), TdrToFragment(), TILLDataParser::V1SingleFippsEventToFragment(), and TILLDataParser::V2SingleFippsEventToFragment().

fChannel

TChannel* TDataParser::fChannel

protectedinherited

Definition at line 95 of file TDataParser.h.

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

fFragmentHasWaveform

bool TDataParser::fFragmentHasWaveform

protectedinherited

Definition at line 103 of file TDataParser.h.

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

fFragmentIdMap

std::map<int, int> TDataParser::fFragmentIdMap

protectedinherited

Definition at line 102 of file TDataParser.h.

Referenced by TDataParser::Push().

fFragmentMap

TFragmentMap TDataParser::fFragmentMap

protectedinherited

Class that holds a map of fragments per address, takes care of calculating charges for GRF4 banks.

Definition at line 105 of file TDataParser.h.

Referenced by TGRSIDataParser::GriffinDataToFragment().

fGoodOutputQueues

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

protectedinherited

Definition at line 88 of file TDataParser.h.

Referenced by TDataParser::AddGoodOutputQueue(), TGRSIDataParser::CaenPhaToFragment(), TGRSIDataParser::CaenPsdToFragment(), TDataParser::ClearQueue(), THILDataParser::EagleEventToFragment(), TGRSIDataParser::EmmaMadcDataToFragment(), TGRSIDataParser::EmmaTdcDataToFragment(), TGRSIDataParser::GriffinDataToFragment(), TDataParser::ItemsPushed(), TDataParser::OutputQueueStatus(), TGRSIDataParser::RFScalerToFragment(), TDataParser::SetFinished(), TdrToFragment(), TGRSIDataParser::TigressDataToFragment(), TILLDataParser::V1SingleFippsEventToFragment(), and TILLDataParser::V2SingleFippsEventToFragment().

fInputSize

std::atomic_long* TDataParser::fInputSize

protectedinherited

Definition at line 113 of file TDataParser.h.

Referenced by THILDataParser::Process(), TILLDataParser::Process(), TDataParser::SetStatusVariables(), and TdrToFragment().

fItemsPopped

std::atomic_size_t* TDataParser::fItemsPopped

protectedinherited

Definition at line 112 of file TDataParser.h.

Referenced by THILDataParser::Process(), TILLDataParser::Process(), TDataParser::SetStatusVariables(), and TdrToFragment().

fLastDaqId

unsigned long TDataParser::fLastDaqId

protectedinherited

The last daq ID in the raw file.

Definition at line 98 of file TDataParser.h.

fLastNetworkPacket

unsigned long TDataParser::fLastNetworkPacket

protectedinherited

The last network packet recieved.

Definition at line 100 of file TDataParser.h.

fLastTimeStampMap

std::map<UInt_t, Long64_t> TDataParser::fLastTimeStampMap

protectedinherited

Definition at line 107 of file TDataParser.h.

Referenced by TGRSIDataParser::GriffinDataToFragment().

fLastTriggerId

unsigned long TDataParser::fLastTriggerId

protectedinherited

The last Trigged ID in the raw File.

Definition at line 99 of file TDataParser.h.

Referenced by TGRSIDataParser::SetTIGTriggerID().

fMaxTriggerId

const unsigned long TDataParser::fMaxTriggerId

protectedinherited

The last trigger ID Called.

Definition at line 97 of file TDataParser.h.

Referenced by TGRSIDataParser::SetTIGTriggerID().

fNoWaveforms

bool TDataParser::fNoWaveforms

protectedinherited

The flag to turn wave_forms on or off.

Definition at line 93 of file TDataParser.h.

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

fOptions

TGRSIOptions * TDataParser::fOptions = nullptr

staticprotectedinherited

Static pointer to TGRSIOptions, gets set on the first call of GriffinDataToFragment.

Definition at line 109 of file TDataParser.h.

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

fRecordDiag

bool TDataParser::fRecordDiag

protectedinherited

The flag to turn on diagnostics recording.

Definition at line 94 of file TDataParser.h.

Referenced by THILDataParser::EagleEventToFragment(), TGRSIDataParser::GriffinDataToFragment(), TDataParser::SetRecordDiag(), TdrToFragment(), TILLDataParser::V1SingleFippsEventToFragment(), and TILLDataParser::V2SingleFippsEventToFragment().

fScalerOutputQueue

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

protectedinherited

Definition at line 90 of file TDataParser.h.

Referenced by TDataParser::ClearQueue(), TGRSIDataParser::EPIXToScalar(), TDataParser::ScalerOutputQueue(), and TDataParser::SetFinished().

fState

EDataParserState TTdrDataParser::fState

private

Definition at line 85 of file TTdrDataParser.h.

Referenced by TTdrDataParser().