Changeset View
Changeset View
Standalone View
Standalone View
test/functional/rpc_net.py
| Show First 20 Lines • Show All 78 Lines • ▼ Show 20 Lines | def _test_getnettotals(self): | ||||
| after['bytesrecv_per_msg']['pong'], before['bytesrecv_per_msg']['pong'] + 32) | after['bytesrecv_per_msg']['pong'], before['bytesrecv_per_msg']['pong'] + 32) | ||||
| assert_greater_than_or_equal( | assert_greater_than_or_equal( | ||||
| after['bytessent_per_msg']['ping'], before['bytessent_per_msg']['ping'] + 32) | after['bytessent_per_msg']['ping'], before['bytessent_per_msg']['ping'] + 32) | ||||
| def _test_getnetworkinginfo(self): | def _test_getnetworkinginfo(self): | ||||
| 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) | ||||
| self.nodes[0].setnetworkactive(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(True) | self.nodes[0].setnetworkactive(state=True) | ||||
| connect_nodes_bi(self.nodes[0], self.nodes[1]) | connect_nodes_bi(self.nodes[0], self.nodes[1]) | ||||
| 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(ip_port, 'add') | self.nodes[0].addnode(node=ip_port, command='add') | ||||
| # check that the node has indeed been added | # check that the node has indeed been added | ||||
| added_nodes = self.nodes[0].getaddednodeinfo(ip_port) | added_nodes = self.nodes[0].getaddednodeinfo(ip_port) | ||||
| assert_equal(len(added_nodes), 1) | assert_equal(len(added_nodes), 1) | ||||
| assert_equal(added_nodes[0]['addednode'], ip_port) | assert_equal(added_nodes[0]['addednode'], ip_port) | ||||
| # check that a non-existent node returns an error | # check that a non-existent node returns an error | ||||
| assert_raises_rpc_error(-24, "Node has not been added", | assert_raises_rpc_error(-24, "Node has not been added", | ||||
| self.nodes[0].getaddednodeinfo, '1.1.1.1') | self.nodes[0].getaddednodeinfo, '1.1.1.1') | ||||
| ▲ Show 20 Lines • Show All 50 Lines • Show Last 20 Lines | |||||