init map

liuxiaolong

2019-06-27 e2eab7661b022557b4cab9199901de5f60b27e0d

 service/FaceSdkService.go

@@ -14,8 +14,9 @@
)

const (
   Url_Service_PUSH = "ipc:///tmp///webserver_2.ipc"
   Url_Service_PULL = "ipc:///tmp///webserver_1.ipc"

   Url_Service_PUSH = "ipc:///tmp///virtual-faceextract-sdk-pull_2.ipc"
   Url_Service_PULL = "ipc:///tmp///virtual-faceextract-sdk-pull_1.ipc"
)
var imgPushChan chan protomsg.Recvmsg
var client_push deliver.Deliver
@@ -39,13 +40,16 @@
         fmt.Println("image is not compressible")
      }
      bc = bc[:n]
      for {
         PushImgMsg(protomsg.Recvmsg{
            Id:uuid.NewV4().String(),
            Addr:"",
            Picdata:bc,
         })
         fmt.Println("pushed img")
         time.Sleep(5*time.Second)
      }

      PushImgMsg(protomsg.Recvmsg{
         Id:uuid.NewV4().String(),
         Addr:"",
         Picdata:bc,
      })
      fmt.Println("pushed img")
   }
}

@@ -89,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() {
@@ -124,9 +129,11 @@
         continue
      }
      rMsg := protomsg.SdkMessage{}
      if err := proto.Unmarshal(resultBytes, &rMsg);err !=nil{
         fmt.Println("recv MSG:",rMsg)
      if err := proto.Unmarshal(resultBytes, &rMsg);err ==nil{
         fmt.Println("received MSG:",rMsg.Cid)
         resultMap[rMsg.Cid] = rMsg
      } else {
         fmt.Println("recv msg Err:",err)
      }

   }