CompressHashPipeline Member List

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

CallbackPtr typedef	Observable< CompressHashResult >
Callbacks typedef	Observable< CompressHashResult >	protected
CallbackTN typedef	Callbackable< CompressHashResult >
CompressHashPipeline()	CompressHashPipeline
item_allocator_	CompressHashPipeline	private
kMemHighWatermark	CompressHashPipeline	privatestatic
kMemLowWatermark	CompressHashPipeline	privatestatic
MakeCallback(typename BoundCallback< CompressHashResult, DelegateT >::CallbackMethod method, DelegateT *delegate)	Callbackable< CompressHashResult >	inlinestatic
MakeCallback(typename Callback< CompressHashResult >::CallbackFunction function)	Callbackable< CompressHashResult >	inlinestatic
MakeClosure(typename BoundClosure< CompressHashResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, const ClosureDataT &closure_data)	Callbackable< CompressHashResult >	inlinestatic
NotifyListeners(const CompressHashResult &parameter)	Observable< CompressHashResult >	protected
Observable()	Observable< CompressHashResult >	protected
OnFileProcessed(const CompressHashResult &compress_hash_result)	CompressHashPipeline
Process(IngestionSource *source, shash::Algorithms hash_algorithm, shash::Suffix hash_suffix)	CompressHashPipeline
RegisterListener(typename BoundClosure< CompressHashResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, ClosureDataT data)	Observable< CompressHashResult >
RegisterListener(typename BoundCallback< CompressHashResult, DelegateT >::CallbackMethod method, DelegateT *delegate)	Observable< CompressHashResult >
RegisterListener(typename Callback< CompressHashResult >::CallbackFunction fn)	Observable< CompressHashResult >
RegisterListener(CallbackPtr callback_object)	Observable< CompressHashResult >	protected
Spawn()	CompressHashPipeline
spawned_	CompressHashPipeline	private
tasks_chunk_	CompressHashPipeline	private
tasks_compress_	CompressHashPipeline	private
tasks_compress_hash_callback_	CompressHashPipeline	private
tasks_hash_	CompressHashPipeline	private
tasks_read_	CompressHashPipeline	private
tube_counter_	CompressHashPipeline	private
tube_input_	CompressHashPipeline	private
tubes_chunk_	CompressHashPipeline	private
tubes_compress_	CompressHashPipeline	private
tubes_compress_hash_callback_	CompressHashPipeline	private
tubes_hash_	CompressHashPipeline	private
UnregisterListener(CallbackPtr callback_object)	Observable< CompressHashResult >
UnregisterListeners()	Observable< CompressHashResult >
WaitFor()	CompressHashPipeline
~CompressHashPipeline()	CompressHashPipeline
~Observable()	Observable< CompressHashResult >	virtual