#include <FedRawDataInputSource.h>

Inheritance diagram for FedRawDataInputSource:

Public Member Functions
	FedRawDataInputSource (edm::ParameterSet const &, edm::InputSourceDescription const &)

std::pair< bool, unsigned int >	getEventReport (unsigned int lumi, bool erase)

virtual	~FedRawDataInputSource ()

Public Member Functions inherited from edm::RawInputSource
	RawInputSource (ParameterSet const &pset, InputSourceDescription const &desc)

virtual	~RawInputSource ()

Public Member Functions inherited from edm::InputSource
std::shared_ptr< ActivityRegistry >	actReg () const
	Accessor for Activity Registry. More...

std::shared_ptr < BranchIDListHelper const >	branchIDListHelper () const
	Accessors for branchIDListHelper. More...

std::shared_ptr < BranchIDListHelper > &	branchIDListHelper ()

void	closeFile (FileBlock *, bool cleaningUpAfterException)
	close current file More...

void	doBeginJob ()
	Called by framework at beginning of job. More...

void	doBeginLumi (LuminosityBlockPrincipal &lbp, ProcessContext const *)
	Called by framework at beginning of lumi block. More...

void	doBeginRun (RunPrincipal &rp, ProcessContext const *)
	Called by framework at beginning of run. More...

void	doEndJob ()
	Called by framework at end of job. More...

void	doEndLumi (LuminosityBlockPrincipal &lbp, bool cleaningUpAfterException, ProcessContext const *)
	Called by framework at end of lumi block. More...

void	doEndRun (RunPrincipal &rp, bool cleaningUpAfterException, ProcessContext const *)
	Called by framework at end of run. More...

void	doPostForkReacquireResources (std::shared_ptr< multicore::MessageReceiverForSource >)

void	doPreForkReleaseResources ()
	Called by the framework before forking the process. More...

ProcessingController::ForwardState	forwardState () const

bool	goToEvent (EventID const &eventID)

	InputSource (ParameterSet const &, InputSourceDescription const &)
	Constructor. More...

	InputSource (InputSource const &)=delete

void	issueReports (EventID const &eventID)
	issue an event report More...

LuminosityBlockNumber_t	luminosityBlock () const
	Accessor for current luminosity block number. More...

std::shared_ptr < LuminosityBlockAuxiliary >	luminosityBlockAuxiliary () const
	Called by the framework to merge or insert lumi in principal cache. More...

int	maxEvents () const

int	maxLuminosityBlocks () const

ModuleDescription const &	moduleDescription () const
	Accessor for 'module' description. More...

ItemType	nextItemType ()
	Advances the source to the next item. More...

InputSource &	operator= (InputSource const &)=delete

ProcessConfiguration const &	processConfiguration () const
	Accessor for Process Configuration. More...

std::string const &	processGUID () const
	Accessor for global process identifier. More...

ProcessHistoryRegistry const &	processHistoryRegistry () const
	Accessors for process history registry. More...

ProcessHistoryRegistry &	processHistoryRegistry ()

ProcessingMode	processingMode () const
	RunsLumisAndEvents (default), RunsAndLumis, or Runs. More...

std::shared_ptr < ProductRegistry const >	productRegistry () const
	Accessors for product registry. More...

std::shared_ptr < ProductRegistry > &	productRegistry ()

bool	randomAccess () const

void	readAndMergeLumi (LuminosityBlockPrincipal &lbp)
	Read next luminosity block (same as a prior lumi) More...

void	readAndMergeRun (RunPrincipal &rp)
	Read next run (same as a prior run) More...

void	readEvent (EventPrincipal &ep, StreamContext &)
	Read next event. More...

bool	readEvent (EventPrincipal &ep, EventID const &, StreamContext &)
	Read a specific event. More...

std::unique_ptr< FileBlock >	readFile ()
	Read next file. More...

void	readLuminosityBlock (LuminosityBlockPrincipal &lumiPrincipal, HistoryAppender &historyAppender)
	Read next luminosity block (new lumi) More...

std::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary ()
	Read next luminosity block Auxilary. More...

void	readRun (RunPrincipal &runPrincipal, HistoryAppender &historyAppender)
	Read next run (new run) More...

std::shared_ptr< RunAuxiliary >	readRunAuxiliary ()
	Read next run Auxiliary. More...

