From ff1a0b41fef6f814bfec105bee115cc701965f42 Mon Sep 17 00:00:00 2001 From: Erhan Ceran Date: Thu, 27 Jan 2022 05:35:49 +0300 Subject: [PATCH] Shifted script lines Signed-off-by: Erhan Ceran --- .../java/org/redisson/RedissonPermitExpirableSemaphore.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/redisson/src/main/java/org/redisson/RedissonPermitExpirableSemaphore.java b/redisson/src/main/java/org/redisson/RedissonPermitExpirableSemaphore.java index a6cc7a964..7ca2751bd 100644 --- a/redisson/src/main/java/org/redisson/RedissonPermitExpirableSemaphore.java +++ b/redisson/src/main/java/org/redisson/RedissonPermitExpirableSemaphore.java @@ -559,7 +559,7 @@ public class RedissonPermitExpirableSemaphore extends RedissonExpirable implemen } return commandExecutor.evalWriteAsync(getRawName(), LongCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN, - "local expire = redis.call('zscore', KEYS[3], ARGV[1]);" + + "local expire = redis.call('zscore', KEYS[3], ARGV[1]);" + "local removed = redis.call('zrem', KEYS[3], ARGV[1]);" + "if tonumber(removed) ~= 1 then " + "return 0;" + @@ -567,7 +567,7 @@ public class RedissonPermitExpirableSemaphore extends RedissonExpirable implemen "local value = redis.call('incrby', KEYS[1], ARGV[2]); " + "redis.call('publish', KEYS[2], value); " + "if tonumber(expire) <= tonumber(ARGV[3]) then " + - "return 0;" + + "return 0;" + "end;" + "return 1;", Arrays.asList(getRawName(), getChannelName(), timeoutName), permitId, 1, System.currentTimeMillis());