diff --git a/main.py b/main.py index 9b9c656..aa2d99a 100644 --- a/main.py +++ b/main.py @@ -18,7 +18,6 @@ for _key in ("http_proxy", "https_proxy", "HTTP_PROXY", "HTTPS_PROXY", "all_prox from config.settings import get_settings, Settings from core.config_sync import get_config_sync_manager, ConfigSyncManager -from core.debug_http_server import start_debug_http_server from core.video_stream import MultiStreamManager, VideoFrame from core.preprocessor import ImagePreprocessor from core.tensorrt_engine import TensorRTEngine, EngineManager @@ -56,8 +55,6 @@ class EdgeInferenceService: self._screenshot_handler: Optional[ScreenshotHandler] = None self._algorithm_manager: Optional[AlgorithmManager] = None self._debug_reload_thread: Optional[threading.Thread] = None - self._debug_http_server = None - self._debug_http_thread: Optional[threading.Thread] = None self._heartbeat_thread: Optional[threading.Thread] = None self._scheduler_thread: Optional[threading.Thread] = None @@ -305,32 +302,6 @@ class EdgeInferenceService: ) self._debug_reload_thread.start() - def _start_debug_http_server(self): - """本地调试:启动 HTTP 同步接口""" - if self._settings.config_sync_mode != "LOCAL": - return - if not getattr(self._settings, "debug", None) or not self._settings.debug.enabled: - return - if self._debug_http_server is not None: - return - - host = self._settings.debug.host - port = self._settings.debug.port - self._debug_http_server = start_debug_http_server(host, port) - - def worker(): - try: - self._debug_http_server.serve_forever() - except Exception as e: - self._logger.warning(f"[DEBUG] HTTP 服务器异常: {e}") - - self._debug_http_thread = threading.Thread( - target=worker, - name="DebugHttpServer", - daemon=True, - ) - self._debug_http_thread.start() - def _start_heartbeat(self): """启动心跳守护线程,每 30 秒向云端上报设备状态""" def worker(): @@ -403,7 +374,6 @@ class EdgeInferenceService: self._init_algorithm_manager() self._init_screenshot_handler() self._start_debug_reload_watcher() - self._start_debug_http_server() self._start_heartbeat() self._performance_stats["start_time"] = datetime.now() @@ -1122,12 +1092,6 @@ class EdgeInferenceService: if self._reporter: self._reporter.close() - if self._debug_http_server: - try: - self._debug_http_server.shutdown() - except Exception: - pass - self._performance_stats["uptime_seconds"] = ( (datetime.now() - self._performance_stats["start_time"]).total_seconds() )