From 3fc4fa8f8bf65030ee0969d73f958b11d90b7daf Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期二, 17 十二月 2019 17:17:52 +0800
Subject: [PATCH] add log

---
 sdk/sdk.go |   30 +++++++++++++++++-------------
 1 files changed, 17 insertions(+), 13 deletions(-)

diff --git a/sdk/sdk.go b/sdk/sdk.go
index 88c0445..5ce179e 100644
--- a/sdk/sdk.go
+++ b/sdk/sdk.go
@@ -155,12 +155,12 @@
 		newSdkList := util.Sdklist
 
 		// 鎵嬪姩娣诲姞鐨勫叏閮ㄥ姞涓�
-		for _, sendTopic := range innerSendTopic {
-			newSdkList = append(newSdkList, sendTopic)
-		}
-		for _, recvTopic := range innerRecvTopic {
-			newSdkList = append(newSdkList, recvTopic)
-		}
+		// for _, sendTopic := range innerSendTopic {
+		// 	newSdkList = append(newSdkList, sendTopic)
+		// }
+		// for _, recvTopic := range innerRecvTopic {
+		// 	newSdkList = append(newSdkList, recvTopic)
+		// }
 
 		sdkListUpdate := util.Difference(oldSdkList, newSdkList)
 		logger.Info(sdkListUpdate)
@@ -190,15 +190,17 @@
 	return sdkmsg
 }
 
+var logShouldUntil = 0
+
 //sdk鏁版嵁鍒嗗彂鍣�
 func GetSdkSendTopic(sdkmsg protomsg.SdkMessage) (sendTopic string) {
 	if int(sdkmsg.Tasklab.Index) < len(sdkmsg.Tasklab.Sdkinfos) {
 		sendTopic = sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Ipcid
-		if "Yolo" != sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype &&
-			"FaceDetect" != sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype &&
-			"FaceCompare" != sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype {
-			//if sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype == "" {
-			logger.Info("----------Sdktype:yitusoutu")
+
+		logShouldUntil++
+		if logShouldUntil > 68 {
+			logShouldUntil = 0
+			logger.Info("=========鍒嗗彂鐨勪富棰�=========")
 			logger.Info("鍒嗗彂鐨勪富棰�:", sendTopic, "!Sdktype锛�", sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype)
 		}
 	} else {
@@ -230,7 +232,8 @@
 					if tryCount > util.ShmMaxTryCount {
 						socket.Sock.Close()
 						socket, err = util.NewSocketListen(socket.Mode, socket.URL, socket.UseSHM)
-						logger.Info("SDK SEND SHM TRY :", util.ShmMaxTryCount, " RESTART IT")
+						logger.Info("=========SDK RECV SHM ERROR=========")
+						logger.Info("SDK RECV FROM:", socket.URL, " ERROR ", util.ShmMaxTryCount, " TIMES SO RESTART IT")
 						tryCount = 0
 						continue
 					}
@@ -286,7 +289,8 @@
 						if tryCount > util.ShmMaxTryCount {
 							socket.Sock.Close()
 							socket, err = util.NewSocketListen(socket.Mode, socket.URL, socket.UseSHM)
-							logger.Info("SDK SEND SHM TRY :", util.ShmMaxTryCount, " RESTART IT")
+							logger.Info("=========SDK SEND SHM ERROR=========")
+							logger.Info("SDK SEND TO: ", socket.URL, " ERROR ", util.ShmMaxTryCount, " TIMES SO RESTART IT")
 							tryCount = 0
 							continue
 						}

--
Gitblit v1.8.0