Hall-D Software
alpha
|
#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 |
Definition at line 29 of file DEVIOWorkerThread.h.
Enumerator | |
---|---|
JOB_NONE | |
JOB_QUIT | |
JOB_SWAP | |
JOB_FULL_PARSE | |
JOB_ASSOCIATE |
Definition at line 32 of file DEVIOWorkerThread.h.
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.
|
virtual |
Definition at line 80 of file DEVIOWorkerThread.cc.
References buff, and parsed_event_pool.
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.
Referenced by ParseBORbank(), ParseDataBank(), and ParseEPICSbank().
|
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.
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().
uint32_t* DEVIOWorkerThread::buff |
Definition at line 80 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::Dispatcher(), MakeEvents(), ParseBank(), Run(), and ~DEVIOWorkerThread().
uint32_t DEVIOWorkerThread::buff_len |
Definition at line 79 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::Dispatcher(), and MakeEvents().
list<DParsedEvent*> DEVIOWorkerThread::current_parsed_events |
Definition at line 62 of file DEVIOWorkerThread.h.
Referenced by LinkAllAssociations(), MakeEvents(), ParseBank(), ParseBORbank(), ParseBuiltTriggerBank(), ParseCAEN1190(), ParseCDAQBank(), ParseControlEvent(), ParseDEventRFBunchBank(), ParseDVertexBank(), ParseEPICSbank(), ParseEventTagBank(), Parsef125Bank(), ParseF1TDCBank(), Parsef250Bank(), Parsef250scalerBank(), ParseModuleConfiguration(), ParsePhysicsBank(), ParseRawTriggerBank(), ParseSSPBank(), ParseTSscalerBank(), PublishEvents(), and Run().
condition_variable DEVIOWorkerThread::cv |
Definition at line 76 of file DEVIOWorkerThread.h.
Referenced by JEventSource_EVIOpp::Dispatcher(), Finish(), and Run().
atomic<bool> DEVIOWorkerThread::done |
Definition at line 70 of file DEVIOWorkerThread.h.
Referenced by Finish(), PublishEvents(), and Run().
JEventSource_EVIOpp* DEVIOWorkerThread::event_source |
Definition at line 51 of file DEVIOWorkerThread.h.
Referenced by ParseBuiltTriggerBank(), ParseCDAQBank(), and PublishEvents().
atomic<bool> DEVIOWorkerThread::in_use |
Definition at line 69 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::Dispatcher(), and Run().
uint64_t DEVIOWorkerThread::istreamorder |
Definition at line 72 of file DEVIOWorkerThread.h.
Referenced by JEventSource_EVIOpp::Dispatcher(), MakeEvents(), and PublishEvents().
JOBTYPE DEVIOWorkerThread::jobtype |
Definition at line 71 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::Dispatcher(), and Run().
bool DEVIOWorkerThread::LINK_CONFIG |
Definition at line 95 of file DEVIOWorkerThread.h.
Referenced by JEventSource_EVIOpp::JEventSource_EVIOpp(), and LinkAllAssociations().
bool DEVIOWorkerThread::LINK_TRIGGERTIME |
Definition at line 94 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::JEventSource_EVIOpp(), and LinkAllAssociations().
uint64_t DEVIOWorkerThread::MAX_EVENT_RECYCLES |
Definition at line 66 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::JEventSource_EVIOpp(), and MakeEvents().
uint64_t DEVIOWorkerThread::MAX_OBJECT_RECYCLES |
Definition at line 67 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::JEventSource_EVIOpp(), and MakeEvents().
uint32_t& DEVIOWorkerThread::MAX_PARSED_EVENTS |
Definition at line 53 of file DEVIOWorkerThread.h.
Referenced by PublishEvents().
mutex DEVIOWorkerThread::mtx |
Definition at line 75 of file DEVIOWorkerThread.h.
Referenced by Run().
uint64_t DEVIOWorkerThread::Nrecycled |
Definition at line 65 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), and MakeEvents().
bool DEVIOWorkerThread::PARSE_BOR |
Definition at line 88 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::JEventSource_EVIOpp(), and ParseBORbank().
bool DEVIOWorkerThread::PARSE_CAEN1290TDC |
Definition at line 86 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::JEventSource_EVIOpp(), and ParseCAEN1190().
bool DEVIOWorkerThread::PARSE_CONFIG |
Definition at line 87 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::JEventSource_EVIOpp(), and ParseModuleConfiguration().
bool DEVIOWorkerThread::PARSE_EPICS |
Definition at line 89 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::JEventSource_EVIOpp(), and ParseEPICSbank().
bool DEVIOWorkerThread::PARSE_EVENTTAG |
Definition at line 90 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), and JEventSource_EVIOpp::JEventSource_EVIOpp().
bool DEVIOWorkerThread::PARSE_F125 |
Definition at line 84 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::JEventSource_EVIOpp(), and Parsef125Bank().
bool DEVIOWorkerThread::PARSE_F1TDC |
Definition at line 85 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::JEventSource_EVIOpp(), and ParseF1TDCBank().
bool DEVIOWorkerThread::PARSE_F250 |
Definition at line 83 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::JEventSource_EVIOpp(), and Parsef250Bank().
bool DEVIOWorkerThread::PARSE_SSP |
Definition at line 92 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::JEventSource_EVIOpp(), and ParseSSPBank().
bool DEVIOWorkerThread::PARSE_TRIGGER |
Definition at line 91 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::JEventSource_EVIOpp(), ParseBuiltTriggerBank(), and ParseRawTriggerBank().
vector<DParsedEvent*> DEVIOWorkerThread::parsed_event_pool |
Definition at line 59 of file DEVIOWorkerThread.h.
Referenced by MakeEvents(), Prune(), Run(), and ~DEVIOWorkerThread().
list<DParsedEvent*>& DEVIOWorkerThread::parsed_events |
Definition at line 52 of file DEVIOWorkerThread.h.
Referenced by PublishEvents().
condition_variable& DEVIOWorkerThread::PARSED_EVENTS_CV |
Definition at line 55 of file DEVIOWorkerThread.h.
Referenced by PublishEvents().
mutex& DEVIOWorkerThread::PARSED_EVENTS_MUTEX |
Definition at line 54 of file DEVIOWorkerThread.h.
Referenced by PublishEvents().
streampos DEVIOWorkerThread::pos |
Definition at line 81 of file DEVIOWorkerThread.h.
Referenced by JEventSource_EVIOpp::Dispatcher().
set<uint32_t>& DEVIOWorkerThread::ROCIDS_TO_PARSE |
Definition at line 56 of file DEVIOWorkerThread.h.
Referenced by ParseDataBank().
uint64_t DEVIOWorkerThread::run_number_seed |
Definition at line 73 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::JEventSource_EVIOpp(), and MakeEvents().
thread DEVIOWorkerThread::thd |
Definition at line 77 of file DEVIOWorkerThread.h.
Referenced by Finish().
int DEVIOWorkerThread::VERBOSE |
Definition at line 64 of file DEVIOWorkerThread.h.
Referenced by DEVIOWorkerThread(), JEventSource_EVIOpp::JEventSource_EVIOpp(), MakeEvents(), ParseBORbank(), ParseCAEN1190(), ParseCDAQBank(), ParseDataBank(), Parsef125Bank(), ParseF1TDCBank(), Parsef250Bank(), ParseModuleConfiguration(), and ParseSSPBank().