CernVM-FS  2.10.0
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
ScrubbingPipeline Member List

This is the complete list of members for ScrubbingPipeline, including all inherited members.

CallbackPtr typedefObservable< ScrubbingResult >
Callbacks typedefObservable< ScrubbingResult >protected
CallbackTN typedefCallbackable< ScrubbingResult >
item_allocator_ScrubbingPipelineprivate
kMaxFilesInFlightScrubbingPipelineprivatestatic
kMemHighWatermarkScrubbingPipelineprivatestatic
kMemLowWatermarkScrubbingPipelineprivatestatic
kNforkChunkScrubbingPipelineprivatestatic
kNforkHashScrubbingPipelineprivatestatic
kNforkReadScrubbingPipelineprivatestatic
kNforkScrubbingCallbackScrubbingPipelineprivatestatic
MakeCallback(typename BoundCallback< ScrubbingResult, DelegateT >::CallbackMethod method, DelegateT *delegate)Callbackable< ScrubbingResult >inlinestatic
MakeCallback(typename Callback< ScrubbingResult >::CallbackFunction function)Callbackable< ScrubbingResult >inlinestatic
MakeClosure(typename BoundClosure< ScrubbingResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, const ClosureDataT &closure_data)Callbackable< ScrubbingResult >inlinestatic
NotifyListeners(const ScrubbingResult &parameter)Observable< ScrubbingResult >protected
Observable()Observable< ScrubbingResult >protected
OnFileProcessed(const ScrubbingResult &scrubbing_result)ScrubbingPipeline
Process(IngestionSource *source, shash::Algorithms hash_algorithm, shash::Suffix hash_suffix)ScrubbingPipeline
RegisterListener(typename BoundClosure< ScrubbingResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, ClosureDataT data)Observable< ScrubbingResult >
RegisterListener(typename BoundCallback< ScrubbingResult, DelegateT >::CallbackMethod method, DelegateT *delegate)Observable< ScrubbingResult >
RegisterListener(typename Callback< ScrubbingResult >::CallbackFunction fn)Observable< ScrubbingResult >
RegisterListener(CallbackPtr callback_object)Observable< ScrubbingResult >protected
ScrubbingPipeline()ScrubbingPipeline
Spawn()ScrubbingPipeline
spawned_ScrubbingPipelineprivate
tasks_chunk_ScrubbingPipelineprivate
tasks_hash_ScrubbingPipelineprivate
tasks_read_ScrubbingPipelineprivate
tasks_scrubbing_callback_ScrubbingPipelineprivate
tube_counter_ScrubbingPipelineprivate
tube_input_ScrubbingPipelineprivate
tubes_chunk_ScrubbingPipelineprivate
tubes_hash_ScrubbingPipelineprivate
tubes_scrubbing_callback_ScrubbingPipelineprivate
UnregisterListener(CallbackPtr callback_object)Observable< ScrubbingResult >
UnregisterListeners()Observable< ScrubbingResult >
WaitFor()ScrubbingPipeline
~Observable()Observable< ScrubbingResult >virtual
~ScrubbingPipeline()ScrubbingPipeline