Project
Loading...
Searching...
No Matches
o2::framework::StreamContext Struct Reference

#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< ServiceProcessingHandlepreProcessingHandles
 Callbacks for services to be executed before every process method invokation.
 
std::vector< ServiceProcessingHandlefinaliseOutputsHandles
 
std::vector< ServiceProcessingHandlepostProcessingHandles
 Callbacks for services to be executed after every process method invokation.
 
std::vector< ServiceEOSHandlepreEOSHandles
 Callbacks for services to be executed before every EOS user callback invokation.
 
std::vector< ServiceEOSHandlepostEOSHandles
 Callbacks for services to be executed after every EOS user callback invokation.
 
std::vector< ServiceStartStreamHandlepreStartStreamHandles
 
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 30 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

◆ finaliseOutputsHandles

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

Definition at line 53 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 60 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 55 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 58 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 52 of file StreamContext.h.

◆ preStartStreamHandles

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

Definition at line 65 of file StreamContext.h.

◆ routeCreated

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

Definition at line 73 of file StreamContext.h.

◆ routeDPLCreated

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

Definition at line 72 of file StreamContext.h.

◆ service_kind

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

Definition at line 31 of file StreamContext.h.


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