o2::workflows Namespace Reference

Typedefs
using	OutputBuffer = o2::pmr::vector< char >

Functions
o2f::Output	getOutput (const o2f::OutputSpec outputSpec)
std::shared_ptr< std::vector< o2f::Output > >	getOutputList (const o2f::Outputs outputSpecs)
o2f::DataProcessorSpec	defineBroadcaster (std::string devName, o2f::InputSpec usrInput, o2f::Outputs usrOutputs, std::function< size_t(o2f::DataRef)> const func)
o2f::DataProcessorSpec	defineBroadcaster (std::string devName, o2f::InputSpec usrInput, o2f::Outputs usrOutputs, size_t fixMsgSize)
o2f::DataProcessorSpec	defineBroadcaster (std::string devName, o2f::InputSpec usrInput, o2f::Outputs usrOutputs)
o2f::DataProcessorSpec	defineMerger (std::string devName, o2f::Inputs usrInputs, o2f::OutputSpec usrOutput, std::function< void(OutputBuffer, const o2f::DataRef)> const mergerFunc)
o2f::DataProcessorSpec	defineMerger (std::string devName, o2f::Inputs usrInputs, o2f::OutputSpec usrOutput)
o2f::DataProcessorSpec	defineRouter (std::string devName, o2f::Inputs usrInput, o2f::Outputs usrOutputs, std::function< size_t(const o2f::DataRef)> const mappingFunc)
o2f::DataProcessorSpec	defineGatherer (std::string devName, o2f::Inputs usrInputs, o2f::OutputSpec usrOutput)

Typedef Documentation

OutputBuffer

using o2::workflows::OutputBuffer = typedef o2::pmr::vector<char>

Definition at line 40 of file Utils.h.

Function Documentation

defineBroadcaster() [1/3]

o2f::DataProcessorSpec o2::workflows::defineBroadcaster	(	std::string	devName,
		o2f::InputSpec	usrInput,
		o2f::Outputs	usrOutputs
	)

defineBroadcaster() [2/3]

o2f::DataProcessorSpec o2::workflows::defineBroadcaster	(	std::string	devName,
		o2f::InputSpec	usrInput,
		o2f::Outputs	usrOutputs,
		size_t	fixMsgSize
	)

defineBroadcaster() [3/3]

o2f::DataProcessorSpec o2::workflows::defineBroadcaster	(	std::string	devName,
		o2f::InputSpec	usrInput,
		o2f::Outputs	usrOutputs,
		std::function< size_t(o2f::DataRef)> const	func
	)

defineGatherer()

o2f::DataProcessorSpec o2::workflows::defineGatherer	(	std::string	devName,
		o2f::Inputs	usrInputs,
		o2f::OutputSpec	usrOutput
	)

defineMerger() [1/2]

o2f::DataProcessorSpec o2::workflows::defineMerger	(	std::string	devName,
		o2f::Inputs	usrInputs,
		o2f::OutputSpec	usrOutput
	)

defineMerger() [2/2]

o2f::DataProcessorSpec o2::workflows::defineMerger	(	std::string	devName,
		o2f::Inputs	usrInputs,
		o2f::OutputSpec	usrOutput,
		std::function< void(OutputBuffer, const o2f::DataRef)> const	mergerFunc
	)

defineRouter()

o2f::DataProcessorSpec o2::workflows::defineRouter	(	std::string	devName,
		o2f::Inputs	usrInput,
		o2f::Outputs	usrOutputs,
		std::function< size_t(const o2f::DataRef)> const	mappingFunc
	)

getOutput()

Output o2::workflows::getOutput

(

const o2f::OutputSpec

outputSpec

)

Definition at line 28 of file Utils.cxx.

getOutputList()

std::shared_ptr< std::vector< Output > > o2::workflows::getOutputList

(

const o2f::Outputs

outputSpecs

)

Definition at line 36 of file Utils.cxx.