debug

zhangmeng

2020-01-11 f7a86c37945d2923a0e9d20aecb9ba2573d0a632

 run.go

@@ -24,8 +24,6 @@
)

func (f *face) channelAvailable() int {
   f.mapChanLock.Lock()
   defer f.mapChanLock.Unlock()

   for i := 0; i < f.maxChannel; i++ {
      found := false
@@ -198,7 +196,9 @@

   for _, msg := range msgs {
      if c, ok := f.channelExist(msg.Cid); ok {
         f.fnLogger("######push image")
         c.msg <- msg
         f.fnLogger("######push over image")
      } else {

         nc := f.channelNew(msg.Cid)
@@ -217,8 +217,8 @@
         imgW, imgH := int(i.Width), int(i.Height)
         ret := f.handle.TrackerResize(imgW, imgH, nc.index)
         f.fnLogger("ResizeFaceTracker: cid: ", msg.Cid, " chan: ", nc.index, " wXh: ", imgW, "x", imgH, " result:", ret)
         go f.detectTrackOneChn(c, out)
         c.msg <- msg
         go f.detectTrackOneChn(nc, out)
         nc.msg <- msg
      }
   }
   f.fnLogger("######run over batch images")
@@ -257,9 +257,14 @@
         // conv to bgr24 and resize
         imgW, imgH := int(i.Width), int(i.Height)

         f.fnLogger("######face sdk run")
         count, data, _ := f.handle.Run(i.Data, imgW, imgH, 3, dtchn)
         f.fnLogger("######face over sdk run")

         f.fnLogger("######face eject data")
         sdkhelper.EjectResult(data, rMsg, out)
         f.fnLogger("######face over eject data")

         var id, name string
         if rMsg.Tasklab != nil {
            id, name = rMsg.Tasklab.Taskid, rMsg.Tasklab.Taskname