From b320f191c6a03c3d19c3c648a85d83d7280747ac Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Fri, 5 Aug 2022 10:21:59 +0300 Subject: [PATCH] Fixed - Connection pinging works incorrectly if new connections were created in pool. #4441 --- .../main/java/org/redisson/connection/pool/ConnectionPool.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java b/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java index d1a499cfb..2e8bbd1e7 100644 --- a/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java +++ b/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java @@ -111,6 +111,7 @@ abstract class ConnectionPool { createConnection(entry, promise); promise.whenComplete((conn, e) -> { if (e == null) { + conn.decUsage(); if (!initPromise.isDone()) { entry.addConnection(conn); } else { @@ -279,6 +280,7 @@ abstract class ConnectionPool { return; } + promise.thenApply(c -> c.incUsage()); connectedSuccessful(entry, promise, conn); }); }