| | |
| | | func main() { |
| | | flag.Parse() |
| | | wg := sync.WaitGroup{} |
| | | wg.Add(1) |
| | | wg.Add(2) |
| | | |
| | | dbapi.Init(*dbIp,*dbPort) |
| | | go cache.Init(initchan,*dbIp,*surveyPort,*pubPort) |
| | | logger.Info("cache init completed!!!",<- initchan)//dbserver初始化完毕 |
| | | //fmt.Println("缓存初始化完成",<- initchan)//dbserver初始化完毕 |
| | | |
| | | go ruleserver.TimeTicker() |
| | | nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1) |
| | |
| | | } |
| | | i := protomsg.Image{} |
| | | err = proto.Unmarshal(bdata, &i) |
| | | logger.Info("----------------看看有几个算法:",len(m.Tasklab.Sdkinfos)) |
| | | //logger.Info("----------------看看有几个算法:",len(m.Tasklab.Sdkinfos)) |
| | | for _, sdkinfo := range m.Tasklab.Sdkinfos { // yolo算法 |
| | | if sdkinfo.Sdktype == "Yolo" { |
| | | arg := ruleserver.SdkData{} |
| | |
| | | logger.Info("解析人脸比对数据时出现错误", err) |
| | | continue |
| | | } |
| | | logger.Info("_________________________________________________________________解析出的人脸的相似的底库数据",binfos) |
| | | logger.Info("_________________________________________________________________解析出的人脸的相似的底库数据",binfos.Infos[0].CompareScore) |
| | | } |
| | | logger.Info("------当前算法name",sdkinfo.SdkName,"--------------看看人脸提取中有几个目标:",len(faceParam.ExtComp)) |
| | | for _, extComp := range faceParam.ExtComp { |