Thrill  0.1
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...
ReferenceCounteroperator= (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()

virtual ~StreamSetBase ( )

Definition at line 206 of file stream_data.hpp.

Member Function Documentation

◆ Close()

virtual void Close ( )
pure virtual

Close all streams in the set.

Implemented in StreamSet< StreamData >.

◆ OnWriterClosed()

virtual void OnWriterClosed ( size_t  peer_worker_rank,
bool  sent 
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

constexpr bool debug = false

Definition at line 204 of file stream_data.hpp.

The documentation for this class was generated from the following file: