#include <Dispatcher.h>

Inherits o2::framework::Task.

Public Member Functions
	Dispatcher (const std::string name, const std::string reconfigurationSource)
	Constructor.

	~Dispatcher () override
	Destructor.

void	init (framework::InitContext &ctx) override
	Dispatcher init callback.

void	run (framework::ProcessingContext &ctx) override
	Dispatcher process callback.

void	registerPolicy (std::unique_ptr< DataSamplingPolicy > &&)
	Register a Data Sampling Policy.

size_t	numberOfPolicies ()
	Returns the number of registered policies.

const std::string &	getName ()

framework::Inputs	getInputSpecs ()
	Assembles InputSpecs of all registered policies in a single vector, removing overlapping entries.

framework::Outputs	getOutputSpecs ()

framework::Options	getOptions ()

Public Member Functions inherited from o2::framework::Task
virtual	~Task ()

virtual void	endOfStream (EndOfStreamContext &context)
	This is invoked whenever we have an EndOfStream event.

virtual void	finaliseCCDB (ConcreteDataMatcher &matcher, void *obj)

virtual void	stop ()
	This is invoked on stop.

Detailed Description

Definition at line 42 of file Dispatcher.h.

Constructor & Destructor Documentation

◆ Dispatcher()

o2::utilities::Dispatcher::Dispatcher	(	const std::string	name,
		const std::string	reconfigurationSource
	)

Constructor.

Definition at line 41 of file Dispatcher.cxx.

◆ ~Dispatcher()

o2::utilities::Dispatcher::~Dispatcher ( )

overridedefault

Destructor.

Member Function Documentation

◆ getInputSpecs()

Inputs o2::utilities::Dispatcher::getInputSpecs ( )

Assembles InputSpecs of all registered policies in a single vector, removing overlapping entries.

Definition at line 212 of file Dispatcher.cxx.

◆ getName()

const std::string & o2::utilities::Dispatcher::getName ( )

Definition at line 207 of file Dispatcher.cxx.

◆ getOptions()

framework::Options o2::utilities::Dispatcher::getOptions ( )

Definition at line 258 of file Dispatcher.cxx.

◆ getOutputSpecs()

Outputs o2::utilities::Dispatcher::getOutputSpecs ( )

Definition at line 245 of file Dispatcher.cxx.

◆ init()

void o2::utilities::Dispatcher::init ( framework::InitContext & ctx )

overridevirtual

Dispatcher init callback.

Reimplemented from o2::framework::Task.

Definition at line 48 of file Dispatcher.cxx.

◆ numberOfPolicies()

size_t o2::utilities::Dispatcher::numberOfPolicies ( )

Returns the number of registered policies.

Definition at line 263 of file Dispatcher.cxx.

◆ registerPolicy()

void o2::utilities::Dispatcher::registerPolicy ( std::unique_ptr< DataSamplingPolicy > && policy )

Register a Data Sampling Policy.

Definition at line 202 of file Dispatcher.cxx.

◆ run()

void o2::utilities::Dispatcher::run ( framework::ProcessingContext & ctx )