epee::net_utils::direct_connect Struct Reference

#include <net_helper.h>

Public Member Functions
boost::unique_future< boost::asio::ip::tcp::socket >	operator() (const std::string &addr, const std::string &port, boost::asio::steady_timer &) const

Detailed Description

Definition at line 63 of file net_helper.h.

Member Function Documentation

operator()()

boost::unique_future< boost::asio::ip::tcp::socket > epee::net_utils::direct_connect::operator()	(	const std::string &	addr,
		const std::string &	port,
		boost::asio::steady_timer &	timeout ) const

Definition at line 8 of file net_helper.cpp.

    {
        // Get a list of endpoints corresponding to the server name.
        boost::asio::ip::tcp::resolver resolver(GET_IO_SERVICE(timeout));
        boost::asio::ip::tcp::resolver::query query(boost::asio::ip::tcp::v4(), addr, port, boost::asio::ip::tcp::resolver::query::canonical_name);
        boost::asio::ip::tcp::resolver::iterator iterator = resolver.resolve(query);
        boost::asio::ip::tcp::resolver::iterator end;
        if(iterator == end) // Documentation states that successful call is guaranteed to be non-empty
            throw boost::system::system_error{boost::asio::error::fault, "Failed to resolve " + addr};

 
        struct new_connection
        {
            boost::promise<boost::asio::ip::tcp::socket> result_;
            boost::asio::ip::tcp::socket socket_;
 
            explicit new_connection(boost::asio::io_service& io_service)
              : result_(), socket_(io_service)
            {}
        };
 
        const auto shared = std::make_shared<new_connection>(GET_IO_SERVICE(timeout));
        timeout.async_wait([shared] (boost::system::error_code error)
        {
            if (error != boost::system::errc::operation_canceled && shared && shared->socket_.is_open())
            {
                shared->socket_.shutdown(boost::asio::ip::tcp::socket::shutdown_both);
                shared->socket_.close();
            }
        });
        shared->socket_.async_connect(*iterator, [shared] (boost::system::error_code error)
        {
            if (shared)
            {
                if (error)
                    shared->result_.set_exception(boost::system::system_error{error});
                else
                    shared->result_.set_value(std::move(shared->socket_));
            }
        });
        return shared->result_.get_future();
    }

---

The documentation for this struct was generated from the following files:

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