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_