pycompat: change users of pycompat.{stdin,stdout,stderr} to use procutil.std*

On Python 3, pycompat.{stdin,stdout,stderr} are usually block-buffered even if
connected to a TTY. procutil.{stdin,stdout,stderr} provide consistent behavior
across platforms and Python versions.

contrib/dumprevlog

@@ -28,7 +28,7 b' binopen.options = {}'
 
 def printb(data, end=b'\n'):
     sys.stdout.flush()
-    pycompat.stdout.write(data + end)
+    procutil.stdout.write(data + end)
 
 
 for f in sys.argv[1:]:

contrib/simplemerge

@@ -45,8 +45,8 b' class ParseError(Exception):'
 
 
 def showhelp():
-    pycompat.stdout.write(usage)
-    pycompat.stdout.write(b'\noptions:\n')
+    procutil.stdout.write(usage)
+    procutil.stdout.write(b'\noptions:\n')
 
     out_opts = []
     for shortopt, longopt, default, desc in options:
@@ -62,11 +62,11 b' def showhelp():'
         )
     opts_len = max([len(opt[0]) for opt in out_opts])
     for first, second in out_opts:
-        pycompat.stdout.write(b' %-*s  %s\n' % (opts_len, first, second))
+        procutil.stdout.write(b' %-*s  %s\n' % (opts_len, first, second))
 
 
 try:
-    for fp in (sys.stdin, pycompat.stdout, sys.stderr):
+    for fp in (sys.stdin, procutil.stdout, sys.stderr):
         procutil.setbinary(fp)
 
     opts = {}
@@ -92,11 +92,11 b' try:'
     )
 except ParseError as e:
     e = stringutil.forcebytestr(e)
-    pycompat.stdout.write(b"%s: %s\n" % (sys.argv[0].encode('utf8'), e))
+    procutil.stdout.write(b"%s: %s\n" % (sys.argv[0].encode('utf8'), e))
     showhelp()
     sys.exit(1)
 except error.Abort as e:
-    pycompat.stderr.write(b"abort: %s\n" % e)
+    procutil.stderr.write(b"abort: %s\n" % e)
     sys.exit(255)
 except KeyboardInterrupt:
     sys.exit(255)

contrib/undumprevlog

@@ -9,7 +9,6 b' import sys'
 from mercurial import (
     encoding,
     node,
-    pycompat,
     revlog,
     transaction,
     vfs as vfsmod,
@@ -30,7 +29,7 b' while True:'
     if l.startswith("file:"):
         f = encoding.strtolocal(l[6:-1])
         r = revlog.revlog(opener, f)
-        pycompat.stdout.write(b'%s\n' % f)
+        procutil.stdout.write(b'%s\n' % f)
     elif l.startswith("node:"):
         n = node.bin(l[6:-1])
     elif l.startswith("linkrev:"):

hgext/releasenotes.py

@@ -30,7 +30,10 b' from mercurial import ('
     scmutil,
     util,
 )
-from mercurial.utils import stringutil
+from mercurial.utils import (
+    procutil,
+    stringutil,
+)
 
 cmdtable = {}
 command = registrar.command(cmdtable)
@@ -689,7 +692,7 b' def releasenotes(ui, repo, file_=None, *'
 def debugparsereleasenotes(ui, path, repo=None):
     """parse release notes and print resulting data structure"""
     if path == b'-':
-        text = pycompat.stdin.read()
+        text = procutil.stdin.read()
     else:
         with open(path, b'rb') as fh:
             text = fh.read()

tests/test-bundle2-format.t

@@ -22,8 +22,8 b' Create an extension to test bundle2 API'
   > from mercurial import changegroup
   > from mercurial import error
   > from mercurial import obsolete
-  > from mercurial import pycompat
   > from mercurial import registrar
+  > from mercurial.utils import procutil
   > 
   > 
   > try:
@@ -148,7 +148,7 b' Create an extension to test bundle2 API'
   >        bundler.newpart(b'output', data=genraise(), mandatory=False)
   > 
   >     if path is None:
-  >         file = pycompat.stdout
+  >         file = procutil.stdout
   >     else:
   >         file = open(path, 'wb')
   > 
