add log

zhangmeng

2019-12-17 3fc4fa8f8bf65030ee0969d73f958b11d90b7daf

 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
                  }