From b71e3dde0583702fdb97d2628630839c6d0e509b Mon Sep 17 00:00:00 2001 From: Nikita Date: Tue, 5 Jul 2016 12:03:32 +0300 Subject: [PATCH] execute all lock, semaphore and countdownlatch commands using master node. #545 --- src/main/java/org/redisson/RedissonCountDownLatch.java | 2 +- src/main/java/org/redisson/RedissonLock.java | 4 ++-- src/main/java/org/redisson/RedissonSemaphore.java | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/org/redisson/RedissonCountDownLatch.java b/src/main/java/org/redisson/RedissonCountDownLatch.java index 1b4e49d45..6e1a977f3 100644 --- a/src/main/java/org/redisson/RedissonCountDownLatch.java +++ b/src/main/java/org/redisson/RedissonCountDownLatch.java @@ -138,7 +138,7 @@ public class RedissonCountDownLatch extends RedissonObject implements RCountDown @Override public Future getCountAsync() { - return commandExecutor.readAsync(getName(), LongCodec.INSTANCE, RedisCommands.GET_LONG, getName()); + return commandExecutor.writeAsync(getName(), LongCodec.INSTANCE, RedisCommands.GET_LONG, getName()); } @Override diff --git a/src/main/java/org/redisson/RedissonLock.java b/src/main/java/org/redisson/RedissonLock.java index f98173d44..1089ec907 100644 --- a/src/main/java/org/redisson/RedissonLock.java +++ b/src/main/java/org/redisson/RedissonLock.java @@ -391,12 +391,12 @@ public class RedissonLock extends RedissonExpirable implements RLock { @Override public boolean isHeldByCurrentThread() { - return commandExecutor.read(getName(), LongCodec.INSTANCE, RedisCommands.HEXISTS, getName(), getLockName(Thread.currentThread().getId())); + return commandExecutor.write(getName(), LongCodec.INSTANCE, RedisCommands.HEXISTS, getName(), getLockName(Thread.currentThread().getId())); } @Override public int getHoldCount() { - Long res = commandExecutor.read(getName(), LongCodec.INSTANCE, RedisCommands.HGET, getName(), getLockName(Thread.currentThread().getId())); + Long res = commandExecutor.write(getName(), LongCodec.INSTANCE, RedisCommands.HGET, getName(), getLockName(Thread.currentThread().getId())); if (res == null) { return 0; } diff --git a/src/main/java/org/redisson/RedissonSemaphore.java b/src/main/java/org/redisson/RedissonSemaphore.java index 6fce66b17..4f60ef927 100644 --- a/src/main/java/org/redisson/RedissonSemaphore.java +++ b/src/main/java/org/redisson/RedissonSemaphore.java @@ -434,7 +434,7 @@ public class RedissonSemaphore extends RedissonExpirable implements RSemaphore { @Override public int availablePermits() { - Long res = commandExecutor.read(getName(), LongCodec.INSTANCE, RedisCommands.GET_LONG, getName()); + Long res = commandExecutor.write(getName(), LongCodec.INSTANCE, RedisCommands.GET_LONG, getName()); return res.intValue(); }