#include <FairMQDeviceProxy.h>

Public Member Functions
	FairMQDeviceProxy ()=default

	FairMQDeviceProxy (FairMQDeviceProxy const &)=delete

void	bind (std::vector< OutputRoute > const &outputs, std::vector< InputRoute > const &inputs, std::vector< ForwardRoute > const &forwards, fair::mq::Device &device)

fair::mq::TransportFactory *	getOutputTransport (RouteIndex routeIndex) const
	Retrieve the transport associated to a given route.

fair::mq::TransportFactory *	getInputTransport (RouteIndex routeIndex) const
	Retrieve the transport associated to a given route.

fair::mq::TransportFactory *	getForwardTransport (RouteIndex routeIndex) const
	Retrieve the transport associated to a given route.

ChannelIndex	getOutputChannelIndexByName (std::string const &channelName) const
	ChannelIndex from a given channel name.

ChannelIndex	getInputChannelIndexByName (std::string const &channelName) const
	ChannelIndex from a given channel name.

ChannelIndex	getForwardChannelIndexByName (std::string const &channelName) const
	ChannelIndex from a given channel name.

ChannelIndex	getOutputChannelIndex (OutputSpec const &spec, size_t timeslice) const
	Retrieve the channel index from a given OutputSpec and the associated timeslice.

void	getMatchingForwardChannelIndexes (std::vector< ChannelIndex > &result, header::DataHeader const &header, size_t timeslice) const
	Retrieve the channel index from a given OutputSpec and the associated timeslice.

ChannelIndex	getOutputChannelIndex (RouteIndex routeIndex) const
	ChannelIndex from a RouteIndex.

ChannelIndex	getInputChannelIndex (RouteIndex routeIndex) const

ChannelIndex	getForwardChannelIndex (RouteIndex routeIndex) const

fair::mq::Channel *	getInputChannel (ChannelIndex channelIndex) const
	Retrieve the channel associated to a given output route.

fair::mq::Channel *	getOutputChannel (ChannelIndex channelIndex) const

fair::mq::Channel *	getForwardChannel (ChannelIndex channelIndex) const

OutputChannelInfo const &	getOutputChannelInfo (ChannelIndex channelIndex) const
	Retrieve information associated to a given forward by ChannelIndex.

ForwardChannelInfo const &	getForwardChannelInfo (ChannelIndex channelIndex) const
	Retrieve information associated to a given forward by ChannelIndex.

OutputChannelState &	getOutputChannelState (ChannelIndex channelIndex)
	Retrieve information associated to a given forward by ChannelIndex.

ForwardChannelState &	getForwardChannelState (ChannelIndex channelIndex)
	Retrieve information associated to a given forward by ChannelIndex.

std::unique_ptr< fair::mq::Message >	createOutputMessage (RouteIndex routeIndex) const

std::unique_ptr< fair::mq::Message >	createOutputMessage (RouteIndex routeIndex, const size_t size) const

std::unique_ptr< fair::mq::Message >	createInputMessage (RouteIndex routeIndex) const

std::unique_ptr< fair::mq::Message >	createInputMessage (RouteIndex routeIndex, const size_t size) const

std::unique_ptr< fair::mq::Message >	createForwardMessage (RouteIndex routeIndex) const

size_t	getNumOutputChannels () const

size_t	getNumInputChannels () const

size_t	getNumForwardChannels () const

size_t	getNumForwards () const

bool	newStateRequested () const

Detailed Description

Helper class to hide fair::mq::Device headers in the DataAllocator header. This is done because fair::mq::Device brings in a bunch of boost.mpl / boost.fusion stuff, slowing down compilation times enourmously.

Definition at line 35 of file FairMQDeviceProxy.h.

Constructor & Destructor Documentation

◆ FairMQDeviceProxy() [1/2]

o2::framework::FairMQDeviceProxy::FairMQDeviceProxy ( )

default

◆ FairMQDeviceProxy() [2/2]

o2::framework::FairMQDeviceProxy::FairMQDeviceProxy ( FairMQDeviceProxy const & )

delete

Member Function Documentation

◆ bind()

void o2::framework::FairMQDeviceProxy::bind	(	std::vector< OutputRoute > const &	outputs,
		std::vector< InputRoute > const &	inputs,
		std::vector< ForwardRoute > const &	forwards,
		fair::mq::Device &	device
	)

Definition at line 231 of file FairMQDeviceProxy.cxx.

