libcaf
0.16.3
|
Default datagram servant implementation. More...
#include <datagram_servant_impl.hpp>
Public Member Functions | |
datagram_servant_impl (default_multiplexer &mx, native_socket sockfd, int64_t id) | |
bool | new_endpoint (network::receive_buffer &buf) override |
void | ack_writes (bool enable) override |
Enables or disables write notifications. | |
std::vector< char > & | wr_buf (datagram_handle hdl) override |
Returns a new output buffer. | |
void | enqueue_datagram (datagram_handle hdl, std::vector< char > buf) override |
Enqueue a buffer to be sent as a datagram. | |
network::receive_buffer & | rd_buf () override |
Returns the current input buffer. | |
void | graceful_shutdown () override |
void | flush () override |
Flushes the output buffer, i.e., sends the content of the buffer via the network. More... | |
std::string | addr () const override |
uint16_t | port (datagram_handle hdl) const override |
uint16_t | local_port () const override |
Returns the local port of associated socket. | |
std::vector< datagram_handle > | hdls () const override |
Returns all the handles associated with this servant. | |
void | add_endpoint (const ip_endpoint &ep, datagram_handle hdl) override |
Adds a new remote endpoint identified by the ip_endpoint to the related manager. More... | |
void | remove_endpoint (datagram_handle hdl) override |
void | launch () override |
void | add_to_loop () override |
void | remove_from_loop () override |
void | detach_handles () override |
![]() | |
datagram_servant (datagram_handle hdl) | |
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 |
![]() | |
broker_servant (handle_type x) | |
handle_type | hdl () const |
void | halt () |
void | trigger () |
void | trigger (size_t num) |
optional< size_t > | activity_tokens () const |
Additional Inherited Members | |
![]() | |
using | handle_type = Handle |
![]() | |
message | detach_message () override |
![]() | |
void | detach_from (abstract_broker *ptr) override |
void | invoke_mailbox_element_impl (execution_unit *ctx, mailbox_element &x) |
bool | invoke_mailbox_element (execution_unit *ctx) |
SysMsgType & | msg () |
![]() | |
handle_type | hdl_ |
mailbox_element_vals< SysMsgType > | value_ |
optional< size_t > | activity_tokens_ |
Default datagram servant implementation.
|
overridevirtual |
Adds a new remote endpoint identified by the ip_endpoint
to the related manager.
Implements caf::io::datagram_servant.
|
overridevirtual |
Flushes the output buffer, i.e., sends the content of the buffer via the network.
Implements caf::io::datagram_servant.