![]() |
Project
|
#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< bool > | routeDPLCreated |
std::vector< bool > | routeCreated |
Static Public Attributes | |
static constexpr ServiceKind | service_kind = ServiceKind::Stream |
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.
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.
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.
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.
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.
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.
void o2::framework::StreamContext::preStartStreamCallbacks | ( | ServiceRegistryRef | ref | ) |
Definition at line 21 of file StreamContext.cxx.
std::vector<ServiceProcessingHandle> o2::framework::StreamContext::finaliseOutputsHandles |
Definition at line 53 of file StreamContext.h.
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.
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.
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.
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.
std::vector<ServiceStartStreamHandle> o2::framework::StreamContext::preStartStreamHandles |
Definition at line 65 of file StreamContext.h.
std::vector<bool> o2::framework::StreamContext::routeCreated |
Definition at line 73 of file StreamContext.h.
std::vector<bool> o2::framework::StreamContext::routeDPLCreated |
Definition at line 72 of file StreamContext.h.
|
staticconstexpr |
Definition at line 31 of file StreamContext.h.