From 63b149279f103a5308af180edc81fbfa1eaf76fd Mon Sep 17 00:00:00 2001 From: zqc <835569504@qq.com> Date: Mon, 2 Mar 2026 15:12:39 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=E5=8F=98=E9=87=8F=E5=90=8D?= =?UTF-8?q?=E7=A7=B0=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rtsp_service_ws_kadian.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/rtsp_service_ws_kadian.py b/rtsp_service_ws_kadian.py index a2d5631..525aca1 100644 --- a/rtsp_service_ws_kadian.py +++ b/rtsp_service_ws_kadian.py @@ -104,6 +104,7 @@ class RTSPCaptureWorker(threading.Thread): "camera_id": self.camera_cfg.id, "camera_name": self.camera_cfg.name, "timestamp": time.time(), + "camera_index": self.camera_cfg.index, "frame": frame, } @@ -183,7 +184,7 @@ class RTSPService: def start(self): self.ws_sender.start() - self.processor.start() + self.biz_processor.start() for cam in self.cameras: w = RTSPCaptureWorker(cam, self.raw_queue, self.stop_event) w.start() @@ -196,7 +197,7 @@ class RTSPService: self.ws_queue.join() for w in self.capture_workers: w.join(timeout=2.0) - self.processor.join(timeout=2.0) + self.biz_processor.join(timeout=2.0) self.ws_sender.join(timeout=2.0) logger.info("[INFO] Service stopped")