◆ createForwardMessage()

std::unique_ptr< fair::mq::Message > o2::framework::FairMQDeviceProxy::createForwardMessage ( RouteIndex routeIndex ) const

Definition at line 226 of file FairMQDeviceProxy.cxx.

◆ createInputMessage() [1/2]

std::unique_ptr< fair::mq::Message > o2::framework::FairMQDeviceProxy::createInputMessage ( RouteIndex routeIndex ) const

Definition at line 216 of file FairMQDeviceProxy.cxx.

◆ createInputMessage() [2/2]

std::unique_ptr< fair::mq::Message > o2::framework::FairMQDeviceProxy::createInputMessage	(	RouteIndex	routeIndex,
		const size_t	size
	)		const

Definition at line 221 of file FairMQDeviceProxy.cxx.

◆ createOutputMessage() [1/2]

std::unique_ptr< fair::mq::Message > o2::framework::FairMQDeviceProxy::createOutputMessage ( RouteIndex routeIndex ) const

Definition at line 206 of file FairMQDeviceProxy.cxx.

◆ createOutputMessage() [2/2]

std::unique_ptr< fair::mq::Message > o2::framework::FairMQDeviceProxy::createOutputMessage	(	RouteIndex	routeIndex,
		const size_t	size
	)		const

Definition at line 211 of file FairMQDeviceProxy.cxx.

◆ getForwardChannel()

fair::mq::Channel * o2::framework::FairMQDeviceProxy::getForwardChannel ( ChannelIndex channelIndex ) const

Definition at line 87 of file FairMQDeviceProxy.cxx.

◆ getForwardChannelIndex()

ChannelIndex o2::framework::FairMQDeviceProxy::getForwardChannelIndex ( RouteIndex routeIndex ) const

Definition at line 49 of file FairMQDeviceProxy.cxx.

◆ getForwardChannelIndexByName()

ChannelIndex o2::framework::FairMQDeviceProxy::getForwardChannelIndexByName ( std::string const & channelName ) const

ChannelIndex from a given channel name.

Definition at line 175 of file FairMQDeviceProxy.cxx.

◆ getForwardChannelInfo()

ForwardChannelInfo const & o2::framework::FairMQDeviceProxy::getForwardChannelInfo ( ChannelIndex channelIndex ) const

Retrieve information associated to a given forward by ChannelIndex.

Definition at line 94 of file FairMQDeviceProxy.cxx.

◆ getForwardChannelState()

ForwardChannelState & o2::framework::FairMQDeviceProxy::getForwardChannelState ( ChannelIndex channelIndex )

Retrieve information associated to a given forward by ChannelIndex.

Definition at line 101 of file FairMQDeviceProxy.cxx.

◆ getForwardTransport()

fair::mq::TransportFactory * o2::framework::FairMQDeviceProxy::getForwardTransport ( RouteIndex routeIndex ) const

Retrieve the transport associated to a given route.

Definition at line 199 of file FairMQDeviceProxy.cxx.

◆ getInputChannel()

fair::mq::Channel * o2::framework::FairMQDeviceProxy::getInputChannel ( ChannelIndex channelIndex ) const

Retrieve the channel associated to a given output route.

Definition at line 80 of file FairMQDeviceProxy.cxx.

◆ getInputChannelIndex()

ChannelIndex o2::framework::FairMQDeviceProxy::getInputChannelIndex ( RouteIndex routeIndex ) const

Definition at line 39 of file FairMQDeviceProxy.cxx.

◆ getInputChannelIndexByName()

ChannelIndex o2::framework::FairMQDeviceProxy::getInputChannelIndexByName ( std::string const & channelName ) const

ChannelIndex from a given channel name.

Definition at line 165 of file FairMQDeviceProxy.cxx.

◆ getInputTransport()

fair::mq::TransportFactory * o2::framework::FairMQDeviceProxy::getInputTransport ( RouteIndex routeIndex ) const

Retrieve the transport associated to a given route.

Definition at line 192 of file FairMQDeviceProxy.cxx.

◆ getMatchingForwardChannelIndexes()

void o2::framework::FairMQDeviceProxy::getMatchingForwardChannelIndexes	(	std::vector< ChannelIndex > &	result,
		header::DataHeader const &	header,
		size_t	timeslice
	)		const

Retrieve the channel index from a given OutputSpec and the associated timeslice.

Definition at line 122 of file FairMQDeviceProxy.cxx.

