From 4f3c77d4bee93f15d72a1d12a19af68428c29151 Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期六, 06 七月 2019 11:53:17 +0800 Subject: [PATCH] --- --- main.go | 9 ++++++--- 1 files changed, 6 insertions(+), 3 deletions(-) diff --git a/main.go b/main.go index 6541dc1..69e09cf 100644 --- a/main.go +++ b/main.go @@ -7,6 +7,7 @@ "bufio" "bytes" "flag" + "fmt" "github.com/golang/protobuf/proto" "gocv.io/x/gocv" "image" @@ -36,11 +37,12 @@ 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) @@ -69,6 +71,7 @@ msg, err = c.Recv() if err != nil { logger.Info("recv error : ", err) + fmt.Println("recv error : ", err) continue } else { arg := ruleserver.SdkDatas{} @@ -118,7 +121,7 @@ } 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{} @@ -223,7 +226,7 @@ logger.Info("瑙f瀽浜鸿劯姣斿鏁版嵁鏃跺嚭鐜伴敊璇�", err) continue } - logger.Info("_________________________________________________________________瑙f瀽鍑虹殑浜鸿劯鐨勭浉浼肩殑搴曞簱鏁版嵁",binfos) + logger.Info("_________________________________________________________________瑙f瀽鍑虹殑浜鸿劯鐨勭浉浼肩殑搴曞簱鏁版嵁",binfos.Infos[0].CompareScore) } logger.Info("------褰撳墠绠楁硶name",sdkinfo.SdkName,"--------------鐪嬬湅浜鸿劯鎻愬彇涓湁鍑犱釜鐩爣锛�",len(faceParam.ExtComp)) for _, extComp := range faceParam.ExtComp { -- Gitblit v1.8.0