| | |
| | | "bufio" |
| | | "bytes" |
| | | "flag" |
| | | "fmt" |
| | | "github.com/golang/protobuf/proto" |
| | | "gocv.io/x/gocv" |
| | | "image" |
| | |
| | | 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) |
| | |
| | | msg, err = c.Recv() |
| | | if err != nil { |
| | | logger.Info("recv error : ", err) |
| | | fmt.Println("recv error : ", err) |
| | | continue |
| | | } else { |
| | | arg := ruleserver.SdkDatas{} |
| | |
| | | } |
| | | 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 { |