|
| 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 |
|
| 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 |
|
| broker_servant (handle_type x) |
|
handle_type | hdl () const |
|
void | halt () |
|
void | trigger () |
|
void | trigger (size_t num) |
|
optional< size_t > | activity_tokens () const |
|
Default datagram servant implementation.