8000 make fork + exec non blocking on unix by Martiusweb · Pull Request #428 · python/asyncio · GitHub
[go: up one dir, main page]
Skip to content
This repository was archived by the owner on Nov 23, 2017. It is now read-only.

make fork + exec non blocking on unix #428

Open
wants to merge 7 commits into
base: master
Choose a base branch
from
Open

make fork + exec non blocking on unix #428

Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
8fef3fe
make fork + exec non blocking on unix
Martiusweb Sep 26, 2016
6aa4e30
compatibility with Python 3.3
Martiusweb Sep 27, 2016
71cf406
preexec_fn not supported on windows
Martiusweb Oct 5, 2016
a77c0ff
handle asynchronous exceptions when creating SubprocessTransport
Martiusweb Oct 6, 2016
0cf2e73
errpipe_read must be non-blocking
Martiusweb Oct 11, 2016
ef41fc8
make asyncio backward compatible with older Popen
Martiusweb Nov 9, 2016
b3a81e0
drop the mockey-patch of Popen in python 3.3
Martiusweb Nov 9, 2016
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
Next Next commit
preexec_fn not supported on windows
  • Loading branch information
@Martiusweb
Martiusweb committed Nov 8, 2016
commit 71cf40645e41d83e89261df70197f2ed39945d03
2 changes: 2 additions & 0 deletions tests/test_subprocess.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -167,6 +167,7 @@ def test_terminate(self):
else:
self.assertEqual(-signal.SIGTERM, returncode)

@unittest.skipIf(sys.platform == 'win32', "Don't support preexec_fn")
def test_exception_in_preexec(self):
def raise_exception():
raise Exception("custom exception")
Expand All @@ -185,6 +186,7 @@ def raise_exception():
self.assertEqual("Exception occurred in preexec_fn.",
str(ctx.exception))

@unittest.skipIf(sys.platform == 'win32', "Don't support preexec_fn")
def test_cancel_during_preexec(self):
lock = multiprocessing.Lock()
lock.acquire()
Expand Down
0