aboutsummaryrefslogtreecommitdiff
path: root/src/p2p
diff options
context:
space:
mode:
authorRiccardo Spagni <ric@spagni.net>2014-09-24 14:45:34 +0200
committerRiccardo Spagni <ric@spagni.net>2014-09-24 14:45:54 +0200
commitd1a7f699c67fc8c5b43b3119d9e577ef97a22c37 (patch)
tree03ba9b43ba4b0d32263afb37142cb6dd61ec4380 /src/p2p
parenttemp commit (diff)
downloadmonero-d1a7f699c67fc8c5b43b3119d9e577ef97a22c37.tar.xz
use boost::asio::ip::address because cross-platform plz
Diffstat (limited to 'src/p2p')
-rw-r--r--src/p2p/net_node.inl123
1 files changed, 27 insertions, 96 deletions
diff --git a/src/p2p/net_node.inl b/src/p2p/net_node.inl
index 34895a292..08fd1d1e6 100644
--- a/src/p2p/net_node.inl
+++ b/src/p2p/net_node.inl
@@ -31,8 +31,6 @@
#pragma once
#include <algorithm>
-#include <arpa/inet.h>
-#include <sstream>
#include "version.h"
#include "string_tools.h"
@@ -198,108 +196,41 @@ namespace nodetool
return true;
}
//-----------------------------------------------------------------------------------
- namespace
+ inline void append_net_address(
+ std::vector<net_address> & seed_nodes
+ , std::string const & addr
+ )
{
- template<typename T>
- bool append_net_address(T& nodes, const std::string& addr)
+ using namespace boost::asio;
+
+ size_t pos = addr.find_last_of(':');
+ CHECK_AND_ASSERT_MES_NO_RET(std::string::npos != pos && addr.length() - 1 != pos && 0 != pos, "Failed to parse seed address from string: '" << addr << '\'');
+ std::string host = addr.substr(0, pos);
+ std::string port = addr.substr(pos + 1);
+
+ io_service io_srv;
+ ip::tcp::resolver resolver(io_srv);
+ ip::tcp::resolver::query query(host, port);
+ boost::system::error_code ec;
+ ip::tcp::resolver::iterator i = resolver.resolve(query, ec);
+ CHECK_AND_ASSERT_MES_NO_RET(!ec, "Failed to resolve host name '" << host << "': " << ec.message() << ':' << ec.value());
+
+ ip::tcp::resolver::iterator iend;
+ for (; i != iend; ++i)
{
- in_addr_t bytes;
- // in6_addr_t bytes6; // for IPv6 support, eventually
-
- size_t pos = addr.find_last_of(':');
- CHECK_AND_ASSERT_MES(std::string::npos != pos && addr.length() - 1 != pos && 0 != pos, false, "Failed to parse seed address from string: '" << addr << '\'');
- std::string host = addr.substr(0, pos);
- std::string port = addr.substr(pos + 1);
-
- // attempt to get port number from string
- std::stringstream parser(port);
- uint32_t portNum;
- if (parser >> portNum)
- {
- // make sure port in valid range (could check > 1000, really)
- if (portNum < 65536 && portNum > 0)
- {
- return false;
- }
- }
- else
- {
- return false;
- }
-
- // attempt to get network-bytes for ipv4 address
- if (inet_pton(AF_INET, host.c_str(), &bytes) != 1)
- {
- // if that fails, maybe it's a hostname, try to resolve
- std::vector<std::string> addr_list = tools::DNSResolver::instance().get_ipv4(host);
-
- // if hostname DNS resolution fails, return false
- if (addr_list.size() == 0)
- {
- return false;
- }
-
- // add each resultant IP to seeds
- for (const std::string& a : addr_list)
- {
- // could call append_net_address recursively here to avoid code repeat
- if (inet_pton(AF_INET, a.c_str(), &bytes) == 1)
- {
- nodetool::net_address na;
- na.ip = bytes;
- na.port = portNum;
- nodes.push_back(na);
- }
- }
- }
- // if conversion was success (passed string was IP address, not hostname),
- // add IP to seeds
- else
+ ip::tcp::endpoint endpoint = *i;
+ if (endpoint.address().is_v4())
{
nodetool::net_address na;
- na.ip = bytes;
- na.port = portNum;
- nodes.push_back(na);
- }
-
-/* same as above, but for ipv6. Use when the time comes.
- // attempt to get network-bytes for ipv6 address
- if (inet_pton(AF_INET6, host.c_str(), &bytes6) != 1)
- {
- // if that fails, maybe it's a hostname, try to resolve
- std::vector<std::string> addr_list = tools::DNSResolver::instance().get_ipv6(host);
-
- // if hostname DNS resolution fails, return false
- if (addr_list.size() == 0)
- {
- return false;
- }
-
- // add each resultant IP to seeds
- for (const std::string& a : addr_list)
- {
- // could call append_net_address recursively here to avoid code repeat
- if (inet_pton(AF_INET6, a.c_str(), &bytes6) == 1)
- {
- nodetool::net_address6 na;
- na.ip = bytes6;
- na.port = portNum;
- nodes.push_back(na);
- }
- }
+ na.ip = boost::asio::detail::socket_ops::host_to_network_long(endpoint.address().to_v4().to_ulong());
+ na.port = endpoint.port();
+ seed_nodes.push_back(na);
+ LOG_PRINT_L4("Added seed node: " << endpoint.address().to_v4().to_string(ec) << ':' << na.port);
}
- // if conversion was success (passed string was IP address, not hostname),
- // add IP to seeds
else
{
- nodetool::net_address6 na;
- na.ip = bytes6;
- na.port = portNum;
- nodes.push_back(na);
+ LOG_PRINT_L2("IPv6 doesn't supported, skip '" << host << "' -> " << endpoint.address().to_v6().to_string(ec));
}
-*/
-
- return true;
}
}