commit b776aef4a9f734c77f55117665e5875358acf112
author Saurav Das <saurav.das@opennetworking.org> Mon Mar 09 14:29:46 2020 -0700
committer Saurav Das <saurav.das@opennetworking.org> Mon Mar 09 14:38:24 2020 -0700
tree 9882e4c650edceb4768e6d2a207659ccdbf5c290
parent 7cbf431dc4b0e24ccb868f9429645a23e8dea7a3

VOL-2729 Handling eapol remove for disabled port in the case where subscriber has not been provisioned yet

Change-Id: Ic9719489993e7343fb9fd75c617e93ddc18c60e4

app/src/main/java/org/opencord/olt/impl/Olt.java

diff --git a/app/src/main/java/org/opencord/olt/impl/Olt.java b/app/src/main/java/org/opencord/olt/impl/Olt.java
index 0489f03..4ffc116 100644
--- a/app/src/main/java/org/opencord/olt/impl/Olt.java
+++ b/app/src/main/java/org/opencord/olt/impl/Olt.java
@@ -1001,15 +1001,19 @@
                         ConnectPoint cp = new ConnectPoint(devId, port.number());
                         Collection<? extends UniTagInformation> uniTagInformationSet = programmedSubs.get(cp).value();
                         if (uniTagInformationSet == null || uniTagInformationSet.isEmpty()) {
-                            if (port.isEnabled() && !port.number().equals(PortNumber.LOCAL)) {
-                                log.info("eapol will be processed for port updated {}", port);
+                            if (!port.number().equals(PortNumber.LOCAL)) {
+                                log.info("eapol will be {} for dev/port updated {}/{}",
+                                         (port.isEnabled()) ? "added" : "removed",
+                                         devId, port.number());
                                 oltFlowService.processEapolFilteringObjectives(devId, port.number(), defaultBpId,
                                                                                null,
                                                                                VlanId.vlanId(EAPOL_DEFAULT_VLAN),
                                                                                port.isEnabled());
                             }
                         } else {
-                            log.info("eapol will be processed for port updated {}", port);
+                            log.info("eapol will be {} for dev/port updated {}/{}",
+                                     (port.isEnabled()) ? "added" : "removed",
+                                     devId, port.number());
                             uniTagInformationSet.forEach(uniTag ->
                                 oltFlowService.processEapolFilteringObjectives(devId, port.number(),
                                     uniTag.getUpstreamBandwidthProfile(), null,