commit

kinglong/master/pkg/svc/produce_window.go

@@ -85,22 +85,20 @@ func PrepareTimeWindowProducerQueue() {
 				return
 			}
 			subscriber1Mutex.Lock()
-			{
-				faultHappenTime := util.GetNowTimeCustom() // 获取当前故障发生时间
-				lastTimeWindow := util.GetLastTimeWindow() // 获取最后一个时间窗口
-				// 更新共享变量
-				m.RLock()
-				velocityX = data.VelocityX
-				velocityY = data.VelocityY
-				yaw = data.Yaw
-				m.RUnlock()
-				var faultLabel string
-				for _, f := range masterConfig.RuleOfCicvLocation {
-					faultLabel = f(data)
-					if faultLabel != "" {
-						saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
-						break
-					}
+			faultHappenTime := util.GetNowTimeCustom() // 获取当前故障发生时间
+			lastTimeWindow := util.GetLastTimeWindow() // 获取最后一个时间窗口
+			// 更新共享变量
+			m.RLock()
+			velocityX = data.VelocityX
+			velocityY = data.VelocityY
+			yaw = data.Yaw
+			m.RUnlock()
+			var faultLabel string
+			for _, f := range masterConfig.RuleOfCicvLocation {
+				faultLabel = f(data)
+				if faultLabel != "" {
+					saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
+					break
 				}
 			}
 			subscriber1Mutex.Unlock()