Changeset View
Changeset View
Standalone View
Standalone View
test/functional/feature_minchainwork.py
| Show First 20 Lines • Show All 41 Lines • ▼ Show 20 Lines | def setup_network(self): | ||||
| for i in range(self.num_nodes-1): | for i in range(self.num_nodes-1): | ||||
| connect_nodes(self.nodes[i+1], self.nodes[i]) | connect_nodes(self.nodes[i+1], self.nodes[i]) | ||||
| def run_test(self): | def run_test(self): | ||||
| # Start building a chain on node0. node2 shouldn't be able to sync until node1's | # Start building a chain on node0. node2 shouldn't be able to sync until node1's | ||||
| # minchainwork is exceeded | # minchainwork is exceeded | ||||
| starting_chain_work = REGTEST_WORK_PER_BLOCK # Genesis block's work | starting_chain_work = REGTEST_WORK_PER_BLOCK # Genesis block's work | ||||
| self.log.info( | self.log.info( | ||||
| "Testing relay across node %d (minChainWork = %d)", 1, self.node_min_work[1]) | "Testing relay across node {} (minChainWork = {})".format( | ||||
| 1, self.node_min_work[1])) | |||||
| starting_blockcount = self.nodes[2].getblockcount() | starting_blockcount = self.nodes[2].getblockcount() | ||||
| num_blocks_to_generate = int( | num_blocks_to_generate = int( | ||||
| (self.node_min_work[1] - starting_chain_work) / REGTEST_WORK_PER_BLOCK) | (self.node_min_work[1] - starting_chain_work) / REGTEST_WORK_PER_BLOCK) | ||||
| self.log.info("Generating %d blocks on node0", num_blocks_to_generate) | self.log.info("Generating {} blocks on node0".format( | ||||
| num_blocks_to_generate)) | |||||
| hashes = self.nodes[0].generate(num_blocks_to_generate) | hashes = self.nodes[0].generate(num_blocks_to_generate) | ||||
| self.log.info("Node0 current chain work: %s", | self.log.info("Node0 current chain work: {}".format( | ||||
| self.nodes[0].getblockheader(hashes[-1])['chainwork']) | self.nodes[0].getblockheader(hashes[-1])['chainwork'])) | ||||
| # Sleep a few seconds and verify that node2 didn't get any new blocks | # Sleep a few seconds and verify that node2 didn't get any new blocks | ||||
| # or headers. We sleep, rather than sync_blocks(node0, node1) because | # or headers. We sleep, rather than sync_blocks(node0, node1) because | ||||
| # it's reasonable either way for node1 to get the blocks, or not get | # it's reasonable either way for node1 to get the blocks, or not get | ||||
| # them (since they're below node1's minchainwork). | # them (since they're below node1's minchainwork). | ||||
| time.sleep(3) | time.sleep(3) | ||||
| self.log.info("Verifying node 2 has no more blocks than before") | self.log.info("Verifying node 2 has no more blocks than before") | ||||
| self.log.info("Blockcounts: %s", [ | self.log.info("Blockcounts: {}".format( | ||||
| n.getblockcount() for n in self.nodes]) | [n.getblockcount() for n in self.nodes])) | ||||
| # Node2 shouldn't have any new headers yet, because node1 should not | # Node2 shouldn't have any new headers yet, because node1 should not | ||||
| # have relayed anything. | # have relayed anything. | ||||
| assert_equal(len(self.nodes[2].getchaintips()), 1) | assert_equal(len(self.nodes[2].getchaintips()), 1) | ||||
| assert_equal(self.nodes[2].getchaintips()[0]['height'], 0) | assert_equal(self.nodes[2].getchaintips()[0]['height'], 0) | ||||
| assert self.nodes[1].getbestblockhash( | assert self.nodes[1].getbestblockhash( | ||||
| ) != self.nodes[0].getbestblockhash() | ) != self.nodes[0].getbestblockhash() | ||||
| assert_equal(self.nodes[2].getblockcount(), starting_blockcount) | assert_equal(self.nodes[2].getblockcount(), starting_blockcount) | ||||
| self.log.info("Generating one more block") | self.log.info("Generating one more block") | ||||
| self.nodes[0].generate(1) | self.nodes[0].generate(1) | ||||
| self.log.info("Verifying nodes are all synced") | self.log.info("Verifying nodes are all synced") | ||||
| # Because nodes in regtest are all manual connections (eg using | # Because nodes in regtest are all manual connections (eg using | ||||
| # addnode), node1 should not have disconnected node0. If not for that, | # addnode), node1 should not have disconnected node0. If not for that, | ||||
| # we'd expect node1 to have disconnected node0 for serving an | # we'd expect node1 to have disconnected node0 for serving an | ||||
| # insufficient work chain, in which case we'd need to reconnect them to | # insufficient work chain, in which case we'd need to reconnect them to | ||||
| # continue the test. | # continue the test. | ||||
| self.sync_all() | self.sync_all() | ||||
| self.log.info("Blockcounts: %s", [ | self.log.info("Blockcounts: {}".format( | ||||
| n.getblockcount() for n in self.nodes]) | [n.getblockcount() for n in self.nodes])) | ||||
| if __name__ == '__main__': | if __name__ == '__main__': | ||||
| MinimumChainWorkTest().main() | MinimumChainWorkTest().main() | ||||