Squashed commit of the following:

[ovsdb.git] / openstack / net-virt / src / main / java / org / opendaylight / ovsdb / openstack / netvirt / impl / EventDispatcherImpl.java

diff --git a/openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/impl/EventDispatcherImpl.java b/openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/impl/EventDispatcherImpl.java
index 8ef0d2c0155ecb021e4fd1c6377ea5a6e2b8b3b6..5ce2c6da8996d6ecea89e23b960afb035ae99192 100644 (file)
--- a/openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/impl/EventDispatcherImpl.java
+++ b/openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/impl/EventDispatcherImpl.java
@@ -43,6 +43,10 @@ public class EventDispatcherImpl implements EventDispatcher {
         eventHandler.submit(new Runnable()  {
             @Override
             public void run() {
+                Thread t = Thread.currentThread();
+                logger.info("Thread = {}", t);
+                t.setName("EventDispatcherImpl");
+                logger.info("Thread = {}", t);
                 while (true) {
                     AbstractEvent ev;
                     try {
@@ -89,6 +93,7 @@ public class EventDispatcherImpl implements EventDispatcher {
             return;
         }
 
+        logger.info("EventDispatcherImpl: dispatchEvent: {}", ev);
         handler.processEvent(ev);
     }
 
@@ -127,10 +132,12 @@ public class EventDispatcherImpl implements EventDispatcher {
     @Override
     public void enqueueEvent(AbstractEvent event) {
         if (event == null) {
+            logger.warn("enqueueEvent: event is null");
             return;
         }
 
         try {
+            logger.info("EventDispatcherImpl: enqueueEvent: {}", event);
             events.put(event);
         } catch (InterruptedException e) {
             logger.error("Thread was interrupted while trying to enqueue event ", e);