Monero
Classes | Public Types | Public Member Functions | Public Attributes | Private Member Functions | Private Attributes | Friends | List of all members
epee::levin::async_protocol_handler< t_connection_context > Class Template Reference

#include <levin_protocol_handler_async.h>

Collaboration diagram for epee::levin::async_protocol_handler< t_connection_context >:
Collaboration graph
[legend]

Classes

struct  anvoke_handler
 
struct  invoke_response_handler_base
 

Public Types

enum  stream_state { stream_state_head, stream_state_body }
 
typedef t_connection_context connection_context
 
typedef async_protocol_handler_config< t_connection_context > config_type
 

Public Member Functions

template<class callback_t >
bool add_invoke_response_handler (const callback_t &cb, uint64_t timeout, async_protocol_handler &con, int command)
 
 async_protocol_handler (net_utils::i_service_endpoint *psnd_hndlr, config_type &config, t_connection_context &conn_context)
 
virtual ~async_protocol_handler ()
 
bool start_outer_call ()
 
bool finish_outer_call ()
 
bool release_protocol ()
 
bool close ()
 
void update_connection_context (const connection_context &contxt)
 
void request_callback ()
 
void handle_qued_callback ()
 
virtual bool handle_recv (const void *ptr, size_t cb)
 
bool after_init_connection ()
 
template<class callback_t >
bool async_invoke (int command, message_writer in_msg, const callback_t &cb, size_t timeout=LEVIN_DEFAULT_TIMEOUT_PRECONFIGURED)
 
int invoke (int command, message_writer in_msg, std::string &buff_out)
 
int send (byte_slice message)
 
boost::uuids::uuid get_connection_id ()
 
t_connection_context & get_context_ref ()
 

Public Attributes

std::atomic< bool > m_protocol_released
 
std::atomic< bool > m_invoke_buf_ready
 
volatile int m_invoke_result_code
 
critical_section m_local_inv_buff_lock
 
std::string m_local_inv_buff
 
critical_section m_call_lock
 
std::atomic< uint32_t > m_wait_count
 
std::atomic< uint32_t > m_close_called
 
bucket_head2 m_current_head
 
net_utils::i_service_endpoint * m_pservice_endpoint
 
config_type & m_config
 
t_connection_context & m_connection_context
 
std::atomic< uint64_t > m_max_packet_size
 
net_utils::buffer m_cache_in_buffer
 
stream_state m_state
 
int32_t m_oponent_protocol_ver
 
bool m_connection_initialized
 
critical_section m_invoke_response_handlers_lock
 
std::list< boost::shared_ptr< invoke_response_handler_base > > m_invoke_response_handlers
 

Private Member Functions

bool send_message (byte_slice message)
 

Private Attributes

std::string m_fragment_buffer
 

Friends

template<class callback_t >
struct anvoke_handler
 

Member Typedef Documentation

◆ config_type

template<class t_connection_context = net_utils::connection_context_base>
typedef async_protocol_handler_config<t_connection_context> epee::levin::async_protocol_handler< t_connection_context >::config_type

◆ connection_context

template<class t_connection_context = net_utils::connection_context_base>
typedef t_connection_context epee::levin::async_protocol_handler< t_connection_context >::connection_context

Member Enumeration Documentation

◆ stream_state

template<class t_connection_context = net_utils::connection_context_base>
enum epee::levin::async_protocol_handler::stream_state
Enumerator
stream_state_head 
stream_state_body 

Constructor & Destructor Documentation

◆ async_protocol_handler()

template<class t_connection_context = net_utils::connection_context_base>
epee::levin::async_protocol_handler< t_connection_context >::async_protocol_handler ( net_utils::i_service_endpoint *  psnd_hndlr,
config_type &  config,
t_connection_context &  conn_context 
)
inline

◆ ~async_protocol_handler()

template<class t_connection_context = net_utils::connection_context_base>
virtual epee::levin::async_protocol_handler< t_connection_context >::~async_protocol_handler ( )
inlinevirtual

