From 945283211d15ab99b408e7a8222f3b8649f6400d Mon Sep 17 00:00:00 2001 From: Maksim Davydov Date: Thu, 11 Jun 2026 12:54:49 +0300 Subject: [PATCH] IGNITE-28769 Add public discoveryRing() method to TcpDiscoverySpi --- .../ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java index a7f68fb1cf542..f634b44f17332 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java @@ -97,6 +97,7 @@ import org.apache.ignite.spi.discovery.DiscoverySpiOrderSupport; import org.apache.ignite.spi.discovery.tcp.internal.DiscoveryDataPacket; import org.apache.ignite.spi.discovery.tcp.internal.TcpDiscoveryNode; +import org.apache.ignite.spi.discovery.tcp.internal.TcpDiscoveryNodesRing; import org.apache.ignite.spi.discovery.tcp.internal.TcpDiscoveryStatistics; import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder; import org.apache.ignite.spi.discovery.tcp.ipfinder.jdbc.TcpDiscoveryJdbcIpFinder; @@ -519,6 +520,16 @@ public ClusterNode getNode0(UUID id) { return getNode(id); } + /** + * @return TCP discovery nodes ring. + */ + @Nullable public TcpDiscoveryNodesRing discoveryRing() { + if (impl instanceof ServerImpl) + return ((ServerImpl)impl).ring(); + + return null; + } + /** {@inheritDoc} */ @Override public boolean pingNode(UUID nodeId) { return impl.pingNode(nodeId);