debug

zhangmeng

2020-01-13 d55be0cac98af0847ab9034ac43fa0ce501a7838

debug

 run.go

@@ -195,6 +195,7 @@

    for _, msg := range msgs {
        if c, ok := f.channelExist(msg.Cid); ok {
            f.fnLogger("######recv from :", msg.Cid, " Chan:", c.index)
            c.msgs.Push(msg)
        } else {

@@ -229,13 +230,13 @@
        select {

        case <-time.After(trackChnTimeout * time.Second):
            f.fnLogger("######Timeout to get image, curCid:", curCid, " Chan:", dtchn)
            f.fnLogger("######Timeout to get image, curCid:", curCid)
            if curCid != "" {
                f.channelRelease(curCid)
            }
            return
        default:
            // f.fnLogger("DETECTTRACKONECHN DTCHN: ", dtchn)
            f.fnLogger("DETECTTRACKONECHN DTCHN: ", dtchn)

            elems := c.msgs.Drain()
            var msgs []protomsg.SdkMessage
@@ -264,16 +265,15 @@
                // conv to bgr24 and resize
                imgW, imgH := int(i.Width), int(i.Height)

                // count, data, _ := f.handle.Run(i.Data, imgW, imgH, 3, dtchn)
                _, data, _ := f.handle.Run(i.Data, imgW, imgH, 3, dtchn)
                count, data, _ := f.handle.Run(i.Data, imgW, imgH, 3, dtchn)

                sdkhelper.EjectResult(data, rMsg, out)

                // var id, name string
                // if rMsg.Tasklab != nil {
                //     id, name = rMsg.Tasklab.Taskid, rMsg.Tasklab.Taskname
                // }
                // f.fnLogger("Chan: ", dtchn, "CAMERAID: ", rMsg.Cid, " TASKID: ", id, " TASKNAME: ", name, " DETECT ", f.typ, " COUNT: ", count)
                var id, name string
                if rMsg.Tasklab != nil {
                    id, name = rMsg.Tasklab.Taskid, rMsg.Tasklab.Taskname
                }
                f.fnLogger("Chan: ", dtchn, "CAMERAID: ", rMsg.Cid, " TASKID: ", id, " TASKNAME: ", name, " DETECT ", f.typ, " COUNT: ", count)
            }
        }
    }