You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by av...@apache.org on 2023/08/08 13:31:45 UTC
[ignite] 24/30: WIP
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 305f3a853d0ffa0d3692e0ec146c3c45d6456719
Author: Anton Vinogradov <av...@apache.org>
AuthorDate: Tue Aug 8 16:06:17 2023 +0300
WIP
---
.../cache/distributed/near/GridNearTxFinishFuture.java | 12 +++++-------
1 file changed, 5 insertions(+), 7 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 40df946166d..e30e9d571a6 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
@@ -475,13 +475,13 @@ public final class GridNearTxFinishFuture<K, V> extends GridCacheCompoundIdentit
if (mapping != null) {
assert !hasFutures() || isDone() : futures();
- finish(1, mapping, commit, !clearThreadMap);
+ finish(1, mapping, commit);
}
}
else {
assert !hasFutures() || isDone() : futures();
- finish(mappings.mappings(), commit, !clearThreadMap);
+ finish(mappings.mappings(), commit);
}
}
@@ -740,23 +740,21 @@ public final class GridNearTxFinishFuture<K, V> extends GridCacheCompoundIdentit
/**
* @param mappings Mappings.
* @param commit Commit flag.
- * @param useCompletedVer {@code True} if need to add completed version on finish.
*/
- private void finish(Iterable<GridDistributedTxMapping> mappings, boolean commit, boolean useCompletedVer) {
+ private void finish(Iterable<GridDistributedTxMapping> mappings, boolean commit) {
int miniId = 0;
// Create mini futures.
for (GridDistributedTxMapping m : mappings)
- finish(++miniId, m, commit, useCompletedVer);
+ finish(++miniId, m, commit);
}
/**
* @param miniId Mini future ID.
* @param m Mapping.
* @param commit Commit flag.
- * @param useCompletedVer {@code True} if need to add completed version on finish.
*/
- private void finish(int miniId, GridDistributedTxMapping m, boolean commit, boolean useCompletedVer) {
+ private void finish(int miniId, GridDistributedTxMapping m, boolean commit) {
ClusterNode n = m.primary();
assert !m.empty() || m.queryUpdate() : m + " " + tx.state();