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 CallbackTN *	MakeClosure (typename BoundClosure< upload::SpoolerResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, const ClosureDataT &closure_data)
static CallbackTN *	MakeCallback (typename BoundCallback< upload::SpoolerResult, DelegateT >::CallbackMethod method, DelegateT *delegate)
static CallbackTN *	MakeCallback (typename Callback< upload::SpoolerResult >::CallbackFunction function)
Protected Types inherited from Observable< upload::SpoolerResult >
typedef std::set< CallbackPtr >	Callbacks
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:

• /home/sftnight/jenkins/workspace/CvmfsDoxygen/label/docker-x86_64/cvmfs/cvmfs/ingestion/task_register.h
• /home/sftnight/jenkins/workspace/CvmfsDoxygen/label/docker-x86_64/cvmfs/cvmfs/ingestion/task_register.cc