Remove redundant signSafeMod (apache#10081) (apache#10082)

lujp · Mar 30, 2021 · 455af30 · 455af30
1 parent c9c1167
commit 455af30
Showing 1 changed file with 1 addition and 8 deletions.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionPool.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionPool.java
@@ -19,6 +19,7 @@
 package org.apache.pulsar.client.impl;
 
 import static org.apache.pulsar.common.util.netty.ChannelFutures.toCompletableFuture;
+import static org.apache.pulsar.client.util.MathUtils.signSafeMod;
 
 import com.google.common.annotations.VisibleForTesting;
 
@@ -340,14 +341,6 @@ int getPoolSize() {
         return pool.values().stream().mapToInt(Map::size).sum();
     }
 
-    public static int signSafeMod(long dividend, int divisor) {
-        int mod = (int) (dividend % divisor);
-        if (mod < 0) {
-            mod += divisor;
-        }
-        return mod;
-    }
-
     private static final Logger log = LoggerFactory.getLogger(ConnectionPool.class);
 
 }