commit 78d3ed372752b150e577fa212cb2cc9c8216b139
author Jian Li <pyguni@gmail.com> Thu Aug 09 12:02:06 2018 +0900
committer Jian Li <pyguni@gmail.com> Fri Aug 10 08:42:13 2018 +0000
tree 0e53bcfc83b285378dd137c431a5f6e35299e195
parent 0b93b00d007fa9ab1e894b0258ec27b1a62ed8b6

Fix: spawn a new thread to handle OPENSTACK port removal events

Change-Id: I8f07d212326eed3f9aace71a515814c8b8a1d549

apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackRoutingFloatingIpHandler.java

diff --git a/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackRoutingFloatingIpHandler.java b/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackRoutingFloatingIpHandler.java
index f20eb51..b23279d 100644
--- a/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackRoutingFloatingIpHandler.java
+++ b/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackRoutingFloatingIpHandler.java
@@ -955,21 +955,15 @@
 
         @Override
         public void event(OpenstackNetworkEvent event) {
-            String portId;
-
             switch (event.type()) {
                 case OPENSTACK_PORT_PRE_REMOVE:
-                    portId = event.port().getId();
-
-                    InstancePort instPort = instancePortService.instancePort(portId);
-                    updateFipStore(instPort);
-
+                    eventExecutor.execute(() ->
+                            updateFipStore(instancePortService.instancePort(event.port().getId()))
+                    );
                     break;
                 case OPENSTACK_PORT_REMOVED:
-                    portId = event.port().getId();
-
-                    instancePortService.removeInstancePort(portId);
-
+                    eventExecutor.execute(() ->
+                            instancePortService.removeInstancePort(event.port().getId()));
                     break;
                 default:
                     break;