#include <DEVIOWorkerThread.h>

Public Types
enum	JOBTYPE { JOB_NONE = 0x0, JOB_QUIT = 0x1, JOB_SWAP = 0x2, JOB_FULL_PARSE = 0x4, JOB_ASSOCIATE = 0x8 }

Public Member Functions
	DEVIOWorkerThread (JEventSource_EVIOpp event_source, list< DParsedEvent > &parsed_events, uint32_t &MAX_PARSED_EVENTS, mutex &PARSED_EVENTS_MUTEX, condition_variable &PARSED_EVENTS_CV, set< uint32_t > &ROCIDS_TO_PARSE)

virtual	~DEVIOWorkerThread ()

void	Run (void)

void	Finish (bool wait_to_complete=true)

void	Prune (void)

void	MakeEvents (void)

void	PublishEvents (void)

void	ParseBank (void)

void	ParseEventTagBank (uint32_t &iptr, uint32_t iend)

void	ParseEPICSbank (uint32_t &iptr, uint32_t iend)

void	ParseBORbank (uint32_t &iptr, uint32_t iend)

void	ParseTSscalerBank (uint32_t &iptr, uint32_t iend)

void	Parsef250scalerBank (uint32_t rocid, uint32_t &iptr, uint32_t iend)

void	ParseControlEvent (uint32_t &iptr, uint32_t iend)

void	ParsePhysicsBank (uint32_t &iptr, uint32_t iend)

void	ParseCDAQBank (uint32_t &iptr, uint32_t iend)

void	ParseBuiltTriggerBank (uint32_t &iptr, uint32_t iend)

void	ParseRawTriggerBank (uint32_t rocid, uint32_t &iptr, uint32_t iend)

void	ParseDataBank (uint32_t &iptr, uint32_t iend)

void	ParseDVertexBank (uint32_t &iptr, uint32_t iend)

void	ParseDEventRFBunchBank (uint32_t &iptr, uint32_t iend)

void	ParseJLabModuleData (uint32_t rocid, uint32_t &iptr, uint32_t iend)

void	ParseTIBank (uint32_t rocid, uint32_t &iptr, uint32_t iend)

void	ParseCAEN1190 (uint32_t rocid, uint32_t &iptr, uint32_t iend)

void	ParseModuleConfiguration (uint32_t rocid, uint32_t &iptr, uint32_t iend)

void	Parsef250Bank (uint32_t rocid, uint32_t &iptr, uint32_t iend)

void	MakeDf250WindowRawData (DParsedEvent pe, uint32_t rocid, uint32_t slot, uint32_t itrigger, uint32_t &iptr)

void	Parsef125Bank (uint32_t rocid, uint32_t &iptr, uint32_t iend)

void	MakeDf125WindowRawData (DParsedEvent pe, uint32_t rocid, uint32_t slot, uint32_t itrigger, uint32_t &iptr)

void	ParseF1TDCBank (uint32_t rocid, uint32_t &iptr, uint32_t iend)

void	ParseSSPBank (uint32_t rocid, uint32_t &iptr, uint32_t iend)

void	LinkAllAssociations (void)

uint32_t	F1TDC_channel (uint32_t chip, uint32_t chan_on_chip, int modtype)

void	DumpBinary (const uint32_t iptr, const uint32_t iend, uint32_t MaxWords=0, const uint32_t *imark=NULL)

Public Attributes
JEventSource_EVIOpp *	event_source

list< DParsedEvent * > &	parsed_events

uint32_t &	MAX_PARSED_EVENTS

mutex &	PARSED_EVENTS_MUTEX

condition_variable &	PARSED_EVENTS_CV

set< uint32_t > &	ROCIDS_TO_PARSE

vector< DParsedEvent * >	parsed_event_pool

list< DParsedEvent * >	current_parsed_events

int	VERBOSE

uint64_t	Nrecycled

uint64_t	MAX_EVENT_RECYCLES

uint64_t	MAX_OBJECT_RECYCLES

atomic< bool >	in_use

atomic< bool >	done

JOBTYPE	jobtype

uint64_t	istreamorder

uint64_t	run_number_seed

mutex	mtx

condition_variable	cv

thread	thd

uint32_t	buff_len

uint32_t *	buff

streampos	pos

bool	PARSE_F250

bool	PARSE_F125

bool	PARSE_F1TDC

bool	PARSE_CAEN1290TDC

bool	PARSE_CONFIG

bool	PARSE_BOR

bool	PARSE_EPICS

bool	PARSE_EVENTTAG

bool	PARSE_TRIGGER

bool	PARSE_SSP

