| | |
| | | "time" |
| | | "unsafe" |
| | | |
| | | "analysis/gosdk" |
| | | |
| | | "basic.com/pubsub/protomsg.git" |
| | | "basic.com/valib/gosdk.git" |
| | | "github.com/gogo/protobuf/proto" |
| | | ) |
| | | |
| | |
| | | select { |
| | | case <-ctx.Done(): |
| | | return |
| | | default: |
| | | rMsg := <-in |
| | | case rMsg := <-in: |
| | | if !validRemoteMessage(rMsg, typ) { |
| | | logo.Errorln("face track validremotemessage invalid") |
| | | ejectResult(nil, rMsg, out) |
| | |
| | | go e.detectTrackOneChn(ctx, e.ftrackChans[rMsg.Msg.Cid], out, typ, e.ftrackChannels[rMsg.Msg.Cid]) |
| | | e.ftrackChans[rMsg.Msg.Cid] <- rMsg |
| | | } |
| | | default: |
| | | time.Sleep(100 * time.Millisecond) |
| | | } |
| | | |
| | | } |
| | | } |
| | | |