task_register.h

Go to the documentation of this file.

#ifndef CVMFS_INGESTION_TASK_REGISTER_H_
#define CVMFS_INGESTION_TASK_REGISTER_H_

#include "ingestion/item.h"
#include "ingestion/task.h"
#include "ingestion/tube.h"
#include "upload_spooler_result.h"
#include "util_concurrency.h"

class TaskRegister
  : public TubeConsumer<FileItem>
  , public Observable<upload::SpoolerResult>
{
 public:
  TaskRegister(Tube<FileItem> *tube_in,
               Tube<FileItem> *tube_counter)
    : TubeConsumer<FileItem>(tube_in)
    , tube_counter_(tube_counter)
  { }

 protected:
  virtual void Process(FileItem *file_item);

 private:
  Tube<FileItem> *tube_counter_;
};  // class TaskRegister

#endif  // CVMFS_INGESTION_TASK_REGISTER_H_