mirror of https://github.com/python/cpython.git
Merged revisions 86207 via svnmerge from
svn+ssh://pythondev@svn.python.org/python/branches/py3k ........ r86207 | brian.curtin | 2010-11-05 12:09:05 -0500 (Fri, 05 Nov 2010) | 2 lines Fix a number of ResourceWarnings on Windows due to open pipes. ........
This commit is contained in:
parent
91a5b818e0
commit
7fe045ef00
|
@ -345,6 +345,9 @@ def test_communicate(self):
|
|||
stdin=subprocess.PIPE,
|
||||
stdout=subprocess.PIPE,
|
||||
stderr=subprocess.PIPE)
|
||||
self.addCleanup(p.stdout.close)
|
||||
self.addCleanup(p.stderr.close)
|
||||
self.addCleanup(p.stdin.close)
|
||||
(stdout, stderr) = p.communicate("banana")
|
||||
self.assertEqual(stdout, "banana")
|
||||
self.assertStderrEqual(stderr, "pineapple")
|
||||
|
@ -393,6 +396,9 @@ def test_communicate_pipe_buf(self):
|
|||
stdin=subprocess.PIPE,
|
||||
stdout=subprocess.PIPE,
|
||||
stderr=subprocess.PIPE)
|
||||
self.addCleanup(p.stdout.close)
|
||||
self.addCleanup(p.stderr.close)
|
||||
self.addCleanup(p.stdin.close)
|
||||
string_to_write = "abc"*pipe_buf
|
||||
(stdout, stderr) = p.communicate(string_to_write)
|
||||
self.assertEqual(stdout, string_to_write)
|
||||
|
@ -405,6 +411,9 @@ def test_writes_before_communicate(self):
|
|||
stdin=subprocess.PIPE,
|
||||
stdout=subprocess.PIPE,
|
||||
stderr=subprocess.PIPE)
|
||||
self.addCleanup(p.stdout.close)
|
||||
self.addCleanup(p.stderr.close)
|
||||
self.addCleanup(p.stdin.close)
|
||||
p.stdin.write("banana")
|
||||
(stdout, stderr) = p.communicate("split")
|
||||
self.assertEqual(stdout, "bananasplit")
|
||||
|
@ -454,6 +463,8 @@ def test_universal_newlines_communicate(self):
|
|||
'sys.stdout.write("\\nline6");'],
|
||||
stdout=subprocess.PIPE, stderr=subprocess.PIPE,
|
||||
universal_newlines=1)
|
||||
self.addCleanup(p.stdout.close)
|
||||
self.addCleanup(p.stderr.close)
|
||||
(stdout, stderr) = p.communicate()
|
||||
if hasattr(file, 'newlines'):
|
||||
# Interpreter with universal newline support
|
||||
|
@ -820,6 +831,7 @@ def test_shell_sequence(self):
|
|||
p = subprocess.Popen(["set"], shell=1,
|
||||
stdout=subprocess.PIPE,
|
||||
env=newenv)
|
||||
self.addCleanup(p.stdout.close)
|
||||
self.assertIn("physalis", p.stdout.read())
|
||||
|
||||
def test_shell_string(self):
|
||||
|
@ -829,6 +841,7 @@ def test_shell_string(self):
|
|||
p = subprocess.Popen("set", shell=1,
|
||||
stdout=subprocess.PIPE,
|
||||
env=newenv)
|
||||
self.addCleanup(p.stdout.close)
|
||||
self.assertIn("physalis", p.stdout.read())
|
||||
|
||||
def test_call_string(self):
|
||||
|
@ -848,6 +861,9 @@ def _kill_process(self, method, *args):
|
|||
stdin=subprocess.PIPE,
|
||||
stdout=subprocess.PIPE,
|
||||
stderr=subprocess.PIPE)
|
||||
self.addCleanup(p.stdout.close)
|
||||
self.addCleanup(p.stderr.close)
|
||||
self.addCleanup(p.stdin.close)
|
||||
# Wait for the interpreter to be completely initialized before
|
||||
# sending any signal.
|
||||
p.stdout.read(1)
|
||||
|
@ -917,6 +933,7 @@ def tearDown(self):
|
|||
def with_spaces(self, *args, **kwargs):
|
||||
kwargs['stdout'] = subprocess.PIPE
|
||||
p = subprocess.Popen(*args, **kwargs)
|
||||
self.addCleanup(p.stdout.close)
|
||||
self.assertEqual(
|
||||
p.stdout.read ().decode("mbcs"),
|
||||
"2 [%r, 'ab cd']" % self.fname
|
||||
|
|
Loading…
Reference in New Issue