8 #include <chainparams.h>
21 #include <validation.h>
26 #include <boost/test/unit_test.hpp>
35 BOOST_FIXTURE_TEST_SUITE(denialofservice_tests,
TestingSetup)
57 CNode dummyNode1{
id++,
86 LOCK(dummyNode1.cs_vSend);
87 const auto& [to_send, _more, _msg_type] = dummyNode1.m_transport->GetBytesToSend(
false);
97 LOCK(dummyNode1.cs_vSend);
98 const auto& [to_send, _more, _msg_type] = dummyNode1.m_transport->GetBytesToSend(
false);
122 vNodes.emplace_back(
new CNode{
id++,
135 node.fSuccessfullyConnected =
true;
150 const auto time_init{GetTime<std::chrono::seconds>()};
152 const auto time_later{time_init + 3 * std::chrono::seconds{
m_node.
chainman->GetConsensus().nPowTargetSpacing} + 1s};
153 connman->Init(options);
154 std::vector<CNode *> vNodes;
157 for (
int i = 0; i < max_outbound_full_relay; ++i) {
161 peerLogic->CheckForStaleTipAndEvictPeers();
172 peerLogic->CheckForStaleTipAndEvictPeers();
187 peerLogic->CheckForStaleTipAndEvictPeers();
188 for (
int i = 0; i < max_outbound_full_relay; ++i) {
194 vNodes.back()->fDisconnect =
false;
198 peerLogic->UpdateLastBlockAnnounceTime(vNodes.back()->GetId(),
GetTime());
200 peerLogic->CheckForStaleTipAndEvictPeers();
201 for (
int i = 0; i < max_outbound_full_relay - 1; ++i) {
204 BOOST_CHECK(vNodes[max_outbound_full_relay-1]->fDisconnect ==
true);
207 vNodes[max_outbound_full_relay - 1]->fDisconnect =
false;
214 peerLogic->CheckForStaleTipAndEvictPeers();
216 for (
int i = 0; i < max_outbound_full_relay - 2; ++i) {
219 BOOST_CHECK(vNodes[max_outbound_full_relay - 2]->fDisconnect ==
false);
220 BOOST_CHECK(vNodes[max_outbound_full_relay - 1]->fDisconnect ==
true);
221 BOOST_CHECK(vNodes[max_outbound_full_relay]->fDisconnect ==
false);
227 peerLogic->CheckForStaleTipAndEvictPeers();
232 peerLogic->FinalizeNode(*
node);
235 connman->ClearTestNodes();
249 connman->Init(options);
250 std::vector<CNode*> vNodes;
253 for (
int i = 0; i < max_outbound_block_relay; ++i) {
256 peerLogic->CheckForStaleTipAndEvictPeers();
258 for (
int i = 0; i < max_outbound_block_relay; ++i) {
264 peerLogic->CheckForStaleTipAndEvictPeers();
267 for (
int i = 0; i < max_outbound_block_relay; ++i) {
273 peerLogic->CheckForStaleTipAndEvictPeers();
274 for (
int i = 0; i < max_outbound_block_relay; ++i) {
281 vNodes.back()->fDisconnect =
false;
282 vNodes.back()->m_last_block_time = GetTime<std::chrono::seconds>();
284 peerLogic->CheckForStaleTipAndEvictPeers();
285 for (
int i = 0; i < max_outbound_block_relay - 1; ++i) {
288 BOOST_CHECK(vNodes[max_outbound_block_relay - 1]->fDisconnect ==
true);
292 peerLogic->FinalizeNode(*
node);
294 connman->ClearTestNodes();
307 tor_netaddr.
SetSpecial(
"pg6mmjiyjmcrsslvykfwnntlaru7p5svn6y2ymmju6nubxndf4pscryd.onion"));
316 std::array<CNode*, 3> nodes;
318 banman->ClearBanned();
320 nodes[0] =
new CNode{
id++,
331 nodes[0]->fSuccessfullyConnected =
true;
332 connman->AddTestNode(*nodes[0]);
333 peerLogic->UnitTestMisbehaving(nodes[0]->GetId());
340 nodes[1] =
new CNode{
id++,
351 nodes[1]->fSuccessfullyConnected =
true;
352 connman->AddTestNode(*nodes[1]);
360 peerLogic->UnitTestMisbehaving(nodes[1]->GetId());
370 nodes[2] =
new CNode{
id++,
381 nodes[2]->fSuccessfullyConnected =
true;
382 connman->AddTestNode(*nodes[2]);
383 peerLogic->UnitTestMisbehaving(nodes[2]->GetId());
393 peerLogic->FinalizeNode(*
node);
395 connman->ClearTestNodes();
406 banman->ClearBanned();
407 int64_t nStartTime =
GetTime();
412 CNode dummyNode{
id++,
423 dummyNode.fSuccessfullyConnected =
true;
425 peerLogic->UnitTestMisbehaving(dummyNode.GetId());
429 peerLogic->FinalizeNode(dummyNode);
static constexpr unsigned int DEFAULT_MISBEHAVING_BANTIME
const CChainParams & Params()
Return the currently selected parameters.
A CService with information about it as peer.
uint16_t GetDefaultPort() const
bool SetSpecial(const std::string &addr)
Parse a Tor or I2P address and set this object to it.
Information about a peer.
A combination of a network address (CNetAddr) and a (TCP) port.
static Mutex g_msgproc_mutex
Mutex for anything that is only accessed via the msg processing thread.
virtual bool SendMessages(CNode *pnode) EXCLUSIVE_LOCKS_REQUIRED(g_msgproc_mutex)=0
Send queued protocol messages to a given node.
virtual void FinalizeNode(const CNode &node)=0
Handle removal of a peer (clear state)
virtual void InitializeNode(const CNode &node, ServiceFlags our_services)=0
Initialize a peer (setup state)
static std::unique_ptr< PeerManager > make(CConnman &connman, AddrMan &addrman, BanMan *banman, ChainstateManager &chainman, CTxMemPool &pool, node::Warnings &warnings, Options opts)
std::vector< B > randbytes(size_t len) noexcept
Generate random bytes.
uint64_t randbits(int bits) noexcept
Generate a random (bits)-bit integer.
ConnectionType
Different types of connections to a peer.
@ BLOCK_RELAY
We use block-relay-only connections to help prevent against partition attacks.
@ OUTBOUND_FULL_RELAY
These are the default connections that we use to connect with the network.
@ INBOUND
Inbound connections are those initiated by a peer.
RecursiveMutex cs_main
Mutex to guard access to validation specific variables, such as reading or changing the chainstate.
BOOST_AUTO_TEST_SUITE_END()
BOOST_AUTO_TEST_CASE(outbound_slow_chain_eviction)
static void AddRandomOutboundPeer(NodeId &id, std::vector< CNode * > &vNodes, PeerManager &peerLogic, ConnmanTestMsg &connman, ConnectionType connType, bool onion_peer=false)
static CService ip(uint32_t i)
static const std::string addr1
static const unsigned int DEFAULT_MAX_PEER_CONNECTIONS
The maximum number of peer connections to maintain.
static const int MAX_OUTBOUND_FULL_RELAY_CONNECTIONS
Maximum number of automatic outgoing nodes over which we'll relay everything (blocks,...
static const int MAX_BLOCK_RELAY_ONLY_CONNECTIONS
Maximum number of block-relay-only outgoing connections.
static constexpr auto MINIMUM_CONNECT_TIME
Minimum time an outbound-peer-eviction candidate must be connected for, in order to evict.
std::string OnionToString(Span< const uint8_t > addr)
static constexpr size_t ADDR_TORV3_SIZE
Size of TORv3 address (in bytes).
#define BOOST_CHECK(expr)
ServiceFlags
nServices flags
static const int PROTOCOL_VERSION
network protocol versioning
int m_max_automatic_connections
void AddTestNode(CNode &node)
void FlushSendBuffer(CNode &node) const
void SetPeerConnectTimeout(std::chrono::seconds timeout)
Testing setup that configures a complete environment.
std::unique_ptr< CConnman > connman
std::unique_ptr< CTxMemPool > mempool
std::unique_ptr< AddrMan > addrman
std::unique_ptr< ChainstateManager > chainman
std::unique_ptr< node::Warnings > warnings
Manages all the node warnings.
std::unique_ptr< PeerManager > peerman
std::unique_ptr< const NetGroupManager > netgroupman
FastRandomContext g_insecure_rand_ctx
This global and the helpers that use it are not thread-safe.
void SetMockTime(int64_t nMockTimeIn)
DEPRECATED Use SetMockTime with chrono type.