This is an automated email from the ASF dual-hosted git repository. av pushed a commit to branch ignite-20177 in repository https://gitbox.apache.org/repos/asf/ignite.git
commit d1d2aa742e9b4e73c1c693d8d6dfdc773778d11a Author: Anton Vinogradov <a...@apache.org> AuthorDate: Mon Aug 7 22:52:02 2023 +0300 WIP --- .../processors/cache/distributed/dht/GridDhtLockFuture.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockFuture.java index c960f8bd8a1..85dc993ddf9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockFuture.java @@ -440,7 +440,7 @@ public final class GridDhtLockFuture extends GridCacheCompoundIdentityFuture<Boo if (log.isDebugEnabled()) log.debug("Failed to acquire lock with negative timeout: " + entry); - onFailed(false); + onFailed(); return null; } @@ -512,10 +512,9 @@ public final class GridDhtLockFuture extends GridCacheCompoundIdentityFuture<Boo /** * - * @param dist {@code True} if need to distribute lock release. */ - private void onFailed(boolean dist) { - undoLocks(dist); + private void onFailed() { + undoLocks(false); onComplete(false, false, true); } @@ -618,7 +617,7 @@ public final class GridDhtLockFuture extends GridCacheCompoundIdentityFuture<Boo if (timeout < 0) { if (owners == null || !owners.hasCandidate(lockVer)) { // We did not send any requests yet. - onFailed(false); + onFailed(); return; } @@ -855,7 +854,7 @@ public final class GridDhtLockFuture extends GridCacheCompoundIdentityFuture<Boo // Possible in case of lock cancellation. if (cand == null) { - onFailed(false); + onFailed(); // Will mark initialized in finally block. return;