bool	LINK_TRIGGERTIME

bool	LINK_CONFIG

Detailed Description

Definition at line 29 of file DEVIOWorkerThread.h.

Member Enumeration Documentation

enum DEVIOWorkerThread::JOBTYPE

Enumerator
JOB_NONE
JOB_QUIT
JOB_SWAP
JOB_FULL_PARSE
JOB_ASSOCIATE

Definition at line 32 of file DEVIOWorkerThread.h.

Constructor & Destructor Documentation

DEVIOWorkerThread::DEVIOWorkerThread	(	JEventSource_EVIOpp *	event_source,
		list< DParsedEvent * > &	parsed_events,
		uint32_t &	MAX_PARSED_EVENTS,
		mutex &	PARSED_EVENTS_MUTEX,
		condition_variable &	PARSED_EVENTS_CV,
		set< uint32_t > &	ROCIDS_TO_PARSE
	)

Definition at line 25 of file DEVIOWorkerThread.cc.

References buff, buff_len, in_use, JOB_NONE, jobtype, LINK_TRIGGERTIME, MAX_EVENT_RECYCLES, MAX_OBJECT_RECYCLES, Nrecycled, PARSE_BOR, PARSE_CAEN1290TDC, PARSE_CONFIG, PARSE_EPICS, PARSE_EVENTTAG, PARSE_F125, PARSE_F1TDC, PARSE_F250, PARSE_SSP, PARSE_TRIGGER, run_number_seed, and VERBOSE.

DEVIOWorkerThread::~DEVIOWorkerThread ( )

virtual

Definition at line 80 of file DEVIOWorkerThread.cc.

References buff, and parsed_event_pool.

Member Function Documentation

void DEVIOWorkerThread::DumpBinary	(	const uint32_t *	iptr,
		const uint32_t *	iend,
		uint32_t	MaxWords = `0`,
		const uint32_t *	imark = `NULL`
	)

This is used for debugging. It will print to the screen the words starting at the address given by iptr and ending just before iend or for MaxWords words, whichever comes first. If iend is NULL, then MaxWords will be printed. If MaxWords is zero then it is ignored and only iend is checked. If both iend==NULL and MaxWords==0, then only the word at iptr is printed.

Definition at line 2406 of file DEVIOWorkerThread.cc.

References Ncols, and string.

Referenced by ParseBORbank(), ParseDataBank(), and ParseEPICSbank().

uint32_t DEVIOWorkerThread::F1TDC_channel	(	uint32_t	chip,
		uint32_t	chan_on_chip,
		int	modtype
	)

inline

Convert a F1TDC chip number and channel on the chip to the front panel channel number. This is based on "Input Channel Mapping" section at the very bottom of the document F1TDC_V2_V3_4_29_14.pdf

Definition at line 146 of file DEVIOWorkerThread.h.

References _DBG_, DModuleType::F1TDC32, DModuleType::F1TDC48, and DModuleType::GetName().

Referenced by ParseF1TDCBank().

void DEVIOWorkerThread::Finish ( bool wait_to_complete = true )

Set the done flag so that the worker thread will exit once it is done processing its current job. The thread is notified to wake up in case it is currently idle. If the wait_to_complete flag is set (default), then the worker thread is joined to guarantee the current job's processing is completed before returning.

Definition at line 145 of file DEVIOWorkerThread.cc.

References cv, done, and thd.

void DEVIOWorkerThread::LinkAllAssociations ( void )

Find objects that should be linked as "associated objects" of one another and add to each other's list.

Definition at line 2309 of file DEVIOWorkerThread.cc.

References current_parsed_events, LINK_CONFIG, LINK_TRIGGERTIME, LinkChannel(), LinkConfig(), LinkConfigSamplesCopy(), LinkModule(), LinkPulse(), and LinkPulsePedCopy().

Referenced by Run().

void DEVIOWorkerThread::MakeDf125WindowRawData	(	DParsedEvent *	pe,
		uint32_t	rocid,
		uint32_t	slot,
		uint32_t	itrigger,
		uint32_t *&	iptr
	)

Definition at line 1932 of file DEVIOWorkerThread.cc.

References Df125WindowRawData::invalid_samples, Df125WindowRawData::overflow, and Df125WindowRawData::samples.

Referenced by Parsef125Bank().

void DEVIOWorkerThread::MakeDf250WindowRawData	(	DParsedEvent *	pe,
		uint32_t	rocid,
		uint32_t	slot,
		uint32_t	itrigger,
		uint32_t *&	iptr
	)

Definition at line 1574 of file DEVIOWorkerThread.cc.

