( )⚙ D11085 sigpipe-remote: check environment variable sooner

This is an archive of the discontinued Mercurial Phabricator instance.

Differential D11085

sigpipe-remote: check environment variable sooner
ClosedPublic

Authored by marmoute on Jul 11 2021, 11:59 PM.

Details

Reviewers
Alphare
Group Reviewers
hg-reviewers
Commits
rHGdf6148ca7120: sigpipe-remote: check environment variable sooner
Summary

Lets make sure we have everything before doing anything.

Diff Detail

Repository
rHG Mercurial
Branch
default
Lint
No Linters Available
Unit
No Unit Test Coverage

Event Timeline

marmoute created this revision.Jul 11 2021, 11:59 PM
Alphare accepted this revision.Jul 13 2021, 12:26 PM
This revision is now accepted and ready to land.Jul 13 2021, 12:26 PM
marmoute added a commit: rHGdf6148ca7120: sigpipe-remote: check environment variable sooner.Jul 16 2021, 1:04 AM
Closed by commit rHGdf6148ca7120: sigpipe-remote: check environment variable sooner (authored by marmoute). · Explain Why
This revision was automatically updated to reflect the committed changes.

Revision Contents
Changeset List

PathPackages
Mtests/testlib/sigpipe-remote.py (30 lines)

Diff 29203

tests/testlib/sigpipe-remote.py

# will only install the mercurial module for python2 in python2 run # will only install the mercurial module for python2 in python2 run
if sys.version_info[0] < 3: if sys.version_info[0] < 3:
ver = '.'.join(str(x) for x in sys.version_info) ver = '.'.join(str(x) for x in sys.version_info)
exe = sys.executable exe = sys.executable
print('SIGPIPE-HELPER: script should run with Python 3', file=sys.stderr) print('SIGPIPE-HELPER: script should run with Python 3', file=sys.stderr)
print('SIGPIPE-HELPER: %s is running %s' % (exe, ver), file=sys.stderr) print('SIGPIPE-HELPER: %s is running %s' % (exe, ver), file=sys.stderr)
sys.exit(255) sys.exit(255)
DEBUG_FILE = os.environ.get('SIGPIPE_REMOTE_DEBUG_FILE')
if DEBUG_FILE is None:
debug_stream = sys.stderr.buffer
else:
debug_stream = open(DEBUG_FILE, 'bw', buffering=0)
SYNCFILE1 = os.environ.get('SYNCFILE1')
SYNCFILE2 = os.environ.get('SYNCFILE2')
if SYNCFILE1 is None:
print('SIGPIPE-HELPER: missing variable $SYNCFILE1', file=sys.stderr)
sys.exit(255)
if SYNCFILE2 is None:
print('SIGPIPE-HELPER: missing variable $SYNCFILE2', file=sys.stderr)
sys.exit(255)
def _timeout_factor(): def _timeout_factor():
"""return the current modification to timeout""" """return the current modification to timeout"""
default = int(os.environ.get('HGTEST_TIMEOUT_DEFAULT', 360)) default = int(os.environ.get('HGTEST_TIMEOUT_DEFAULT', 360))
current = int(os.environ.get('HGTEST_TIMEOUT', default)) current = int(os.environ.get('HGTEST_TIMEOUT', default))
if current == 0: if current == 0:
return 1 return 1
return current / float(default) return current / float(default)
piped_stdout = os.pipe2(os.O_NONBLOCK | os.O_CLOEXEC) piped_stdout = os.pipe2(os.O_NONBLOCK | os.O_CLOEXEC)
piped_stderr = os.pipe2(os.O_NONBLOCK | os.O_CLOEXEC) piped_stderr = os.pipe2(os.O_NONBLOCK | os.O_CLOEXEC)
stdout_writer = os.fdopen(piped_stdout[1], "rb") stdout_writer = os.fdopen(piped_stdout[1], "rb")
stdout_reader = os.fdopen(piped_stdout[0], "rb") stdout_reader = os.fdopen(piped_stdout[0], "rb")
stderr_writer = os.fdopen(piped_stderr[1], "rb") stderr_writer = os.fdopen(piped_stderr[1], "rb")
stderr_reader = os.fdopen(piped_stderr[0], "rb") stderr_reader = os.fdopen(piped_stderr[0], "rb")
DEBUG_FILE = os.environ.get('SIGPIPE_REMOTE_DEBUG_FILE')
if DEBUG_FILE is None:
debug_stream = sys.stderr.buffer
else:
debug_stream = open(DEBUG_FILE, 'bw', buffering=0)
SYNCFILE1 = os.environ.get('SYNCFILE1')
SYNCFILE2 = os.environ.get('SYNCFILE2')
if SYNCFILE1 is None:
print('SIGPIPE-HELPER: missing variable $SYNCFILE1', file=sys.stderr)
sys.exit(255)
if SYNCFILE2 is None:
print('SIGPIPE-HELPER: missing variable $SYNCFILE2', file=sys.stderr)
sys.exit(255)
debug_stream.write(b'SIGPIPE-HELPER: Starting\n') debug_stream.write(b'SIGPIPE-HELPER: Starting\n')
TESTLIB_DIR = os.path.dirname(sys.argv[0]) TESTLIB_DIR = os.path.dirname(sys.argv[0])
WAIT_SCRIPT = os.path.join(TESTLIB_DIR, 'wait-on-file') WAIT_SCRIPT = os.path.join(TESTLIB_DIR, 'wait-on-file')
hooks_cmd = '%s 10 %s %s' hooks_cmd = '%s 10 %s %s'
hooks_cmd %= ( hooks_cmd %= (
WAIT_SCRIPT, WAIT_SCRIPT,