StreamSink Member List

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

allocate_can_fail_	StreamSink	static
AllocateByteBlock(size_t block_size)	BlockSink	inlinevirtual
AppendBlock(const Block &block, bool is_last_block) final	StreamSink	virtual
AppendBlock(Block &&block, bool is_last_block) final	StreamSink	virtual
AppendPinnedBlock(PinnedBlock &&block, bool is_last_block) final	StreamSink	virtual
block_counter_	StreamSink	private
block_pool() const	BlockSink	inline
block_queue_	StreamSink	private
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_	StreamSink	private
Close() final	StreamSink	virtual
closed() const	StreamSink	inline
closed_	StreamSink	private
connection_	StreamSink	private
debug	StreamSink	privatestatic
Finalize()	StreamSink
host_rank_	StreamSink	private
id_	StreamSink	private
IsValid() const	StreamSink	inline
item_counter_	StreamSink	private
local_worker_id() const	BlockSink	inline
local_worker_id_	BlockSink	protected
logger()	BlockSink	inline
magic_	StreamSink	private
my_worker_rank() const	StreamSink
operator=(StreamSink &&)=default	StreamSink
thrill::data::BlockSink::operator=(const BlockSink &)=default	BlockSink
thrill::data::BlockSink::operator=(BlockSink &&)=default	BlockSink
peer_local_worker_	StreamSink	private
peer_rank_	StreamSink	private
peer_worker_rank() const	StreamSink
ReleaseByteBlock(ByteBlockPtr &block)	BlockSink	inlinevirtual
stream_	StreamSink	private
StreamId typedef	StreamSink
StreamSink()	StreamSink
StreamSink(StreamDataPtr stream, BlockPool &block_pool, net::Connection *connection, MagicByte magic, StreamId stream_id, size_t host_rank, size_t host_local_worker, size_t peer_rank, size_t peer_local_worker)	StreamSink
StreamSink(StreamDataPtr stream, BlockPool &block_pool, BlockQueue *block_queue, StreamId stream_id, size_t host_rank, size_t host_local_worker, size_t peer_rank, size_t peer_local_worker)	StreamSink
StreamSink(StreamDataPtr stream, BlockPool &block_pool, MixStreamDataPtr target, StreamId stream_id, size_t host_rank, size_t host_local_worker, size_t peer_rank, size_t peer_local_worker)	StreamSink
StreamSink(StreamSink &&)=default	StreamSink
target_mix_stream_	StreamSink	private
timespan_	StreamSink	private
workers_per_host() const	BlockSink	inline
~BlockSink()	BlockSink	inlinevirtual