ljydlv
/
VideoStream
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

内存泄漏解决测试

This commit is contained in:
lijun 2025-01-22 13:51:04 +08:00
parent f1401e8a9b
commit 4d7521e4b5
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
handler/tool.go
View File

@ -235,6 +235,10 @@ func subscribeAndHandleMessagesV3(ws *websocket.Conn, device_id int) {
worker.SetRedisSetRemove(online_conn_key, con_id) worker.SetRedisSetRemove(online_conn_key, con_id)
break break
} }
t++
if t%10 == 0 {
log.Printf("device:%d send frame count:%d,img is closed", device_id, c)
}
buf1 := buf.GetBytes() buf1 := buf.GetBytes()
err2 := ws.WriteMessage(websocket.BinaryMessage, buf1) err2 := ws.WriteMessage(websocket.BinaryMessage, buf1)
@ -244,10 +248,6 @@ func subscribeAndHandleMessagesV3(ws *websocket.Conn, device_id int) {
break break
} }
c = count c = count
t++
if t%10 == 0 {
log.Printf("device:%d send frame count:%d,img is closed", device_id, c)
}
err5 := img.Close() err5 := img.Close()
if err5 != nil { if err5 != nil {
log.Printf("img close err:%v", err) log.Printf("img close err:%v", err)