◆ getNumForwardChannels()

size_t o2::framework::FairMQDeviceProxy::getNumForwardChannels ( ) const

inline

Definition at line 88 of file FairMQDeviceProxy.h.

◆ getNumForwards()

size_t o2::framework::FairMQDeviceProxy::getNumForwards ( ) const

inline

Definition at line 89 of file FairMQDeviceProxy.h.

◆ getNumInputChannels()

size_t o2::framework::FairMQDeviceProxy::getNumInputChannels ( ) const

inline

Definition at line 87 of file FairMQDeviceProxy.h.

◆ getNumOutputChannels()

size_t o2::framework::FairMQDeviceProxy::getNumOutputChannels ( ) const

inline

Definition at line 86 of file FairMQDeviceProxy.h.

◆ getOutputChannel()

fair::mq::Channel * o2::framework::FairMQDeviceProxy::getOutputChannel ( ChannelIndex channelIndex ) const

Definition at line 59 of file FairMQDeviceProxy.cxx.

◆ getOutputChannelIndex() [1/2]

ChannelIndex o2::framework::FairMQDeviceProxy::getOutputChannelIndex	(	OutputSpec const &	spec,
		size_t	timeslice
	)		const

Retrieve the channel index from a given OutputSpec and the associated timeslice.

Definition at line 108 of file FairMQDeviceProxy.cxx.

◆ getOutputChannelIndex() [2/2]

ChannelIndex o2::framework::FairMQDeviceProxy::getOutputChannelIndex ( RouteIndex routeIndex ) const

ChannelIndex from a RouteIndex.

Definition at line 29 of file FairMQDeviceProxy.cxx.

◆ getOutputChannelIndexByName()

ChannelIndex o2::framework::FairMQDeviceProxy::getOutputChannelIndexByName ( std::string const & channelName ) const

ChannelIndex from a given channel name.

Definition at line 155 of file FairMQDeviceProxy.cxx.

◆ getOutputChannelInfo()

OutputChannelInfo const & o2::framework::FairMQDeviceProxy::getOutputChannelInfo ( ChannelIndex channelIndex ) const

Retrieve information associated to a given forward by ChannelIndex.

Definition at line 66 of file FairMQDeviceProxy.cxx.

◆ getOutputChannelState()

OutputChannelState & o2::framework::FairMQDeviceProxy::getOutputChannelState ( ChannelIndex channelIndex )

Retrieve information associated to a given forward by ChannelIndex.

Definition at line 73 of file FairMQDeviceProxy.cxx.

◆ getOutputTransport()

fair::mq::TransportFactory * o2::framework::FairMQDeviceProxy::getOutputTransport ( RouteIndex routeIndex ) const

Retrieve the transport associated to a given route.

Definition at line 185 of file FairMQDeviceProxy.cxx.

◆ newStateRequested()

bool o2::framework::FairMQDeviceProxy::newStateRequested ( ) const

inline

Definition at line 91 of file FairMQDeviceProxy.h.

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

/home/runner/work/AliceO2/AliceO2/Framework/Core/include/Framework/FairMQDeviceProxy.h
/home/runner/work/AliceO2/AliceO2/Framework/Core/src/FairMQDeviceProxy.cxx

Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ FairMQDeviceProxy() [1/2]

◆ FairMQDeviceProxy() [2/2]

Member Function Documentation

◆ bind()

◆ createForwardMessage()

◆ createInputMessage() [1/2]

◆ createInputMessage() [2/2]

◆ createOutputMessage() [1/2]

◆ createOutputMessage() [2/2]

◆ getForwardChannel()

◆ getForwardChannelIndex()

◆ getForwardChannelIndexByName()

◆ getForwardChannelInfo()

◆ getForwardChannelState()

◆ getForwardTransport()

◆ getInputChannel()

◆ getInputChannelIndex()

◆ getInputChannelIndexByName()

◆ getInputTransport()

◆ getMatchingForwardChannelIndexes()

◆ getNumForwardChannels()

◆ getNumForwards()

◆ getNumInputChannels()

◆ getNumOutputChannels()

◆ getOutputChannel()

◆ getOutputChannelIndex() [1/2]

◆ getOutputChannelIndex() [2/2]

◆ getOutputChannelIndexByName()

◆ getOutputChannelInfo()

◆ getOutputChannelState()

◆ getOutputTransport()

◆ newStateRequested()