| | |
| | | case <-ctx.Done(): |
| | | e.fnFree(e.handle) |
| | | return |
| | | default: |
| | | rMsg := <-in |
| | | case rMsg := <-in: |
| | | if !validRemoteMessage(rMsg, typ) { |
| | | logo.Errorln("face track validremotemessage invalid") |
| | | ejectResult(nil, rMsg, out) |
| | |
| | | } |
| | | // conv to bgr24 and resize |
| | | imgW, imgH := int(i.Width), int(i.Height) |
| | | ret := e.fnTrackerResize(e.handle, e.ftrackChannels[rMsg.Msg.Cid], imgW, imgH) |
| | | logo.Infof("ResizeFaceTracker: cid:%s, chan:%d, wXh:%d x %d ,result:%d\n", |
| | | rMsg.Msg.Cid, e.ftrackChannels[rMsg.Msg.Cid], imgW, imgH, ret) |
| | | go e.detectTrackOneChn(ctx, e.ftrackChans[rMsg.Msg.Cid], out, typ, e.ftrackChannels[rMsg.Msg.Cid]) |
| | | ret := e.fnTrackerResize(e.handle, imgW, imgH, chn) |
| | | logo.Infof("ResizeFaceTracker: cid:%s, chan:%d, wXh:%d x %d ,result:%t\n", |
| | | rMsg.Msg.Cid, chn, imgW, imgH, ret) |
| | | go e.detectTrackOneChn(ctx, e.ftrackChans[rMsg.Msg.Cid], out, typ, chn) |
| | | e.ftrackChans[rMsg.Msg.Cid] <- rMsg |
| | | } |
| | | default: |
| | | time.Sleep(time.Millisecond * 100) |
| | | } |
| | | } |
| | | } |