reformat code

Signed-off-by: yunfeiyanggzq <[email protected]>
alibaba · Sep 3, 2020 · 7faf1b1 · 7faf1b1
1 parent d4d2d47
commit 7faf1b1
Showing 1 changed file with 23 additions and 27 deletions.
diff --git a/...ault/src/main/java/com/alibaba/csp/sentinel/cluster/flow/rule/ClusterFlowRuleManager.java b/...ault/src/main/java/com/alibaba/csp/sentinel/cluster/flow/rule/ClusterFlowRuleManager.java
@@ -15,18 +15,10 @@
  */
 package com.alibaba.csp.sentinel.cluster.flow.rule;
 
-import java.util.ArrayList;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.concurrent.ConcurrentHashMap;
-
 import com.alibaba.csp.sentinel.cluster.flow.statistic.ClusterMetricStatistics;
 import com.alibaba.csp.sentinel.cluster.flow.statistic.concurrent.CurrentConcurrencyManager;
 import com.alibaba.csp.sentinel.cluster.flow.statistic.metric.ClusterMetric;
 import com.alibaba.csp.sentinel.cluster.server.ServerConstants;
-import com.alibaba.csp.sentinel.cluster.server.config.ClusterServerConfigManager;
 import com.alibaba.csp.sentinel.cluster.server.connection.ConnectionManager;
 import com.alibaba.csp.sentinel.cluster.server.util.ClusterRuleUtil;
 import com.alibaba.csp.sentinel.log.RecordLog;
@@ -42,6 +34,9 @@
 import com.alibaba.csp.sentinel.util.function.Function;
 import com.alibaba.csp.sentinel.util.function.Predicate;
 
+import java.util.*;
+import java.util.concurrent.ConcurrentHashMap;
+
 /**
  * Manager for cluster flow rules.
  *
@@ -55,12 +50,12 @@ public final class ClusterFlowRuleManager {
      * for a specific namespace to do rule management manually.
      */
     public static final Function<String, SentinelProperty<List<FlowRule>>> DEFAULT_PROPERTY_SUPPLIER =
-        new Function<String, SentinelProperty<List<FlowRule>>>() {
-            @Override
-            public SentinelProperty<List<FlowRule>> apply(String namespace) {
-                return new DynamicSentinelProperty<>();
-            }
-        };
+            new Function<String, SentinelProperty<List<FlowRule>>>() {
+                @Override
+                public SentinelProperty<List<FlowRule>> apply(String namespace) {
+                    return new DynamicSentinelProperty<>();
+                }
+            };
 
     /**
      * (flowId, clusterRule)
@@ -88,7 +83,7 @@ public SentinelProperty<List<FlowRule>> apply(String namespace) {
      * Cluster flow rule property supplier for a specific namespace.
      */
     private static volatile Function<String, SentinelProperty<List<FlowRule>>> propertySupplier
-        = DEFAULT_PROPERTY_SUPPLIER;
+            = DEFAULT_PROPERTY_SUPPLIER;
 
     private static final Object UPDATE_LOCK = new Object();
 
@@ -119,18 +114,18 @@ public static void register2Property(String namespace) {
         AssertUtil.notEmpty(namespace, "namespace cannot be empty");
         if (propertySupplier == null) {
             RecordLog.warn(
-                "[ClusterFlowRuleManager] Cluster flow property supplier is absent, cannot register property");
+                    "[ClusterFlowRuleManager] Cluster flow property supplier is absent, cannot register property");
             return;
         }
         SentinelProperty<List<FlowRule>> property = propertySupplier.apply(namespace);
         if (property == null) {
             RecordLog.warn(
-                "[ClusterFlowRuleManager] Wrong created property from cluster flow property supplier, ignoring");
+                    "[ClusterFlowRuleManager] Wrong created property from cluster flow property supplier, ignoring");
             return;
         }
         synchronized (UPDATE_LOCK) {
             RecordLog.info("[ClusterFlowRuleManager] Registering new property to cluster flow rule manager"
-                + " for namespace <{}>", namespace);
+                    + " for namespace <{}>", namespace);
             registerPropertyInternal(namespace, property);
         }
     }
@@ -181,7 +176,7 @@ public static void removeProperty(String namespace) {
                 PROPERTY_MAP.remove(namespace);
             }
             RecordLog.info("[ClusterFlowRuleManager] Removing property from cluster flow rule manager"
-                + " for namespace <{}>", namespace);
+                    + " for namespace <{}>", namespace);
         }
     }
 
@@ -254,7 +249,7 @@ public static List<FlowRule> getFlowRules(String namespace) {
      * Load flow rules for a specific namespace. The former rules of the namespace will be replaced.
      *
      * @param namespace a valid namespace
-     * @param rules rule list
+     * @param rules     rule list
      */
     public static void loadRules(String namespace, List<FlowRule> rules) {
         AssertUtil.notEmpty(namespace, "namespace cannot be empty");
@@ -342,7 +337,7 @@ private static void applyClusterFlowRule(List<FlowRule> list, /*@Valid*/ String
             }
             if (!FlowRuleUtil.isValidRule(rule)) {
                 RecordLog.warn(
-                    "[ClusterFlowRuleManager] Ignoring invalid flow rule when loading new flow rules: " + rule);
+                        "[ClusterFlowRuleManager] Ignoring invalid flow rule when loading new flow rules: " + rule);
                 continue;
             }
             if (StringUtil.isBlank(rule.getLimitApp())) {
@@ -358,13 +353,13 @@ private static void applyClusterFlowRule(List<FlowRule> list, /*@Valid*/ String
             ruleMap.put(flowId, rule);
             FLOW_NAMESPACE_MAP.put(flowId, namespace);
             flowIdSet.add(flowId);
-            if(!CurrentConcurrencyManager.containsFlowId(flowId)){
-                CurrentConcurrencyManager.put(flowId,0);
+            if (!CurrentConcurrencyManager.containsFlowId(flowId)) {
+                CurrentConcurrencyManager.put(flowId, 0);
             }
 
             // Prepare cluster metric from valid flow ID.
             ClusterMetricStatistics.putMetricIfAbsent(flowId,
-                new ClusterMetric(clusterConfig.getSampleCount(), clusterConfig.getWindowIntervalMs()));
+                    new ClusterMetric(clusterConfig.getSampleCount(), clusterConfig.getWindowIntervalMs()));
         }
 
         // Cleanup unused cluster metrics.
@@ -391,16 +386,17 @@ public FlowRulePropertyListener(String namespace) {
         public synchronized void configUpdate(List<FlowRule> conf) {
             applyClusterFlowRule(conf, namespace);
             RecordLog.info("[ClusterFlowRuleManager] Cluster flow rules received for namespace <{}>: {}",
-                namespace, FLOW_RULES);
+                    namespace, FLOW_RULES);
         }
 
         @Override
         public synchronized void configLoad(List<FlowRule> conf) {
             applyClusterFlowRule(conf, namespace);
             RecordLog.info("[ClusterFlowRuleManager] Cluster flow rules loaded for namespace <{}>: {}",
-                namespace, FLOW_RULES);
+                    namespace, FLOW_RULES);
         }
     }
 
-    private ClusterFlowRuleManager() {}
+    private ClusterFlowRuleManager() {
+    }
 }