|
libcaf
0.16.3
|
Default scribe implementation. More...
#include <scribe_impl.hpp>
Public Member Functions | |
| scribe_impl (default_multiplexer &mx, native_socket sockfd) | |
| void | configure_read (receive_policy::config config) override |
| Implicitly starts the read loop on first call. | |
| void | ack_writes (bool enable) override |
| Enables or disables write notifications. | |
| std::vector< char > & | wr_buf () override |
| Returns the current output buffer. | |
| std::vector< char > & | 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 () const override |
| void | launch () |
| void | add_to_loop () override |
| void | remove_from_loop () override |
Public Member Functions inherited from caf::io::scribe | |
| scribe (connection_handle conn_hdl) | |
| bool | consume (execution_unit *, const void *, size_t) override |
| void | data_transferred (execution_unit *, size_t, size_t) override |
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 |
Protected Attributes | |
| bool | launched_ |
| stream_impl< policy::tcp > | stream_ |
Protected Attributes inherited from caf::io::broker_servant< Base, Handle, SysMsgType > | |
| handle_type | hdl_ |
| mailbox_element_vals< SysMsgType > | value_ |
| optional< size_t > | activity_tokens_ |
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::scribe | |
| 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 () |
Default scribe implementation.
1.8.16