Loading [MathJax]/extensions/tex2jax.js
Thrill  0.1
All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Modules Pages
StreamData Member List

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

all_writers_closed_StreamDataprotected
Close()=0StreamDatapure virtual
closed() const =0StreamDatapure virtual
debugStreamDatastatic
dec_reference() const noexceptReferenceCounterinline
dia_id_StreamDataprotected
GetWriters()=0StreamDatapure virtual
id() constStreamDatainline
id_StreamDataprotected
inc_reference() const noexceptReferenceCounterinline
local_worker_id_StreamDataprotected
multiplexer_StreamDataprotected
my_host_rank() constStreamDatainline
my_worker_rank() constStreamDatainline
num_hosts() constStreamDatainline
num_workers() constStreamDatainline
OnAllWritersClosed()StreamData
OnWriterClosed(size_t peer_worker_rank, bool sent)StreamData
operator=(const ReferenceCounter &) noexceptReferenceCounterinline
reference_count() const noexceptReferenceCounterinline
ReferenceCounter() noexceptReferenceCounterinline
ReferenceCounter(const ReferenceCounter &) noexceptReferenceCounterinline
remaining_closing_blocks_StreamDataprotected
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_StreamDataprotected
sem_queue_StreamData
stream_set_base_StreamDataprotected
stream_type()=0StreamDatapure 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 noexceptReferenceCounterinline
workers_per_host() constStreamDatainline
Writer typedefStreamData
writers_closed_StreamDataprotected
~ReferenceCounter()ReferenceCounterinline
~StreamData()StreamDatavirtual