Changeset View
Changeset View
Standalone View
Standalone View
test/functional/test_framework/test_node.py
Show First 20 Lines • Show All 242 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(wallet_name) | wallet_path = "wallet/{}".format(wallet_name) | ||||
return self.rpc / wallet_path | return self.rpc / wallet_path | ||||
def stop_node(self, expected_stderr=''): | def stop_node(self, expected_stderr='', wait=0): | ||||
"""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() | 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.") | ||||
# Check that stderr is as expected | # Check that stderr is as expected | ||||
self.stderr.seek(0) | self.stderr.seek(0) | ||||
stderr = self.stderr.read().decode('utf-8').strip() | stderr = self.stderr.read().decode('utf-8').strip() | ||||
if stderr != expected_stderr: | if stderr != expected_stderr: | ||||
raise AssertionError( | raise AssertionError( | ||||
▲ Show 20 Lines • Show All 227 Lines • Show Last 20 Lines |