epee::net_utils::async_blocked_mode_client Class Reference

#include <net_helper.h>

Inheritance diagram for epee::net_utils::async_blocked_mode_client:

Collaboration diagram for epee::net_utils::async_blocked_mode_client:

Public Member Functions
	async_blocked_mode_client ()
	~async_blocked_mode_client ()
bool	shutdown ()
bool	send (const void *data, size_t sz)
Public Member Functions inherited from epee::net_utils::blocked_mode_client
	blocked_mode_client ()
	~blocked_mode_client ()
void	set_ssl (ssl_options_t ssl_options)
bool	connect (const std::string &addr, int port, std::chrono::milliseconds timeout)
try_connect_result_t	try_connect (const std::string &addr, const std::string &port, std::chrono::milliseconds timeout, epee::net_utils::ssl_support_t ssl_support)
bool	connect (const std::string &addr, const std::string &port, std::chrono::milliseconds timeout)
void	set_connector (std::function< connect_func > connector)
	Change the connection routine (proxy, etc.).
bool	disconnect ()
bool	send (const std::string &buff, std::chrono::milliseconds timeout)
bool	send (const void *data, size_t sz)
bool	is_connected (bool *ssl=NULL)
bool	recv (std::string &buff, std::chrono::milliseconds timeout)
bool	recv_n (std::string &buff, int64_t sz, std::chrono::milliseconds timeout)
bool	shutdown ()
boost::asio::io_service &	get_io_service ()
boost::asio::ip::tcp::socket &	get_socket ()
uint64_t	get_bytes_sent () const
uint64_t	get_bytes_received () const

Additional Inherited Members
Public Types inherited from epee::net_utils::blocked_mode_client
using	connect_func = boost::unique_future<boost::asio::ip::tcp::socket>(const std::string&, const std::string&, boost::asio::steady_timer&)
Protected Member Functions inherited from epee::net_utils::blocked_mode_client
bool	write (const void *data, size_t sz, boost::system::error_code &ec)
void	async_write (const void *data, size_t sz, boost::system::error_code &ec)
void	async_read (char *buff, size_t sz, boost::asio::detail::transfer_at_least_t transfer_at_least, handler_obj &hndlr)
Protected Attributes inherited from epee::net_utils::blocked_mode_client
boost::asio::io_service	m_io_service
boost::asio::ssl::context	m_ctx
std::shared_ptr< boost::asio::ssl::stream< boost::asio::ip::tcp::socket > >	m_ssl_socket
std::function< connect_func >	m_connector
ssl_options_t	m_ssl_options
bool	m_initialized
bool	m_connected
boost::asio::steady_timer	m_deadline
volatile uint32_t	m_shutdowned
std::atomic< uint64_t >	m_bytes_sent
std::atomic< uint64_t >	m_bytes_received

Detailed Description

Definition at line 694 of file net_helper.h.

Constructor & Destructor Documentation

async_blocked_mode_client()

epee::net_utils::async_blocked_mode_client::async_blocked_mode_client ( )

inline

Definition at line 697 of file net_helper.h.

                                   :m_send_deadline(blocked_mode_client::m_io_service)
        {
 
            // No deadline is required until the first socket operation is started. We
            // set the deadline to positive infinity so that the actor takes no action
            // until a specific deadline is set.
            m_send_deadline.expires_at(boost::posix_time::pos_infin);
 
            // Start the persistent actor that checks for deadline expiry.
            check_send_deadline();
        }

Here is the call graph for this function:

~async_blocked_mode_client()

epee::net_utils::async_blocked_mode_client::~async_blocked_mode_client ( )

inline

Definition at line 708 of file net_helper.h.

        {
            m_send_deadline.cancel();
        }

Member Function Documentation

send()

bool epee::net_utils::async_blocked_mode_client::send ( const void * data, size_t sz )

inline

Definition at line 721 of file net_helper.h.

        {
            try
            {
                /*
                m_send_deadline.expires_from_now(boost::posix_time::milliseconds(m_reciev_timeout));
 
                // Set up the variable that receives the result of the asynchronous
                // operation. The error code is set to would_block to signal that the
                // operation is incomplete. Asio guarantees that its asynchronous
                // operations will never fail with would_block, so any other value in
                // ec indicates completion.
                boost::system::error_code ec = boost::asio::error::would_block;
 
                // Start the asynchronous operation itself. The boost::lambda function
                // object is used as a callback and will update the ec variable when the
                // operation completes. The blocking_udp_client.cpp example shows how you
                // can use boost::bind rather than boost::lambda.
                boost::asio::async_write(m_socket, boost::asio::buffer(data, sz), boost::lambda::var(ec) = boost::lambda::_1);
 
                // Block until the asynchronous operation has completed.
                while(ec == boost::asio::error::would_block)
                {
                    m_io_service.run_one();
                }*/
                
                boost::system::error_code ec;
 
                size_t writen = write(data, sz, ec);
                
                if (!writen || ec)
                {
                    LOG_PRINT_L3("Problems at write: " << ec.message());
                    return false;
                }else
                {
                    m_send_deadline.expires_at(boost::posix_time::pos_infin);
                }
            }
 
            catch(const boost::system::system_error& er)
            {
                LOG_ERROR("Some problems at connect, message: " << er.what());
                return false;
            }
            catch(...)
            {
                LOG_ERROR("Some fatal problems.");
                return false;
            }
 
            return true;
        }

Here is the call graph for this function:

shutdown()

bool epee::net_utils::async_blocked_mode_client::shutdown ( )

inline

Definition at line 713 of file net_helper.h.

        {
            blocked_mode_client::shutdown();
            m_send_deadline.cancel();
            return true;
        }

Here is the call graph for this function:

---

The documentation for this class was generated from the following file:

• /home/abuild/rpmbuild/BUILD/electroneum-5.1.3.1-build/electroneum-5.1.3.1/contrib/epee/include/net/net_helper.h