Bug fixed: devices are not properly closed. (#175) (#176)

Author: ATATC

leads/__init__.py

@@ -1,18 +1,10 @@
-from atexit import register as _register
-
 from leads.config import *
 from leads.context import *
 from leads.data import *
 from leads.dt import *
 from leads.event import *
 from leads.leads import *
 from leads.logger import Level, L
-from leads.os import _thread_flags
 from leads.plugin import *
 from leads.registry import *
 from leads.sft import SFT, mark_system, read_marked_system
-
-
-@_register
-def _request_threads_stop() -> None:
-    _thread_flags.active = False

leads/dt/registry.py

@@ -1,3 +1,4 @@
+from atexit import register as _register
 from typing import Any as _Any, Callable as _Callable, Sequence as _Sequence
 
 from leads.dt.controller import Controller
@@ -84,7 +85,8 @@ def get_device(tag: str) -> Device:
     return _devices[tag]
 
 
-def reset() -> None:
+@_register
+def release() -> None:
     for d in _devices.values():
         d.close()
     _devices.clear()

leads/os.py

@@ -1,4 +1,5 @@
 import sys as _sys
+from atexit import register as _register
 from threading import Lock as _Lock
 from types import FrameType as _FrameType
 
@@ -32,3 +33,8 @@ def active(self, active: bool) -> None:
 
 
 _thread_flags: _ThreadFlags = _ThreadFlags()
+
+
+@_register
+def _request_threads_stop() -> None:
+    _thread_flags.active = False

leads_audio/prototype.py

@@ -31,10 +31,7 @@ def _try_open_audio_device() -> None:
 
 _Thread(name="sdl initializer", target=_try_open_audio_device, daemon=True).start()
 
-
-@_register
-def _release_resources() -> None:
-    _close_audio()
+_register(_close_audio)
 
 
 class _SoundEffect(object):

leads_vec/run.py

@@ -6,7 +6,7 @@
 from customtkinter import set_default_color_theme as _set_default_color_theme
 
 from leads import register_controller as _register_controller, MAIN_CONTROLLER as _MAIN_CONTROLLER, \
-    L as _L, load_config as _load_config, register_config as _register_config, reset as _reset
+    L as _L, load_config as _load_config, register_config as _register_config, release as _release
 from leads_gui import Config as _Config
 
 
@@ -68,7 +68,7 @@ def run(config: str,
                 return main()
             else:
                 _L.warn(f"Specified devices module ({devices}) is not available, using emulation module instead...")
-        _reset()
+        _release()
         try:
             from leads_emulation import SinController as _Controller
 

leads_vec_rc/cli.py

@@ -120,6 +120,4 @@ async def hazard() -> str:
     return "done"
 
 
-@register
-def cleanup() -> None:
-    csv.close()
+register(csv.close)