( )⚙ D11086 sigpipe-remote: verify the script is IO are unbuffered

This is an archive of the discontinued Mercurial Phabricator instance.

Differential D11086

sigpipe-remote: verify the script is IO are unbuffered
ClosedPublic

Authored by marmoute on Jul 12 2021, 12:00 AM.

Details

Reviewers
Alphare
Group Reviewers
hg-reviewers
Commits
rHGd5fc1b59a2df: sigpipe-remote: verify the script is IO are unbuffered
Summary

We don't want to get stuck anywhere by buffers.

Diff Detail

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

Revision Contents
Changeset List

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

Diff 29204

tests/testlib/sigpipe-remote.py

#!/usr/bin/env python3 #!/usr/bin/env python3
from __future__ import print_function from __future__ import print_function
import io
import os import os
import subprocess import subprocess
import sys import sys
import threading import threading
import time import time
# we cannot use mercurial.testing as long as python2 is not dropped as the test # we cannot use mercurial.testing as long as python2 is not dropped as the test
# 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)
if isinstance(sys.stdout.buffer, io.BufferedWriter):
print('SIGPIPE-HELPER: script need unbuffered output', file=sys.stderr)
sys.exit(255)
DEBUG_FILE = os.environ.get('SIGPIPE_REMOTE_DEBUG_FILE') DEBUG_FILE = os.environ.get('SIGPIPE_REMOTE_DEBUG_FILE')
if DEBUG_FILE is None: if DEBUG_FILE is None:
debug_stream = sys.stderr.buffer debug_stream = sys.stderr.buffer
else: else:
debug_stream = open(DEBUG_FILE, 'bw', buffering=0) debug_stream = open(DEBUG_FILE, 'bw', buffering=0)
SYNCFILE1 = os.environ.get('SYNCFILE1') SYNCFILE1 = os.environ.get('SYNCFILE1')
SYNCFILE2 = os.environ.get('SYNCFILE2') SYNCFILE2 = os.environ.get('SYNCFILE2')