StreamSetBase Class Referenceabstract
Detailed Description
Base class for StreamSet.
Definition at line 201 of file stream_data.hpp.
Inheritance diagram for StreamSetBase: Collaboration diagram for StreamSetBase:#include <stream_data.hpp>
Public Member Functions | |
| virtual | ~StreamSetBase () |
| virtual void | Close ()=0 |
| Close all streams in the set. More... | |
| virtual void | OnWriterClosed (size_t peer_worker_rank, bool sent)=0 |
| Public Member Functions inherited from ReferenceCounter | |
| ReferenceCounter () noexcept | |
| new objects have zero reference count More... | |
| ReferenceCounter (const ReferenceCounter &) noexcept | |
| coping still creates a new object with zero reference count More... | |
| ~ReferenceCounter () | |
| bool | dec_reference () const noexcept |
| Call whenever resetting (i.e. More... | |
| void | inc_reference () const noexcept |
| Call whenever setting a pointer to the object. More... | |
| ReferenceCounter & | operator= (const ReferenceCounter &) noexcept |
| assignment operator, leaves pointers unchanged More... | |
| size_t | reference_count () const noexcept |
| Return the number of references to this object (for debugging) More... | |
| bool | unique () const noexcept |
| Test if the ReferenceCounter is referenced by only one CountingPtr. More... | |
Static Public Attributes | |
| static constexpr bool | debug = false |
Constructor & Destructor Documentation
◆ ~StreamSetBase()
|
inlinevirtual |
Definition at line 206 of file stream_data.hpp.
Member Function Documentation
◆ Close()
|
pure virtual |
Close all streams in the set.
Implemented in StreamSet< StreamData >.
◆ OnWriterClosed()
|
pure virtual |
method called from StreamSink when it is closed, used to aggregate Close messages to remote hosts
Implemented in StreamSet< StreamData >.
Referenced by StreamData::OnWriterClosed().
Member Data Documentation
◆ debug
|
static |
Definition at line 204 of file stream_data.hpp.
The documentation for this class was generated from the following file:
- thrill/data/stream_data.hpp
