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); }