Default datagram servant implementation. More...

#include <datagram_servant_impl.hpp>

Inheritance diagram for caf::io::network::datagram_servant_impl:

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. More...

std::vector< char > &	wr_buf (datagram_handle hdl) override
	Returns a new output buffer. More...

void	enqueue_datagram (datagram_handle hdl, std::vector< char > buf) override
	Enqueue a buffer to be sent as a datagram. More...

network::receive_buffer &	rd_buf () override
	Returns the current input buffer. More...

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. More...

std::vector< datagram_handle >	hdls () const override
	Returns all the handles associated with this servant. More...

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

Public Member Functions inherited from caf::io::datagram_servant
	datagram_servant (datagram_handle hdl)

virtual void	ack_writes (bool enable)=0
	Enables or disables write notifications. More...

virtual std::vector< char > &	wr_buf (datagram_handle)=0
	Returns a new output buffer. More...

virtual void	enqueue_datagram (datagram_handle, std::vector< char >)=0
	Enqueue a buffer to be sent as a datagram. More...

virtual network::receive_buffer &	rd_buf ()=0
	Returns the current input buffer. More...

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. More...

virtual std::vector< datagram_handle >	hdls () const =0
	Returns all the handles associated with this servant. More...

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

Public Member Functions inherited from caf::io::broker_servant< Base, Handle, SysMsgType >
	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
Public Types inherited from caf::io::broker_servant< Base, Handle, SysMsgType >
using	handle_type = Handle

Protected Member Functions inherited from caf::io::datagram_servant
message	detach_message () override

Protected Member Functions inherited from caf::io::broker_servant< Base, Handle, SysMsgType >
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 ()

Protected Attributes inherited from caf::io::broker_servant< Base, Handle, SysMsgType >
handle_type	hdl_

mailbox_element_vals< SysMsgType >	value_

optional< size_t >	activity_tokens_