commit 9df1508342fcfddaeb9c3a5020557fd57ed20504
author Thomas Lee S <thomas.sebastian@radisys.com> Mon Dec 23 11:31:15 2019 +0530
committer Thomas Lee S <thomas.sebastian@radisys.com> Wed Jan 08 14:38:44 2020 +0530
tree ba415271af808d7f65d6a75c0a2fba2fab5cbcf9
parent cfb501fbf6665dc95ccde49c8b6598c2d42e2c9b

VOL-2343: Remove DHCP Allocations upon OLT Removal

Change-Id: I2f0dcfdac53930a7e7f1226bdfbf7a8d4726eaef

app/src/main/java/org/opencord/dhcpl2relay/impl/DhcpL2Relay.java

diff --git a/app/src/main/java/org/opencord/dhcpl2relay/impl/DhcpL2Relay.java b/app/src/main/java/org/opencord/dhcpl2relay/impl/DhcpL2Relay.java
index 411d763..2cd4f88 100755
--- a/app/src/main/java/org/opencord/dhcpl2relay/impl/DhcpL2Relay.java
+++ b/app/src/main/java/org/opencord/dhcpl2relay/impl/DhcpL2Relay.java
@@ -1088,6 +1088,20 @@
     private class InnerDeviceListener implements DeviceListener {
         @Override
         public void event(DeviceEvent event) {
+            switch (event.type()) {
+                case DEVICE_AVAILABILITY_CHANGED:
+                    log.info("Device Avail Changed {}", event.subject().id());
+                    DeviceId deviceId = event.subject().id();
+                    if (!deviceService.isAvailable(deviceId)) {
+                        log.warn("Device {} is not available ", deviceId);
+                        allocationMap.entrySet().removeIf(entry -> deviceId.equals(entry.getValue().
+                                location().deviceId()));
+                        log.info("Device {} is removed from DHCP allocationmap ", deviceId);
+                    }
+                    break;
+                default:
+                    break;
+            }
             if (log.isTraceEnabled() &&
                     !event.type().equals(DeviceEvent.Type.PORT_STATS_UPDATED)) {
                 log.trace("Device Event received for {} event {}",