ScrubbingPipeline Member List

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

CallbackPtr typedef	Observable< ScrubbingResult >
Callbacks typedef	Observable< ScrubbingResult >	protected
CallbackTN typedef	Callbackable< ScrubbingResult >
item_allocator_	ScrubbingPipeline	private
kMaxFilesInFlight	ScrubbingPipeline	privatestatic
kMemHighWatermark	ScrubbingPipeline	privatestatic
kMemLowWatermark	ScrubbingPipeline	privatestatic
kNforkChunk	ScrubbingPipeline	privatestatic
kNforkHash	ScrubbingPipeline	privatestatic
kNforkRead	ScrubbingPipeline	privatestatic
kNforkScrubbingCallback	ScrubbingPipeline	privatestatic
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_	ScrubbingPipeline	private
tasks_chunk_	ScrubbingPipeline	private
tasks_hash_	ScrubbingPipeline	private
tasks_read_	ScrubbingPipeline	private
tasks_scrubbing_callback_	ScrubbingPipeline	private
tube_counter_	ScrubbingPipeline	private
tube_input_	ScrubbingPipeline	private
tubes_chunk_	ScrubbingPipeline	private
tubes_hash_	ScrubbingPipeline	private
tubes_scrubbing_callback_	ScrubbingPipeline	private
UnregisterListener(CallbackPtr callback_object)	Observable< ScrubbingResult >
UnregisterListeners()	Observable< ScrubbingResult >
WaitFor()	ScrubbingPipeline
~Observable()	Observable< ScrubbingResult >	virtual
~ScrubbingPipeline()	ScrubbingPipeline