Changeset View
Changeset View
Standalone View
Standalone View
test/functional/rpc_net.py
| Show All 9 Lines | |||||
| from decimal import Decimal | from decimal import Decimal | ||||
| 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_greater_than_or_equal, | assert_greater_than_or_equal, | ||||
| assert_greater_than, | assert_greater_than, | ||||
| assert_raises_rpc_error, | assert_raises_rpc_error, | ||||
| connect_nodes_bi, | connect_nodes, | ||||
| p2p_port, | p2p_port, | ||||
| wait_until, | wait_until, | ||||
| ) | ) | ||||
| from test_framework.mininode import P2PInterface | from test_framework.mininode import P2PInterface | ||||
| from test_framework.messages import CAddress, msg_addr, NODE_NETWORK | from test_framework.messages import CAddress, msg_addr, NODE_NETWORK | ||||
| class NetTest(BitcoinTestFramework): | class NetTest(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 = [["-minrelaytxfee=0.00001000"], | self.extra_args = [["-minrelaytxfee=0.00001000"], | ||||
| ["-minrelaytxfee=0.00000500"]] | ["-minrelaytxfee=0.00000500"]] | ||||
| def run_test(self): | def run_test(self): | ||||
| self.log.info('Connect nodes both way') | |||||
| connect_nodes(self.nodes[0], self.nodes[1]) | |||||
| connect_nodes(self.nodes[1], self.nodes[0]) | |||||
| self._test_connection_count() | self._test_connection_count() | ||||
| self._test_getnettotals() | self._test_getnettotals() | ||||
| self._test_getnetworkinginfo() | self._test_getnetworkinginfo() | ||||
| self._test_getaddednodeinfo() | self._test_getaddednodeinfo() | ||||
| self._test_getpeerinfo() | self._test_getpeerinfo() | ||||
| self._test_getnodeaddresses() | self._test_getnodeaddresses() | ||||
| def _test_connection_count(self): | def _test_connection_count(self): | ||||
| ▲ Show 20 Lines • Show All 48 Lines • ▼ Show 20 Lines | def _test_getnetworkinginfo(self): | ||||
| self.nodes[0].setnetworkactive(state=False) | self.nodes[0].setnetworkactive(state=False) | ||||
| assert_equal(self.nodes[0].getnetworkinfo()['networkactive'], False) | assert_equal(self.nodes[0].getnetworkinfo()['networkactive'], False) | ||||
| # Wait a bit for all sockets to close | # Wait a bit for all sockets to close | ||||
| wait_until(lambda: self.nodes[0].getnetworkinfo()[ | wait_until(lambda: self.nodes[0].getnetworkinfo()[ | ||||
| 'connections'] == 0, timeout=3) | 'connections'] == 0, timeout=3) | ||||
| self.nodes[0].setnetworkactive(state=True) | self.nodes[0].setnetworkactive(state=True) | ||||
| connect_nodes_bi(self.nodes[0], self.nodes[1]) | self.log.info('Connect nodes both way') | ||||
| connect_nodes(self.nodes[0], self.nodes[1]) | |||||
| connect_nodes(self.nodes[1], self.nodes[0]) | |||||
| assert_equal(self.nodes[0].getnetworkinfo()['networkactive'], True) | assert_equal(self.nodes[0].getnetworkinfo()['networkactive'], True) | ||||
| assert_equal(self.nodes[0].getnetworkinfo()['connections'], 2) | assert_equal(self.nodes[0].getnetworkinfo()['connections'], 2) | ||||
| def _test_getaddednodeinfo(self): | def _test_getaddednodeinfo(self): | ||||
| assert_equal(self.nodes[0].getaddednodeinfo(), []) | assert_equal(self.nodes[0].getaddednodeinfo(), []) | ||||
| # add a node (node2) to node0 | # add a node (node2) to node0 | ||||
| ip_port = "127.0.0.1:{}".format(p2p_port(2)) | ip_port = "127.0.0.1:{}".format(p2p_port(2)) | ||||
| self.nodes[0].addnode(node=ip_port, command='add') | self.nodes[0].addnode(node=ip_port, command='add') | ||||
| ▲ Show 20 Lines • Show All 58 Lines • Show Last 20 Lines | |||||