summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorVictor Stinner <victor.stinner@gmail.com>2015-01-15 13:10:31 +0100
committerVictor Stinner <victor.stinner@gmail.com>2015-01-15 13:10:31 +0100
commit419ebd1308cd5086bc8bcb5199a4051b905ae9c0 (patch)
tree98fb5cc7765a19965a5cf65b55982fde220739d2
parent1acecaf9ed3ad034135ba55ee886f77cdc741f88 (diff)
downloadtrollius-419ebd1308cd5086bc8bcb5199a4051b905ae9c0.tar.gz
Python issue #23243: Close explicitly event loops in tests
-rw-r--r--tests/test_base_events.py1
-rw-r--r--tests/test_proactor_events.py4
-rw-r--r--tests/test_selector_events.py16
3 files changed, 20 insertions, 1 deletions
diff --git a/tests/test_base_events.py b/tests/test_base_events.py
index bd6c0d8..9e7c50c 100644
--- a/tests/test_base_events.py
+++ b/tests/test_base_events.py
@@ -590,6 +590,7 @@ class BaseEventLoopTests(test_utils.TestCase):
raise ValueError('spam')
loop = Loop()
+ self.addCleanup(loop.close)
asyncio.set_event_loop(loop)
def run_loop():
diff --git a/tests/test_proactor_events.py b/tests/test_proactor_events.py
index 8258238..08c622a 100644
--- a/tests/test_proactor_events.py
+++ b/tests/test_proactor_events.py
@@ -16,6 +16,7 @@ class ProactorSocketTransportTests(test_utils.TestCase):
def setUp(self):
self.loop = self.new_test_loop()
+ self.addCleanup(self.loop.close)
self.proactor = mock.Mock()
self.loop._proactor = self.proactor
self.protocol = test_utils.make_test_protocol(asyncio.Protocol)
@@ -459,6 +460,9 @@ class BaseProactorEventLoopTests(test_utils.TestCase):
self.assertIsNone(self.loop._ssock)
self.assertIsNone(self.loop._csock)
+ # Don't call close(): _close_self_pipe() cannot be called twice
+ self.loop._closed = True
+
def test_close(self):
self.loop._close_self_pipe = mock.Mock()
self.loop.close()
diff --git a/tests/test_selector_events.py b/tests/test_selector_events.py
index 3e8392e..f519419 100644
--- a/tests/test_selector_events.py
+++ b/tests/test_selector_events.py
@@ -24,6 +24,11 @@ MOCK_ANY = mock.ANY
class TestBaseSelectorEventLoop(BaseSelectorEventLoop):
+ def close(self):
+ # Don't call the close() method of the parent class, because the
+ # selector is mocked
+ self._closed = True
+
def _make_self_pipe(self):
self._ssock = mock.Mock()
self._csock = mock.Mock()
@@ -40,7 +45,7 @@ class BaseSelectorEventLoopTests(test_utils.TestCase):
self.selector = mock.Mock()
self.selector.select.return_value = []
self.loop = TestBaseSelectorEventLoop(self.selector)
- self.set_event_loop(self.loop, cleanup=False)
+ self.set_event_loop(self.loop)
def test_make_socket_transport(self):
m = mock.Mock()
@@ -76,6 +81,15 @@ class BaseSelectorEventLoopTests(test_utils.TestCase):
self.loop._make_ssl_transport(m, m, m, m)
def test_close(self):
+ class EventLoop(BaseSelectorEventLoop):
+ def _make_self_pipe(self):
+ self._ssock = mock.Mock()
+ self._csock = mock.Mock()
+ self._internal_fds += 1
+
+ self.loop = EventLoop(self.selector)
+ self.set_event_loop(self.loop)
+
ssock = self.loop._ssock
ssock.fileno.return_value = 7
csock = self.loop._csock