(original) (raw)

changeset: 68684:16a386443055 parent: 68683:64eeb4cd4b56 parent: 68681:cb148da52c47 user: Skip Montanaro skip@pobox.com date: Sat Mar 19 13:03:33 2011 -0500 description: merge from upstream diff -r 64eeb4cd4b56 -r 16a386443055 Doc/library/platform.rst --- a/Doc/library/platform.rst Sat Mar 19 09:15:28 2011 -0500 +++ b/Doc/library/platform.rst Sat Mar 19 13:03:33 2011 -0500 @@ -208,7 +208,7 @@ Win95/98 specific ^^^^^^^^^^^^^^^^^ -.. function:: popen(cmd, mode='r', bufsize=None) +.. function:: popen(cmd, mode='r', bufsize=-1) Portable :func:`popen` interface. Find a working popen implementation preferring :func:`win32pipe.popen`. On Windows NT, :func:`win32pipe.popen` diff -r 64eeb4cd4b56 -r 16a386443055 Lib/os.py --- a/Lib/os.py Sat Mar 19 09:15:28 2011 -0500 +++ b/Lib/os.py Sat Mar 19 13:03:33 2011 -0500 @@ -779,11 +779,13 @@ return bs # Supply os.popen() -def popen(cmd, mode="r", buffering=None): +def popen(cmd, mode="r", buffering=-1): if not isinstance(cmd, str): raise TypeError("invalid cmd type (%s, expected string)" % type(cmd)) if mode not in ("r", "w"): raise ValueError("invalid mode %r" % mode) + if buffering == 0 or buffering == None: + raise ValueError("popen() does not support unbuffered streams") import subprocess, io if mode == "r": proc = subprocess.Popen(cmd, diff -r 64eeb4cd4b56 -r 16a386443055 Lib/platform.py --- a/Lib/platform.py Sat Mar 19 09:15:28 2011 -0500 +++ b/Lib/platform.py Sat Mar 19 13:03:33 2011 -0500 @@ -357,7 +357,7 @@ supported_dists=supported_dists, full_distribution_name=0) -def popen(cmd, mode='r', bufsize=None): +def popen(cmd, mode='r', bufsize=-1): """ Portable popen() interface. """ diff -r 64eeb4cd4b56 -r 16a386443055 Lib/subprocess.py --- a/Lib/subprocess.py Sat Mar 19 09:15:28 2011 -0500 +++ b/Lib/subprocess.py Sat Mar 19 13:03:33 2011 -0500 @@ -743,8 +743,6 @@ if errread != -1: errread = msvcrt.open_osfhandle(errread.Detach(), 0) - if bufsize == 0: - bufsize = 1 # Nearly unbuffered (XXX for now) if p2cwrite != -1: self.stdin = io.open(p2cwrite, 'wb', bufsize) if self.universal_newlines: diff -r 64eeb4cd4b56 -r 16a386443055 Lib/test/test_subprocess.py --- a/Lib/test/test_subprocess.py Sat Mar 19 09:15:28 2011 -0500 +++ b/Lib/test/test_subprocess.py Sat Mar 19 13:03:33 2011 -0500 @@ -1315,6 +1315,22 @@ " non-zero with this error:\n%s" % stderr.decode('utf-8')) + def test_select_unbuffered(self): + # Issue #11459: bufsize=0 should really set the pipes as + # unbuffered (and therefore let select() work properly). + select = support.import_module("select") + p = subprocess.Popen([sys.executable, "-c", + 'import sys;' + 'sys.stdout.write("apple")'], + stdout=subprocess.PIPE, + bufsize=0) + f = p.stdout + try: + self.assertEqual(f.read(4), b"appl") + self.assertIn(f, select.select([f], [], [], 0.0)[0]) + finally: + p.wait() + @unittest.skipUnless(mswindows, "Windows specific tests") class Win32ProcessTestCase(BaseTestCase): diff -r 64eeb4cd4b56 -r 16a386443055 Misc/NEWS --- a/Misc/NEWS Sat Mar 19 09:15:28 2011 -0500 +++ b/Misc/NEWS Sat Mar 19 13:03:33 2011 -0500 @@ -75,6 +75,9 @@ Library ------- +- Issue #11459: A ``bufsize`` value of 0 in subprocess.Popen() really creates + unbuffered pipes, such that select() works properly on them. + - Issue #5421: Fix misleading error message when one of socket.sendto()'s arguments has the wrong type. Patch by Nikita Vetoshkin. /skip@pobox.com