From 1e519b668aea20bffc959c315ee9db03843ba181 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期一, 29 七月 2019 13:47:22 +0800
Subject: [PATCH] fix sock
---
service/FaceCompareService.go | 4 ++--
controllers/esSearch.go | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/controllers/esSearch.go b/controllers/esSearch.go
index 8679c38..7dff7de 100644
--- a/controllers/esSearch.go
+++ b/controllers/esSearch.go
@@ -146,7 +146,7 @@
"\"sort\":[{\"_score\":{\"order\":\"desc\"}},{\"picDate\":{\"order\":\"desc\"}}]," +
"\"_source\":[\"baseInfo\",\"alarmRules\",\"sex\",\"analyServerName\",\"sdkName\",\"ageDescription\",\"content\",\"id\",\"cameraAddr\",\"picMaxUrl\",\"picDate\",\"race\",\"videoUrl\",\"picSmUrl\",\"taskName\",\"personIsHub\",\"isAlarm\",\"analyServerIp\",\"cameraId\"]" +
"}"
- logger.Debug(prama)
+ //logger.Debug(prama)
//鏁版嵁瑙ｆ瀽
tokenRes := esutil.GetEsDataReq(url, prama, true)
return tokenRes
diff --git a/service/FaceCompareService.go b/service/FaceCompareService.go
index 5c1dbc4..1035a50 100644
--- a/service/FaceCompareService.go
+++ b/service/FaceCompareService.go
@@ -13,7 +13,6 @@
"sort"
"strconv"
"sync"
- "time"
"webserver/extend/config"
"webserver/extend/logger"
"webserver/extend/util"
@@ -157,7 +156,8 @@
}
sock.AddTransport(ipc.NewTransport())
sock.AddTransport(tcp.NewTransport())
- sock.SetOption(mangos.OptionRecvDeadline, time.Second*10)
+ sock.SetOption(mangos.OptionMaxRecvSize, 1024*1024*100)
+ //sock.SetOption(mangos.OptionRecvDeadline, time.Second*10)
if err = sock.Dial(url);err !=nil {
logger.Debug("can't dial on req socket:%s",err.Error())
return nil
--
Gitblit v1.8.0