ProcessHistoryID const &	reducedProcessHistoryID () const

void	registerProducts ()
	Register any produced products. More...

int	remainingEvents () const

int	remainingLuminosityBlocks () const

void	repeat ()
	Reset the remaining number of events/lumis to the maximum number. More...

SharedResourcesAcquirer *	resourceSharedWithDelayedReader ()
	Returns nullptr if no resource shared between the Source and a DelayedReader. More...

ProcessingController::ReverseState	reverseState () const

void	rewind ()
	Begin again at the first event. More...

RunNumber_t	run () const
	Accessor for current run number. More...

std::shared_ptr< RunAuxiliary >	runAuxiliary () const
	Called by the framework to merge or insert run in principal cache. More...

void	setLuminosityBlockNumber_t (LuminosityBlockNumber_t lb)
	Set the luminosity block ID. More...

void	setRunNumber (RunNumber_t r)
	Set the run number. More...

void	skipEvents (int offset)

bool	skipForForking ()

std::shared_ptr < ThinnedAssociationsHelper const >	thinnedAssociationsHelper () const
	Accessors for thinnedAssociationsHelper. More...

std::shared_ptr < ThinnedAssociationsHelper > &	thinnedAssociationsHelper ()

Timestamp const &	timestamp () const
	Accessor for the current time, as seen by the input source. More...

virtual	~InputSource ()
	Destructor. More...

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)

Static Public Member Functions inherited from edm::RawInputSource
static void	fillDescription (ParameterSetDescription &description)

Static Public Member Functions inherited from edm::InputSource
static const std::string &	baseType ()

static void	fillDescription (ParameterSetDescription &desc)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Protected Member Functions
virtual bool	checkNextEvent () override

virtual void	read (edm::EventPrincipal &eventPrincipal) override

Protected Member Functions inherited from edm::RawInputSource
void	makeEvent (EventPrincipal &eventPrincipal, EventAuxiliary const &eventAuxiliary)

void	setInputFileTransitionsEachEvent ()

Protected Member Functions inherited from edm::InputSource
void	decreaseRemainingEventsBy (int iSkipped)

bool	eventCached () const

bool	newLumi () const

bool	newRun () const

ProcessHistoryRegistry &	processHistoryRegistryForUpdate ()

ProductRegistry &	productRegistryUpdate ()

void	reset () const

void	resetEventCached ()

void	resetLuminosityBlockAuxiliary (bool isNewLumi=true) const

void	resetNewLumi ()

void	resetNewRun ()

void	resetRunAuxiliary (bool isNewRun=true) const

void	setEventCached ()
	Called by the framework to merge or ached() const {return eventCached_;}. More...

void	setLuminosityBlockAuxiliary (LuminosityBlockAuxiliary *lbp)

void	setNewLumi ()

void	setNewRun ()

void	setRunAuxiliary (RunAuxiliary *rp)

void	setTimestamp (Timestamp const &theTime)
	To set the current time, as seen by the input source. More...

virtual void	skip (int offset)

ItemType	state () const

Private Types
typedef std::pair< InputFile , InputChunk >	ReaderInfo

Private Member Functions
void	createBoLSFile (const uint32_t lumiSection, bool checkIfExists)

void	deleteFile (std::string const &)

bool	exceptionState ()

edm::Timestamp	fillFEDRawDataCollection (FEDRawDataCollection &)

evf::EvFDaqDirector::FileStatus	getFile (unsigned int &ls, std::string &nextFile, uint32_t &fsize, uint64_t &lockWaitTime)

evf::EvFDaqDirector::FileStatus	getNextEvent ()

int	grabNextJsonFile (boost::filesystem::path const &)

long	initFileList ()

void	maybeOpenNewLumiSection (const uint32_t lumiSection)

evf::EvFDaqDirector::FileStatus	nextEvent ()

virtual void	postForkReacquireResources (std::shared_ptr< edm::multicore::MessageReceiverForSource >) override

virtual void	preForkReleaseResources () override

void	readNextChunkIntoBuffer (InputFile *file)

void	readSupervisor ()

void	readWorker (unsigned int tid)

void	reportEventsThisLumiInSource (unsigned int lumi, unsigned int events)

virtual void	rewind_ () override

void	threadError ()

