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 f0efc7411ddeca4f0cbf9d639e3c36e67e47699d
Author: Anton Vinogradov <a...@apache.org>
AuthorDate: Mon Aug 7 22:59:15 2023 +0300

    WIP
---
 .../distributed/dht/colocated/GridDhtColocatedLockFuture.java      | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedLockFuture.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedLockFuture.java
index 37d55334828..d3f13813581 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedLockFuture.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedLockFuture.java
@@ -125,7 +125,7 @@ public final class GridDhtColocatedLockFuture extends 
GridCacheCompoundIdentityF
 
     /** Keys to lock. */
     @GridToStringInclude
-    private Collection<KeyCacheObject> keys;
+    private final Collection<KeyCacheObject> keys;
 
     /** Future ID. */
     private final IgniteUuid futId;
@@ -1213,7 +1213,7 @@ public final class GridDhtColocatedLockFuture extends 
GridCacheCompoundIdentityF
 
         // Fail fast if the transaction is timed out.
         if (tx != null && tx.remainingTime() == -1) {
-            GridDhtColocatedLockFuture.this.onDone(false, 
tx.timeoutException());
+            onDone(false, tx.timeoutException());
 
             clear();
 
@@ -1292,8 +1292,7 @@ public final class GridDhtColocatedLockFuture extends 
GridCacheCompoundIdentityF
         add(new GridEmbeddedFuture<>(
             new C2<Exception, Exception, Boolean>() {
                 @Override public Boolean apply(Exception resEx, Exception e) {
-                    if (CU.isLockTimeoutOrCancelled(e) ||
-                        (resEx != null && CU.isLockTimeoutOrCancelled(resEx)))
+                    if (CU.isLockTimeoutOrCancelled(e) || 
(CU.isLockTimeoutOrCancelled(resEx)))
                         return false;
 
                     if (e != null) {

Reply via email to