[Author Prev][Author Next][Thread Prev][Thread Next][Author Index][Thread Index]
[tor-commits] [stem/master] Stop canceling asynchronous tasks for reader and event loops
commit 163b3b383bc88cc373f9b97f8f458995f09bf498
Author: Illia Volochii <illia.volochii@xxxxxxxxx>
Date: Thu Apr 30 19:29:37 2020 +0300
Stop canceling asynchronous tasks for reader and event loops
They finish automatically when detect that their controller is not alive.
---
stem/control.py | 6 +-----
1 file changed, 1 insertion(+), 5 deletions(-)
diff --git a/stem/control.py b/stem/control.py
index 98631428..ff0f3bc1 100644
--- a/stem/control.py
+++ b/stem/control.py
@@ -641,7 +641,6 @@ class BaseController(_BaseControllerSocketMixin):
self._socket = control_socket
self._asyncio_loop = asyncio.get_event_loop()
- self._asyncio_loop_tasks = []
self._msg_lock = _MsgLock()
@@ -785,9 +784,6 @@ class BaseController(_BaseControllerSocketMixin):
await self._socket.close()
- for task in self._asyncio_loop_tasks:
- task.cancel()
-
# Join on any outstanding state change listeners. Closing is a state change
# of its own, so if we have any listeners it's quite likely there's some
# work in progress.
@@ -951,7 +947,7 @@ class BaseController(_BaseControllerSocketMixin):
"""
for coroutine in (self._reader_loop(), self._event_loop()):
- self._asyncio_loop_tasks.append(self._asyncio_loop.create_task(coroutine))
+ self._asyncio_loop.create_task(coroutine)
async def _reader_loop(self) -> None:
"""
_______________________________________________
tor-commits mailing list
tor-commits@xxxxxxxxxxxxxxxxxxxx
https://lists.torproject.org/cgi-bin/mailman/listinfo/tor-commits