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

This commit is contained in:
Antoine Pitrou 2017-10-22 11:40:31 +02:00 committed by GitHub
parent 73c4708630
commit daeefd2e04
3 changed files with 30 additions and 2 deletions

View file

@ -582,6 +582,27 @@ class _TestProcess(BaseTestCase):
proc.join()
self.assertTrue(evt.is_set())
@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)
#
#