summaryrefslogtreecommitdiffstats
path: root/Lib/test/test_asyncio
diff options
context:
space:
mode:
authorKumar Aditya <kumaraditya@python.org>2024-07-01 04:47:36 (GMT)
committerGitHub <noreply@github.com>2024-07-01 04:47:36 (GMT)
commitbd473aa598c5161521a7018896dc124728214a6c (patch)
tree804fb037a9ee7efed79c9207075179bb2d548100 /Lib/test/test_asyncio
parent1a84bdc2371ada60c01c72493caba62c9860007b (diff)
downloadcpython-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.py15
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