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 34d8098a764127e1e7d85118c45ebd6cc5a244be
Author: Anton Vinogradov <a...@apache.org>
AuthorDate: Tue Aug 8 16:01:43 2023 +0300

    WIP
---
 .../cache/distributed/near/GridNearTxFinishFuture.java           | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java
index 8e2d4666635..40df946166d 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java
@@ -279,7 +279,7 @@ public final class GridNearTxFinishFuture<K, V> extends 
GridCacheCompoundIdentit
                     CheckRemoteTxMiniFuture f = (CheckRemoteTxMiniFuture)fut;
 
                     if (f.futureId() == res.miniId())
-                        f.onDhtFinishResponse(nodeId, false);
+                        f.onDhtFinishResponse(nodeId);
                 }
             }
 
@@ -1037,7 +1037,7 @@ public final class GridNearTxFinishFuture<K, V> extends 
GridCacheCompoundIdentit
 
                                         fut.listen(new 
CI1<IgniteInternalFuture<?>>() {
                                             @Override public void 
apply(IgniteInternalFuture<?> fut) {
-                                                
mini.onDhtFinishResponse(cctx.localNodeId(), true);
+                                                
mini.onDhtFinishResponse(cctx.localNodeId());
                                             }
                                         });
                                     }
@@ -1054,7 +1054,7 @@ public final class GridNearTxFinishFuture<K, V> extends 
GridCacheCompoundIdentit
                                     }
                                 }
                                 else
-                                    mini.onDhtFinishResponse(backupId, true);
+                                    mini.onDhtFinishResponse(backupId);
                             }
                         }
                     }
@@ -1193,9 +1193,8 @@ public final class GridNearTxFinishFuture<K, V> extends 
GridCacheCompoundIdentit
 
         /**
          * @param nodeId Node ID.
-         * @param discoThread {@code True} if executed from discovery thread.
          */
-        void onDhtFinishResponse(UUID nodeId, boolean discoThread) {
+        void onDhtFinishResponse(UUID nodeId) {
             onResponse(nodeId);
         }
 

Reply via email to