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 |
1.8.13