Private Attributes
uint32_t	bufferInputRead_ = 0

unsigned int	checkEvery_ = 10

bool	chunkIsFree_ =false

InputFile *	currentFile_ = 0

int	currentFileIndex_ = -1

unsigned int	currentLumiSection_

std::vector < std::condition_variable * >	cvReader_

std::condition_variable	cvWakeup_

evf::EvFDaqDirector *	daqDirector_ = 0

const edm::DaqProvenanceHelper	daqProvenanceHelper_

std::string	defPath_

uint32	detectedFRDversion_ =0

jsoncollector::DataPointDefinition *	dpd_

std::unique_ptr< FRDEventMsgView >	event_

unsigned int	eventChunkBlock_

unsigned int	eventChunkSize_

edm::EventID	eventID_

uint32_t	eventRunNumber_ =0

unsigned int	eventsThisLumi_

unsigned long	eventsThisRun_ = 0

std::mutex	fileDeleteLock_

int	fileDescriptor_ = -1

unsigned int	fileListIndex_ = 0

const bool	fileListLoopMode_

const bool	fileListMode_

std::vector< std::string >	fileNames_

std::list< std::pair< int, std::string > >	fileNamesToDelete_

tbb::concurrent_queue < InputFile * >	fileQueue_

std::list< std::pair< int, InputFile * > >	filesToDelete_

evf::FastMonitoringService *	fms_ = 0

tbb::concurrent_queue < InputChunk * >	freeChunks_

std::string	fuOutputDir_

const bool	getLSFromFilename_

uint32_t	GTPEventID_ = 0

uint32_t	L1EventID_ = 0

unsigned int	loopModeIterationInc_ = 0

unsigned int	maxBufferedFiles_

std::mutex	monlock_

std::mutex	mReader_

std::mutex	mWakeup_

unsigned int	nStreams_ = 0

unsigned int	numBuffers_

unsigned int	numConcurrentReads_

edm::ProcessHistoryID	processHistoryID_

std::atomic< bool >	quit_threads_

unsigned int	readBlocks_

std::atomic< unsigned int >	readingFilesCount_

std::unique_ptr< std::thread >	readSupervisorThread_

edm::RunNumber_t	runNumber_

bool	setExceptionState_ = false

bool	singleBufferMode_

std::map< unsigned int, unsigned int >	sourceEventsReport_

bool	startedSupervisorThread_ = false

std::condition_variable	startupCv_

std::mutex	startupLock_

std::vector< int > *	streamFileTrackerPtr_ = 0

unsigned char *	tcds_pointer_

std::vector< unsigned int >	thread_quit_signal

std::atomic< bool >	threadInit_

std::vector< unsigned int >	tid_active_

const bool	useL1EventID_

const bool	verifyAdler32_

const bool	verifyChecksum_

std::vector< ReaderInfo >	workerJob_

tbb::concurrent_queue < unsigned int >	workerPool_

std::vector< std::thread * >	workerThreads_

Friends
class	InputChunk

class	InputFile
	Open Root file and provide MEs ############. More...

Additional Inherited Members
Public Types inherited from edm::InputSource
enum	ItemType { IsInvalid, IsStop, IsFile, IsRun, IsLumi, IsEvent, IsRepeat, IsSynchronize }

enum	ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents }

typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Detailed Description

Definition at line 43 of file FedRawDataInputSource.h.

Member Typedef Documentation

typedef std::pair<InputFile*,InputChunk*> FedRawDataInputSource::ReaderInfo

private

Definition at line 138 of file FedRawDataInputSource.h.

Constructor & Destructor Documentation

FedRawDataInputSource::FedRawDataInputSource	(	edm::ParameterSet const &	pset,
		edm::InputSourceDescription const &	desc
	)

explicit

Definition at line 54 of file FedRawDataInputSource.cc.

FedRawDataInputSource::~FedRawDataInputSource ( )

virtual

Definition at line 182 of file FedRawDataInputSource.cc.

Member Function Documentation

bool FedRawDataInputSource::checkNextEvent ( )

overrideprotectedvirtual

Implements edm::RawInputSource.

Definition at line 232 of file FedRawDataInputSource.cc.

void FedRawDataInputSource::createBoLSFile	(	const uint32_t	lumiSection,
		bool	checkIfExists
	)

private

Definition at line 309 of file FedRawDataInputSource.cc.

void FedRawDataInputSource::deleteFile ( std::string const & fileName )

private

Definition at line 641 of file FedRawDataInputSource.cc.

bool FedRawDataInputSource::exceptionState ( )

inlineprivate

Definition at line 74 of file FedRawDataInputSource.h.

void FedRawDataInputSource::fillDescriptions ( edm::ConfigurationDescriptions & descriptions )

static

Definition at line 215 of file FedRawDataInputSource.cc.

edm::Timestamp FedRawDataInputSource::fillFEDRawDataCollection ( FEDRawDataCollection & rawData )

private

Definition at line 746 of file FedRawDataInputSource.cc.

std::pair< bool, unsigned int > FedRawDataInputSource::getEventReport	(	unsigned int	lumi,
		bool	erase
	)

Definition at line 1403 of file FedRawDataInputSource.cc.

evf::EvFDaqDirector::FileStatus FedRawDataInputSource::getFile	(	unsigned int &	ls,
		std::string &	nextFile,
		uint32_t &	fsize,
		uint64_t &	lockWaitTime
	)

private

Definition at line 1446 of file FedRawDataInputSource.cc.

evf::EvFDaqDirector::FileStatus FedRawDataInputSource::getNextEvent ( )

inlineprivate

Definition at line 371 of file FedRawDataInputSource.cc.

int FedRawDataInputSource::grabNextJsonFile ( boost::filesystem::path const & jsonSourcePath )

private

Definition at line 800 of file FedRawDataInputSource.cc.

long FedRawDataInputSource::initFileList ( )

private

Definition at line 1417 of file FedRawDataInputSource.cc.

void FedRawDataInputSource::maybeOpenNewLumiSection ( const uint32_t lumiSection )

private

Definition at line 320 of file FedRawDataInputSource.cc.

evf::EvFDaqDirector::FileStatus FedRawDataInputSource::nextEvent ( )

inlineprivate

Definition at line 361 of file FedRawDataInputSource.cc.

void FedRawDataInputSource::postForkReacquireResources ( std::shared_ptr< edm::multicore::MessageReceiverForSource > )

overrideprivatevirtual

Definition at line 909 of file FedRawDataInputSource.cc.

void FedRawDataInputSource::preForkReleaseResources ( )

overrideprivatevirtual

Reimplemented from edm::RawInputSource.

Definition at line 906 of file FedRawDataInputSource.cc.

void FedRawDataInputSource::read ( edm::EventPrincipal & eventPrincipal )

overrideprotectedvirtual

Implements edm::RawInputSource.

Definition at line 674 of file FedRawDataInputSource.cc.

void FedRawDataInputSource::readNextChunkIntoBuffer ( InputFile * file )

private

Definition at line 1338 of file FedRawDataInputSource.cc.

void FedRawDataInputSource::readSupervisor ( )

private

Definition at line 921 of file FedRawDataInputSource.cc.

void FedRawDataInputSource::readWorker ( unsigned int tid )

private

Definition at line 1203 of file FedRawDataInputSource.cc.

void FedRawDataInputSource::reportEventsThisLumiInSource	(	unsigned int	lumi,
		unsigned int	events
	)

private

Definition at line 1392 of file FedRawDataInputSource.cc.

void FedRawDataInputSource::rewind_ ( )

overrideprivatevirtual

Reimplemented from edm::RawInputSource.

Definition at line 917 of file FedRawDataInputSource.cc.

void FedRawDataInputSource::threadError ( )

private

Definition at line 1278 of file FedRawDataInputSource.cc.

Friends And Related Function Documentation

friend class InputChunk

friend

Definition at line 46 of file FedRawDataInputSource.h.

friend class InputFile

friend

Open Root file and provide MEs ############.

Definition at line 45 of file FedRawDataInputSource.h.

Member Data Documentation

uint32_t FedRawDataInputSource::bufferInputRead_ = 0

private

Definition at line 179 of file FedRawDataInputSource.h.

unsigned int FedRawDataInputSource::checkEvery_ = 10

private

Definition at line 170 of file FedRawDataInputSource.h.

bool FedRawDataInputSource::chunkIsFree_ =false

private

Definition at line 142 of file FedRawDataInputSource.h.

