CatStreamData Member List

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

all_writers_closed_	StreamData	protected
BlockQueueReader typedef	CatStreamData
BlockQueueSource typedef	CatStreamData
CatBlockReader typedef	CatStreamData
CatBlockSource typedef	CatStreamData
CatReader typedef	CatStreamData
CatStreamData(StreamSetBase *stream_set_base, Multiplexer &multiplexer, size_t send_size_limit, const StreamId &id, size_t local_worker_id, size_t dia_id)	CatStreamData
CatStreamData(const CatStreamData &)=delete	CatStreamData
CatStreamData(CatStreamData &&)=default	CatStreamData
Close() final	CatStreamData	virtual
closed() const final	CatStreamData	virtual
debug	CatStreamData	static
debug_data	CatStreamData	static
dec_reference() const noexcept	ReferenceCounter	inline
dia_id_	StreamData	protected
GetCatBlockSource(bool consume)	CatStreamData
GetCatReader(bool consume)	CatStreamData
GetReader(bool consume)	CatStreamData
GetReaders()	CatStreamData
GetWriters() final	CatStreamData	virtual
Handle typedef	CatStreamData
id() const	StreamData	inline
id_	StreamData	protected
inc_reference() const noexcept	ReferenceCounter	inline
is_closed_	CatStreamData	private
is_queue_closed(size_t from)	CatStreamData
local_worker_id_	StreamData	protected
loopback_queue(size_t from_worker_id)	CatStreamData	private
multiplexer_	StreamData	protected
my_host_rank() const	StreamData	inline
my_worker_rank() const	StreamData	inline
num_hosts() const	StreamData	inline
num_workers() const	StreamData	inline
OnAllWritersClosed()	StreamData
OnStreamBlock(size_t from, uint32_t seq, Block &&b)	CatStreamData	private
OnStreamBlockOrdered(size_t from, Block &&b)	CatStreamData	private
OnWriterClosed(size_t peer_worker_rank, bool sent)	StreamData
operator=(const CatStreamData &)=delete	CatStreamData
thrill::data::StreamData::operator=(const ReferenceCounter &) noexcept	ReferenceCounter	inline
queues_	CatStreamData	private
Reader typedef	CatStreamData
reference_count() const noexcept	ReferenceCounter	inline
ReferenceCounter() noexcept	ReferenceCounter	inline
ReferenceCounter(const ReferenceCounter &) noexcept	ReferenceCounter	inline
remaining_closing_blocks_	StreamData	protected
rx_int_blocks_	StreamData
rx_int_bytes_	StreamData
rx_int_items_	StreamData
rx_lifetime_	StreamData
rx_net_blocks_	StreamData
rx_net_bytes_	StreamData
rx_net_items_	StreamData
rx_timespan_	StreamData
sem_closing_blocks_	StreamData	protected
sem_queue_	StreamData
seq_	CatStreamData	private
set_dia_id(size_t dia_id)	CatStreamData
stream_set_base_	StreamData	protected
stream_type() final	CatStreamData	virtual
StreamData(StreamSetBase *stream_set_base, Multiplexer &multiplexer, size_t send_size_limit, const StreamId &id, size_t local_worker_id, size_t dia_id)	StreamData
tx_int_blocks_	StreamData
tx_int_bytes_	StreamData
tx_int_items_	StreamData
tx_lifetime_	StreamData
tx_net_blocks_	StreamData
tx_net_bytes_	StreamData
tx_net_items_	StreamData
tx_timespan_	StreamData
unique() const noexcept	ReferenceCounter	inline
workers_per_host() const	StreamData	inline
Writer typedef	StreamData
writers_closed_	StreamData	protected
~CatStreamData() final	CatStreamData
~ReferenceCounter()	ReferenceCounter	inline
~StreamData()	StreamData	virtual