Changeset View
Changeset View
Standalone View
Standalone View
test/functional/abc_p2p_avalanche.py
| Show First 20 Lines • Show All 131 Lines • ▼ Show 20 Lines | |||||
| class AvalancheTest(BitcoinTestFramework): | class AvalancheTest(BitcoinTestFramework): | ||||
| def set_test_params(self): | def set_test_params(self): | ||||
| self.setup_clean_chain = True | self.setup_clean_chain = True | ||||
| self.num_nodes = 2 | self.num_nodes = 2 | ||||
| self.extra_args = [ | self.extra_args = [ | ||||
| ['-enableavalanche=1', '-avacooldown=0'], | ['-enableavalanche=1', '-avacooldown=0'], | ||||
| ['-enableavalanche=1', '-avacooldown=0', '-noparkdeepreorg', '-maxreorgdepth=-1']] | ['-enableavalanche=1', '-avacooldown=0', '-noparkdeepreorg', '-maxreorgdepth=-1']] | ||||
| self.supports_cli = False | self.supports_cli = False | ||||
| self.rpc_timeout = 120 | |||||
| def run_test(self): | def run_test(self): | ||||
| node = self.nodes[0] | node = self.nodes[0] | ||||
| self.log.info("Check the node is signalling the avalanche service.") | self.log.info("Check the node is signalling the avalanche service.") | ||||
| assert_equal( | assert_equal( | ||||
| int(node.getnetworkinfo()['localservices'], 16) & NODE_AVALANCHE, | int(node.getnetworkinfo()['localservices'], 16) & NODE_AVALANCHE, | ||||
| NODE_AVALANCHE) | NODE_AVALANCHE) | ||||
| ▲ Show 20 Lines • Show All 236 Lines • ▼ Show 20 Lines | def run_test(self): | ||||
| "The proof verification should be delayed until IBD is complete") | "The proof verification should be delayed until IBD is complete") | ||||
| assert node.getblockchaininfo()["initialblockdownload"] is True | assert node.getblockchaininfo()["initialblockdownload"] is True | ||||
| # Our proof cannot be verified during IBD, so we should have no peer | # Our proof cannot be verified during IBD, so we should have no peer | ||||
| assert not node.getavalanchepeerinfo() | assert not node.getavalanchepeerinfo() | ||||
| # Mining a few more blocks should cause us to leave IBD | # Mining a few more blocks should cause us to leave IBD | ||||
| node.generate(2) | node.generate(2) | ||||
| # Our proof is now verified and our node is added as a peer | # Our proof is now verified and our node is added as a peer | ||||
| assert node.getblockchaininfo()["initialblockdownload"] is False | assert node.getblockchaininfo()["initialblockdownload"] is False | ||||
| assert_equal(len(node.getavalanchepeerinfo()), 1) | wait_until(lambda: len(node.getavalanchepeerinfo()) == 1, timeout=5) | ||||
| # Rebuild the quorum | # Rebuild the quorum | ||||
| self.log.info("Test the avahello signature") | self.log.info("Test the avahello signature") | ||||
| quorum = get_quorum() | quorum = get_quorum() | ||||
| poll_node = quorum[0] | poll_node = quorum[0] | ||||
| avahello = poll_node.wait_for_avahello().hello | avahello = poll_node.wait_for_avahello().hello | ||||
| ▲ Show 20 Lines • Show All 88 Lines • Show Last 20 Lines | |||||