diff options
author | Kumar Aditya <kumaraditya@python.org> | 2024-07-01 04:47:36 (GMT) |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-07-01 04:47:36 (GMT) |
commit | bd473aa598c5161521a7018896dc124728214a6c (patch) | |
tree | 804fb037a9ee7efed79c9207075179bb2d548100 /Lib/test/test_asyncio | |
parent | 1a84bdc2371ada60c01c72493caba62c9860007b (diff) | |
download | cpython-bd473aa598c5161521a7018896dc124728214a6c.zip cpython-bd473aa598c5161521a7018896dc124728214a6c.tar.gz cpython-bd473aa598c5161521a7018896dc124728214a6c.tar.bz2 |
gh-87744: fix waitpid race while calling send_signal in asyncio (#121126)
asyncio earlier relied on subprocess module to send signals to the process, this has some drawbacks one being that subprocess module unnecessarily calls waitpid on child processes and hence it races with asyncio implementation which internally uses child watchers. To mitigate this, now asyncio sends signals directly to the process without going through the subprocess on non windows systems. On Windows it fallbacks to subprocess module handling but on windows there are no child watchers so this issue doesn't exists altogether.
Diffstat (limited to 'Lib/test/test_asyncio')
-rw-r--r-- | Lib/test/test_asyncio/test_subprocess.py | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/Lib/test/test_asyncio/test_subprocess.py b/Lib/test/test_asyncio/test_subprocess.py index 23987c7..5450130 100644 --- a/Lib/test/test_asyncio/test_subprocess.py +++ b/Lib/test/test_asyncio/test_subprocess.py @@ -864,6 +864,21 @@ class SubprocessMixin: self.loop.run_until_complete(main()) + @unittest.skipIf(sys.platform != 'linux', "Linux only") + def test_subprocess_send_signal_race(self): + # See https://github.com/python/cpython/issues/87744 + async def main(): + for _ in range(10): + proc = await asyncio.create_subprocess_exec('sleep', '0.1') + await asyncio.sleep(0.1) + try: + proc.send_signal(signal.SIGUSR1) + except ProcessLookupError: + pass + self.assertNotEqual(await proc.wait(), 255) + + self.loop.run_until_complete(main()) + if sys.platform != 'win32': # Unix |