Skip to content

bpo-31804: multiprocessing calls flush on sys.stdout at exit even if … #5492

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
SlaushVunter wants to merge 4 commits into from
Closed

bpo-31804: multiprocessing calls flush on sys.stdout at exit even if … #5492

Changes from 1 commit
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
cab49f2
bpo-31804: multiprocessing calls flush on sys.stdout at exit even if …
SlaushVunter Feb 2, 2018
fe03c62
bpo-31804: multiprocessing calls flush on sys.stdout at exit even if …
SlaushVunter Feb 12, 2018
e860a4f
bpo-31804: Review changes 2 - unit tests unified
SlaushVunter Feb 22, 2018
5e91e60
bpo-31804: Review changes 3 - decorate StringIO with _file_like and a…
SlaushVunter Feb 22, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
bpo-31804: Review changes 3 - decorate StringIO with _file_like and a… 
…dd close method to _file_like
  • Loading branch information
@SlaushVunter
SlaushVunter committed Feb 22, 2018
commit 5e91e604062f583b1a04b8045386cdc51b43dfbb
5 changes: 4 additions & 1 deletion Lib/test/_test_multiprocessing.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -588,7 +588,7 @@ def closeIO(stream_name, evt, type_):
if type_ == 'threads':
# it is safe to close std streams in another process, but if thread
# are used, we must not close the original std streams
closed_stream = io.StringIO()
closed_stream = _file_like(io.StringIO())
closed_stream.close()
setattr(sys, stream_name, closed_stream)
else:
Expand Down Expand Up @@ -3874,6 +3874,9 @@ def flush(self):
self._delegate.write(''.join(self.cache))
self._cache = []

def close(self):
self._delegate.close()

class TestStdinBadfiledescriptor(unittest.TestCase):

def test_queue_in_process(self):
Expand Down