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 "upload_spooler_result.h"
#include "util/concurrency.h"
#include "util/tube.h"

class TaskRegister
  : public TubeConsumer<FileItem>
  , public Observable<upload::SpoolerResult>
{
 public:
  TaskRegister(Tube<FileItem> *tube_in,
               Tube<FileItem> *tube_ctr_inflight_pre,
               Tube<FileItem> *tube_ctr_inflight_post)
    : TubeConsumer<FileItem>(tube_in)
    , tube_ctr_inflight_pre_(tube_ctr_inflight_pre)
    , tube_ctr_inflight_post_(tube_ctr_inflight_post)
  { }

 protected:
  virtual void Process(FileItem *file_item);

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

#endif  // CVMFS_INGESTION_TASK_REGISTER_H_