CAF 0.17.6
|
A stream manager configures an IO stream and provides callbacks for incoming data as well as for error handling. More...
#include <stream_manager.hpp>
Public Member Functions | |
virtual bool | consume (execution_unit *ctx, const void *buf, size_t bsize)=0 |
Called by the underlying I/O device whenever it received data. | |
virtual void | data_transferred (execution_unit *ctx, size_t num_bytes, size_t remaining_bytes)=0 |
Called by the underlying I/O device whenever it sent data. | |
virtual uint16_t | port () const =0 |
Get the port of the underlying I/O device. | |
![]() | |
void | set_parent (abstract_broker *ptr) |
Sets the parent for this manager. | |
abstract_broker * | parent () |
Returns the parent broker of this manager. | |
bool | detached () const |
Returns true if this manager has a parent, false otherwise. | |
virtual void | detach_from (abstract_broker *ptr)=0 |
Detach this manager from its parent and invoke detach_message() / if invoke_detach_message == true`. | |
![]() | |
ref_counted (const ref_counted &) | |
ref_counted & | operator= (const ref_counted &) |
void | ref () const noexcept |
Increases reference count by one. | |
void | deref () const noexcept |
Decreases reference count by one and calls request_deletion when it drops to zero. | |
bool | unique () const noexcept |
Queries whether there is exactly one reference. | |
size_t | get_reference_count () const noexcept |
![]() | |
virtual void | request_deletion (bool decremented_rc) const noexcept |
Default implementations calls `delete this, but can be overriden in case deletion depends on some condition or the class doesn't use default new/delete. | |
Additional Inherited Members | |
![]() | |
strong_actor_ptr | parent_ |
![]() | |
![]() | |
std::atomic< size_t > | rc_ |
![]() | |
void | intrusive_ptr_add_ref (const ref_counted *p) |
void | intrusive_ptr_release (const ref_counted *p) |
A stream manager configures an IO stream and provides callbacks for incoming data as well as for error handling.
|
pure virtual |
Called by the underlying I/O device whenever it received data.
true
if the manager accepts further reads, otherwise false
.