< public DataConsumer, public Configurable More...

#include <otsdaq/DataProcessorPlugins/ARTDAQConsumer.h>

Inheritance diagram for ots::ARTDAQConsumer:

Public Member Functions
	ARTDAQConsumer (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, const ConfigurationTree &theXDAQContextConfigTree, const std::string &configurationPath)

virtual	~ARTDAQConsumer (void)

void	pauseProcessingData (void) override

void	resumeProcessingData (void) override

void	startProcessingData (std::string runNumber) override

void	stopProcessingData (void) override

Public Member Functions inherited from ots::DataConsumer
	DataConsumer (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, ConsumerPriority priority)

virtual void	registerToBuffer (void)
	mirror DataProducerBase::registerToBuffer

virtual void	configure (void)

template<class D , class H >
int	read (D &buffer, H &header)
	Copies the buffer into the passed parameters.

template<class D , class H >
int	read (D &buffer, H &header)
	Fast version where you point to the buffer without copying.

template<class D , class H >
int	setReadSubBuffer (void)

template<class D , class H >
int	read (D &buffer)

ConsumerPriority	getPriority (void)

Public Member Functions inherited from ots::DataProcessor
	DataProcessor (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID)

const std::string &	getProcessorID (void) const
	Getters.

void	setCircularBuffer (CircularBufferBase *circularBuffer)

Public Member Functions inherited from ots::WorkLoop
	WorkLoop (const std::string &name)

void	startWorkLoop (void)

bool	stopWorkLoop (void)

bool	isActive (void) const

Public Member Functions inherited from ots::ARTDAQReaderProcessorBase
	ARTDAQReaderProcessorBase (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, const ConfigurationTree &theXDAQContextConfigTree, const std::string &configurationPath)

virtual	~ARTDAQReaderProcessorBase (void)

void	initLocalGroup (int rank)
	these functions are not inherited, they define the core reader functionality

void	configure (int rank)

void	halt (void)

void	pause (void)

void	resume (void)

void	start (const std::string &runNumber)

void	stop (void)

Public Member Functions inherited from ots::Configurable
	Configurable (const ConfigurationTree &theXDAQContextConfigTree, const std::string &theConfigurationPath)

ConfigurationTree	getSelfNode () const

const ConfigurationManager *	getConfigurationManager () const

const std::string &	getContextUID () const

const std::string &	getApplicationUID () const

unsigned int	getApplicationLID () const

std::string	getContextAddress () const

unsigned int	getContextPort () const

Additional Inherited Members
Public Types inherited from ots::DataConsumer
enum	ConsumerPriority { LowConsumerPriority , HighConsumerPriority }

Protected Member Functions inherited from ots::WorkLoop
const std::string &	getWorkLoopName (void) const
	Getters.

Protected Attributes inherited from ots::DataProcessor
const std::string	supervisorApplicationUID_

const std::string	bufferUID_

const std::string	processorUID_

CircularBufferBase *	theCircularBuffer_

Protected Attributes inherited from ots::WorkLoop
volatile bool	continueWorkLoop_

Protected Attributes inherited from ots::Configurable
const ConfigurationTree	theXDAQContextConfigTree_

const std::string	theConfigurationPath_

const std::string	theConfigurationRecordName_

Detailed Description

< public DataConsumer, public Configurable

ARTDAQConsumer This class is a Data Consumer plugin that allows a single artdaq Board Reader to be instantiated on the read side of an otsdaq Buffer.

Definition at line 20 of file ARTDAQConsumer.h.

Constructor & Destructor Documentation

◆ ARTDAQConsumer()

ARTDAQConsumer::ARTDAQConsumer	(	std::string	supervisorApplicationUID,
		std::string	bufferUID,
		std::string	processorUID,
		const ConfigurationTree &	theXDAQContextConfigTree,
		const std::string &	configurationPath
	)

: WorkLoop(processorUID) , DataConsumer(supervisorApplicationUID, bufferUID, processorUID, LowConsumerPriority) , Configurable(theXDAQContextConfigTree, configurationPath)

Definition at line 20 of file ARTDAQConsumerImpl.cc.

◆ ~ARTDAQConsumer()

ARTDAQConsumer::~ARTDAQConsumer ( void )

virtual

ARTDAQConsumer::ARTDAQConsumer(std::string interfaceID, MPI_Comm local_group_comm, std::string name) :FEVInterface (feId, 0) ,local_group_comm_(local_group_comm) ,name_ (name)

Definition at line 134 of file ARTDAQConsumerImpl.cc.

Member Function Documentation

◆ pauseProcessingData()

void ARTDAQConsumer::pauseProcessingData ( void )

overridevirtual

============================================================================== void ARTDAQConsumer::initLocalGroup(int rank) ============================================================================== void ARTDAQConsumer::configure(int rank) ============================================================================== void ARTDAQConsumer::halt(void)

Reimplemented from ots::DataProcessor.

Definition at line 202 of file ARTDAQConsumerImpl.cc.

◆ startProcessingData()

void ARTDAQConsumer::startProcessingData ( std::string runNumber )

overridevirtual

mirror DataProducerBase::unregisterFromBuffer void DataConsumer::unregisterFromBuffer(void)

Reimplemented from ots::DataConsumer.

Definition at line 234 of file ARTDAQConsumerImpl.cc.

The documentation for this class was generated from the following files:

otsdaq/otsdaq/DataProcessorPlugins/ARTDAQConsumer.h
otsdaq/otsdaq/DataProcessorPlugins/ARTDAQConsumerImpl.cc

Public Member Functions