liuxiaolong
2019-11-13 f26a0cab5bca17b7eab57f6330e576271e17a17f
service/FDetectClient.go
@@ -1 +1,35 @@
package service
import (
   "basic.com/pubsub/protomsg.git"
   "context"
   "errors"
   "strconv"
   "time"
   "webserver/extend/config"
   "basic.com/valib/logger.git"
   "google.golang.org/grpc"
)
func DoFDetectWithRpc(fdr *protomsg.FaceDetectRequest,t time.Duration) ([]*protomsg.ResultFaceDetect,error) {
   fdUrl:=config.FaceDetectSet.Ip + ":" + strconv.Itoa(config.FaceDetectSet.Port)
   conn,err := grpc.Dial(fdUrl, grpc.WithInsecure())
   if err !=nil {
      logger.Debug("grpc dial err:",err)
   }
   defer conn.Close()
   c := protomsg.NewFaceDetectClient(conn)
   ctx,cancel := context.WithTimeout(context.Background(), t)
   defer cancel()
   faces,err := c.FaceDetect(ctx,fdr)
   if err !=nil {
      logger.Debug("rpc call err:",err)
      return nil,err
   }
   if faces !=nil {
      return faces.Faces,nil
   }
   return nil,errors.New("no face detected")
}