diff options
author | Yury Selivanov <yury@magic.io> | 2018-05-30 00:47:56 (GMT) |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-05-30 00:47:56 (GMT) |
commit | 99279ad823a758288e4e41962abfc4dad8943ce8 (patch) | |
tree | f5f6c3dca3e98850adf7aac9a8fe88ba50042640 /Lib/test/test_asyncio/test_unix_events.py | |
parent | dec947ca26bd598a26869226dcac592a7ccf0d56 (diff) | |
download | cpython-99279ad823a758288e4e41962abfc4dad8943ce8.zip cpython-99279ad823a758288e4e41962abfc4dad8943ce8.tar.gz cpython-99279ad823a758288e4e41962abfc4dad8943ce8.tar.bz2 |
Revert "bpo-22087: Fix Policy.get_event_loop() to detect fork (GH-7208)" (#7232)
This reverts commit 5d97b7bcc19496617bf8c448d2f149cc28c73bc7.
Diffstat (limited to 'Lib/test/test_asyncio/test_unix_events.py')
-rw-r--r-- | Lib/test/test_asyncio/test_unix_events.py | 32 |
1 files changed, 0 insertions, 32 deletions
diff --git a/Lib/test/test_asyncio/test_unix_events.py b/Lib/test/test_asyncio/test_unix_events.py index 1bc2d86..a01efed 100644 --- a/Lib/test/test_asyncio/test_unix_events.py +++ b/Lib/test/test_asyncio/test_unix_events.py @@ -13,7 +13,6 @@ import sys import tempfile import threading import unittest -import multiprocessing from unittest import mock from test import support @@ -1805,37 +1804,6 @@ class FastChildWatcherTests (ChildWatcherTestsMixin, test_utils.TestCase): return asyncio.FastChildWatcher() -class ForkedProcessTests(unittest.TestCase): - def setUp(self): - self.parent_loop = asyncio.SelectorEventLoop() - asyncio.set_event_loop(self.parent_loop) - self.ctx = multiprocessing.get_context("fork") - - def tearDown(self): - self.parent_loop.close() - - def _check_loops_not_equal(self, old_loop): - loop = asyncio.get_event_loop() - if loop is old_loop: - raise RuntimeError("Child process inherited parent's event loop") - - try: - val = loop.run_until_complete(asyncio.sleep(0.05, result=42)) - if val != 42: - raise RuntimeError("new event loop does not work") - finally: - loop.close() - - sys.exit(loop is old_loop) - - def test_new_loop_in_child(self): - p = self.ctx.Process(target=self._check_loops_not_equal, - args=(self.parent_loop,)) - p.start() - p.join() - self.assertEqual(p.exitcode, 0) - - class PolicyTests(unittest.TestCase): def create_policy(self): |