References Df250WindowRawData::invalid_samples, Df250WindowRawData::overflow, and Df250WindowRawData::samples.

Referenced by Parsef250Bank().

void DEVIOWorkerThread::MakeEvents ( void )

Make DParsedEvent objects from data currently in buff. This will look at the begining of the EVIO event to see how many L1 events are in it. It will then grab that many DParsedEvent objects from this threads pool , or create new ones and add them all to the current_parsed_events vector. These are then filled out later as the data is parsed.

Definition at line 196 of file DEVIOWorkerThread.cc.

References buff, buff_len, current_parsed_events, event_num, istreamorder, MAX_EVENT_RECYCLES, MAX_OBJECT_RECYCLES, Nrecycled, ParseBank(), parsed_event_pool, Prune(), run_number_seed, and VERBOSE.

Referenced by Run().

void DEVIOWorkerThread::ParseBank ( void )

Definition at line 325 of file DEVIOWorkerThread.cc.

References _DBG_, buff, current_parsed_events, ParseBORbank(), ParseCDAQBank(), ParseControlEvent(), ParseEPICSbank(), and ParsePhysicsBank().

Referenced by MakeEvents().

void DEVIOWorkerThread::ParseBORbank	(	uint32_t *&	iptr,
		uint32_t *	iend
	)

Create BOR config objects from the EVIO bank and store them in the event (should only be one since BOR events are not entangled). These objects will eventually be inherited by the JEventSource_EVIOpp object and passed to all subsequent events.

Definition at line 448 of file DEVIOWorkerThread.cc.

References _DBG_, DParsedEvent::borptrs, DModuleType::CAEN1190, DModuleType::CAEN1290, DModuleType::CDAQTSG, current_parsed_events, DumpBinary(), DParsedEvent::event_status_bits, DModuleType::F1TDC32, DModuleType::F1TDC48, DModuleType::FADC125, DModuleType::FADC250, Df250BORConfig::FillDerived(), kSTATUS_BOR_EVENT, DTSGBORConfig::misc_words, PARSE_BOR, DTSGBORConfig::rocid, f250config::rocid, f125config::rocid, F1TDCconfig::rocid, caen1190config::rocid, DTSGBORConfig::run_number, DTSGBORConfig::slot, DBORptrs::Sort(), DTSGBORConfig::unix_time, and VERBOSE.

Referenced by ParseBank(), and ParseCDAQBank().

