| | |
| | | //fmt.Println("缓存初始化完成",<- initchan)//dbserver初始化完毕 |
| | | ruleserver.Init() |
| | | go ruleserver.TimeTicker() |
| | | go ruleserver.StartServer() |
| | | nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1) |
| | | wg.Wait() |
| | | } |
| | |
| | | // 暂时写死,sdk还没有这俩算法 |
| | | arg.KeepRight = false |
| | | arg.IsStatic = false |
| | | logger.Info("-----追踪之后sdkinfo.Sdkdata的长度为:----",len(sdkinfo.Sdkdata)) |
| | | if len(sdkinfo.Sdkdata) > 1 { |
| | | // 大于1才有数据 |
| | | yoloParam := protomsg.ParamYoloObj{} |
| | |
| | | yoloNum++ |
| | | } |
| | | } |
| | | logger.Info("--------------追踪之后yolo的个数:",len(yoloParam.Infos)) |
| | | logger.Info("--------------追踪之后yolo的个数:",yoloNum) |
| | | args.Sdkdata = append(args.Sdkdata,&arg) |
| | | } else { |
| | | continue |