CernVM-FS  2.13.0
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Member Functions | Private Attributes | List of all members
CatalogDownloadPipeline Class Reference

#include <catalog_downloader.h>

Inheritance diagram for CatalogDownloadPipeline:
[legend]
Collaboration diagram for CatalogDownloadPipeline:
[legend]

Public Member Functions

 CatalogDownloadPipeline (catalog::SimpleCatalogManager *catalog_mgr)
 
 ~CatalogDownloadPipeline ()
 
void Spawn ()
 
void Process (const shash::Any &catalog_hash)
 
void WaitFor ()
 
void OnFileProcessed (const CatalogDownloadResult &catalog_download_result)
 
- Public Member Functions inherited from Observable< CatalogDownloadResult >
virtual ~Observable ()
 
CallbackPtr RegisterListener (typename BoundClosure< CatalogDownloadResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, ClosureDataT data)
 
CallbackPtr RegisterListener (typename BoundCallback< CatalogDownloadResult, DelegateT >::CallbackMethod method, DelegateT *delegate)
 
CallbackPtr RegisterListener (typename Callback< CatalogDownloadResult >::CallbackFunction fn)
 
void UnregisterListener (CallbackPtr callback_object)
 
void UnregisterListeners ()
 

Private Attributes

bool spawned_
 
Tube< CatalogItem > tube_input_
 
Tube< CatalogItem > tube_counter_
 
TubeConsumerGroup< CatalogItem > tasks_download_
 
catalog::SimpleCatalogManager * catalog_mgr_
 

Additional Inherited Members

- Public Types inherited from Observable< CatalogDownloadResult >
typedef Callbackable
< CatalogDownloadResult >
::CallbackTN * 		CallbackPtr
 
- Public Types inherited from Callbackable< CatalogDownloadResult >
typedef CallbackBase
< CatalogDownloadResult > 		CallbackTN
 
- Static Public Member Functions inherited from Callbackable< CatalogDownloadResult >
static CallbackTN * MakeClosure (typename BoundClosure< CatalogDownloadResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, const ClosureDataT &closure_data)
 
static CallbackTN * MakeCallback (typename BoundCallback< CatalogDownloadResult, DelegateT >::CallbackMethod method, DelegateT *delegate)
 
static CallbackTN * MakeCallback (typename Callback< CatalogDownloadResult >::CallbackFunction function)
 
- Protected Types inherited from Observable< CatalogDownloadResult >
typedef std::set< CallbackPtr > Callbacks
 
- Protected Member Functions inherited from Observable< CatalogDownloadResult >
void RegisterListener (CallbackPtr callback_object)
 
 Observable ()
 
void NotifyListeners (const CatalogDownloadResult &parameter)
 

Detailed Description

Definition at line 52 of file catalog_downloader.h.

Constructor & Destructor Documentation

CatalogDownloadPipeline::CatalogDownloadPipeline ( catalog::SimpleCatalogManager *  catalog_mgr)
explicit

Definition at line 18 of file catalog_downloader.cc.

Here is the call graph for this function:

CatalogDownloadPipeline::~CatalogDownloadPipeline ( )

Definition at line 34 of file catalog_downloader.cc.

Here is the call graph for this function:

Member Function Documentation

void CatalogDownloadPipeline::OnFileProcessed ( const CatalogDownloadResult &  catalog_download_result)

Definition at line 40 of file catalog_downloader.cc.

Referenced by CatalogDownloadPipeline().

Here is the call graph for this function:

Here is the caller graph for this function:

void CatalogDownloadPipeline::Process ( const shash::Any &  catalog_hash)

Definition at line 46 of file catalog_downloader.cc.

Referenced by catalog::WritableCatalogManager::CatalogDownloadCallback(), and catalog::WritableCatalogManager::LoadCatalogs().

Here is the call graph for this function:

Here is the caller graph for this function:

void CatalogDownloadPipeline::Spawn ( )

Definition at line 54 of file catalog_downloader.cc.

Referenced by catalog::WritableCatalogManager::LoadCatalogs().

Here is the call graph for this function:

Here is the caller graph for this function:

void CatalogDownloadPipeline::WaitFor ( )

Definition at line 59 of file catalog_downloader.cc.

Referenced by catalog::WritableCatalogManager::LoadCatalogs().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

catalog::SimpleCatalogManager* CatalogDownloadPipeline::catalog_mgr_
private

Definition at line 70 of file catalog_downloader.h.

Referenced by CatalogDownloadPipeline().

bool CatalogDownloadPipeline::spawned_
private

Definition at line 64 of file catalog_downloader.h.

Referenced by Spawn(), and ~CatalogDownloadPipeline().

TubeConsumerGroup<CatalogItem> CatalogDownloadPipeline::tasks_download_
private

Definition at line 68 of file catalog_downloader.h.

Referenced by CatalogDownloadPipeline(), Spawn(), and ~CatalogDownloadPipeline().

Tube<CatalogItem> CatalogDownloadPipeline::tube_counter_
private

Definition at line 66 of file catalog_downloader.h.

Referenced by CatalogDownloadPipeline(), Process(), and WaitFor().

Tube<CatalogItem> CatalogDownloadPipeline::tube_input_
private

Definition at line 65 of file catalog_downloader.h.

Referenced by CatalogDownloadPipeline(), and Process().

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