Changeset View
Changeset View
Standalone View
Standalone View
test/functional/example_test.py
| Show First 20 Lines • Show All 111 Lines • ▼ Show 20 Lines | def setup_network(self): | ||||
| If you do override this method, remember to start the nodes, assign | If you do override this method, remember to start the nodes, assign | ||||
| them to self.nodes, connect them and then sync.""" | them to self.nodes, connect them and then sync.""" | ||||
| self.setup_nodes() | self.setup_nodes() | ||||
| # In this test, we're not connecting node2 to node0 or node1. Calls to | # In this test, we're not connecting node2 to node0 or node1. Calls to | ||||
| # sync_all() should not include node2, since we're not expecting it to | # sync_all() should not include node2, since we're not expecting it to | ||||
| # sync. | # sync. | ||||
| connect_nodes(self.nodes[0], 1) | connect_nodes(self.nodes[0], self.nodes[1]) | ||||
| self.sync_all([self.nodes[0:1]]) | self.sync_all([self.nodes[0:1]]) | ||||
| # Use setup_nodes() to customize the node start behaviour (for example if | # Use setup_nodes() to customize the node start behaviour (for example if | ||||
| # you don't want to start all nodes at the start of the test). | # you don't want to start all nodes at the start of the test). | ||||
| # def setup_nodes(): | # def setup_nodes(): | ||||
| # pass | # pass | ||||
| def custom_method(self): | def custom_method(self): | ||||
| ▲ Show 20 Lines • Show All 64 Lines • ▼ Show 20 Lines | def run_test(self): | ||||
| self.block_time += 1 | self.block_time += 1 | ||||
| height += 1 | height += 1 | ||||
| self.log.info( | self.log.info( | ||||
| "Wait for node1 to reach current tip (height 11) using RPC") | "Wait for node1 to reach current tip (height 11) using RPC") | ||||
| self.nodes[1].waitforblockheight(11) | self.nodes[1].waitforblockheight(11) | ||||
| self.log.info("Connect node2 and node1") | self.log.info("Connect node2 and node1") | ||||
| connect_nodes(self.nodes[1], 2) | connect_nodes(self.nodes[1], self.nodes[2]) | ||||
| self.log.info("Add P2P connection to node2") | self.log.info("Add P2P connection to node2") | ||||
| node2 = BaseNode() | node2 = BaseNode() | ||||
| connections.append( | connections.append( | ||||
| NodeConn('127.0.0.1', p2p_port(2), self.nodes[2], node2)) | NodeConn('127.0.0.1', p2p_port(2), self.nodes[2], node2)) | ||||
| node2.add_connection(connections[1]) | node2.add_connection(connections[1]) | ||||
| node2.wait_for_verack() | node2.wait_for_verack() | ||||
| Show All 24 Lines | |||||