Deanonymize BGP threads

Use thread factories to identify boss and worker threads.

Change-Id: Ibfe7bf6b869e94a2e243b11d61ecfba0e5ccc008
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>

diff --git a/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/BGPNettyGroups.java b/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/BGPNettyGroups.java
index 7971251fadade0ea350b80efaf92d2329f757697..a16e4635a30baef5127cd369ef528d375ae27320 100644 (file)
--- a/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/BGPNettyGroups.java
+++ b/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/BGPNettyGroups.java
@@ -9,6 +9,7 @@ package org.opendaylight.protocol.bgp.rib.impl;
 
 import static java.util.Objects.requireNonNull;
 
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
 import io.netty.bootstrap.Bootstrap;
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.channel.EventLoopGroup;
@@ -21,6 +22,7 @@ import io.netty.channel.epoll.EpollSocketChannel;
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.nio.NioServerSocketChannel;
 import io.netty.channel.socket.nio.NioSocketChannel;
+import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.TimeUnit;
 import javax.annotation.PreDestroy;
 import javax.inject.Inject;
@@ -52,7 +54,7 @@ public final class BGPNettyGroups implements AutoCloseable {
 
     private static final class EpollImpl extends AbstractImpl {
         EpollImpl() {
-            super(new EpollEventLoopGroup(), new EpollEventLoopGroup());
+            super(new EpollEventLoopGroup(BOSS_TF), new EpollEventLoopGroup(WORKER_TF));
         }
 
         @Override
@@ -75,7 +77,7 @@ public final class BGPNettyGroups implements AutoCloseable {
 
     private static final class NioImpl extends AbstractImpl {
         NioImpl() {
-            super(new NioEventLoopGroup(), new NioEventLoopGroup());
+            super(new NioEventLoopGroup(BOSS_TF), new NioEventLoopGroup(WORKER_TF));
         }
 
         @Override
@@ -94,6 +96,14 @@ public final class BGPNettyGroups implements AutoCloseable {
         }
     }
 
+    private static final ThreadFactory BOSS_TF = new ThreadFactoryBuilder()
+        .setNameFormat("bgp-boss-%d")
+        .setDaemon(true)
+        .build();
+    private static final ThreadFactory WORKER_TF = new ThreadFactoryBuilder()
+        .setNameFormat("bgp-worker-%d")
+        .setDaemon(true)
+        .build();
     private static final long TIMEOUT = 10;
 
     private AbstractImpl impl;