BlockQueue Member List

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

allocate_can_fail_	BlockQueue	static
AllocateByteBlock(size_t block_size)	BlockSink	inlinevirtual
AppendBlock(const Block &b, bool) final	BlockQueue	inlinevirtual
AppendBlock(Block &&b, bool) final	BlockQueue	inlinevirtual
AppendPinnedBlock(PinnedBlock &&b, bool is_last_block)	BlockSink	inlinevirtual
block_counter() const	BlockQueue	inline
block_counter_	BlockQueue	private
block_pool() const	BlockSink	inline
BlockQueue(BlockPool &block_pool, size_t local_worker_id, size_t dia_id, const CloseCallback &close_callback=CloseCallback())	BlockQueue
BlockQueue(const BlockQueue &)=delete	BlockQueue
BlockQueue(BlockQueue &&)=default	BlockQueue
BlockSink(BlockPool &block_pool, size_t local_worker_id)	BlockSink	inlineexplicit
BlockSink(BlockPool *block_pool, size_t local_worker_id)	BlockSink	inlineexplicit
BlockSink(const BlockSink &)=default	BlockSink
BlockSink(BlockSink &&)=default	BlockSink
byte_counter() const	BlockQueue	inline
byte_counter_	BlockQueue	private
Close() final	BlockQueue	virtual
close_callback_	BlockQueue	private
CloseCallback typedef	BlockQueue
ConsumeReader typedef	BlockQueue
debug	BlockQueue	static
empty() const	BlockQueue	inline
file_	BlockQueue	private
GetBlockSource(bool consume, size_t local_worker_id)	BlockQueue
GetConsumeReader(size_t local_worker_id)	BlockQueue
GetReader(bool consume, size_t local_worker_id)	BlockQueue
GetWriter(size_t block_size=default_block_size)	BlockQueue
item_counter() const	BlockQueue	inline
item_counter_	BlockQueue	private
local_worker_id() const	BlockSink	inline
local_worker_id_	BlockSink	protected
logger()	BlockSink	inline
operator=(const BlockQueue &)=delete	BlockQueue
operator=(BlockQueue &&)=default	BlockQueue
thrill::data::BlockSink::operator=(const BlockSink &)=default	BlockSink
thrill::data::BlockSink::operator=(BlockSink &&)=default	BlockSink
Pop()	BlockQueue	inline
queue_	BlockQueue	private
read_closed() const	BlockQueue	inline
read_closed_	BlockQueue	private
Reader typedef	BlockQueue
ReleaseByteBlock(ByteBlockPtr &block)	BlockSink	inlinevirtual
set_close_callback(const CloseCallback &cb)	BlockQueue	inline
set_dia_id(size_t dia_id)	BlockQueue	inline
size()	BlockQueue	inline
timespan() const	BlockQueue	inline
timespan_	BlockQueue	private
workers_per_host() const	BlockSink	inline
write_closed() const	BlockQueue	inline
write_closed_	BlockQueue	private
Writer typedef	BlockQueue
~BlockSink()	BlockSink	inlinevirtual