fix(ConnectionsHolder): correct usage counting logic

Signed-off-by: wjx <jiaxuan.wjx@alibaba-inc.com>
5 months ago · edf7ca0ccf
parent 1a92a610f8
commit edf7ca0ccf
1 changed files with 4 additions and 2 deletions
--- a/redisson/src/main/java/org/redisson/connection/ConnectionsHolder.java
+++ b/redisson/src/main/java/org/redisson/connection/ConnectionsHolder.java
@ -91,7 +91,7 @@ public class ConnectionsHolder<T extends RedisConnection> {

    private T pollConnection(RedisCommand<?> command) {
        T c = freeConnections.poll();
-        if (c != null) {
+        if (c != null && changeUsage) {
            c.incUsage();
        }
        return c;
@ -109,7 +109,9 @@ public class ConnectionsHolder<T extends RedisConnection> {

        connection.setLastUsageTime(System.nanoTime());
        freeConnections.add(connection);
-        connection.decUsage();
+        if (changeUsage) {
+            connection.decUsage();
+        }
    }

    public Queue<T> getAllConnections() {