File tree 3 files changed +0
-42
lines changed
3 files changed +0
-42
lines changed Original file line number Diff line number Diff line change @@ -625,23 +625,16 @@ class BaseDefaultEventLoopPolicy(AbstractEventLoopPolicy):
625
625
626
626
class _Local (threading .local ):
627
627
_loop = None
628
- _pid = None
629
628
_set_called = False
630
629
631
630
def __init__ (self ):
632
631
self ._local = self ._Local ()
633
- self ._local ._pid = os .getpid ()
634
632
635
633
def get_event_loop (self ):
636
634
"""Get the event loop.
637
635
638
636
This may be None or an instance of EventLoop.
639
637
"""
640
- if self ._local ._pid != os .getpid ():
641
- # If we detect we're in a child process forked by multiprocessing,
642
- # we reset self._local so that we'll get a new event loop.
643
- self ._local = self ._Local ()
644
-
645
638
if (self ._local ._loop is None and
646
639
not self ._local ._set_called and
647
640
isinstance (threading .current_thread (), threading ._MainThread )):
Original file line number Diff line number Diff line change 13
13
import tempfile
14
14
import threading
15
15
import unittest
16
- import multiprocessing
17
16
from unittest import mock
18
17
from test import support
19
18
@@ -1805,37 +1804,6 @@ def create_watcher(self):
1805
1804
return asyncio .FastChildWatcher ()
1806
1805
1807
1806
1808
- class ForkedProcessTests (unittest .TestCase ):
1809
- def setUp (self ):
1810
- self .parent_loop = asyncio .SelectorEventLoop ()
1811
- asyncio .set_event_loop (self .parent_loop )
1812
- self .ctx = multiprocessing .get_context ("fork" )
1813
-
1814
- def tearDown (self ):
1815
- self .parent_loop .close ()
1816
-
1817
- def _check_loops_not_equal (self , old_loop ):
1818
- loop = asyncio .get_event_loop ()
1819
- if loop is old_loop :
1820
- raise RuntimeError ("Child process inherited parent's event loop" )
1821
-
1822
- try :
1823
- val = loop .run_until_complete (asyncio .sleep (0.05 , result = 42 ))
1824
- if val != 42 :
1825
- raise RuntimeError ("new event loop does not work" )
1826
- finally :
1827
- loop .close ()
1828
-
1829
- sys .exit (loop is old_loop )
1830
-
1831
- def test_new_loop_in_child (self ):
1832
- p = self .ctx .Process (target = self ._check_loops_not_equal ,
1833
- args = (self .parent_loop ,))
1834
- p .start ()
1835
- p .join ()
1836
- self .assertEqual (p .exitcode , 0 )
1837
-
1838
-
1839
1807
class PolicyTests (unittest .TestCase ):
1840
1808
1841
1809
def create_policy (self ):
Load Diff This file was deleted.
You can’t perform that action at this time.
0 commit comments