| | |
| | | |
| | | 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) |
| | |
| | | // 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 |