Member Function Documentation

◆ add_invoke_response_handler()

template<class t_connection_context = net_utils::connection_context_base>
template<class callback_t >
bool epee::levin::async_protocol_handler< t_connection_context >::add_invoke_response_handler ( const callback_t &  cb,
uint64_t  timeout,
async_protocol_handler< t_connection_context > &  con,
int  command 
)
inline

◆ after_init_connection()

template<class t_connection_context = net_utils::connection_context_base>
bool epee::levin::async_protocol_handler< t_connection_context >::after_init_connection ( )
inline

◆ async_invoke()

template<class t_connection_context = net_utils::connection_context_base>
template<class callback_t >
bool epee::levin::async_protocol_handler< t_connection_context >::async_invoke ( int  command,
message_writer  in_msg,
const callback_t &  cb,
size_t  timeout = LEVIN_DEFAULT_TIMEOUT_PRECONFIGURED 
)
inline

◆ close()

template<class t_connection_context = net_utils::connection_context_base>
bool epee::levin::async_protocol_handler< t_connection_context >::close ( )
inline

◆ finish_outer_call()

template<class t_connection_context = net_utils::connection_context_base>
bool epee::levin::async_protocol_handler< t_connection_context >::finish_outer_call ( )
inline

◆ get_connection_id()

template<class t_connection_context = net_utils::connection_context_base>
boost::uuids::uuid epee::levin::async_protocol_handler< t_connection_context >::get_connection_id ( )
inline

◆ get_context_ref()

template<class t_connection_context = net_utils::connection_context_base>
t_connection_context& epee::levin::async_protocol_handler< t_connection_context >::get_context_ref ( )
inline

◆ handle_qued_callback()

template<class t_connection_context = net_utils::connection_context_base>
void epee::levin::async_protocol_handler< t_connection_context >::handle_qued_callback ( )
inline

◆ handle_recv()

template<class t_connection_context = net_utils::connection_context_base>
virtual bool epee::levin::async_protocol_handler< t_connection_context >::handle_recv ( const void *  ptr,
size_t  cb 
)
inlinevirtual

◆ invoke()

template<class t_connection_context = net_utils::connection_context_base>
int epee::levin::async_protocol_handler< t_connection_context >::invoke ( int  command,
message_writer  in_msg,
std::string &  buff_out 
)
inline

◆ release_protocol()

template<class t_connection_context = net_utils::connection_context_base>
bool epee::levin::async_protocol_handler< t_connection_context >::release_protocol ( )
inline

◆ request_callback()

template<class t_connection_context = net_utils::connection_context_base>
void epee::levin::async_protocol_handler< t_connection_context >::request_callback ( )
inline

◆ send()

template<class t_connection_context = net_utils::connection_context_base>
int epee::levin::async_protocol_handler< t_connection_context >::send ( byte_slice  message)
inline

Sends message without adding a levin header. The message must have been created with make_noise_notify, make_fragmented_notify, or message_writer::finalize_notify. See additional instructions for make_fragmented_notify.

Returns
1 on success

◆ send_message()

template<class t_connection_context = net_utils::connection_context_base>
bool epee::levin::async_protocol_handler< t_connection_context >::send_message ( byte_slice  message)
inlineprivate

◆ start_outer_call()

template<class t_connection_context = net_utils::connection_context_base>
bool epee::levin::async_protocol_handler< t_connection_context >::start_outer_call ( )
inline

◆ update_connection_context()

template<class t_connection_context = net_utils::connection_context_base>
void epee::levin::async_protocol_handler< t_connection_context >::update_connection_context ( const connection_context &  contxt)
inline

Friends And Related Function Documentation

◆ anvoke_handler

template<class t_connection_context = net_utils::connection_context_base>
template<class callback_t >
friend struct anvoke_handler
friend

Member Data Documentation

