Netvirt troubleshooting improvements

Change-Id: I0bec5b26a5fe2f68b1e735e06a60dd493a83e467
Signed-off-by: M Navaneethan <m.navaneethan@ericsson.com>
Signed-off-by: Ashik Alias <ashik.alias@ericsson.com>

diff --git a/bgpmanager/impl/src/main/java/org/opendaylight/netvirt/bgpmanager/BgpConfigurationManager.java b/bgpmanager/impl/src/main/java/org/opendaylight/netvirt/bgpmanager/BgpConfigurationManager.java
index b353c0013c002214f90e907291277fb5eaebf0c0..78c2642f023f3296df27551514422cd7a9632c06 100755 (executable)
--- a/bgpmanager/impl/src/main/java/org/opendaylight/netvirt/bgpmanager/BgpConfigurationManager.java
+++ b/bgpmanager/impl/src/main/java/org/opendaylight/netvirt/bgpmanager/BgpConfigurationManager.java
@@ -250,7 +250,7 @@ public class BgpConfigurationManager implements EbgpService {
     private int totalExternalMacRoutes;
 
     private final ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor(
-            new ThreadFactoryBuilder().setNameFormat("BgpConfigurationManager-%d").setDaemon(true).build());
+            new ThreadFactoryBuilder().setNameFormat("bgp-config-%d").setDaemon(true).build());
 
     /**
      * this map store the new address families to send to quagga. When it is sended you must clear it.

diff --git a/elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/utils/Scheduler.java b/elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/utils/Scheduler.java
index 03140128a1546a4429184b36b5a187e1f043b023..3540440a47120340bd33b5b8b8fdd743684117ce 100644 (file)
--- a/elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/utils/Scheduler.java
+++ b/elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/utils/Scheduler.java
@@ -8,14 +8,21 @@
 
 package org.opendaylight.netvirt.elan.utils;
 
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
+
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.ThreadFactory;
 import javax.inject.Singleton;
 
 @Singleton
 public class Scheduler implements AutoCloseable {
 
-    private final ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
+    private final ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
+            .setNameFormat("elan-sched-%d").build();
+
+    private final ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1,
+            namedThreadFactory);
 
     public ScheduledExecutorService getScheduledExecutorService() {
         return scheduledExecutorService;

diff --git a/ipv6service/impl/src/main/java/org/opendaylight/netvirt/ipv6service/Ipv6PktHandler.java b/ipv6service/impl/src/main/java/org/opendaylight/netvirt/ipv6service/Ipv6PktHandler.java
index dafaf918cf9f795ac0c4ce9bd04aa97ef366a3f2..81e461ffba428483cc92fa2e4b07ed68686ec2ba 100644 (file)
--- a/ipv6service/impl/src/main/java/org/opendaylight/netvirt/ipv6service/Ipv6PktHandler.java
+++ b/ipv6service/impl/src/main/java/org/opendaylight/netvirt/ipv6service/Ipv6PktHandler.java
@@ -7,6 +7,7 @@
  */
 package org.opendaylight.netvirt.ipv6service;
 
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
 import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
 import java.net.InetAddress;
 import java.net.UnknownHostException;
@@ -14,6 +15,7 @@ import java.nio.ByteBuffer;
 import java.util.Arrays;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.atomic.AtomicLong;
 import javax.annotation.PreDestroy;
 import javax.inject.Inject;
@@ -63,7 +65,10 @@ public class Ipv6PktHandler implements AutoCloseable, PacketProcessingListener {
     private final IfMgr ifMgr;
     private final IIpv6PacketListener ipv6PktListener;
 
-    private final ExecutorService packetProcessor = Executors.newCachedThreadPool();
+    private final ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
+            .setNameFormat("ipv6-pkt-%d").build();
+
+    private final ExecutorService packetProcessor = Executors.newCachedThreadPool(namedThreadFactory);
 
     @Inject
     public Ipv6PktHandler(PacketProcessingService pktService, IfMgr ifMgr, IIpv6PacketListener ipv6PktListener) {