Merge #13867: qa: Make extended tests pass on native Windows

fafe73a626 qa: Raise feature_help timeout to 5s (MarcoFalke)
faabd7bc47 qa: Use files for stdout/stderr to support Windows (MarcoFalke)
facb56ffaf qa: Run gen_rpcauth with sys.executable (MarcoFalke)
fada8966c5 qa: Close stdout and stderr file when node stops (MarcoFalke)

Pull request description:

  ### qa: Close stdout and stderr file when node stops

  Since these files are potentially deleted by the test framework for cleanup, they should be closed first. Otherwise this will lead to errors on Windows when the tests finish successfully.

  Side note: After the patch, it is no longer possible to reopen the file on Windows (see https://docs.python.org/3/library/tempfile.html#tempfile.NamedTemporaryFile)

  ### qa: Run gen_rpcauth with sys.executable

  Similar to `test_runner.py`, the `sys.executable` needs to be passed down into subprocesses to pass on native Windows. (Should have no effect on Linux)

  ###   qa: Use files for stdout/stderr to support Windows

  It seems that using PIPE is not supported on Windows. Also, it is easier to just use the files that capture the stdout and stderr within the test node class.

Tree-SHA512: ec675012b10705978606b7fcbdb287c39a8e6e3732aae2fa4041d963a3c6993c6eac6a9a3cbd5479514e7d8017fe74c12235d1ed6fed2e8af8f3c71981e91864
This commit is contained in:
MarcoFalke 2018-08-11 07:01:29 -04:00 committed by UdjinM6
parent 290a23a9e4
commit 2972dbb951
No known key found for this signature in database
GPG Key ID: 83592BD1400D58D9
3 changed files with 42 additions and 33 deletions

View File

@ -3,7 +3,6 @@
# Distributed under the MIT software license, see the accompanying # Distributed under the MIT software license, see the accompanying
# file COPYING or http://www.opensource.org/licenses/mit-license.php. # file COPYING or http://www.opensource.org/licenses/mit-license.php.
"""Verify that starting dashd with -h works as expected.""" """Verify that starting dashd with -h works as expected."""
import subprocess
from test_framework.test_framework import BitcoinTestFramework from test_framework.test_framework import BitcoinTestFramework
from test_framework.util import assert_equal from test_framework.util import assert_equal
@ -17,35 +16,15 @@ class HelpTest(BitcoinTestFramework):
self.add_nodes(self.num_nodes) self.add_nodes(self.num_nodes)
# Don't start the node # Don't start the node
def run_test(self): def get_node_output(self, *, ret_code_expected):
self.log.info("Start dashd with -h for help text") ret_code = self.nodes[0].process.wait(timeout=5)
self.nodes[0].start(extra_args=['-h'], stderr=subprocess.PIPE, stdout=subprocess.PIPE) assert_equal(ret_code, ret_code_expected)
# Node should exit immediately and output help to stdout. self.nodes[0].stdout.seek(0)
ret_code = self.nodes[0].process.wait(timeout=1) self.nodes[0].stderr.seek(0)
assert_equal(ret_code, 0) out = self.nodes[0].stdout.read()
output = self.nodes[0].process.stdout.read() err = self.nodes[0].stderr.read()
assert b'Options' in output self.nodes[0].stdout.close()
self.log.info("Help text received: {} (...)".format(output[0:60])) self.nodes[0].stderr.close()
self.nodes[0].running = False
self.log.info("Start dashd with -version for version information")
self.nodes[0].start(extra_args=['-version'], stderr=subprocess.PIPE, stdout=subprocess.PIPE)
# Node should exit immediately and output version to stdout.
ret_code = self.nodes[0].process.wait(timeout=1)
assert_equal(ret_code, 0)
output = self.nodes[0].process.stdout.read()
assert b'version' in output
self.log.info("Version text received: {} (...)".format(output[0:60]))
# Test that arguments not in the help results in an error
self.log.info("Start dashdd with -fakearg to make sure it does not start")
self.nodes[0].start(extra_args=['-fakearg'], stderr=subprocess.PIPE, stdout=subprocess.PIPE)
# Node should exit immediately and output an error to stderr
ret_code = self.nodes[0].process.wait(timeout=1)
assert_equal(ret_code, 1)
output = self.nodes[0].process.stderr.read()
assert b'Error parsing command line arguments' in output
self.log.info("Error message received: {} (...)".format(output[0:60]))
# Clean up TestNode state # Clean up TestNode state
self.nodes[0].running = False self.nodes[0].running = False
@ -53,5 +32,31 @@ class HelpTest(BitcoinTestFramework):
self.nodes[0].rpc_connected = False self.nodes[0].rpc_connected = False
self.nodes[0].rpc = None self.nodes[0].rpc = None
return out, err
def run_test(self):
self.log.info("Start dashd with -h for help text")
self.nodes[0].start(extra_args=['-h'])
# Node should exit immediately and output help to stdout.
output, _ = self.get_node_output(ret_code_expected=0)
assert b'Options' in output
self.log.info("Help text received: {} (...)".format(output[0:60]))
self.log.info("Start dashd with -version for version information")
self.nodes[0].start(extra_args=['-version'])
# Node should exit immediately and output version to stdout.
output, _ = self.get_node_output(ret_code_expected=0)
assert b'version' in output
self.log.info("Version text received: {} (...)".format(output[0:60]))
# Test that arguments not in the help results in an error
self.log.info("Start dashdd with -fakearg to make sure it does not start")
self.nodes[0].start(extra_args=['-fakearg'])
# Node should exit immediately and output an error to stderr
_, output = self.get_node_output(ret_code_expected=1)
assert b'Error parsing command line arguments' in output
self.log.info("Error message received: {} (...)".format(output[0:60]))
if __name__ == '__main__': if __name__ == '__main__':
HelpTest().main() HelpTest().main()

View File

@ -18,6 +18,7 @@ import subprocess
from random import SystemRandom from random import SystemRandom
import string import string
import configparser import configparser
import sys
class HTTPBasicsTest(BitcoinTestFramework): class HTTPBasicsTest(BitcoinTestFramework):
@ -36,7 +37,7 @@ class HTTPBasicsTest(BitcoinTestFramework):
config = configparser.ConfigParser() config = configparser.ConfigParser()
config.read_file(open(self.options.configfile)) config.read_file(open(self.options.configfile))
gen_rpcauth = config['environment']['RPCAUTH'] gen_rpcauth = config['environment']['RPCAUTH']
p = subprocess.Popen([gen_rpcauth, self.user], stdout=subprocess.PIPE, universal_newlines=True) p = subprocess.Popen([sys.executable, gen_rpcauth, self.user], stdout=subprocess.PIPE, universal_newlines=True)
lines = p.stdout.read().splitlines() lines = p.stdout.read().splitlines()
rpcauth3 = lines[1] rpcauth3 = lines[1]
self.password = lines[3] self.password = lines[3]

View File

@ -132,7 +132,7 @@ class TestNode():
assert self.rpc_connected and self.rpc is not None, self._node_msg("Error: no RPC connection") assert self.rpc_connected and self.rpc is not None, self._node_msg("Error: no RPC connection")
return getattr(self.rpc, name) return getattr(self.rpc, name)
def start(self, extra_args=None, stdout=None, stderr=None, *args, **kwargs): def start(self, extra_args=None, *, stdout=None, stderr=None, **kwargs):
"""Start the node.""" """Start the node."""
if extra_args is None: if extra_args is None:
extra_args = self.extra_args extra_args = self.extra_args
@ -157,7 +157,7 @@ class TestNode():
# add environment variable LIBC_FATAL_STDERR_=1 so that libc errors are written to stderr and not the terminal # add environment variable LIBC_FATAL_STDERR_=1 so that libc errors are written to stderr and not the terminal
subp_env = dict(os.environ, LIBC_FATAL_STDERR_="1") subp_env = dict(os.environ, LIBC_FATAL_STDERR_="1")
self.process = subprocess.Popen(all_args, env=subp_env, stdout=stdout, stderr=stderr, *args, **kwargs) self.process = subprocess.Popen(all_args, env=subp_env, stdout=stdout, stderr=stderr, **kwargs)
self.running = True self.running = True
self.log.debug("dashd started, waiting for RPC to come up") self.log.debug("dashd started, waiting for RPC to come up")
@ -216,6 +216,9 @@ class TestNode():
if stderr != expected_stderr: if stderr != expected_stderr:
raise AssertionError("Unexpected stderr {} != {}".format(stderr, expected_stderr)) raise AssertionError("Unexpected stderr {} != {}".format(stderr, expected_stderr))
self.stdout.close()
self.stderr.close()
del self.p2ps[:] del self.p2ps[:]
def is_node_stopped(self): def is_node_stopped(self):