commit f1af068af12c86be09fb7f543b49277ca6c13bb1
author Daniel Park <dan.park@sk.com> Tue Aug 09 14:39:57 2016 +0900
committer Gerrit Code Review <gerrit@onlab.us> Wed Aug 10 17:13:55 2016 +0000
tree 1c9af1c958f23cb28a1b38b176d62f7c07ee8c75
parent 6a8cb4f3e54bb186331e7fbb4062551f63366461

[ONOS-5094] Fix to update group bucket when a gateway node jumped to INCOMPLETE state

Change-Id: I630e97c353694dc0f635d4070baf44d0df49b083

apps/openstacknetworking/routing/src/main/java/org/onosproject/openstacknetworking/routing/OpenstackRoutingManager.java

diff --git a/apps/openstacknetworking/routing/src/main/java/org/onosproject/openstacknetworking/routing/OpenstackRoutingManager.java b/apps/openstacknetworking/routing/src/main/java/org/onosproject/openstacknetworking/routing/OpenstackRoutingManager.java
index b6aeab9..9b12402 100644
--- a/apps/openstacknetworking/routing/src/main/java/org/onosproject/openstacknetworking/routing/OpenstackRoutingManager.java
+++ b/apps/openstacknetworking/routing/src/main/java/org/onosproject/openstacknetworking/routing/OpenstackRoutingManager.java
@@ -495,6 +495,17 @@
                 case INIT:
                 case DEVICE_CREATED:
                 case INCOMPLETE:
+                    eventExecutor.execute(() -> {
+                        if (node.type() == GATEWAY) {
+                            GatewayNode gnode = GatewayNode.builder()
+                                    .gatewayDeviceId(node.intBridge())
+                                    .dataIpAddress(node.dataIp().getIp4Address())
+                                    .uplinkIntf(node.externalPortName().get())
+                                    .build();
+                            gatewayService.deleteGatewayNode(gnode);
+                        }
+                        reloadRoutingRules();
+                    });
                 default:
                     break;
             }