From e2eab7661b022557b4cab9199901de5f60b27e0d Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期四, 27 六月 2019 13:21:23 +0800
Subject: [PATCH] init map
---
service/FaceSdkService.go | 9 +++++----
1 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/service/FaceSdkService.go b/service/FaceSdkService.go
index f56ab10..5c83969 100644
--- a/service/FaceSdkService.go
+++ b/service/FaceSdkService.go
@@ -40,15 +40,15 @@
fmt.Println("image is not compressible")
}
bc = bc[:n]
- //for {
+ for {
PushImgMsg(protomsg.Recvmsg{
Id:uuid.NewV4().String(),
Addr:"",
Picdata:bc,
})
fmt.Println("pushed img")
- //time.Sleep(10*time.Second)
- //}
+ time.Sleep(5*time.Second)
+ }
}
}
@@ -93,6 +93,7 @@
func InitService(){
fmt.Println("service init!")
imgPushChan = make(chan protomsg.Recvmsg)
+ resultMap = make(map[string]protomsg.SdkMessage,0)
client_push = deliver.NewClient(deliver.PushPull, Url_Service_PUSH)
client_pull = deliver.NewClient(deliver.PushPull, Url_Service_PULL)
defer func() {
@@ -129,7 +130,7 @@
}
rMsg := protomsg.SdkMessage{}
if err := proto.Unmarshal(resultBytes, &rMsg);err ==nil{
- fmt.Println("recv MSG:",rMsg)
+ fmt.Println("received MSG:",rMsg.Cid)
resultMap[rMsg.Cid] = rMsg
} else {
fmt.Println("recv msg Err:",err)
--
Gitblit v1.8.0