This is an automated email from the ASF dual-hosted git repository. tkalkirill pushed a commit to branch ignite-25908 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit d271d6105c653c09e73b04d3e3f36b9db07a4776 Author: Kirill Tkalenko <[email protected]> AuthorDate: Tue Jul 15 14:24:41 2025 +0300 IGNITE-25908 wip --- .../org/apache/ignite/internal/network/NettyBootstrapFactory.java | 6 +++--- .../org/apache/ignite/internal/network/NettyWorkersRegistrar.java | 3 +-- 2 files changed, 4 insertions(+), 5 deletions(-) diff --git a/modules/network/src/main/java/org/apache/ignite/internal/network/NettyBootstrapFactory.java b/modules/network/src/main/java/org/apache/ignite/internal/network/NettyBootstrapFactory.java index de51b03b29c..d01ab57f1a7 100644 --- a/modules/network/src/main/java/org/apache/ignite/internal/network/NettyBootstrapFactory.java +++ b/modules/network/src/main/java/org/apache/ignite/internal/network/NettyBootstrapFactory.java @@ -141,10 +141,10 @@ public class NettyBootstrapFactory implements IgniteComponent, ChannelEventLoops } /** - * Returns all event loop groups managed by this factory. + * Returns all event loop groups managed by this factory for which it is necessary to determine blocked threads. */ - List<EventLoopGroup> eventLoopGroups() { - return List.of(bossGroup, workerGroup); + List<EventLoopGroup> eventLoopGroupsForDetectBlockedThreads() { + return List.of(workerGroup); } /** {@inheritDoc} */ diff --git a/modules/network/src/main/java/org/apache/ignite/internal/network/NettyWorkersRegistrar.java b/modules/network/src/main/java/org/apache/ignite/internal/network/NettyWorkersRegistrar.java index 01a4389eaf0..c372361b688 100644 --- a/modules/network/src/main/java/org/apache/ignite/internal/network/NettyWorkersRegistrar.java +++ b/modules/network/src/main/java/org/apache/ignite/internal/network/NettyWorkersRegistrar.java @@ -54,7 +54,6 @@ public class NettyWorkersRegistrar implements IgniteComponent { * of the worker corresponding to an event loop. If an event loop's thread is blocked, the hearbeat will not * be updated, and the worker watchdog will treat the event loop worker as blocked. */ - private final CriticalWorkerRegistry criticalWorkerRegistry; private final ScheduledExecutorService scheduler; @@ -96,7 +95,7 @@ public class NettyWorkersRegistrar implements IgniteComponent { @Override public CompletableFuture<Void> startAsync(ComponentContext componentContext) { List<NettyWorker> nettyWorkers = new ArrayList<>(); - for (EventLoopGroup group : bootstrapFactory.eventLoopGroups()) { + for (EventLoopGroup group : bootstrapFactory.eventLoopGroupsForDetectBlockedThreads()) { registerWorkersFor(group, nettyWorkers); } workers = List.copyOf(nettyWorkers);
