Changeset View
Changeset View
Standalone View
Standalone View
test/functional/p2p_unrequested_blocks.py
Show First 20 Lines • Show All 68 Lines • ▼ Show 20 Lines | from test_framework.mininode import ( | ||||
mininode_lock, | mininode_lock, | ||||
P2PInterface, | P2PInterface, | ||||
) | ) | ||||
from test_framework.test_framework import BitcoinTestFramework | from test_framework.test_framework import BitcoinTestFramework | ||||
from test_framework.util import ( | from test_framework.util import ( | ||||
assert_equal, | assert_equal, | ||||
assert_raises_rpc_error, | assert_raises_rpc_error, | ||||
connect_nodes, | connect_nodes, | ||||
sync_blocks, | |||||
) | ) | ||||
class AcceptBlockTest(BitcoinTestFramework): | class AcceptBlockTest(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 | ||||
▲ Show 20 Lines • Show All 260 Lines • ▼ Show 20 Lines | def run_test(self): | ||||
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) | ||||
test_node.wait_for_disconnect() | 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]]) | self.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() |