CernVM-FS
2.11.0
Main Page
Related Pages
Namespaces
Classes
Files
File List
File Members
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
19
class
TaskRegister
20
:
public
TubeConsumer
<FileItem>
21
,
public
Observable
<upload::SpoolerResult>
22
{
23
public
:
24
TaskRegister
(
Tube<FileItem>
*tube_in,
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
:
34
Tube<FileItem>
*
tube_counter_
;
35
};
// class TaskRegister
36
37
#endif // CVMFS_INGESTION_TASK_REGISTER_H_
tube.h
upload_spooler_result.h
TaskRegister
Definition:
task_register.h:19
TaskRegister::Process
virtual void Process(FileItem *file_item)
Definition:
task_register.cc:12
Observable
Definition:
concurrency.h:196
item.h
FileItem
Definition:
item.h:34
task.h
TubeConsumer
Definition:
task.h:32
TaskRegister::tube_counter_
Tube< FileItem > * tube_counter_
Definition:
task_register.h:34
TaskRegister::TaskRegister
TaskRegister(Tube< FileItem > *tube_in, Tube< FileItem > *tube_counter)
Definition:
task_register.h:24
Tube< FileItem >
concurrency.h
cvmfs
cvmfs
ingestion
task_register.h
Generated on Sun Jan 29 2023 01:23:17 for CernVM-FS by
1.8.5