debug

zhangmeng

2020-01-13 dd56c126c4e2ac2b309e05b47aa9477dee8ed318

 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,12 @@
      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)

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

            f.fnLogger("######run cid:", rMsg.Cid, "chan: ", dtchn)
            count, data, _ := f.handle.Run(i.Data, imgW, imgH, 3, dtchn)
            f.fnLogger("######over run cid:", rMsg.Cid, "chan: ", dtchn)

            f.fnLogger("######eject cid:", rMsg.Cid, "chan: ", dtchn)
            sdkhelper.EjectResult(data, rMsg, out)
            f.fnLogger("######over eject cid:", rMsg.Cid, "chan: ", dtchn)

            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)
            f.fnLogger("Chan: ", dtchn, "CAMERAID: ", rMsg.Cid, " TASKID: ", id, " TASKNAME: ", name, " DETECT ", f.typ, " COUNT: ", count)
         }
      }
   }