From f7a86c37945d2923a0e9d20aecb9ba2573d0a632 Mon Sep 17 00:00:00 2001 From: zhangmeng <775834166@qq.com> Date: 星期六, 11 一月 2020 18:28:22 +0800 Subject: [PATCH] debug --- run.go | 13 +++++++++---- 1 files changed, 9 insertions(+), 4 deletions(-) diff --git a/run.go b/run.go index f3b9434..cc5a50b 100644 --- a/run.go +++ b/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 -- Gitblit v1.8.0