mirror of
https://github.com/bitcoin/bitcoin.git
synced 2025-06-30 18:51:15 +02:00
net: don't bind on 0.0.0.0 if binds are restricted to Tor
The semantic of `-bind` is to restrict the binding only to some address. If not specified, then the user does not care and we bind to `0.0.0.0`. If specified then we should honor the restriction and bind only to the specified address. Before this change, if no `-bind` is given then we would bind to `0.0.0.0:8333` and to `127.0.0.1:8334` (incoming Tor) which is ok - the user does not care to restrict the binding. However, if only `-bind=addr:port=onion` is given (without ordinary `-bind=`) then we would bind to `addr:port` _and_ to `0.0.0.0:8333` in addition. Change the above to not do the additional bind: if only `-bind=addr:port=onion` is given (without ordinary `-bind=`) then bind to `addr:port` (only) and consider incoming connections to that as Tor and do not advertise it. I.e. a Tor-only node.
This commit is contained in:
33
src/init.cpp
33
src/init.cpp
@ -1721,18 +1721,6 @@ bool AppInitMain(NodeContext& node, interfaces::BlockAndHeaderTipInfo* tip_info)
|
|||||||
return InitError(ResolveErrMsg("bind", bind_arg));
|
return InitError(ResolveErrMsg("bind", bind_arg));
|
||||||
}
|
}
|
||||||
|
|
||||||
if (connOptions.onion_binds.empty()) {
|
|
||||||
connOptions.onion_binds.push_back(DefaultOnionServiceTarget());
|
|
||||||
}
|
|
||||||
|
|
||||||
if (args.GetBoolArg("-listenonion", DEFAULT_LISTEN_ONION)) {
|
|
||||||
const auto bind_addr = connOptions.onion_binds.front();
|
|
||||||
if (connOptions.onion_binds.size() > 1) {
|
|
||||||
InitWarning(strprintf(_("More than one onion bind address is provided. Using %s for the automatically created Tor onion service."), bind_addr.ToStringIPPort()));
|
|
||||||
}
|
|
||||||
StartTorControl(bind_addr);
|
|
||||||
}
|
|
||||||
|
|
||||||
for (const std::string& strBind : args.GetArgs("-whitebind")) {
|
for (const std::string& strBind : args.GetArgs("-whitebind")) {
|
||||||
NetWhitebindPermissions whitebind;
|
NetWhitebindPermissions whitebind;
|
||||||
bilingual_str error;
|
bilingual_str error;
|
||||||
@ -1740,6 +1728,27 @@ bool AppInitMain(NodeContext& node, interfaces::BlockAndHeaderTipInfo* tip_info)
|
|||||||
connOptions.vWhiteBinds.push_back(whitebind);
|
connOptions.vWhiteBinds.push_back(whitebind);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// If the user did not specify -bind= or -whitebind= then we bind
|
||||||
|
// on any address - 0.0.0.0 (IPv4) and :: (IPv6).
|
||||||
|
connOptions.bind_on_any = args.GetArgs("-bind").empty() && args.GetArgs("-whitebind").empty();
|
||||||
|
|
||||||
|
CService onion_service_target;
|
||||||
|
if (!connOptions.onion_binds.empty()) {
|
||||||
|
onion_service_target = connOptions.onion_binds.front();
|
||||||
|
} else {
|
||||||
|
onion_service_target = DefaultOnionServiceTarget();
|
||||||
|
connOptions.onion_binds.push_back(onion_service_target);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (args.GetBoolArg("-listenonion", DEFAULT_LISTEN_ONION)) {
|
||||||
|
if (connOptions.onion_binds.size() > 1) {
|
||||||
|
InitWarning(strprintf(_("More than one onion bind address is provided. Using %s "
|
||||||
|
"for the automatically created Tor onion service."),
|
||||||
|
onion_service_target.ToStringIPPort()));
|
||||||
|
}
|
||||||
|
StartTorControl(onion_service_target);
|
||||||
|
}
|
||||||
|
|
||||||
for (const auto& net : args.GetArgs("-whitelist")) {
|
for (const auto& net : args.GetArgs("-whitelist")) {
|
||||||
NetWhitelistPermissions subnet;
|
NetWhitelistPermissions subnet;
|
||||||
bilingual_str error;
|
bilingual_str error;
|
||||||
|
21
src/net.cpp
21
src/net.cpp
@ -2418,30 +2418,25 @@ bool CConnman::Bind(const CService &addr, unsigned int flags, NetPermissionFlags
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
bool CConnman::InitBinds(
|
bool CConnman::InitBinds(const Options& options)
|
||||||
const std::vector<CService>& binds,
|
|
||||||
const std::vector<NetWhitebindPermissions>& whiteBinds,
|
|
||||||
const std::vector<CService>& onion_binds)
|
|
||||||
{
|
{
|
||||||
bool fBound = false;
|
bool fBound = false;
|
||||||
for (const auto& addrBind : binds) {
|
for (const auto& addrBind : options.vBinds) {
|
||||||
fBound |= Bind(addrBind, (BF_EXPLICIT | BF_REPORT_ERROR), NetPermissionFlags::None);
|
fBound |= Bind(addrBind, (BF_EXPLICIT | BF_REPORT_ERROR), NetPermissionFlags::None);
|
||||||
}
|
}
|
||||||
for (const auto& addrBind : whiteBinds) {
|
for (const auto& addrBind : options.vWhiteBinds) {
|
||||||
fBound |= Bind(addrBind.m_service, (BF_EXPLICIT | BF_REPORT_ERROR), addrBind.m_flags);
|
fBound |= Bind(addrBind.m_service, (BF_EXPLICIT | BF_REPORT_ERROR), addrBind.m_flags);
|
||||||
}
|
}
|
||||||
if (binds.empty() && whiteBinds.empty()) {
|
for (const auto& addr_bind : options.onion_binds) {
|
||||||
|
fBound |= Bind(addr_bind, BF_EXPLICIT | BF_DONT_ADVERTISE, NetPermissionFlags::None);
|
||||||
|
}
|
||||||
|
if (options.bind_on_any) {
|
||||||
struct in_addr inaddr_any;
|
struct in_addr inaddr_any;
|
||||||
inaddr_any.s_addr = htonl(INADDR_ANY);
|
inaddr_any.s_addr = htonl(INADDR_ANY);
|
||||||
struct in6_addr inaddr6_any = IN6ADDR_ANY_INIT;
|
struct in6_addr inaddr6_any = IN6ADDR_ANY_INIT;
|
||||||
fBound |= Bind(CService(inaddr6_any, GetListenPort()), BF_NONE, NetPermissionFlags::None);
|
fBound |= Bind(CService(inaddr6_any, GetListenPort()), BF_NONE, NetPermissionFlags::None);
|
||||||
fBound |= Bind(CService(inaddr_any, GetListenPort()), !fBound ? BF_REPORT_ERROR : BF_NONE, NetPermissionFlags::None);
|
fBound |= Bind(CService(inaddr_any, GetListenPort()), !fBound ? BF_REPORT_ERROR : BF_NONE, NetPermissionFlags::None);
|
||||||
}
|
}
|
||||||
|
|
||||||
for (const auto& addr_bind : onion_binds) {
|
|
||||||
fBound |= Bind(addr_bind, BF_EXPLICIT | BF_DONT_ADVERTISE, NetPermissionFlags::None);
|
|
||||||
}
|
|
||||||
|
|
||||||
return fBound;
|
return fBound;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -2449,7 +2444,7 @@ bool CConnman::Start(CScheduler& scheduler, const Options& connOptions)
|
|||||||
{
|
{
|
||||||
Init(connOptions);
|
Init(connOptions);
|
||||||
|
|
||||||
if (fListen && !InitBinds(connOptions.vBinds, connOptions.vWhiteBinds, connOptions.onion_binds)) {
|
if (fListen && !InitBinds(connOptions)) {
|
||||||
if (clientInterface) {
|
if (clientInterface) {
|
||||||
clientInterface->ThreadSafeMessageBox(
|
clientInterface->ThreadSafeMessageBox(
|
||||||
_("Failed to listen on any port. Use -listen=0 if you want this."),
|
_("Failed to listen on any port. Use -listen=0 if you want this."),
|
||||||
|
@ -824,6 +824,9 @@ public:
|
|||||||
std::vector<NetWhitebindPermissions> vWhiteBinds;
|
std::vector<NetWhitebindPermissions> vWhiteBinds;
|
||||||
std::vector<CService> vBinds;
|
std::vector<CService> vBinds;
|
||||||
std::vector<CService> onion_binds;
|
std::vector<CService> onion_binds;
|
||||||
|
/// True if the user did not specify -bind= or -whitebind= and thus
|
||||||
|
/// we should bind on `0.0.0.0` (IPv4) and `::` (IPv6).
|
||||||
|
bool bind_on_any;
|
||||||
bool m_use_addrman_outgoing = true;
|
bool m_use_addrman_outgoing = true;
|
||||||
std::vector<std::string> m_specified_outgoing;
|
std::vector<std::string> m_specified_outgoing;
|
||||||
std::vector<std::string> m_added_nodes;
|
std::vector<std::string> m_added_nodes;
|
||||||
@ -1033,10 +1036,7 @@ private:
|
|||||||
|
|
||||||
bool BindListenPort(const CService& bindAddr, bilingual_str& strError, NetPermissionFlags permissions);
|
bool BindListenPort(const CService& bindAddr, bilingual_str& strError, NetPermissionFlags permissions);
|
||||||
bool Bind(const CService& addr, unsigned int flags, NetPermissionFlags permissions);
|
bool Bind(const CService& addr, unsigned int flags, NetPermissionFlags permissions);
|
||||||
bool InitBinds(
|
bool InitBinds(const Options& options);
|
||||||
const std::vector<CService>& binds,
|
|
||||||
const std::vector<NetWhitebindPermissions>& whiteBinds,
|
|
||||||
const std::vector<CService>& onion_binds);
|
|
||||||
|
|
||||||
void ThreadOpenAddedConnections();
|
void ThreadOpenAddedConnections();
|
||||||
void AddAddrFetch(const std::string& strDest);
|
void AddAddrFetch(const std::string& strDest);
|
||||||
|
95
test/functional/feature_bind_extra.py
Executable file
95
test/functional/feature_bind_extra.py
Executable file
@ -0,0 +1,95 @@
|
|||||||
|
#!/usr/bin/env python3
|
||||||
|
# Copyright (c) 2014-2021 The Bitcoin Core developers
|
||||||
|
# Distributed under the MIT software license, see the accompanying
|
||||||
|
# file COPYING or http://www.opensource.org/licenses/mit-license.php.
|
||||||
|
"""
|
||||||
|
Test starting bitcoind with -bind and/or -bind=...=onion and confirm
|
||||||
|
that bind happens on the expected ports.
|
||||||
|
"""
|
||||||
|
|
||||||
|
import sys
|
||||||
|
|
||||||
|
from test_framework.netutil import (
|
||||||
|
addr_to_hex,
|
||||||
|
get_bind_addrs,
|
||||||
|
)
|
||||||
|
from test_framework.test_framework import (
|
||||||
|
BitcoinTestFramework,
|
||||||
|
SkipTest,
|
||||||
|
)
|
||||||
|
from test_framework.util import (
|
||||||
|
PORT_MIN,
|
||||||
|
PORT_RANGE,
|
||||||
|
assert_equal,
|
||||||
|
rpc_port,
|
||||||
|
)
|
||||||
|
|
||||||
|
class BindExtraTest(BitcoinTestFramework):
|
||||||
|
def set_test_params(self):
|
||||||
|
self.setup_clean_chain = True
|
||||||
|
# Avoid any -bind= on the command line. Force the framework to avoid
|
||||||
|
# adding -bind=127.0.0.1.
|
||||||
|
self.bind_to_localhost_only = False
|
||||||
|
self.num_nodes = 2
|
||||||
|
|
||||||
|
def setup_network(self):
|
||||||
|
# Override setup_network() because we want to put the result of
|
||||||
|
# p2p_port() in self.extra_args[], before the nodes are started.
|
||||||
|
# p2p_port() is not usable in set_test_params() because PortSeed.n is
|
||||||
|
# not set at that time.
|
||||||
|
|
||||||
|
# Due to OS-specific network stats queries, we only run on Linux.
|
||||||
|
self.log.info("Checking for Linux")
|
||||||
|
if not sys.platform.startswith('linux'):
|
||||||
|
raise SkipTest("This test can only be run on Linux.")
|
||||||
|
|
||||||
|
loopback_ipv4 = addr_to_hex("127.0.0.1")
|
||||||
|
|
||||||
|
# Start custom ports after p2p and rpc ports.
|
||||||
|
port = PORT_MIN + 2 * PORT_RANGE
|
||||||
|
|
||||||
|
# Array of tuples [command line arguments, expected bind addresses].
|
||||||
|
self.expected = []
|
||||||
|
|
||||||
|
# Node0, no normal -bind=... with -bind=...=onion, thus only the tor target.
|
||||||
|
self.expected.append(
|
||||||
|
[
|
||||||
|
[f"-bind=127.0.0.1:{port}=onion"],
|
||||||
|
[(loopback_ipv4, port)]
|
||||||
|
],
|
||||||
|
)
|
||||||
|
port += 1
|
||||||
|
|
||||||
|
# Node1, both -bind=... and -bind=...=onion.
|
||||||
|
self.expected.append(
|
||||||
|
[
|
||||||
|
[f"-bind=127.0.0.1:{port}", f"-bind=127.0.0.1:{port + 1}=onion"],
|
||||||
|
[(loopback_ipv4, port), (loopback_ipv4, port + 1)]
|
||||||
|
],
|
||||||
|
)
|
||||||
|
port += 2
|
||||||
|
|
||||||
|
self.extra_args = list(map(lambda e: e[0], self.expected))
|
||||||
|
self.add_nodes(self.num_nodes, self.extra_args)
|
||||||
|
# Don't start the nodes, as some of them would collide trying to bind on the same port.
|
||||||
|
|
||||||
|
def run_test(self):
|
||||||
|
for i in range(len(self.expected)):
|
||||||
|
self.log.info(f"Starting node {i} with {self.expected[i][0]}")
|
||||||
|
self.start_node(i)
|
||||||
|
pid = self.nodes[i].process.pid
|
||||||
|
binds = set(get_bind_addrs(pid))
|
||||||
|
# Remove IPv6 addresses because on some CI environments "::1" is not configured
|
||||||
|
# on the system (so our test_ipv6_local() would return False), but it is
|
||||||
|
# possible to bind on "::". This makes it unpredictable whether to expect
|
||||||
|
# that bitcoind has bound on "::1" (for RPC) and "::" (for P2P).
|
||||||
|
ipv6_addr_len_bytes = 32
|
||||||
|
binds = set(filter(lambda e: len(e[0]) != ipv6_addr_len_bytes, binds))
|
||||||
|
# Remove RPC ports. They are not relevant for this test.
|
||||||
|
binds = set(filter(lambda e: e[1] != rpc_port(i), binds))
|
||||||
|
assert_equal(binds, set(self.expected[i][1]))
|
||||||
|
self.stop_node(i)
|
||||||
|
self.log.info(f"Stopped node {i}")
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
BindExtraTest().main()
|
@ -138,6 +138,7 @@ BASE_SCRIPTS = [
|
|||||||
'interface_zmq.py',
|
'interface_zmq.py',
|
||||||
'rpc_invalid_address_message.py',
|
'rpc_invalid_address_message.py',
|
||||||
'interface_bitcoin_cli.py',
|
'interface_bitcoin_cli.py',
|
||||||
|
'feature_bind_extra.py',
|
||||||
'mempool_resurrect.py',
|
'mempool_resurrect.py',
|
||||||
'wallet_txn_doublespend.py --mineblock',
|
'wallet_txn_doublespend.py --mineblock',
|
||||||
'tool_wallet.py --legacy-wallet',
|
'tool_wallet.py --legacy-wallet',
|
||||||
|
Reference in New Issue
Block a user