From f26a0cab5bca17b7eab57f6330e576271e17a17f Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期三, 13 十一月 2019 19:12:08 +0800
Subject: [PATCH] update ynSwagger,sync to master
---
service/FDetectClient.go | 34 ++++++++++++++++++++++++++++++++++
1 files changed, 34 insertions(+), 0 deletions(-)
diff --git a/service/FDetectClient.go b/service/FDetectClient.go
index 6d43c33..b020870 100644
--- a/service/FDetectClient.go
+++ b/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")
+}
--
Gitblit v1.8.0