Changeset View
Changeset View
Standalone View
Standalone View
src/avalanche/test/processor_tests.cpp
Show First 20 Lines • Show All 107 Lines • ▼ Show 20 Lines | AvalancheTestingSetup() | ||||
*m_node.scheduler, *m_node.chainman, *m_node.mempool, false); | *m_node.scheduler, *m_node.chainman, *m_node.mempool, false); | ||||
m_node.chain = interfaces::MakeChain(m_node, config.GetChainParams()); | m_node.chain = interfaces::MakeChain(m_node, config.GetChainParams()); | ||||
// Get the processor ready. | // Get the processor ready. | ||||
bilingual_str error; | bilingual_str error; | ||||
m_processor = Processor::MakeProcessor(*m_node.args, *m_node.chain, | m_processor = Processor::MakeProcessor(*m_node.args, *m_node.chain, | ||||
m_node.connman.get(), error); | m_node.connman.get(), error); | ||||
BOOST_CHECK(m_processor); | BOOST_CHECK(m_processor); | ||||
gArgs.ForceSetArg("-avaproofstakeutxoconfirmations", "1"); | |||||
} | } | ||||
~AvalancheTestingSetup() { | ~AvalancheTestingSetup() { | ||||
m_connman->ClearNodes(); | m_connman->ClearNodes(); | ||||
SyncWithValidationInterfaceQueue(); | SyncWithValidationInterfaceQueue(); | ||||
gArgs.ClearForcedArg("-avaproofstakeutxoconfirmations"); | |||||
} | } | ||||
CNode *ConnectNode(ServiceFlags nServices) { | CNode *ConnectNode(ServiceFlags nServices) { | ||||
static NodeId id = 0; | static NodeId id = 0; | ||||
CAddress addr(ip(GetRandInt(0xffffffff)), NODE_NONE); | CAddress addr(ip(GetRandInt(0xffffffff)), NODE_NONE); | ||||
auto node = | auto node = | ||||
new CNode(id++, ServiceFlags(NODE_NETWORK), INVALID_SOCKET, addr, | new CNode(id++, ServiceFlags(NODE_NETWORK), INVALID_SOCKET, addr, | ||||
▲ Show 20 Lines • Show All 1,003 Lines • ▼ Show 20 Lines | BOOST_AUTO_TEST_CASE(quorum_detection) { | ||||
gArgs.ForceSetArg("-avaminquorumstake", ToString(minStake)); | gArgs.ForceSetArg("-avaminquorumstake", ToString(minStake)); | ||||
gArgs.ForceSetArg("-avaminquorumconnectedstakeratio", "0.5"); | gArgs.ForceSetArg("-avaminquorumconnectedstakeratio", "0.5"); | ||||
// Create a new processor with our given quorum parameters | // Create a new processor with our given quorum parameters | ||||
const auto currency = Currency::get(); | const auto currency = Currency::get(); | ||||
uint32_t minScore = Proof::amountToScore(minStake * currency.baseunit); | uint32_t minScore = Proof::amountToScore(minStake * currency.baseunit); | ||||
const CKey key = CKey::MakeCompressedKey(); | const CKey key = CKey::MakeCompressedKey(); | ||||
auto localProof = buildRandomProof(minScore / 4, 1234, key); | auto localProof = buildRandomProof(minScore / 4, 100, key); | ||||
gArgs.ForceSetArg("-avamasterkey", EncodeSecret(key)); | gArgs.ForceSetArg("-avamasterkey", EncodeSecret(key)); | ||||
gArgs.ForceSetArg("-avaproof", localProof->ToHex()); | gArgs.ForceSetArg("-avaproof", localProof->ToHex()); | ||||
bilingual_str error; | bilingual_str error; | ||||
std::unique_ptr<Processor> processor = Processor::MakeProcessor( | std::unique_ptr<Processor> processor = Processor::MakeProcessor( | ||||
*m_node.args, *m_node.chain, m_node.connman.get(), error); | *m_node.args, *m_node.chain, m_node.connman.get(), error); | ||||
BOOST_CHECK(processor != nullptr); | BOOST_CHECK(processor != nullptr); | ||||
▲ Show 20 Lines • Show All 304 Lines • Show Last 20 Lines |