Thrill
0.1
|
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 |