派生自 libgowrapper/face

zhangmeng
2020-01-13 e6e44004a9d5b892ce0136599a73f1e7dc5da31a
debug
1个文件已修改
26 ■■■■ 已修改文件
run.go 26 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
run.go
@@ -195,9 +195,7 @@
    for _, msg := range msgs {
        if c, ok := f.channelExist(msg.Cid); ok {
            f.fnLogger("######push image: ", c.index)
            c.msgs.Push(msg)
            f.fnLogger("######push over image: ", c.index)
        } else {
            nc := f.channelNew(msg.Cid)
@@ -223,11 +221,8 @@
}
func (f *face) detectTrackOneChn(c *channel, out chan<- sdkstruct.MsgSDK) {
    tm := time.Now()
    sc := 0
    dtchn := c.index
    f.fnLogger("DETECTTRACKONECHN DTCHN: ", dtchn)
    var curCid string
    for {
@@ -240,6 +235,7 @@
            }
            return
        default:
            f.fnLogger("DETECTTRACKONECHN DTCHN: ", dtchn)
            elems := c.msgs.Drain()
            var msgs []protomsg.SdkMessage
@@ -250,7 +246,7 @@
                if !sdkhelper.ValidRemoteMessage(rMsg, f.typ, f.fnLogger) {
                    sdkhelper.EjectResult(nil, rMsg, out)
                    f.fnLogger("Face!!!!!!SkdMessage Invalid")
                    f.fnLogger("Face!!!!!!SkdMessage Invalid: ", dtchn)
                    continue
                }
@@ -258,7 +254,7 @@
                i := sdkhelper.UnpackImage(rMsg, f.typ, f.fnLogger)
                if i == nil || i.Data == nil || i.Width <= 0 || i.Height <= 0 {
                    sdkhelper.EjectResult(nil, rMsg, out)
                    f.fnLogger("Face!!!!!!Unpack Image From SkdMessage Failed")
                    f.fnLogger("Face!!!!!!Unpack Image From SkdMessage Failed: ", dtchn)
                    continue
                }
@@ -276,22 +272,8 @@
                if rMsg.Tasklab != nil {
                    id, name = rMsg.Tasklab.Taskid, rMsg.Tasklab.Taskname
                }
                f.fnLogger("CAMERAID: ", rMsg.Cid, " TASKID: ", id, " TASKNAME: ", name, " DETECT ", f.typ, " COUNT: ", count)
                f.fnLogger("Chan: ", dtchn, "CAMERAID: ", rMsg.Cid, " TASKID: ", id, " TASKNAME: ", name, " DETECT ", f.typ, " COUNT: ", count)
            }
            sc++
            if sc == 25 {
                f.fnLogger("CHAN:%d, FACE RUN 25 FRAME USE TIME: ", dtchn, time.Since(tm))
                sc = 0
                tm = time.Now()
            }
            if time.Since(tm) > time.Second {
                f.fnLogger("CHAN: ", dtchn, " FACE RUN ", sc, " FRAME USE TIME: ", time.Since(tm))
                sc = 0
                tm = time.Now()
            }
        }
    }
}