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
	Called by the underlying I/O device to indicate that a new remote endpoint has been detected, passing in the received datagram.
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.
std::string	addr () const override
uint16_t	port (datagram_handle hdl) const override
	Get the port of the underlying I/O device.
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.
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)
bool	consume (execution_unit *, datagram_handle hdl, network::receive_buffer &buf) override
	Called by the underlying I/O device whenever it received data.
void	datagram_sent (execution_unit *, datagram_handle hdl, size_t, std::vector< char > buffer) override
	Called by the underlying I/O device whenever it sent data.
Public Member Functions inherited from caf::io::broker_servant< network::datagram_manager, datagram_handle, new_datagram_msg >
	broker_servant (handle_type x)
handle_type	hdl () const
void	halt ()
void	trigger ()
void	trigger (size_t num)
optional< size_t >	activity_tokens () const
Public Member Functions inherited from caf::io::network::manager
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.
Public Member Functions inherited from caf::ref_counted
	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

Additional Inherited Members
Public Types inherited from caf::io::broker_servant< network::datagram_manager, datagram_handle, new_datagram_msg >
using	handle_type
Protected Member Functions inherited from caf::io::datagram_servant
message	detach_message () override
Protected Member Functions inherited from caf::io::broker_servant< network::datagram_manager, datagram_handle, new_datagram_msg >
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)
new_datagram_msg &	msg ()
Protected Attributes inherited from caf::io::broker_servant< network::datagram_manager, datagram_handle, new_datagram_msg >
handle_type	hdl_
mailbox_element_vals< new_datagram_msg >	value_
optional< size_t >	activity_tokens_
Protected Attributes inherited from caf::ref_counted
std::atomic< size_t >	rc_
Related Symbols inherited from caf::ref_counted
void	intrusive_ptr_add_ref (const ref_counted *p)
void	intrusive_ptr_release (const ref_counted *p)