![]() |
Project
|
FullHistoryMerger data processor class. More...
#include <FullHistoryMerger.h>
Inherits o2::framework::Task.
Public Member Functions | |
FullHistoryMerger (const MergerConfig &, const header::DataHeader::SubSpecificationType &) | |
Default constructor. It expects Merger configuration and subSpec of output channel. | |
~FullHistoryMerger () override | |
Default destructor. | |
void | init (framework::InitContext &ctx) override |
FullHistoryMerger init callback. | |
void | run (framework::ProcessingContext &ctx) override |
FullHistoryMerger process callback. | |
void | endOfStream (framework::EndOfStreamContext &eosContext) override |
Callback for CallbackService::Id::EndOfStream. | |
![]() | |
virtual | ~Task () |
virtual void | finaliseCCDB (ConcreteDataMatcher &matcher, void *obj) |
virtual void | stop () |
This is invoked on stop. | |
FullHistoryMerger data processor class.
Mergers are DPL devices able to merge objects produced in parallel.
Definition at line 36 of file FullHistoryMerger.h.
o2::mergers::FullHistoryMerger::FullHistoryMerger | ( | const MergerConfig & | config, |
const header::DataHeader::SubSpecificationType & | subSpec | ||
) |
Default constructor. It expects Merger configuration and subSpec of output channel.
Definition at line 36 of file FullHistoryMerger.cxx.
|
override |
Default destructor.
Definition at line 42 of file FullHistoryMerger.cxx.
|
overridevirtual |
Callback for CallbackService::Id::EndOfStream.
Reimplemented from o2::framework::Task.
Definition at line 106 of file FullHistoryMerger.cxx.
|
overridevirtual |
FullHistoryMerger init callback.
Reimplemented from o2::framework::Task.
Definition at line 49 of file FullHistoryMerger.cxx.
|
overridevirtual |
FullHistoryMerger process callback.
Implements o2::framework::Task.
Definition at line 67 of file FullHistoryMerger.cxx.