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

使用v3获取当前帧

This commit is contained in:
lijun 2025-01-20 18:13:39 +08:00
parent 7d55d68c90
commit b155ce2c1d
1 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
handler/tool.go
View File

@ -213,10 +213,9 @@ func subscribeAndHandleMessagesV3(ws *websocket.Conn, device_id int) {
count := 0 count := 0
//定时器，发送计数器 //定时器，发送计数器
t_count := 0 t_count := 0
img := gocv.NewMat()
for { for {
//从service获取当前帧 //从service获取当前帧
c := service.GetDeviceCurrentFrameV2(&img, device_id) img, c := service.GetDeviceCurrentFrameV3(device_id)
if c != count { if c != count {
if c == -1 { if c == -1 {
log.Printf("device:%d get frame err!", device_id) log.Printf("device:%d get frame err!", device_id)
@ -260,11 +259,6 @@ func subscribeAndHandleMessagesV3(ws *websocket.Conn, device_id int) {
time.Sleep(100 * time.Millisecond) time.Sleep(100 * time.Millisecond)
t_count++ t_count++
} }
// 关闭img
err := img.Close()
if err != nil {
log.Printf("device:%d img close err:%v", device_id, err)
}
// 查看是否还有其他连接，没有则设置 is_play 为 0 // 查看是否还有其他连接，没有则设置 is_play 为 0
if worker.IsContainKey(online_conn_key) == false { if worker.IsContainKey(online_conn_key) == false {