| | |
| | | |
| | | for _, msg := range msgs { |
| | | if c, ok := f.channelExist(msg.Cid); ok { |
| | | f.fnLogger("######push image: ", c.index) |
| | | c.msgs.Push(msg) |
| | | f.fnLogger("######push over image: ", c.index) |
| | | } else { |
| | | |
| | | nc := f.channelNew(msg.Cid) |
| | |
| | | } |
| | | |
| | | func (f *face) detectTrackOneChn(c *channel, out chan<- sdkstruct.MsgSDK) { |
| | | tm := time.Now() |
| | | sc := 0 |
| | | |
| | | dtchn := c.index |
| | | f.fnLogger("DETECTTRACKONECHN DTCHN: ", dtchn) |
| | | var curCid string |
| | | |
| | | for { |
| | |
| | | } |
| | | return |
| | | default: |
| | | f.fnLogger("DETECTTRACKONECHN DTCHN: ", dtchn) |
| | | |
| | | elems := c.msgs.Drain() |
| | | var msgs []protomsg.SdkMessage |
| | |
| | | |
| | | if !sdkhelper.ValidRemoteMessage(rMsg, f.typ, f.fnLogger) { |
| | | sdkhelper.EjectResult(nil, rMsg, out) |
| | | f.fnLogger("Face!!!!!!SkdMessage Invalid") |
| | | f.fnLogger("Face!!!!!!SkdMessage Invalid: ", dtchn) |
| | | |
| | | continue |
| | | } |
| | |
| | | i := sdkhelper.UnpackImage(rMsg, f.typ, f.fnLogger) |
| | | if i == nil || i.Data == nil || i.Width <= 0 || i.Height <= 0 { |
| | | sdkhelper.EjectResult(nil, rMsg, out) |
| | | f.fnLogger("Face!!!!!!Unpack Image From SkdMessage Failed") |
| | | f.fnLogger("Face!!!!!!Unpack Image From SkdMessage Failed: ", dtchn) |
| | | |
| | | continue |
| | | } |
| | |
| | | if rMsg.Tasklab != nil { |
| | | id, name = rMsg.Tasklab.Taskid, rMsg.Tasklab.Taskname |
| | | } |
| | | f.fnLogger("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) |
| | | } |
| | | |
| | | sc++ |
| | | if sc == 25 { |
| | | f.fnLogger("CHAN:%d, FACE RUN 25 FRAME USE TIME: ", dtchn, time.Since(tm)) |
| | | sc = 0 |
| | | tm = time.Now() |
| | | } |
| | | |
| | | if time.Since(tm) > time.Second { |
| | | f.fnLogger("CHAN: ", dtchn, " FACE RUN ", sc, " FRAME USE TIME: ", time.Since(tm)) |
| | | sc = 0 |
| | | tm = time.Now() |
| | | } |
| | | |
| | | } |
| | | } |
| | | } |