@@ -181,7 +181,7 b' Create an extension to test bundle2 API'
   >         lock = repo.lock()
   >         tr = repo.transaction(b'processbundle')
   >         try:
-  >             unbundler = bundle2.getunbundler(ui, pycompat.stdin)
+  >             unbundler = bundle2.getunbundler(ui, procutil.stdin)
   >             op = bundle2.processbundle(repo, unbundler, lambda: tr)
   >             tr.close()
   >         except error.BundleValueError as exc:
@@ -192,7 +192,7 b' Create an extension to test bundle2 API'
   >         if tr is not None:
   >             tr.release()
   >         lock.release()
-  >         remains = pycompat.stdin.read()
+  >         remains = procutil.stdin.read()
   >         ui.write(b'%i unread bytes\n' % len(remains))
   >     if op.records[b'song']:
   >         totalverses = sum(r[b'verses'] for r in op.records[b'song'])
@@ -207,7 +207,7 b' Create an extension to test bundle2 API'
   > @command(b'statbundle2', [], b'')
   > def cmdstatbundle2(ui, repo):
   >     """print statistic on the bundle2 container read from stdin"""
-  >     unbundler = bundle2.getunbundler(ui, pycompat.stdin)
+  >     unbundler = bundle2.getunbundler(ui, procutil.stdin)
   >     try:
   >         params = unbundler.params
   >     except error.BundleValueError as exc:

tests/test-debugcommands.t

@@ -573,11 +573,13 b' Test internal debugstacktrace command'
   $ cat > debugstacktrace.py << EOF
   > from __future__ import absolute_import
   > from mercurial import (
-  >     pycompat,
   >     util,
   > )
+  > from mercurial.utils import (
+  >     procutil,
+  > )
   > def f():
-  >     util.debugstacktrace(f=pycompat.stdout)
+  >     util.debugstacktrace(f=procutil.stdout)
   >     g()
   > def g():
   >     util.dst(b'hello from g\\n', skip=1)
@@ -588,15 +590,15 b' Test internal debugstacktrace command'
   > EOF
   $ "$PYTHON" debugstacktrace.py
   stacktrace at:
-   *debugstacktrace.py:14 in * (glob)
-   *debugstacktrace.py:7  in f (glob)
+   *debugstacktrace.py:16 in * (glob)
+   *debugstacktrace.py:9  in f (glob)
   hello from g at:
-   *debugstacktrace.py:14 in * (glob)
-   *debugstacktrace.py:8  in f (glob)
+   *debugstacktrace.py:16 in * (glob)
+   *debugstacktrace.py:10 in f (glob)
   hi ...
   from h hidden in g at:
-   *debugstacktrace.py:8  in f (glob)
-   *debugstacktrace.py:11 in g (glob)
+   *debugstacktrace.py:10 in f (glob)
+   *debugstacktrace.py:13 in g (glob)
 
 Test debugcapabilities command:
 

tests/test-help.t

@@ -1917,9 +1917,9 b' such str.lower().'
   > EOF
 
   $ "$PYTHON" <<EOF | sh
-  > from mercurial import pycompat
+  > from mercurial.utils import procutil
   > upper = b"\x8bL\x98^"
-  > pycompat.stdout.write(b"hg --encoding cp932 help -e ambiguous.%s\n" % upper)
+  > procutil.stdout.write(b"hg --encoding cp932 help -e ambiguous.%s\n" % upper)
   > EOF
   \x8bL\x98^ (esc)
   ----
@@ -1928,9 +1928,9 b' such str.lower().'
   
 
   $ "$PYTHON" <<EOF | sh
-  > from mercurial import pycompat
+  > from mercurial.utils import procutil
   > lower = b"\x8bl\x98^"
-  > pycompat.stdout.write(b"hg --encoding cp932 help -e ambiguous.%s\n" % lower)
+  > procutil.stdout.write(b"hg --encoding cp932 help -e ambiguous.%s\n" % lower)
   > EOF
   \x8bl\x98^ (esc)
   ----

tests/test-hgweb-non-interactive.t

@@ -14,10 +14,12 b' by the WSGI standard and strictly implem'
   >     dispatch,
   >     encoding,
   >     hg,
