debug

zhangmeng

2020-01-13 d55be0cac98af0847ab9034ac43fa0ce501a7838

 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)
         }
      }
   }