Changeset View
Changeset View
Standalone View
Standalone View
test/functional/test_framework/test_node.py
| Show First 20 Lines • Show All 361 Lines • ▼ Show 20 Lines | def get_wallet_rpc(self, wallet_name): | ||||
| else: | else: | ||||
| assert self.rpc is not None, self._node_msg( | assert self.rpc is not None, self._node_msg( | ||||
| "Error: RPC not initialized") | "Error: RPC not initialized") | ||||
| assert self.rpc_connected, self._node_msg( | assert self.rpc_connected, self._node_msg( | ||||
| "Error: RPC not connected") | "Error: RPC not connected") | ||||
| wallet_path = "wallet/{}".format(urllib.parse.quote(wallet_name)) | wallet_path = "wallet/{}".format(urllib.parse.quote(wallet_name)) | ||||
| return RPCOverloadWrapper(self.rpc / wallet_path) | return RPCOverloadWrapper(self.rpc / wallet_path) | ||||
| def stop_node(self, expected_stderr='', wait=0): | def stop_node(self, expected_stderr='', *, wait=0, | ||||
| wait_until_stopped=True): | |||||
| """Stop the node.""" | """Stop the node.""" | ||||
| if not self.running: | if not self.running: | ||||
| return | return | ||||
| self.log.debug("Stopping node") | self.log.debug("Stopping node") | ||||
| try: | try: | ||||
| self.stop(wait=wait) | self.stop(wait=wait) | ||||
| except http.client.CannotSendRequest: | except http.client.CannotSendRequest: | ||||
| self.log.exception("Unable to stop node.") | self.log.exception("Unable to stop node.") | ||||
| Show All 9 Lines | def stop_node(self, expected_stderr='', *, wait=0, | ||||
| raise AssertionError( | raise AssertionError( | ||||
| "Unexpected stderr {} != {}".format(stderr, expected_stderr)) | "Unexpected stderr {} != {}".format(stderr, expected_stderr)) | ||||
| self.stdout.close() | self.stdout.close() | ||||
| self.stderr.close() | self.stderr.close() | ||||
| del self.p2ps[:] | del self.p2ps[:] | ||||
| if wait_until_stopped: | |||||
| self.wait_until_stopped() | |||||
| def is_node_stopped(self): | def is_node_stopped(self): | ||||
| """Checks whether the node has stopped. | """Checks whether the node has stopped. | ||||
| Returns True if the node has stopped. False otherwise. | Returns True if the node has stopped. False otherwise. | ||||
| This method is responsible for freeing resources (self.process).""" | This method is responsible for freeing resources (self.process).""" | ||||
| if not self.running: | if not self.running: | ||||
| return True | return True | ||||
| return_code = self.process.poll() | return_code = self.process.poll() | ||||
| ▲ Show 20 Lines • Show All 455 Lines • Show Last 20 Lines | |||||