You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ni...@apache.org on 2025/01/29 20:38:33 UTC

(ignite) branch master updated: IGNITE-24101 Remove SEPARATE_CACHE_PER_NON_COLLOCATED_SET_SINCE (#11810)

This is an automated email from the ASF dual-hosted git repository.

nizhikov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new 89d70d4879a IGNITE-24101 Remove SEPARATE_CACHE_PER_NON_COLLOCATED_SET_SINCE (#11810)
89d70d4879a is described below

commit 89d70d4879ab4f32c198dabf9d62f0d098168140
Author: Vladislav Novikov <47...@users.noreply.github.com>
AuthorDate: Wed Jan 29 23:38:27 2025 +0300

    IGNITE-24101 Remove SEPARATE_CACHE_PER_NON_COLLOCATED_SET_SINCE (#11810)
---
 .../processors/datastructures/DataStructuresProcessor.java    | 11 ++---------
 1 file changed, 2 insertions(+), 9 deletions(-)

diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
index 00d333ef86f..cf3614ebc7e 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
@@ -93,7 +93,6 @@ import org.apache.ignite.internal.util.typedef.internal.GPR;
 import org.apache.ignite.internal.util.typedef.internal.S;
 import org.apache.ignite.internal.util.typedef.internal.U;
 import org.apache.ignite.lang.IgnitePredicate;
-import org.apache.ignite.lang.IgniteProductVersion;
 import org.apache.ignite.spi.systemview.view.datastructures.AtomicLongView;
 import org.apache.ignite.spi.systemview.view.datastructures.AtomicReferenceView;
 import org.apache.ignite.spi.systemview.view.datastructures.AtomicSequenceView;
@@ -197,10 +196,6 @@ public final class DataStructuresProcessor extends GridProcessorAdapter implemen
     /** */
     private static final String SEQUENCES_VIEW_DESC = "Data structure atomic sequences";
 
-    /** Non collocated IgniteSet will use separate cache if all nodes in cluster is not older then specified version. */
-    private static final IgniteProductVersion SEPARATE_CACHE_PER_NON_COLLOCATED_SET_SINCE =
-        IgniteProductVersion.fromString("2.7.0");
-
     /** Initial capacity. */
     private static final int INITIAL_CAPACITY = 10;
 
@@ -1775,14 +1770,12 @@ public final class DataStructuresProcessor extends GridProcessorAdapter implemen
 
         final boolean create = cfg != null;
         final boolean collocated = isCollocated(cfg);
-        final boolean separated = !collocated &&
-            U.isOldestNodeVersionAtLeast(SEPARATE_CACHE_PER_NON_COLLOCATED_SET_SINCE, ctx.grid().cluster().nodes());
 
         return getCollection(new CX1<GridCacheContext, IgniteSet<T>>() {
             @Override public IgniteSet<T> applyx(GridCacheContext cctx) throws IgniteCheckedException {
-                return cctx.dataStructures().set(name, collocated, create, separated);
+                return cctx.dataStructures().set(name, collocated, create, !collocated);
             }
-        }, cfg, name, grpName, SET, create, separated);
+        }, cfg, name, grpName, SET, create, !collocated);
     }
 
     /**