From 4d7521e4b5dc86dc78b6b9c6a935d6bcaf76f1d1 Mon Sep 17 00:00:00 2001 From: lijun Date: Wed, 22 Jan 2025 13:51:04 +0800 Subject: [PATCH] =?UTF-8?q?=E5=86=85=E5=AD=98=E6=B3=84=E6=BC=8F=E8=A7=A3?= =?UTF-8?q?=E5=86=B3=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- handler/tool.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/handler/tool.go b/handler/tool.go index 525e65f..87decff 100644 --- a/handler/tool.go +++ b/handler/tool.go @@ -235,6 +235,10 @@ func subscribeAndHandleMessagesV3(ws *websocket.Conn, device_id int) { worker.SetRedisSetRemove(online_conn_key, con_id) break } + t++ + if t%10 == 0 { + log.Printf("device:%d send frame count:%d,img is closed", device_id, c) + } buf1 := buf.GetBytes() err2 := ws.WriteMessage(websocket.BinaryMessage, buf1) @@ -244,10 +248,6 @@ func subscribeAndHandleMessagesV3(ws *websocket.Conn, device_id int) { break } c = count - t++ - if t%10 == 0 { - log.Printf("device:%d send frame count:%d,img is closed", device_id, c) - } err5 := img.Close() if err5 != nil { log.Printf("img close err:%v", err)