[Author Prev][Author Next][Thread Prev][Thread Next][Author Index][Thread Index]
[tor-commits] [stem/master] Lingering thread due to recent event unit tests
commit bc06836ee87169da8118ff985fc87ea6880ca219
Author: Damian Johnson <atagar@xxxxxxxxxxxxxx>
Date: Sun Aug 12 13:56:45 2018 -0700
Lingering thread due to recent event unit tests
Oops, new tests for #27053 didn't close the threads of the mock controller it
created. Unit tests passed because we don't check for lingering tests, but if
ran along with our integ tests the test run concluded with...
Threads lingering after test run:
<_MainThread(MainThread, started 140086124480256)>
<Thread(Event Notifier, started daemon 140085629839104)>
<Thread(Event Notifier, started daemon 140085657794304)>
<Thread(Event Notifier, started daemon 140085638756096)>
Tracked this down by dumping the internal attributes of those controllers.
They had mocks from these tests, providing the eureka to get the root cause.
---
docs/change_log.rst | 2 +-
test/unit/control/controller.py | 63 +++++++++++++++++++++++++----------------
2 files changed, 40 insertions(+), 25 deletions(-)
diff --git a/docs/change_log.rst b/docs/change_log.rst
index 75a25847..9f4049e6 100644
--- a/docs/change_log.rst
+++ b/docs/change_log.rst
@@ -46,8 +46,8 @@ The following are only available within Stem's `git repository
* **Controller**
- * Documented v3 hidden service support (:trac:`25124`, :spec:`6bd0a69`)
* Listener exceptions and malformed events no longer break further event processing (:trac:`27053`)
+ * Documented v3 hidden service support (:trac:`25124`, :spec:`6bd0a69`)
* Added the stem.control.MALFORMED_EVENTS event listener constant
* Added support for limiting the maximum number of streams to :func:`~stem.control.Controller.create_ephemeral_hidden_service` (:spec:`2fcb1c2`)
* Added a timeout argument to :class:`~stem.control.Controller` methods that could await a response (:trac:`26056`)
diff --git a/test/unit/control/controller.py b/test/unit/control/controller.py
index c5809192..8034abe2 100644
--- a/test/unit/control/controller.py
+++ b/test/unit/control/controller.py
@@ -624,25 +624,30 @@ class TestControl(unittest.TestCase):
self.assertRaises(InvalidRequest, self.controller.add_event_listener, Mock(), EventType.SIGNAL)
@patch('time.time', Mock(return_value = TEST_TIMESTAMP))
- @patch('stem.control.Controller.is_alive', Mock(return_value = True))
- def test_events_get_received(self):
+ @patch('stem.control.Controller.is_alive')
+ def test_events_get_received(self, is_alive_mock):
"""
Trigger an event, checking that our listeners get notified.
"""
+ is_alive_mock.return_value = True
self.controller._launch_threads()
- self._emit_event(CIRC_EVENT)
- self.circ_listener.assert_called_once_with(CIRC_EVENT)
- self.bw_listener.assert_not_called()
- self.malformed_listener.assert_not_called()
+ try:
+ self._emit_event(CIRC_EVENT)
+ self.circ_listener.assert_called_once_with(CIRC_EVENT)
+ self.bw_listener.assert_not_called()
+ self.malformed_listener.assert_not_called()
- self._emit_event(BW_EVENT)
- self.bw_listener.assert_called_once_with(BW_EVENT)
+ self._emit_event(BW_EVENT)
+ self.bw_listener.assert_called_once_with(BW_EVENT)
+ finally:
+ is_alive_mock.return_value = False
+ self.controller._close()
@patch('time.time', Mock(return_value = TEST_TIMESTAMP))
- @patch('stem.control.Controller.is_alive', Mock(return_value = True))
- def test_event_listing_with_error(self):
+ @patch('stem.control.Controller.is_alive')
+ def test_event_listing_with_error(self, is_alive_mock):
"""
Raise an exception in an event listener to confirm it doesn't break our
event thread.
@@ -650,33 +655,43 @@ class TestControl(unittest.TestCase):
self.circ_listener.side_effect = ValueError('boom')
+ is_alive_mock.return_value = True
self.controller._launch_threads()
- self._emit_event(CIRC_EVENT)
- self.circ_listener.assert_called_once_with(CIRC_EVENT)
- self.bw_listener.assert_not_called()
- self.malformed_listener.assert_not_called()
+ try:
+ self._emit_event(CIRC_EVENT)
+ self.circ_listener.assert_called_once_with(CIRC_EVENT)
+ self.bw_listener.assert_not_called()
+ self.malformed_listener.assert_not_called()
- self._emit_event(BW_EVENT)
- self.bw_listener.assert_called_once_with(BW_EVENT)
+ self._emit_event(BW_EVENT)
+ self.bw_listener.assert_called_once_with(BW_EVENT)
+ finally:
+ is_alive_mock.return_value = False
+ self.controller._close()
@patch('time.time', Mock(return_value = TEST_TIMESTAMP))
- @patch('stem.control.Controller.is_alive', Mock(return_value = True))
- def test_event_listing_with_malformed_event(self):
+ @patch('stem.control.Controller.is_alive')
+ def test_event_listing_with_malformed_event(self, is_alive_mock):
"""
Attempt to parse a malformed event emitted from Tor. It's important this
doesn't break our event thread.
"""
+ is_alive_mock.return_value = True
self.controller._launch_threads()
- self._emit_event(BAD_EVENT)
- self.circ_listener.assert_not_called()
- self.bw_listener.assert_not_called()
- self.malformed_listener.assert_called_once()
+ try:
+ self._emit_event(BAD_EVENT)
+ self.circ_listener.assert_not_called()
+ self.bw_listener.assert_not_called()
+ self.malformed_listener.assert_called_once()
- self._emit_event(BW_EVENT)
- self.bw_listener.assert_called_once_with(BW_EVENT)
+ self._emit_event(BW_EVENT)
+ self.bw_listener.assert_called_once_with(BW_EVENT)
+ finally:
+ is_alive_mock.return_value = False
+ self.controller._close()
@patch('stem.control.Controller.get_version', Mock(return_value = stem.version.Version('0.5.0.14')))
@patch('stem.control.Controller.msg', Mock(return_value = ControlMessage.from_str('250 OK\r\n')))
_______________________________________________
tor-commits mailing list
tor-commits@xxxxxxxxxxxxxxxxxxxx
https://lists.torproject.org/cgi-bin/mailman/listinfo/tor-commits