MixStreamData Member List

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

all_writers_closed_	StreamData	protected
Close() final	MixStreamData	virtual
closed() const final	MixStreamData	virtual
debug	MixStreamData	privatestatic
dec_reference() const noexcept	ReferenceCounter	inline
dia_id_	StreamData	protected
GetMixReader(bool consume)	MixStreamData
GetReader(bool consume)	MixStreamData
GetWriters() final	MixStreamData	virtual
Handle typedef	MixStreamData
id() const	StreamData	inline
id_	StreamData	protected
inc_reference() const noexcept	ReferenceCounter	inline
is_closed_	MixStreamData	private
is_queue_closed(size_t from)	MixStreamData
local_worker_id_	StreamData	protected
MixReader typedef	MixStreamData
MixStreamData(StreamSetBase *stream_set_base, Multiplexer &multiplexer, size_t send_size_limit, const StreamId &id, size_t local_worker_id, size_t dia_id)	MixStreamData
MixStreamData(const MixStreamData &)=delete	MixStreamData
MixStreamData(MixStreamData &&)=default	MixStreamData
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)	MixStreamData	private
OnStreamBlockOrdered(size_t from, Block &&b)	MixStreamData	private
OnWriterClosed(size_t peer_worker_rank, bool sent)	StreamData
operator=(const MixStreamData &)=delete	MixStreamData
thrill::data::StreamData::operator=(const ReferenceCounter &) noexcept	ReferenceCounter	inline
queue_	MixStreamData	private
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_	MixStreamData	private
set_dia_id(size_t dia_id)	MixStreamData
stream_set_base_	StreamData	protected
stream_type() final	MixStreamData	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
~MixStreamData() final	MixStreamData
~ReferenceCounter()	ReferenceCounter	inline
~StreamData()	StreamData	virtual