void DEVIOWorkerThread::ParseBuiltTriggerBank	(	uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 803 of file DEVIOWorkerThread.cc.

References DCODAEventInfo::avg_timestamp, current_parsed_events, DCODAEventInfo::event_number, event_source, DCODAEventInfo::event_type, ievent, JEventSource_EVIOpp::kETSource, DCODAROCInfo::misc, PARSE_TRIGGER, DCODAROCInfo::rocid, DCODAEventInfo::run_number, DCODAEventInfo::run_type, JEventSource_EVIOpp::source_type, and DCODAROCInfo::timestamp.

Referenced by ParsePhysicsBank().

void DEVIOWorkerThread::ParseCAEN1190	(	uint32_t	rocid,
		uint32_t *&	iptr,
		uint32_t *	iend
	)

Parse data from a CAEN 1190 or 1290 module (See ppg. 72-74 of V1290_REV15.pdf manual)

Definition at line 1071 of file DEVIOWorkerThread.cc.

References _DBG_, current_parsed_events, event_count, PARSE_CAEN1290TDC, and VERBOSE.

Referenced by ParseDataBank().

void DEVIOWorkerThread::ParseCDAQBank	(	uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 760 of file DEVIOWorkerThread.cc.

References current_parsed_events, e, event_source, JEventSource_EVIOpp::IS_CDAQ_FILE, kSTATUS_CDAQ, kSTATUS_PHYSICS_EVENT, ParseBORbank(), ParseDataBank(), and VERBOSE.

Referenced by ParseBank().

void DEVIOWorkerThread::ParseControlEvent	(	uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 696 of file DEVIOWorkerThread.cc.

References current_parsed_events, and kSTATUS_CONTROL_EVENT.

Referenced by ParseBank().

void DEVIOWorkerThread::ParseDataBank	(	uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 946 of file DEVIOWorkerThread.cc.

References DumpBinary(), ParseCAEN1190(), ParseDEventRFBunchBank(), ParseDVertexBank(), ParseEventTagBank(), Parsef250scalerBank(), ParseJLabModuleData(), ParseModuleConfiguration(), ParseRawTriggerBank(), ParseSSPBank(), ParseTSscalerBank(), ROCIDS_TO_PARSE, and VERBOSE.

Referenced by ParseCDAQBank(), and ParsePhysicsBank().

void DEVIOWorkerThread::ParseDEventRFBunchBank	(	uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 2232 of file DEVIOWorkerThread.cc.

References _DBG_, current_parsed_events, DEventRFBunch::dNumParticleVotes, DEventRFBunch::dTime, DEventRFBunch::dTimeSource, and DEventRFBunch::dTimeVariance.

Referenced by ParseDataBank().

void DEVIOWorkerThread::ParseDVertexBank	(	uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 2265 of file DEVIOWorkerThread.cc.

References _DBG_, current_parsed_events, DVertex::dKinFitChiSq, DVertex::dKinFitNDF, and DVertex::dSpacetimeVertex.

Referenced by ParseDataBank().

void DEVIOWorkerThread::ParseEPICSbank	(	uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 394 of file DEVIOWorkerThread.cc.

References _DBG_, current_parsed_events, DumpBinary(), DParsedEvent::event_status_bits, kSTATUS_EPICS_EVENT, and PARSE_EPICS.

Referenced by ParseBank().

void DEVIOWorkerThread::ParseEventTagBank	(	uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 365 of file DEVIOWorkerThread.cc.

References current_parsed_events.

Referenced by ParseDataBank().

void DEVIOWorkerThread::Parsef125Bank	(	uint32_t	rocid,
		uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 1616 of file DEVIOWorkerThread.cc.

References current_parsed_events, MakeDf125WindowRawData(), PARSE_F125, pedestal, sum, and VERBOSE.

Referenced by ParseJLabModuleData().

void DEVIOWorkerThread::ParseF1TDCBank	(	uint32_t	rocid,
		uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 1971 of file DEVIOWorkerThread.cc.

References _DBG_, current_parsed_events, F1TDC_channel(), PARSE_F1TDC, and VERBOSE.

Referenced by ParseJLabModuleData().

void DEVIOWorkerThread::Parsef250Bank	(	uint32_t	rocid,
		uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 1378 of file DEVIOWorkerThread.cc.

References _DBG_, current_parsed_events, MakeDf250WindowRawData(), PARSE_F250, pedestal, sum, and VERBOSE.

Referenced by ParseJLabModuleData().

void DEVIOWorkerThread::Parsef250scalerBank	(	uint32_t	rocid,
		uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 662 of file DEVIOWorkerThread.cc.

References _DBG_, Df250Scaler::crate, current_parsed_events, Df250Scaler::fa250_sc, Df250Scaler::nsync, Df250Scaler::trig_number, and Df250Scaler::version.

Referenced by ParseDataBank().

void DEVIOWorkerThread::ParseJLabModuleData	(	uint32_t	rocid,
		uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 1323 of file DEVIOWorkerThread.cc.

References DModuleType::F1TDC32, DModuleType::F1TDC48, DModuleType::FADC125, DModuleType::FADC250, Parsef125Bank(), ParseF1TDCBank(), Parsef250Bank(), ParseTIBank(), DModuleType::TID, and DModuleType::UNKNOWN.

Referenced by ParseDataBank().

void DEVIOWorkerThread::ParseModuleConfiguration	(	uint32_t	rocid,
		uint32_t *&	iptr,
		uint32_t *	iend
	)

Parse a bank of module configuration data. These are configuration values

programmed into the module at the beginning of the run that may be needed in the offline. For example, the number of samples to sum in a FADC pulse integral.

The bank has one or more sections, each describing parameters applicable to a number of modules as indicated by a 24bit slot mask.

This bank should appear only once per DAQ event which, if in multi-event block mode, may have multiple L1 events. The parameters here will apply to all L1 events in the block. This method will put the config objects into each event in current_parsed_events. The config objects are duplicated as needed so each event has its own, indepenent set of config object.

Definition at line 1187 of file DEVIOWorkerThread.cc.

References _DBG_, Df125Config::ABIT, DF1TDCConfig::BINSIZE, current_parsed_events, Df125Config::H, DF1TDCConfig::HSDIV, Df125Config::IBIT, Df125Config::IE, kPARAM125_ABIT, kPARAM125_H, kPARAM125_IBIT, kPARAM125_IE, kPARAM125_NPED, kPARAM125_NPK, kPARAM125_NSA, kPARAM125_NSA_NSB, kPARAM125_NSB, kPARAM125_NW, kPARAM125_P1, kPARAM125_P2, kPARAM125_PBIT, kPARAM125_PG, kPARAM125_PL, kPARAM125_TH, kPARAM125_TL, kPARAM125_WINWIDTH, kPARAM250_NPED, kPARAM250_NSA, kPARAM250_NSA_NSB, kPARAM250_NSB, kPARAMCAEN1290_WINOFFSET, kPARAMCAEN1290_WINWIDTH, kPARAMF1_BINSIZE, kPARAMF1_HSDIV, kPARAMF1_REFCLKDIV, kPARAMF1_REFCNT, kPARAMF1_TRIGLAT, kPARAMF1_TRIGWIN, Df250Config::NPED, Df125Config::NPED, Df125Config::NPK, Df250Config::NSA, Df125Config::NSA, Df250Config::NSA_NSB, Df125Config::NSA_NSB, Df250Config::NSB, Df125Config::NSB, Df125Config::NW, Df125Config::P1, Df125Config::P2, PARSE_CONFIG, Df125Config::PBIT, Df125Config::PG, Df125Config::PL, DF1TDCConfig::REFCLKDIV, DF1TDCConfig::REFCNT, Df125Config::TH, Df125Config::TL, DF1TDCConfig::TRIGLAT, DF1TDCConfig::TRIGWIN, VERBOSE, DCAEN1290TDCConfig::WINOFFSET, DCAEN1290TDCConfig::WINWIDTH, and Df125Config::WINWIDTH.

Referenced by ParseDataBank().

void DEVIOWorkerThread::ParsePhysicsBank	(	uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 728 of file DEVIOWorkerThread.cc.

References current_parsed_events, kSTATUS_CODA, kSTATUS_PHYSICS_EVENT, ParseBuiltTriggerBank(), and ParseDataBank().

Referenced by ParseBank().

void DEVIOWorkerThread::ParseRawTriggerBank	(	uint32_t	rocid,
		uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 908 of file DEVIOWorkerThread.cc.

References current_parsed_events, ievent, DCODAROCInfo::misc, PARSE_TRIGGER, DCODAROCInfo::rocid, and DCODAROCInfo::timestamp.

Referenced by ParseDataBank().

void DEVIOWorkerThread::ParseSSPBank	(	uint32_t	rocid,
		uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 2101 of file DEVIOWorkerThread.cc.

References block_size, current_parsed_events, PARSE_SSP, and VERBOSE.

Referenced by ParseDataBank().

void DEVIOWorkerThread::ParseTIBank	(	uint32_t	rocid,
		uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 1060 of file DEVIOWorkerThread.cc.

Referenced by ParseJLabModuleData().

void DEVIOWorkerThread::ParseTSscalerBank	(	uint32_t *&	iptr,
		uint32_t *	iend
	)

Definition at line 631 of file DEVIOWorkerThread.cc.

References _DBG_, DL1Info::busy_time, current_parsed_events, DL1Info::fp_rate, DL1Info::fp_sc, DL1Info::gtp_rate, DL1Info::gtp_sc, DL1Info::live_inst, DL1Info::live_time, DL1Info::nsync, DL1Info::trig_number, and DL1Info::unix_time.

Referenced by ParseDataBank().

void DEVIOWorkerThread::Prune ( void )

Delete any DParsedEvent objects not currently in use. If the DParsedEvent object pool and their internal hit object pools are allowed to continuously grow, it will appear as a though there is a memory leak. Occasional pruning will reduce the average memory footprint. This is called from MakeEvents() every MAX_EVENT_RECYCLES EVIO events processed by this worker thread. Note that this is in EVIO events (i.e. possibly a block of events) not in L1 trigger events.

NOTE: We currently do NOT reduce the size of buff here if it is too big. We may wish to do that at some point!

Definition at line 166 of file DEVIOWorkerThread.cc.

References parsed_event_pool.

Referenced by MakeEvents().

void DEVIOWorkerThread::PublishEvents ( void )

Copy our "current_parsed_events" pointers into the global "parsed_events" list making them available for consumption.

Definition at line 284 of file DEVIOWorkerThread.cc.

References current_parsed_events, done, event_source, istreamorder, MAX_PARSED_EVENTS, JEventSource_EVIOpp::NPARSER_STALLED, parsed_events, PARSED_EVENTS_CV, and PARSED_EVENTS_MUTEX.

Referenced by Run().

void DEVIOWorkerThread::Run ( void )

Definition at line 89 of file DEVIOWorkerThread.cc.

References buff, current_parsed_events, cv, done, e, in_use, japp, JOB_ASSOCIATE, JOB_FULL_PARSE, JOB_NONE, JOB_QUIT, JOB_SWAP, jobtype, LinkAllAssociations(), MakeEvents(), mtx, parsed_event_pool, PublishEvents(), swap32, and swap_bank().