From 5b938edd2f016c3df3db3d7d8ac8520e2d810301 Mon Sep 17 00:00:00 2001 From: blackstorm Date: Mon, 23 Nov 2020 12:29:44 +0800 Subject: [PATCH] RedisNodes ping results check optimization Signed-off-by: blackstorm --- redisson/src/main/java/org/redisson/RedisNodes.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/redisson/src/main/java/org/redisson/RedisNodes.java b/redisson/src/main/java/org/redisson/RedisNodes.java index 0e5ed4dd5..2a35b65c8 100644 --- a/redisson/src/main/java/org/redisson/RedisNodes.java +++ b/redisson/src/main/java/org/redisson/RedisNodes.java @@ -149,10 +149,12 @@ public class RedisNodes implements NodesGroup { for (Entry> entry : result.entrySet()) { RFuture f = entry.getValue(); f.awaitUninterruptibly(); - if (!"PONG".equals(f.getNow())) { + String pong = f.getNow(); + entry.getKey().closeAsync(); + if (!"PONG".equals(pong)) { res = false; + break; } - entry.getKey().closeAsync(); } // true and no futures were missed during client connection