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 6f45bdead6f8bb7b238cf2c007cefaa9adb92c3e..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 {
@@ -51,7 +55,11 @@ public class EventDispatcherImpl implements EventDispatcher {
                         logger.info("The event handler thread was interrupted, shutting down", e);
                         return;
                     }
-                    dispatchEvent(ev);
+                    try {
+                        dispatchEvent(ev);
+                    } catch (Exception e) {
+                        logger.error("Exception in dispatching event "+ev.toString(), e);
+                    }
                 }
             }
         });
@@ -85,6 +93,7 @@ public class EventDispatcherImpl implements EventDispatcher {
             return;
         }
 
+        logger.info("EventDispatcherImpl: dispatchEvent: {}", ev);
         handler.processEvent(ev);
     }
 
@@ -123,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);