DEBUG/DROPME: Mac, what doing?

Tribler · Nov 25, 2024 · 2c363bf · 2c363bf
1 parent 3ce7030
commit 2c363bf
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 4 deletions.
diff --git a/ipv8/taskmanager.py b/ipv8/taskmanager.py
@@ -1,5 +1,6 @@
 from __future__ import annotations
 
+import asyncio
 import logging
 import time
 import traceback
@@ -251,13 +252,24 @@ async def after_cancel() -> None:
                 if not callable(task) or iscoroutinefunction(task):
                     await cast(Awaitable, fut)
 
-        done_future.after_cancel_task = after_cancel()  # type: ignore[attr-defined]
-        self.register_anonymous_task(f"[Catch shutdown] {basename}", catch_shutdown)
-        self.register_anonymous_task(f"[Run shutdown]  {basename}",
-                                     shield(done_future.after_cancel_task))  # type: ignore[attr-defined]
+        t1 = self.register_anonymous_task(f"[Catch shutdown] {basename}", catch_shutdown)
+        inner_t2 = ensure_future(after_cancel())
+        t2 = self.register_anonymous_task(f"[Run shutdown] {basename}", shield(inner_t2))
+
+        print()
+        print(t1)
+        print(inner_t2)
+        print(t2)
+        print(done_future)
 
         await sleep(0)  # Enter both infinite loops
 
+        print(t1)
+        print(inner_t2)
+        print(t2)
+        print(done_future)
+
+
         return done_future
 
     def cancel_pending_task(self, name: Hashable) -> Future:

diff --git a/ipv8/test/test_taskmanager.py b/ipv8/test/test_taskmanager.py
@@ -301,6 +301,8 @@ async def test_register_shutdown_task(self) -> None:
 
         await self.tm.shutdown_task_manager()
 
+        print(fut)  # TODO: Mac, what are you doing!?
+
         self.assertTrue(fut.done())
         self.assertTrue(sub_fut.cancelled())