libcaf
0.17.1
|
Manages writing to a datagram sink. More...
#include <datagram_servant.hpp>
Public Member Functions | |
datagram_servant (datagram_handle hdl) | |
virtual void | ack_writes (bool enable)=0 |
Enables or disables write notifications. | |
virtual std::vector< char > & | wr_buf (datagram_handle)=0 |
Returns a new output buffer. | |
virtual void | enqueue_datagram (datagram_handle, std::vector< char >)=0 |
Enqueue a buffer to be sent as a datagram. | |
virtual network::receive_buffer & | rd_buf ()=0 |
Returns the current input buffer. | |
virtual void | flush ()=0 |
Flushes the output buffer, i.e., sends the content of the buffer via the network. More... | |
virtual uint16_t | local_port () const =0 |
Returns the local port of associated socket. | |
virtual std::vector < datagram_handle > | hdls () const =0 |
Returns all the handles associated with this servant. | |
virtual void | add_endpoint (const network::ip_endpoint &ep, datagram_handle hdl)=0 |
Adds a new remote endpoint identified by the ip_endpoint to the related manager. More... | |
virtual void | remove_endpoint (datagram_handle hdl)=0 |
bool | consume (execution_unit *, datagram_handle hdl, network::receive_buffer &buf) override |
void | datagram_sent (execution_unit *, datagram_handle hdl, size_t, std::vector< char > buffer) override |
virtual void | detach_handles ()=0 |
virtual void | launch ()=0 |
![]() | |
broker_servant (handle_type x) | |
Protected Member Functions | |
message | detach_message () override |
Additional Inherited Members | |
![]() | |
using | handle_type = Handle |
![]() | |
mailbox_element_vals< SysMsgType > | value_ |
optional< size_t > | activity_tokens_ |
Manages writing to a datagram sink.
|
pure virtual |
Adds a new remote endpoint identified by the ip_endpoint
to the related manager.
Implemented in caf::io::network::datagram_servant_impl.
|
pure virtual |
Flushes the output buffer, i.e., sends the content of the buffer via the network.
Implemented in caf::io::network::datagram_servant_impl.