diff --git a/src/main/java/redis/clients/jedis/JedisClusterInfoCache.java b/src/main/java/redis/clients/jedis/JedisClusterInfoCache.java index 95a3feb..3274b4a 100644 --- a/src/main/java/redis/clients/jedis/JedisClusterInfoCache.java +++ b/src/main/java/redis/clients/jedis/JedisClusterInfoCache.java @@ -118,7 +118,7 @@ public class JedisClusterInfoCache { } } - public synchronized void assignSlotsToNode(List targetSlots, + public void assignSlotsToNode(List targetSlots, HostAndPort targetNode) { w.lock(); try { @@ -137,7 +137,7 @@ public class JedisClusterInfoCache { } } - public synchronized JedisPool getNode(String nodeKey) { + public JedisPool getNode(String nodeKey) { r.lock(); try { return nodes.get(nodeKey); @@ -146,7 +146,7 @@ public class JedisClusterInfoCache { } } - public synchronized JedisPool getSlotPool(int slot) { + public JedisPool getSlotPool(int slot) { r.lock(); try { return slots.get(slot); @@ -155,7 +155,7 @@ public class JedisClusterInfoCache { } } - public synchronized Map getNodes() { + public Map getNodes() { r.lock(); try { return new HashMap(nodes);