#include <StreamContext.h>

Public Member Functions
void	preStartStreamCallbacks (ServiceRegistryRef)

void	preProcessingCallbacks (ProcessingContext &pcx)
	Invoke callbacks to be executed before every process method invokation.

void	finaliseOutputsCallbacks (ProcessingContext &)
	Invoke callbacks to be executed after every process method invokation.

void	postProcessingCallbacks (ProcessingContext &pcx)
	Invoke callbacks to be executed after every process method invokation.

void	preEOSCallbacks (EndOfStreamContext &eosContext)
	Invoke callbacks to be executed before every EOS user callback invokation.

void	postEOSCallbacks (EndOfStreamContext &eosContext)
	Invoke callbacks to be executed after every EOS user callback invokation.

Public Attributes
std::vector< ServiceProcessingHandle >	preProcessingHandles
	Callbacks for services to be executed before every process method invokation.

std::vector< ServiceProcessingHandle >	finaliseOutputsHandles

std::vector< ServiceProcessingHandle >	postProcessingHandles
	Callbacks for services to be executed after every process method invokation.

std::vector< ServiceEOSHandle >	preEOSHandles
	Callbacks for services to be executed before every EOS user callback invokation.

std::vector< ServiceEOSHandle >	postEOSHandles
	Callbacks for services to be executed after every EOS user callback invokation.

std::vector< ServiceStartStreamHandle >	preStartStreamHandles

std::vector< DataRelayer::RecordAction >	completed

std::vector< bool >	routeDPLCreated

std::vector< bool >	routeCreated

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

Detailed Description

This context exists only for a given stream, it can therefore be used for e.g. callbacks which need to happen on a per stream basis or for caching information which is specific to a given stream (like wether or not we processed something in the current iteration).

Definition at line 31 of file StreamContext.h.

Member Function Documentation

◆ finaliseOutputsCallbacks()

void o2::framework::StreamContext::finaliseOutputsCallbacks ( ProcessingContext & pcx )

Invoke callbacks to be executed after every process method invokation.

Invoke callbacks to be executed after the outputs have been created by the processing, but before the post processing callbacks.

Definition at line 48 of file StreamContext.cxx.

◆ postEOSCallbacks()

void o2::framework::StreamContext::postEOSCallbacks ( EndOfStreamContext & eosContext )

Invoke callbacks to be executed after every EOS user callback invokation.

Definition at line 86 of file StreamContext.cxx.

◆ postProcessingCallbacks()

void o2::framework::StreamContext::postProcessingCallbacks ( ProcessingContext & pcx )

Invoke callbacks to be executed after every process method invokation.

Definition at line 59 of file StreamContext.cxx.

◆ preEOSCallbacks()

void o2::framework::StreamContext::preEOSCallbacks ( EndOfStreamContext & eosContext )

Invoke callbacks to be executed before every EOS user callback invokation.

Definition at line 75 of file StreamContext.cxx.

◆ preProcessingCallbacks()

void o2::framework::StreamContext::preProcessingCallbacks ( ProcessingContext & pcx )

Invoke callbacks to be executed before every process method invokation.

Definition at line 32 of file StreamContext.cxx.

◆ preStartStreamCallbacks()

void o2::framework::StreamContext::preStartStreamCallbacks ( ServiceRegistryRef ref )

Definition at line 21 of file StreamContext.cxx.

Member Data Documentation

◆ completed

std::vector<DataRelayer::RecordAction> o2::framework::StreamContext::completed

Per-stream list of actions ready to be dispatched. Populated by getReadyToProcess() and consumed by tryDispatchComputation().

Definition at line 70 of file StreamContext.h.

◆ finaliseOutputsHandles

std::vector<ServiceProcessingHandle> o2::framework::StreamContext::finaliseOutputsHandles

Definition at line 54 of file StreamContext.h.

◆ postEOSHandles

std::vector<ServiceEOSHandle> o2::framework::StreamContext::postEOSHandles

Callbacks for services to be executed after every EOS user callback invokation.

Definition at line 61 of file StreamContext.h.

◆ postProcessingHandles

std::vector<ServiceProcessingHandle> o2::framework::StreamContext::postProcessingHandles

Callbacks for services to be executed after every process method invokation.

Definition at line 56 of file StreamContext.h.

◆ preEOSHandles

std::vector<ServiceEOSHandle> o2::framework::StreamContext::preEOSHandles

Callbacks for services to be executed before every EOS user callback invokation.

Definition at line 59 of file StreamContext.h.

◆ preProcessingHandles

std::vector<ServiceProcessingHandle> o2::framework::StreamContext::preProcessingHandles

Callbacks for services to be executed before every process method invokation.

Definition at line 53 of file StreamContext.h.

◆ preStartStreamHandles

std::vector<ServiceStartStreamHandle> o2::framework::StreamContext::preStartStreamHandles

Definition at line 66 of file StreamContext.h.

◆ routeCreated

std::vector<bool> o2::framework::StreamContext::routeCreated

Definition at line 78 of file StreamContext.h.

◆ routeDPLCreated

std::vector<bool> o2::framework::StreamContext::routeDPLCreated

Definition at line 77 of file StreamContext.h.

◆ service_kind

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

staticconstexpr

Definition at line 32 of file StreamContext.h.

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

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

Public Member Functions

Public Attributes

Static Public Attributes