Changeset View
Changeset View
Standalone View
Standalone View
test/functional/p2p_unrequested_blocks.py
Show First 20 Lines • Show All 355 Lines • ▼ Show 20 Lines | def run_test(self): | ||||
# Now send a new header on the invalid chain, indicating we're forked off, and expect to get disconnected | # Now send a new header on the invalid chain, indicating we're forked off, and expect to get disconnected | ||||
block_293 = create_block( | block_293 = create_block( | ||||
block_292.sha256, create_coinbase(293), block_292.nTime+1) | block_292.sha256, create_coinbase(293), block_292.nTime+1) | ||||
block_293.solve() | block_293.solve() | ||||
headers_message = msg_headers() | headers_message = msg_headers() | ||||
headers_message.headers.append(CBlockHeader(block_293)) | headers_message.headers.append(CBlockHeader(block_293)) | ||||
test_node.send_message(headers_message) | test_node.send_message(headers_message) | ||||
# FIXME: Uncomment this line once Core backport 015a525 is completed. | test_node.wait_for_disconnect() | ||||
# Current behavior does not ban peers that give us headers on invalid chains. | |||||
# test_node.wait_for_disconnect() | |||||
# 9. Connect node1 to node0 and ensure it is able to sync | # 9. Connect node1 to node0 and ensure it is able to sync | ||||
connect_nodes(self.nodes[0], self.nodes[1]) | connect_nodes(self.nodes[0], self.nodes[1]) | ||||
sync_blocks([self.nodes[0], self.nodes[1]]) | sync_blocks([self.nodes[0], self.nodes[1]]) | ||||
self.log.info("Successfully synced nodes 1 and 0") | self.log.info("Successfully synced nodes 1 and 0") | ||||
if __name__ == '__main__': | if __name__ == '__main__': | ||||
AcceptBlockTest().main() | AcceptBlockTest().main() |