Page MenuHomePhabricator
Differential D6762 Diff 21839 src/test/avalanche_tests.cpp

Changeset View

Standalone View

View Options

src/test/avalanche_tests.cpp

// Copyright (c) 2010-2020 The Bitcoin developers // Copyright (c) 2018-2020 The Bitcoin developers
// Distributed under the MIT software license, see the accompanying // Distributed under the MIT software license, see the accompanying
// file COPYING or http://www.opensource.org/licenses/mit-license.php. // file COPYING or http://www.opensource.org/licenses/mit-license.php.
#include <avalanche.h> #include <avalanche.h>
#include <config.h> #include <config.h>
#include <net_processing.h> // For PeerLogicValidation #include <net_processing.h> // For PeerLogicValidation
#include <util/time.h> #include <util/time.h>
▲ Show 20 Lines • Show All 629 Lines • ▼ Show 20 LinesBOOST_AUTO_TEST_CASE(poll_and_response) {
AvalancheTest::runEventLoop(p); AvalancheTest::runEventLoop(p);
BOOST_CHECK(p.registerVotes(avanodeid, resp, updates)); BOOST_CHECK(p.registerVotes(avanodeid, resp, updates));
BOOST_CHECK_EQUAL(updates.size(), 0); BOOST_CHECK_EQUAL(updates.size(), 0);
BOOST_CHECK_EQUAL(AvalancheTest::getSuitableNodeToQuery(p), avanodeid); BOOST_CHECK_EQUAL(AvalancheTest::getSuitableNodeToQuery(p), avanodeid);
connman->ClearNodes(); connman->ClearNodes();
} }
#if BOOST_VERSION >= 105900
BOOST_AUTO_TEST_CASE(poll_inflight_timeout, *boost::unit_test::timeout(60)) { BOOST_AUTO_TEST_CASE(poll_inflight_timeout, *boost::unit_test::timeout(60)) {
#else
// TODO: Cleanup this branch when boost 1.58 is no longer supported.
BOOST_AUTO_TEST_CASE(poll_inflight_timeout) {
int64_t timeStart = GetTimeMillis();
#endif
const Config &config = GetConfig(); const Config &config = GetConfig();
auto connman = std::make_unique<CConnmanTest>(config, 0x1337, 0x1337); auto connman = std::make_unique<CConnmanTest>(config, 0x1337, 0x1337);
auto peerLogic = std::make_unique<PeerLogicValidation>( auto peerLogic = std::make_unique<PeerLogicValidation>(
connman.get(), nullptr, *m_node.scheduler, false); connman.get(), nullptr, *m_node.scheduler, false);
AvalancheProcessor p(connman.get()); AvalancheProcessor p(connman.get());
Show All 15 Lines auto avanode =
ConnectNode(config, NODE_AVALANCHE, *peerLogic, connman.get()); ConnectNode(config, NODE_AVALANCHE, *peerLogic, connman.get());
NodeId avanodeid = avanode->GetId(); NodeId avanodeid = avanode->GetId();
BOOST_CHECK(p.addPeer(avanodeid, 0, CPubKey())); BOOST_CHECK(p.addPeer(avanodeid, 0, CPubKey()));
// Expire requests after some time. // Expire requests after some time.
auto queryTimeDuration = std::chrono::milliseconds(10); auto queryTimeDuration = std::chrono::milliseconds(10);
p.setQueryTimeoutDuration(queryTimeDuration); p.setQueryTimeoutDuration(queryTimeDuration);
for (int i = 0; i < 10; i++) { for (int i = 0; i < 10; i++) {
#if BOOST_VERSION < 105900
// TODO: Cleanup this statement when boost 1.58 is no longer supported.
BOOST_REQUIRE(timeStart + 60 * 1000 > GetTimeMillis());
#endif
AvalancheResponse resp = { AvalancheResponse resp = {
AvalancheTest::getRound(p), 0, {AvalancheVote(0, blockHash)}}; AvalancheTest::getRound(p), 0, {AvalancheVote(0, blockHash)}};
auto start = std::chrono::steady_clock::now(); auto start = std::chrono::steady_clock::now();
AvalancheTest::runEventLoop(p); AvalancheTest::runEventLoop(p);
// We cannot guarantee that we'll wait for just 1ms, so we have to bail // We cannot guarantee that we'll wait for just 1ms, so we have to bail
// if we aren't within the proper time range. // if we aren't within the proper time range.
std::this_thread::sleep_for(std::chrono::milliseconds(1)); std::this_thread::sleep_for(std::chrono::milliseconds(1));
▲ Show 20 Lines • Show All 277 Lines • Show Last 20 Lines