IngestionPipeline Member List

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

average_chunk_size_	IngestionPipeline	private
CallbackPtr typedef	Observable< upload::SpoolerResult >
Callbacks typedef	Observable< upload::SpoolerResult >	protected
CallbackTN typedef	Callbackable< upload::SpoolerResult >
chunking_enabled_	IngestionPipeline	private
compression_algorithm_	IngestionPipeline	private
generate_legacy_bulk_chunks_	IngestionPipeline	private
hash_algorithm_	IngestionPipeline	private
IngestionPipeline(upload::AbstractUploader *uploader, const upload::SpoolerDefinition &spooler_definition)	IngestionPipeline	explicit
item_allocator_	IngestionPipeline	private
kMaxFilesInFlight	IngestionPipeline	privatestatic
kMaxPipelineMem	IngestionPipeline	privatestatic
kNforkChunk	IngestionPipeline	privatestatic
kNforkCompress	IngestionPipeline	privatestatic
kNforkHash	IngestionPipeline	privatestatic
kNforkRead	IngestionPipeline	privatestatic
kNforkRegister	IngestionPipeline	privatestatic
kNforkWrite	IngestionPipeline	privatestatic
MakeCallback(typename BoundCallback< upload::SpoolerResult, DelegateT >::CallbackMethod method, DelegateT *delegate)	Callbackable< upload::SpoolerResult >	inlinestatic
MakeCallback(typename Callback< upload::SpoolerResult >::CallbackFunction function)	Callbackable< upload::SpoolerResult >	inlinestatic
MakeClosure(typename BoundClosure< upload::SpoolerResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, const ClosureDataT &closure_data)	Callbackable< upload::SpoolerResult >	inlinestatic
maximal_chunk_size_	IngestionPipeline	private
minimal_chunk_size_	IngestionPipeline	private
NotifyListeners(const upload::SpoolerResult &parameter)	Observable< upload::SpoolerResult >	protected
Observable()	Observable< upload::SpoolerResult >	protected
OnFileProcessed(const upload::SpoolerResult &spooler_result)	IngestionPipeline
Process(IngestionSource *source, bool allow_chunking, shash::Suffix hash_suffix=shash::kSuffixNone)	IngestionPipeline
RegisterListener(typename BoundClosure< upload::SpoolerResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, ClosureDataT data)	Observable< upload::SpoolerResult >
RegisterListener(typename BoundCallback< upload::SpoolerResult, DelegateT >::CallbackMethod method, DelegateT *delegate)	Observable< upload::SpoolerResult >
RegisterListener(typename Callback< upload::SpoolerResult >::CallbackFunction fn)	Observable< upload::SpoolerResult >
RegisterListener(CallbackPtr callback_object)	Observable< upload::SpoolerResult >	protected
Spawn()	IngestionPipeline
spawned_	IngestionPipeline	private
tasks_chunk_	IngestionPipeline	private
tasks_compress_	IngestionPipeline	private
tasks_hash_	IngestionPipeline	private
tasks_read_	IngestionPipeline	private
tasks_register_	IngestionPipeline	private
tasks_write_	IngestionPipeline	private
tube_ctr_inflight_post_	IngestionPipeline	private
tube_ctr_inflight_pre_	IngestionPipeline	private
tube_input_	IngestionPipeline	private
tubes_chunk_	IngestionPipeline	private
tubes_compress_	IngestionPipeline	private
tubes_hash_	IngestionPipeline	private
tubes_register_	IngestionPipeline	private
tubes_write_	IngestionPipeline	private
UnregisterListener(CallbackPtr callback_object)	Observable< upload::SpoolerResult >
UnregisterListeners()	Observable< upload::SpoolerResult >
uploader_	IngestionPipeline	private
WaitFor()	IngestionPipeline
~IngestionPipeline()	IngestionPipeline
~Observable()	Observable< upload::SpoolerResult >	virtual