(ignite-3) branch main updated: IGNITE-25908 Remove pool "network-accept" from CriticalWorkerWatchdog (#6248)

[tkalkirill]

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

tkalkirill pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 13ff703b22a IGNITE-25908 Remove pool "network-accept" from 
CriticalWorkerWatchdog (#6248)
13ff703b22a is described below

commit 13ff703b22afb61db8379abd00a50d11970e5457
Author: Kirill Tkalenko <tkalkir...@yandex.ru>
AuthorDate: Tue Jul 15 15:03:46 2025 +0300

    IGNITE-25908 Remove pool "network-accept" from CriticalWorkerWatchdog 
(#6248)
---
 .../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..e3dfb22a612 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> eventLoopGroupsForBlockedThreadsDetection() {
+        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..733036183ce 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.eventLoopGroupsForBlockedThreadsDetection()) {
             registerWorkersFor(group, nettyWorkers);
         }
         workers = List.copyOf(nettyWorkers);