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