update

zhangmeng

2019-12-16 93c3c5e031eb1ca0960c2cf69d81423875b553c7

 camera/camera.go

@@ -182,7 +182,7 @@
               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 TRY :", util.ShmMaxTryCount, " RESTART IT")
                  tryCount = 0
                  continue
               }
@@ -207,7 +207,6 @@
         } else {
            taskIDs := GetAllTaskByID(imagemsg.Cid)
            for _, taskID := range taskIDs {
               // logger.Debug("id: ", imagemsg.Cid, " taskid: ", taskID)
               doTaskList(imagemsg.Cid, "", taskID, recvmessage)
            }
         }
@@ -244,13 +243,17 @@
   //  计算分发的主题
   SendTopic := sdk.GetSdkSendTopic(sdkmsg)
   //logger.Info(SendTopic)

   if "facedetect-sdk-no-track" == SendTopic || "virtual-faceextract-sdk-pull" == SendTopic {
      logger.Info(SendTopic)
   }
   if _, ok := sdk.SdkMap[SendTopic]; ok {

      logger.Debug("recv from camera id: ", cid, " len: ", len(data), " send to sdk id: ", SendTopic)

      if "facedetect-sdk-no-track" == SendTopic || "virtual-faceextract-sdk-pull" == SendTopic {
         logger.Info(SendTopic)
      }
      sdk.SdkMap[SendTopic] <- sdkmsg

      if "facedetect-sdk-no-track" == SendTopic || "virtual-faceextract-sdk-pull" == SendTopic {
         logger.Info("dispute sendtopic success", SendTopic)
      }
   } else {
      logger.Info("分发的主题不存在")
   }