CernVM-FS  2.12.0
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
TaskRegister Class Reference

#include <task_register.h>

Inheritance diagram for TaskRegister:
Collaboration diagram for TaskRegister:

Public Member Functions

 TaskRegister (Tube< FileItem > *tube_in, Tube< FileItem > *tube_ctr_inflight_pre, Tube< FileItem > *tube_ctr_inflight_post)
 
- Public Member Functions inherited from TubeConsumer< FileItem >
virtual ~TubeConsumer ()
 
- Public Member Functions inherited from Observable< upload::SpoolerResult >
virtual ~Observable ()
 
CallbackPtr RegisterListener (typename BoundClosure< upload::SpoolerResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, ClosureDataT data)
 
CallbackPtr RegisterListener (typename BoundCallback< upload::SpoolerResult, DelegateT >::CallbackMethod method, DelegateT *delegate)
 
CallbackPtr RegisterListener (typename Callback< upload::SpoolerResult >::CallbackFunction fn)
 
void UnregisterListener (CallbackPtr callback_object)
 
void UnregisterListeners ()
 

Protected Member Functions

virtual void Process (FileItem *file_item)
 
- Protected Member Functions inherited from TubeConsumer< FileItem >
 TubeConsumer (Tube< FileItem > *tube)
 
virtual void OnTerminate ()
 
- Protected Member Functions inherited from Observable< upload::SpoolerResult >
void RegisterListener (CallbackPtr callback_object)
 
 Observable ()
 
void NotifyListeners (const upload::SpoolerResult &parameter)
 

Private Attributes

Tube< FileItem > * tube_ctr_inflight_pre_
 
Tube< FileItem > * tube_ctr_inflight_post_
 

Additional Inherited Members

- Public Types inherited from Observable< upload::SpoolerResult >
typedef Callbackable
< upload::SpoolerResult >
::CallbackTN
CallbackPtr
 
- Public Types inherited from Callbackable< upload::SpoolerResult >
typedef CallbackBase
< upload::SpoolerResult
CallbackTN
 
- Static Public Member Functions inherited from Callbackable< upload::SpoolerResult >
static CallbackTNMakeClosure (typename BoundClosure< upload::SpoolerResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, const ClosureDataT &closure_data)
 
static CallbackTNMakeCallback (typename BoundCallback< upload::SpoolerResult, DelegateT >::CallbackMethod method, DelegateT *delegate)
 
static CallbackTNMakeCallback (typename Callback< upload::SpoolerResult >::CallbackFunction function)
 
- Protected Types inherited from Observable< upload::SpoolerResult >
typedef std::set< CallbackPtrCallbacks
 
- Protected Attributes inherited from TubeConsumer< FileItem >
Tube< FileItem > * tube_
 

Detailed Description

This file is part of the CernVM File System. Runs the callback to register processed files in the file catalog. Encapsulated in a task so that only a single thread operates on the file catalog, which is serialized anyway.

Definition at line 19 of file task_register.h.

Constructor & Destructor Documentation

TaskRegister::TaskRegister ( Tube< FileItem > *  tube_in,
Tube< FileItem > *  tube_ctr_inflight_pre,
Tube< FileItem > *  tube_ctr_inflight_post 
)
inline

Definition at line 24 of file task_register.h.

Member Function Documentation

void TaskRegister::Process ( FileItem file_item)
protectedvirtual

This file is part of the CernVM File System.

Implements TubeConsumer< FileItem >.

Definition at line 12 of file task_register.cc.

Here is the call graph for this function:

Member Data Documentation

Tube<FileItem>* TaskRegister::tube_ctr_inflight_post_
private

Definition at line 37 of file task_register.h.

Referenced by Process().

Tube<FileItem>* TaskRegister::tube_ctr_inflight_pre_
private

Definition at line 36 of file task_register.h.

Referenced by Process().


The documentation for this class was generated from the following files: