Thrill  0.1
BlockQueue Member List

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

allocate_can_fail_BlockQueuestatic
AllocateByteBlock(size_t block_size)BlockSinkinlinevirtual
AppendBlock(const Block &b, bool) finalBlockQueueinlinevirtual
AppendBlock(Block &&b, bool) finalBlockQueueinlinevirtual
AppendPinnedBlock(PinnedBlock &&b, bool is_last_block)BlockSinkinlinevirtual
block_counter() constBlockQueueinline
block_counter_BlockQueueprivate
block_pool() constBlockSinkinline
BlockQueue(BlockPool &block_pool, size_t local_worker_id, size_t dia_id, const CloseCallback &close_callback=CloseCallback())BlockQueue
BlockQueue(const BlockQueue &)=deleteBlockQueue
BlockQueue(BlockQueue &&)=defaultBlockQueue
BlockSink(BlockPool &block_pool, size_t local_worker_id)BlockSinkinlineexplicit
BlockSink(BlockPool *block_pool, size_t local_worker_id)BlockSinkinlineexplicit
BlockSink(const BlockSink &)=defaultBlockSink
BlockSink(BlockSink &&)=defaultBlockSink
byte_counter() constBlockQueueinline
byte_counter_BlockQueueprivate
Close() finalBlockQueuevirtual
close_callback_BlockQueueprivate
CloseCallback typedefBlockQueue
ConsumeReader typedefBlockQueue
debugBlockQueuestatic
empty() constBlockQueueinline
file_BlockQueueprivate
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() constBlockQueueinline
item_counter_BlockQueueprivate
local_worker_id() constBlockSinkinline
local_worker_id_BlockSinkprotected
logger()BlockSinkinline
operator=(const BlockQueue &)=deleteBlockQueue
operator=(BlockQueue &&)=defaultBlockQueue
thrill::data::BlockSink::operator=(const BlockSink &)=defaultBlockSink
thrill::data::BlockSink::operator=(BlockSink &&)=defaultBlockSink
Pop()BlockQueueinline
queue_BlockQueueprivate
read_closed() constBlockQueueinline
read_closed_BlockQueueprivate
Reader typedefBlockQueue
ReleaseByteBlock(ByteBlockPtr &block)BlockSinkinlinevirtual
set_close_callback(const CloseCallback &cb)BlockQueueinline
set_dia_id(size_t dia_id)BlockQueueinline
size()BlockQueueinline
timespan() constBlockQueueinline
timespan_BlockQueueprivate
workers_per_host() constBlockSinkinline
write_closed() constBlockQueueinline
write_closed_BlockQueueprivate
Writer typedefBlockQueue
~BlockSink()BlockSinkinlinevirtual