CernVM-FS
2.12.0
|
#include <task.h>
Public Member Functions | |
virtual | ~TubeConsumer () |
Protected Member Functions | |
TubeConsumer (Tube< ItemT > *tube) | |
virtual void | Process (ItemT *item)=0 |
virtual void | OnTerminate () |
Protected Attributes | |
Tube< ItemT > * | tube_ |
Static Private Member Functions | |
static void * | MainConsumer (void *data) |
Friends | |
class | TubeConsumerGroup< ItemT > |
Additional Inherited Members | |
Private Member Functions inherited from SingleCopy | |
SingleCopy () | |
Base class for threads that processes items from a tube one by one. Concrete implementations overwrite the Process() method.
|
inlinevirtual |
|
inlineexplicitprotected |
|
inlinestaticprivate |
|
inlineprotectedvirtual |
Definition at line 41 of file task.h.
Referenced by TubeConsumer< FileItem >::MainConsumer().
|
protectedpure virtual |
Implemented in TaskScrubbingCallback, TaskRead, TaskChunk, TaskCompress, TaskRegister, TaskWrite, and TaskHash.
Referenced by TubeConsumer< FileItem >::MainConsumer().
|
friend |
|
protected |
Definition at line 43 of file task.h.
Referenced by TubeConsumer< FileItem >::MainConsumer().