![]() |
Project
|
#include <CompressorTask.h>
Inherits o2::framework::Task.
Public Member Functions | |
CompressorTask (long payloadLim=-1) | |
~CompressorTask () override=default | |
void | init (InitContext &ic) final |
void | run (ProcessingContext &pc) final |
![]() | |
virtual | ~Task () |
virtual void | endOfStream (EndOfStreamContext &context) |
This is invoked whenever we have an EndOfStream event. | |
virtual void | finaliseCCDB (ConcreteDataMatcher &matcher, void *obj) |
virtual void | stop () |
This is invoked on stop. | |
Definition at line 33 of file CompressorTask.h.
|
inline |
Definition at line 36 of file CompressorTask.h.
|
overridedefault |
|
finalvirtual |
The method which is called once to initialise the task. Derived classes can use this to save extra state.
Reimplemented from o2::framework::Task.
Definition at line 31 of file CompressorTask.cxx.
|
finalvirtual |
This is invoked whenever a new InputRecord is demeed to be complete.
to store data sorted by subspec id
loop over inputs routes
loop over input parts
store parts in map
increase subspec buffer size
loop over subspecs
use the first part to define output headers
initialise output message
loop over subspec parts
input
prepare compressor
run
Implements o2::framework::Task.
Definition at line 58 of file CompressorTask.cxx.