CernVM-FS  2.9.0
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
task_register.h
Go to the documentation of this file.
1 
5 #ifndef CVMFS_INGESTION_TASK_REGISTER_H_
6 #define CVMFS_INGESTION_TASK_REGISTER_H_
7 
8 #include "ingestion/item.h"
9 #include "ingestion/task.h"
10 #include "ingestion/tube.h"
11 #include "upload_spooler_result.h"
12 #include "util_concurrency.h"
13 
20  : public TubeConsumer<FileItem>
21  , public Observable<upload::SpoolerResult>
22 {
23  public:
25  Tube<FileItem> *tube_counter)
26  : TubeConsumer<FileItem>(tube_in)
27  , tube_counter_(tube_counter)
28  { }
29 
30  protected:
31  virtual void Process(FileItem *file_item);
32 
33  private:
35 }; // class TaskRegister
36 
37 #endif // CVMFS_INGESTION_TASK_REGISTER_H_
virtual void Process(FileItem *file_item)
Definition: item.h:34
Tube< FileItem > * tube_counter_
Definition: task_register.h:34
TaskRegister(Tube< FileItem > *tube_in, Tube< FileItem > *tube_counter)
Definition: task_register.h:24