diff --git a/redisson/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java b/redisson/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java index b4d6698df..24a765c6a 100644 --- a/redisson/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java +++ b/redisson/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java @@ -142,8 +142,6 @@ public class MasterSlaveConnectionManager implements ConnectionManager { private final ConnectionEventsHub connectionEventsHub = new ConnectionEventsHub(); - private final AsyncSemaphore[] locks = new AsyncSemaphore[50]; - private final ExecutorService executor; private final CommandSyncService commandExecutor; @@ -156,12 +154,6 @@ public class MasterSlaveConnectionManager implements ConnectionManager { private final Map nodeConnections = PlatformDependent.newConcurrentHashMap(); - { - for (int i = 0; i < locks.length; i++) { - locks[i] = new AsyncSemaphore(1); - } - } - public MasterSlaveConnectionManager(MasterSlaveServersConfig cfg, Config config, UUID id) { this(config, id); this.config = cfg; diff --git a/redisson/src/main/java/org/redisson/connection/MasterSlaveEntry.java b/redisson/src/main/java/org/redisson/connection/MasterSlaveEntry.java index 119addfff..a9be96df1 100644 --- a/redisson/src/main/java/org/redisson/connection/MasterSlaveEntry.java +++ b/redisson/src/main/java/org/redisson/connection/MasterSlaveEntry.java @@ -471,22 +471,6 @@ public class MasterSlaveEntry { }); } - public boolean isFreezed() { - return masterEntry.isFreezed(); - } - - public FreezeReason getFreezeReason() { - return masterEntry.getFreezeReason(); - } - - public void unfreeze() { - masterEntry.resetFirstFail(); - synchronized (masterEntry) { - masterEntry.setFreezed(false); - masterEntry.setFreezeReason(null); - } - } - public void shutdownMasterAsync() { if (!active.compareAndSet(true, false)) { return;