◆ m_cache_in_buffer

template<class t_connection_context = net_utils::connection_context_base>
net_utils::buffer epee::levin::async_protocol_handler< t_connection_context >::m_cache_in_buffer

◆ m_call_lock

template<class t_connection_context = net_utils::connection_context_base>
critical_section epee::levin::async_protocol_handler< t_connection_context >::m_call_lock

◆ m_close_called

template<class t_connection_context = net_utils::connection_context_base>
std::atomic<uint32_t> epee::levin::async_protocol_handler< t_connection_context >::m_close_called

◆ m_config

template<class t_connection_context = net_utils::connection_context_base>
config_type& epee::levin::async_protocol_handler< t_connection_context >::m_config

◆ m_connection_context

template<class t_connection_context = net_utils::connection_context_base>
t_connection_context& epee::levin::async_protocol_handler< t_connection_context >::m_connection_context

◆ m_connection_initialized

template<class t_connection_context = net_utils::connection_context_base>
bool epee::levin::async_protocol_handler< t_connection_context >::m_connection_initialized

◆ m_current_head

template<class t_connection_context = net_utils::connection_context_base>
bucket_head2 epee::levin::async_protocol_handler< t_connection_context >::m_current_head

◆ m_fragment_buffer

template<class t_connection_context = net_utils::connection_context_base>
std::string epee::levin::async_protocol_handler< t_connection_context >::m_fragment_buffer
private

◆ m_invoke_buf_ready

template<class t_connection_context = net_utils::connection_context_base>
std::atomic<bool> epee::levin::async_protocol_handler< t_connection_context >::m_invoke_buf_ready

◆ m_invoke_response_handlers

template<class t_connection_context = net_utils::connection_context_base>
std::list<boost::shared_ptr<invoke_response_handler_base> > epee::levin::async_protocol_handler< t_connection_context >::m_invoke_response_handlers

◆ m_invoke_response_handlers_lock

template<class t_connection_context = net_utils::connection_context_base>
critical_section epee::levin::async_protocol_handler< t_connection_context >::m_invoke_response_handlers_lock

◆ m_invoke_result_code

template<class t_connection_context = net_utils::connection_context_base>
volatile int epee::levin::async_protocol_handler< t_connection_context >::m_invoke_result_code

◆ m_local_inv_buff

template<class t_connection_context = net_utils::connection_context_base>
std::string epee::levin::async_protocol_handler< t_connection_context >::m_local_inv_buff

◆ m_local_inv_buff_lock

template<class t_connection_context = net_utils::connection_context_base>
critical_section epee::levin::async_protocol_handler< t_connection_context >::m_local_inv_buff_lock

◆ m_max_packet_size

template<class t_connection_context = net_utils::connection_context_base>
std::atomic<uint64_t> epee::levin::async_protocol_handler< t_connection_context >::m_max_packet_size

◆ m_oponent_protocol_ver

template<class t_connection_context = net_utils::connection_context_base>
int32_t epee::levin::async_protocol_handler< t_connection_context >::m_oponent_protocol_ver

◆ m_protocol_released

template<class t_connection_context = net_utils::connection_context_base>
std::atomic<bool> epee::levin::async_protocol_handler< t_connection_context >::m_protocol_released

◆ m_pservice_endpoint

template<class t_connection_context = net_utils::connection_context_base>
net_utils::i_service_endpoint* epee::levin::async_protocol_handler< t_connection_context >::m_pservice_endpoint

◆ m_state

template<class t_connection_context = net_utils::connection_context_base>
stream_state epee::levin::async_protocol_handler< t_connection_context >::m_state

◆ m_wait_count

template<class t_connection_context = net_utils::connection_context_base>
std::atomic<uint32_t> epee::levin::async_protocol_handler< t_connection_context >::m_wait_count
The documentation for this class was generated from the following file:
Generated on Sun Oct 12 2025 12:00:00 for Monero by   doxygen 1.8.14