-  >     pycompat,
   >     ui as uimod,
   >     util,
   > )
+  > from mercurial.utils import (
+  >     procutil,
+  > )
   > ui = uimod.ui
   > from mercurial.hgweb import hgweb_mod
   > stringio = util.stringio
@@ -69,8 +71,8 b' by the WSGI standard and strictly implem'
   > for c in i(env, startrsp):
   >     pass
   > sys.stdout.flush()
-  > pycompat.stdout.write(b'---- ERRORS\n')
-  > pycompat.stdout.write(b'%s\n' % errors.getvalue())
+  > procutil.stdout.write(b'---- ERRORS\n')
+  > procutil.stdout.write(b'%s\n' % errors.getvalue())
   > print('---- OS.ENVIRON wsgi variables')
   > print(sorted([x for x in os.environ if x.startswith('wsgi')]))
   > print('---- request.ENVIRON wsgi variables')

tests/test-import-context.t

@@ -19,9 +19,8 b' Test applying context diffs'
   > EOF
   $ cat > cat.py <<EOF
   > import sys
-  > from mercurial import pycompat
-  > from mercurial.utils import stringutil
-  > pycompat.stdout.write(b'%s\n'
+  > from mercurial.utils import procutil, stringutil
+  > procutil.stdout.write(b'%s\n'
   >                       % stringutil.pprint(open(sys.argv[1], 'rb').read()))
   > EOF
 

tests/test-lfs.t

@@ -697,6 +697,7 b" absence doesn't cause an abort.)"
   >     revlog,
   > )
   > from mercurial.utils import (
+  >     procutil,
   >     stringutil,
   > )
   > def hash(rawtext):
@@ -713,7 +714,7 b" absence doesn't cause an abort.)"
   >         texts = [fl.rawdata(i) for i in fl]
   >         flags = [int(fl._revlog.flags(i)) for i in fl]
   >         hashes = [hash(t) for t in texts]
-  >         pycompat.stdout.write(b'  %s: rawsizes=%r flags=%r hashes=%s\n'
+  >         procutil.stdout.write(b'  %s: rawsizes=%r flags=%r hashes=%s\n'
   >                               % (name, sizes, flags, stringutil.pprint(hashes)))
   > EOF
 

tests/test-template-functions.t

@@ -1575,15 +1575,15 b' Test cbor filter:'
   > from __future__ import absolute_import
   > from mercurial import (
   >     dispatch,
-  >     pycompat,
   > )
   > from mercurial.utils import (
   >     cborutil,
+  >     procutil,
   >     stringutil,
   > )
   > dispatch.initstdio()
-  > items = cborutil.decodeall(pycompat.stdin.read())
-  > pycompat.stdout.write(stringutil.pprint(items, indent=1) + b'\n')
+  > items = cborutil.decodeall(procutil.stdin.read())
+  > procutil.stdout.write(stringutil.pprint(items, indent=1) + b'\n')
   > EOF
 
   $ hg log -T "{rev|cbor}" -R a -l2 | "$PYTHON" "$TESTTMP/decodecbor.py"

tests/test-template-map.t

@@ -675,20 +675,20 b' test CBOR style:'
   > from __future__ import absolute_import
   > from mercurial import (
   >     dispatch,
-  >     pycompat,
   > )
   > from mercurial.utils import (
   >     cborutil,
+  >     procutil,
   >     stringutil,
   > )
   > dispatch.initstdio()
-  > data = pycompat.stdin.read()
+  > data = procutil.stdin.read()
   > # our CBOR decoder doesn't support parsing indefinite-length arrays,
   > # but the log output is indefinite stream by nature.
   > assert data[:1] == cborutil.BEGIN_INDEFINITE_ARRAY
   > assert data[-1:] == cborutil.BREAK
   > items = cborutil.decodeall(data[1:-1])
-  > pycompat.stdout.write(stringutil.pprint(items, indent=1) + b'\n')
+  > procutil.stdout.write(stringutil.pprint(items, indent=1) + b'\n')
   > EOF
 
   $ hg log -k nosuch -Tcbor | "$PYTHON" "$TESTTMP/decodecborarray.py"