InputFile* FedRawDataInputSource::currentFile_ = 0

private

Definition at line 141 of file FedRawDataInputSource.h.

int FedRawDataInputSource::currentFileIndex_ = -1

private

Definition at line 164 of file FedRawDataInputSource.h.

unsigned int FedRawDataInputSource::currentLumiSection_

private

Definition at line 122 of file FedRawDataInputSource.h.

std::vector<std::condition_variable*> FedRawDataInputSource::cvReader_

private

Definition at line 155 of file FedRawDataInputSource.h.

std::condition_variable FedRawDataInputSource::cvWakeup_

private

Definition at line 174 of file FedRawDataInputSource.h.

evf::EvFDaqDirector* FedRawDataInputSource::daqDirector_ = 0

private

Definition at line 87 of file FedRawDataInputSource.h.

const edm::DaqProvenanceHelper FedRawDataInputSource::daqProvenanceHelper_

private

Definition at line 115 of file FedRawDataInputSource.h.

std::string FedRawDataInputSource::defPath_

private

Definition at line 89 of file FedRawDataInputSource.h.

uint32 FedRawDataInputSource::detectedFRDversion_ =0

private

Definition at line 140 of file FedRawDataInputSource.h.

jsoncollector::DataPointDefinition* FedRawDataInputSource::dpd_

private

Definition at line 130 of file FedRawDataInputSource.h.

std::unique_ptr<FRDEventMsgView> FedRawDataInputSource::event_

private

Definition at line 117 of file FedRawDataInputSource.h.

unsigned int FedRawDataInputSource::eventChunkBlock_

private

Definition at line 92 of file FedRawDataInputSource.h.

unsigned int FedRawDataInputSource::eventChunkSize_

private

Definition at line 91 of file FedRawDataInputSource.h.

edm::EventID FedRawDataInputSource::eventID_

private

Definition at line 119 of file FedRawDataInputSource.h.

uint32_t FedRawDataInputSource::eventRunNumber_ =0

private

Definition at line 123 of file FedRawDataInputSource.h.

unsigned int FedRawDataInputSource::eventsThisLumi_

private

Definition at line 127 of file FedRawDataInputSource.h.

unsigned long FedRawDataInputSource::eventsThisRun_ = 0

private

Definition at line 128 of file FedRawDataInputSource.h.

std::mutex FedRawDataInputSource::fileDeleteLock_

private

Definition at line 167 of file FedRawDataInputSource.h.

int FedRawDataInputSource::fileDescriptor_ = -1

private

Definition at line 178 of file FedRawDataInputSource.h.

unsigned int FedRawDataInputSource::fileListIndex_ = 0

private

Definition at line 108 of file FedRawDataInputSource.h.

const bool FedRawDataInputSource::fileListLoopMode_

private

Definition at line 109 of file FedRawDataInputSource.h.

const bool FedRawDataInputSource::fileListMode_

private

Definition at line 107 of file FedRawDataInputSource.h.

std::vector<std::string> FedRawDataInputSource::fileNames_

private

Definition at line 104 of file FedRawDataInputSource.h.

std::list<std::pair<int,std::string> > FedRawDataInputSource::fileNamesToDelete_

private

Definition at line 166 of file FedRawDataInputSource.h.

tbb::concurrent_queue<InputFile*> FedRawDataInputSource::fileQueue_

private

Definition at line 152 of file FedRawDataInputSource.h.

std::list<std::pair<int,InputFile*> > FedRawDataInputSource::filesToDelete_

private

Definition at line 165 of file FedRawDataInputSource.h.

evf::FastMonitoringService* FedRawDataInputSource::fms_ = 0

private

Definition at line 86 of file FedRawDataInputSource.h.

tbb::concurrent_queue<InputChunk*> FedRawDataInputSource::freeChunks_

private

Definition at line 151 of file FedRawDataInputSource.h.

std::string FedRawDataInputSource::fuOutputDir_

private

Definition at line 113 of file FedRawDataInputSource.h.

const bool FedRawDataInputSource::getLSFromFilename_

private

Definition at line 100 of file FedRawDataInputSource.h.

uint32_t FedRawDataInputSource::GTPEventID_ = 0

private

Definition at line 124 of file FedRawDataInputSource.h.

uint32_t FedRawDataInputSource::L1EventID_ = 0

private

