|
|
@ -338,6 +338,7 @@ public abstract class RedissonBaseLock extends RedissonExpirable implements RLoc
|
|
|
|
String id = getServiceManager().generateId();
|
|
|
|
String id = getServiceManager().generateId();
|
|
|
|
MasterSlaveServersConfig config = getServiceManager().getConfig();
|
|
|
|
MasterSlaveServersConfig config = getServiceManager().getConfig();
|
|
|
|
int timeout = (config.getTimeout() + config.getRetryInterval()) * config.getRetryAttempts();
|
|
|
|
int timeout = (config.getTimeout() + config.getRetryInterval()) * config.getRetryAttempts();
|
|
|
|
|
|
|
|
timeout = Math.max(timeout, 1);
|
|
|
|
RFuture<Boolean> r = unlockInnerAsync(threadId, id, timeout);
|
|
|
|
RFuture<Boolean> r = unlockInnerAsync(threadId, id, timeout);
|
|
|
|
CompletionStage<Boolean> ff = r.thenApply(v -> {
|
|
|
|
CompletionStage<Boolean> ff = r.thenApply(v -> {
|
|
|
|
CommandAsyncExecutor ce = commandExecutor;
|
|
|
|
CommandAsyncExecutor ce = commandExecutor;
|
|
|
|