This is an automated email from the ASF dual-hosted git repository.
NSAmelchev 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 05f03f64837 IGNITE-28978 Make MDC-aware discovery ring mode testable
in a single JVM (#13471)
05f03f64837 is described below
commit 05f03f64837a12e81420017f29f51302d8f60b31
Author: Nikita Amelchev <[email protected]>
AuthorDate: Thu Aug 13 16:36:47 2026 +0300
IGNITE-28978 Make MDC-aware discovery ring mode testable in a single JVM
(#13471)
---
.../ignite/spi/discovery/tcp/internal/TcpDiscoveryNodesRing.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNodesRing.java
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNodesRing.java
index 5cafd170732..03a862b6bf9 100644
---
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNodesRing.java
+++
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNodesRing.java
@@ -46,7 +46,7 @@ import org.jetbrains.annotations.Nullable;
*/
public class TcpDiscoveryNodesRing {
/** */
- private static final boolean MDC_AWARE_RING =
IgniteSystemProperties.getBoolean("MDC_AWARE_RING", true);
+ private final boolean mdcAwareRing =
IgniteSystemProperties.getBoolean("MDC_AWARE_RING", true);
/** Visible nodes filter. */
public static final IgnitePredicate<TcpDiscoveryNode> VISIBLE_NODES = new
P1<TcpDiscoveryNode>() {
@@ -481,7 +481,7 @@ public class TcpDiscoveryNodesRing {
Collection<TcpDiscoveryNode> sorted;
- if (MDC_AWARE_RING) {
+ if (mdcAwareRing) {
sorted = new TreeSet<>(new MdcAwareNodesComparator());
sorted.addAll(filtered);
}
@@ -525,7 +525,7 @@ public class TcpDiscoveryNodesRing {
Collection<TcpDiscoveryNode> sorted;
- if (MDC_AWARE_RING) {
+ if (mdcAwareRing) {
sorted = new TreeSet<>(new MdcAwareNodesComparator());
sorted.addAll(filtered);
}
@@ -562,7 +562,7 @@ public class TcpDiscoveryNodesRing {
Collection<TcpDiscoveryNode> sorted;
- if (MDC_AWARE_RING) {
+ if (mdcAwareRing) {
sorted = new TreeSet<>(new MdcAwareNodesComparator());
sorted.addAll(nodes);
}