Definition at line 125 of file FedRawDataInputSource.h.

unsigned int FedRawDataInputSource::loopModeIterationInc_ = 0

private

Definition at line 110 of file FedRawDataInputSource.h.

unsigned int FedRawDataInputSource::maxBufferedFiles_

private

Definition at line 95 of file FedRawDataInputSource.h.

std::mutex FedRawDataInputSource::monlock_

private

Definition at line 184 of file FedRawDataInputSource.h.

std::mutex FedRawDataInputSource::mReader_

private

Definition at line 154 of file FedRawDataInputSource.h.

std::mutex FedRawDataInputSource::mWakeup_

private

Definition at line 173 of file FedRawDataInputSource.h.

unsigned int FedRawDataInputSource::nStreams_ = 0

private

Definition at line 169 of file FedRawDataInputSource.h.

unsigned int FedRawDataInputSource::numBuffers_

private

Definition at line 94 of file FedRawDataInputSource.h.

unsigned int FedRawDataInputSource::numConcurrentReads_

private

Definition at line 96 of file FedRawDataInputSource.h.

edm::ProcessHistoryID FedRawDataInputSource::processHistoryID_

private

Definition at line 120 of file FedRawDataInputSource.h.

std::atomic<bool> FedRawDataInputSource::quit_threads_

private

Definition at line 158 of file FedRawDataInputSource.h.

unsigned int FedRawDataInputSource::readBlocks_

private

Definition at line 93 of file FedRawDataInputSource.h.

std::atomic<unsigned int> FedRawDataInputSource::readingFilesCount_

private

Definition at line 97 of file FedRawDataInputSource.h.

std::unique_ptr<std::thread> FedRawDataInputSource::readSupervisorThread_

private

Definition at line 145 of file FedRawDataInputSource.h.

edm::RunNumber_t FedRawDataInputSource::runNumber_

private

Definition at line 112 of file FedRawDataInputSource.h.

bool FedRawDataInputSource::setExceptionState_ = false

private

Definition at line 160 of file FedRawDataInputSource.h.

bool FedRawDataInputSource::singleBufferMode_

private

Definition at line 177 of file FedRawDataInputSource.h.

std::map<unsigned int,unsigned int> FedRawDataInputSource::sourceEventsReport_

private

Definition at line 183 of file FedRawDataInputSource.h.

bool FedRawDataInputSource::startedSupervisorThread_ = false

private

Definition at line 144 of file FedRawDataInputSource.h.

std::condition_variable FedRawDataInputSource::startupCv_

private

Definition at line 162 of file FedRawDataInputSource.h.

std::mutex FedRawDataInputSource::startupLock_

private

Definition at line 161 of file FedRawDataInputSource.h.

std::vector<int>* FedRawDataInputSource::streamFileTrackerPtr_ = 0

private

Definition at line 168 of file FedRawDataInputSource.h.

unsigned char* FedRawDataInputSource::tcds_pointer_

private

Definition at line 126 of file FedRawDataInputSource.h.

std::vector<unsigned int> FedRawDataInputSource::thread_quit_signal

private

Definition at line 159 of file FedRawDataInputSource.h.

std::atomic<bool> FedRawDataInputSource::threadInit_

private

Definition at line 181 of file FedRawDataInputSource.h.

std::vector<unsigned int> FedRawDataInputSource::tid_active_

private

Definition at line 156 of file FedRawDataInputSource.h.

const bool FedRawDataInputSource::useL1EventID_

private

Definition at line 103 of file FedRawDataInputSource.h.

const bool FedRawDataInputSource::verifyAdler32_

private

Definition at line 101 of file FedRawDataInputSource.h.

const bool FedRawDataInputSource::verifyChecksum_

private

Definition at line 102 of file FedRawDataInputSource.h.

std::vector<ReaderInfo> FedRawDataInputSource::workerJob_

private

Definition at line 149 of file FedRawDataInputSource.h.

tbb::concurrent_queue<unsigned int> FedRawDataInputSource::workerPool_

private

Definition at line 148 of file FedRawDataInputSource.h.

std::vector<std::thread*> FedRawDataInputSource::workerThreads_

private

Definition at line 146 of file FedRawDataInputSource.h.

Public Member Functions

Static Public Member Functions

Protected Member Functions

Private Types

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation