|
Monero
|
#include <levin_protocol_handler_async.h>

Public Types | |
| typedef t_connection_context | connection_context |
Public Member Functions | |
| int | invoke (int command, message_writer in_msg, std::string &buff_out, boost::uuids::uuid connection_id) |
| template<class callback_t> | |
| int | invoke_async (int command, message_writer in_msg, boost::uuids::uuid connection_id, const callback_t &cb, size_t timeout=LEVIN_DEFAULT_TIMEOUT_PRECONFIGURED) |
| int | send (epee::byte_slice message, const boost::uuids::uuid &connection_id) |
| bool | close (boost::uuids::uuid connection_id, const bool wait_for_shutdown) |
| bool | update_connection_context (const t_connection_context &contxt) |
| bool | request_callback (boost::uuids::uuid connection_id) |
| template<class callback_t> | |
| bool | foreach_connection (const callback_t &cb) |
| template<class callback_t> | |
| bool | for_connection (const boost::uuids::uuid &connection_id, const callback_t &cb) |
| size_t | get_connections_count () |
| size_t | get_out_connections_count () |
| size_t | get_in_connections_count () |
| void | set_handler (levin_commands_handler< t_connection_context > *handler, void(*destroy)(levin_commands_handler< t_connection_context > *)=NULL) |
| async_protocol_handler_config () | |
| virtual | ~async_protocol_handler_config () |
| void | del_out_connections (size_t count) |
| void | del_in_connections (size_t count) |
Public Attributes | |
| uint64_t | m_initial_max_packet_size |
| uint64_t | m_max_packet_size |
| uint64_t | m_invoke_timeout |
Private Types | |
| typedef boost::unordered_map< boost::uuids::uuid, async_protocol_handler< t_connection_context > * > | connections_map |
Private Member Functions | |
| void | add_connection (async_protocol_handler< t_connection_context > *pc) |
| void | del_connection (async_protocol_handler< t_connection_context > *pc) |
| async_protocol_handler< t_connection_context > * | find_connection (boost::uuids::uuid connection_id) const |
| int | find_and_lock_connection (boost::uuids::uuid connection_id, async_protocol_handler< t_connection_context > *&aph) |
| void | delete_connections (size_t count, bool incoming) |
Private Attributes | |
| critical_section | m_connects_lock |
| connections_map | m_connects |
| levin_commands_handler< t_connection_context > * | m_pcommands_handler |
| void(* | m_pcommands_handler_destroy )(levin_commands_handler< t_connection_context > *) |
Friends | |
| class | async_protocol_handler< t_connection_context > |
| typedef t_connection_context epee::levin::async_protocol_handler_config< t_connection_context >::connection_context |
|
private |
|
inline |
|
inlinevirtual |
|
private |
| bool epee::levin::async_protocol_handler_config< t_connection_context >::close | ( | boost::uuids::uuid | connection_id, |
| const bool | wait_for_shutdown ) |
|
private |
| void epee::levin::async_protocol_handler_config< t_connection_context >::del_in_connections | ( | size_t | count | ) |
| void epee::levin::async_protocol_handler_config< t_connection_context >::del_out_connections | ( | size_t | count | ) |
|
private |
|
private |
|
private |
| bool epee::levin::async_protocol_handler_config< t_connection_context >::for_connection | ( | const boost::uuids::uuid & | connection_id, |
| const callback_t & | cb ) |
| bool epee::levin::async_protocol_handler_config< t_connection_context >::foreach_connection | ( | const callback_t & | cb | ) |
| size_t epee::levin::async_protocol_handler_config< t_connection_context >::get_connections_count | ( | ) |
| size_t epee::levin::async_protocol_handler_config< t_connection_context >::get_in_connections_count | ( | ) |
| size_t epee::levin::async_protocol_handler_config< t_connection_context >::get_out_connections_count | ( | ) |
| int epee::levin::async_protocol_handler_config< t_connection_context >::invoke | ( | int | command, |
| message_writer | in_msg, | ||
| std::string & | buff_out, | ||
| boost::uuids::uuid | connection_id ) |
| int epee::levin::async_protocol_handler_config< t_connection_context >::invoke_async | ( | int | command, |
| message_writer | in_msg, | ||
| boost::uuids::uuid | connection_id, | ||
| const callback_t & | cb, | ||
| size_t | timeout = LEVIN_DEFAULT_TIMEOUT_PRECONFIGURED ) |
| bool epee::levin::async_protocol_handler_config< t_connection_context >::request_callback | ( | boost::uuids::uuid | connection_id | ) |
| int epee::levin::async_protocol_handler_config< t_connection_context >::send | ( | epee::byte_slice | message, |
| const boost::uuids::uuid & | connection_id ) |
| void epee::levin::async_protocol_handler_config< t_connection_context >::set_handler | ( | levin_commands_handler< t_connection_context > * | handler, |
| void(* | destroy )(levin_commands_handler< t_connection_context > *) = NULL ) |
| bool epee::levin::async_protocol_handler_config< t_connection_context >::update_connection_context | ( | const t_connection_context & | contxt | ) |
|
friend |
|
private |
|
private |
| uint64_t epee::levin::async_protocol_handler_config< t_connection_context >::m_initial_max_packet_size |
| uint64_t epee::levin::async_protocol_handler_config< t_connection_context >::m_invoke_timeout |
| uint64_t epee::levin::async_protocol_handler_config< t_connection_context >::m_max_packet_size |
|
private |
|
private |