X-Git-Url: https://arthur.barton.de/cgi-bin/gitweb.cgi?p=bup.git;a=blobdiff_plain;f=buptest.py;h=7c7cc2f37f1d04f13b5094edf285ee382dc1f823;hp=a50387212c5a8a68dbcc992d6db8079aa9cd3c42;hb=6b6559e405d264d4127211b935b21a3dda93ad93;hpb=544208fae44dfeaccb626c16f3a5c387f318d08f

diff --git a/buptest.py b/buptest.py
index a503872..7c7cc2f 100644
--- a/buptest.py
+++ b/buptest.py
@@ -11,6 +11,8 @@ import errno, os, subprocess, sys, tempfile
 from wvtest import WVPASSEQ, wvfailure_count
 
 from bup import helpers
+from bup.compat import str_type
+from bup.io import byte_stream
 
 
 @contextmanager
@@ -67,15 +69,18 @@ def run(cmd, check=True, input=None, **kwargs):
     out, err = p.communicate(input=input)
     if check and p.returncode != 0:
         raise Exception('subprocess %r failed with status %d%s'
-                        % (' '.join(map(quote, cmd)), p.returncode,
+                        % (cmd, p.returncode,
                            (', stderr: %r' % err) if err else ''))
     return ex_res(out=out, err=err, proc=p, rc=p.returncode)
 
 def logcmd(cmd):
-    if isinstance(cmd, basestring):
-        print(cmd, file=sys.stderr)
+    s = helpers.shstr(cmd)
+    if isinstance(cmd, str_type):
+        print(s, file=sys.stderr)
     else:
-        print(' '.join(map(quote, cmd)), file=sys.stderr)
+        # bytes - for now just continue to pass it through given
+        # bup-python wrapper
+        print(s.decode('iso-8859-1'), file=sys.stderr)
 
 def ex(cmd, **kwargs):
     """Print cmd to stderr and then run it as per ex(...).
@@ -85,7 +90,8 @@ def ex(cmd, **kwargs):
     logcmd(cmd)
     result = run(cmd, **kwargs)
     if result.err:
-        sys.stderr.write(result.err)
+        sys.stderr.flush()
+        byte_stream(sys.stderr).write(result.err)
     return result
 
 def exo(cmd, **kwargs):