o2::framework::ArrowContext Class Reference

#include <ArrowContext.h>

Classes
struct	MessageRef

Public Types
using	Messages = std::vector< MessageRef >

Public Member Functions
	ArrowContext (FairMQDeviceProxy &proxy)
void	addBuffer (std::unique_ptr< fair::mq::Message > header, std::shared_ptr< FairMQResizableBuffer > buffer, std::function< void(std::shared_ptr< FairMQResizableBuffer >)> finalize, RouteIndex routeIndex)
Messages::iterator	begin ()
Messages::iterator	end ()
size_t	size ()
void	clear ()
FairMQDeviceProxy &	proxy ()
void	updateBytesSent (size_t value)
void	updateBytesDestroyed (size_t value)
void	updateMessagesSent (size_t value)
void	updateMessagesDestroyed (size_t value)
size_t	bytesSent ()
size_t	bytesDestroyed ()
size_t	messagesCreated ()
size_t	messagesDestroyed ()

Static Public Attributes
static constexpr ServiceKind	service_kind = ServiceKind::Stream

Detailed Description

A context which holds std::strings being passed around useful for debug purposes and as an illustration of how to add a context for a new kind of object.

Definition at line 32 of file ArrowContext.h.

Member Typedef Documentation

Messages

using o2::framework::ArrowContext::Messages = std::vector<MessageRef>

Definition at line 52 of file ArrowContext.h.

Constructor & Destructor Documentation

ArrowContext()

o2::framework::ArrowContext::ArrowContext ( FairMQDeviceProxy &  proxy )

inline

Definition at line 37 of file ArrowContext.h.

Member Function Documentation

addBuffer()

void o2::framework::ArrowContext::addBuffer ( std::unique_ptr< fair::mq::Message >  header, std::shared_ptr< FairMQResizableBuffer >  buffer, std::function< void(std::shared_ptr< FairMQResizableBuffer >)>  finalize, RouteIndex  routeIndex  )

inline

Definition at line 54 of file ArrowContext.h.

begin()

Messages::iterator o2::framework::ArrowContext::begin ( )

inline

Definition at line 65 of file ArrowContext.h.

bytesDestroyed()

size_t o2::framework::ArrowContext::bytesDestroyed ( )

inline

Definition at line 118 of file ArrowContext.h.

bytesSent()

size_t o2::framework::ArrowContext::bytesSent ( )

inline

Definition at line 113 of file ArrowContext.h.

clear()

void o2::framework::ArrowContext::clear ( )

inline

Definition at line 80 of file ArrowContext.h.

end()

Messages::iterator o2::framework::ArrowContext::end ( )

inline

Definition at line 70 of file ArrowContext.h.

messagesCreated()

size_t o2::framework::ArrowContext::messagesCreated ( )

inline

Definition at line 123 of file ArrowContext.h.

messagesDestroyed()

size_t o2::framework::ArrowContext::messagesDestroyed ( )

inline

Definition at line 128 of file ArrowContext.h.

proxy()

FairMQDeviceProxy & o2::framework::ArrowContext::proxy ( )

inline

Definition at line 88 of file ArrowContext.h.

size()

size_t o2::framework::ArrowContext::size ( )

inline

Definition at line 75 of file ArrowContext.h.

updateBytesDestroyed()

void o2::framework::ArrowContext::updateBytesDestroyed ( size_t  value )

inline

Definition at line 98 of file ArrowContext.h.

updateBytesSent()

void o2::framework::ArrowContext::updateBytesSent ( size_t  value )

inline

Definition at line 93 of file ArrowContext.h.

updateMessagesDestroyed()

void o2::framework::ArrowContext::updateMessagesDestroyed ( size_t  value )

inline

Definition at line 108 of file ArrowContext.h.

updateMessagesSent()

void o2::framework::ArrowContext::updateMessagesSent ( size_t  value )

inline

Definition at line 103 of file ArrowContext.h.

Member Data Documentation

service_kind

constexpr ServiceKind o2::framework::ArrowContext::service_kind = ServiceKind::Stream

staticconstexpr

Definition at line 35 of file ArrowContext.h.

---

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

• /home/runner/work/AliceO2/AliceO2/Framework/Core/include/Framework/ArrowContext.h