mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-10-06 15:11:58 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 10

[3.6] bpo-28326: Fix multiprocessing.Process when stdout and/or stderr is closed or None. (GH-4073). (#4075)

Browse source 
* bpo-28326: Fix multiprocessing.Process when stdout and/or stderr is closed or None. (#4073)

(cherry picked from commit daeefd2e04)

* [3.6] bpo-28326: Fix multiprocessing.Process when stdout and/or stderr is closed or None. (GH-4073).
(cherry picked from commit daeefd2e04)
This commit is contained in:
Antoine Pitrou 2017-10-22 12:27:13 +02:00 • committed by GitHub
parent 1e78ed6825
commit 34ef6da8f5
3 changed files with 30 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

21
Lib/test/_test_multiprocessing.py
View file

@ -425,6 +425,27 @@ class _TestProcess(BaseTestCase):
self.assertEqual(q.get(), 5)
close_queue(q)
@classmethod
def _test_error_on_stdio_flush(self, evt):
evt.set()
def test_error_on_stdio_flush(self):
streams = [io.StringIO(), None]
streams[0].close()
for stream_name in ('stdout', 'stderr'):
for stream in streams:
old_stream = getattr(sys, stream_name)
setattr(sys, stream_name, stream)
try:
evt = self.Event()
proc = self.Process(target=self._test_error_on_stdio_flush,
args=(evt,))
proc.start()
proc.join()
self.assertTrue(evt.is_set())
finally:
setattr(sys, stream_name, old_stream)
#
#