Netvirt-QoS: new listener for bw rules programming

[netvirt.git] / qosservice / impl / src / main / java / org / opendaylight / netvirt / qosservice / QosNeutronPortChangeListener.java

diff --git a/qosservice/impl/src/main/java/org/opendaylight/netvirt/qosservice/QosNeutronPortChangeListener.java b/qosservice/impl/src/main/java/org/opendaylight/netvirt/qosservice/QosNeutronPortChangeListener.java
index ac2b963aed1d6893b82973e3e1eff11a9b3be31a..d05fb785dd69c2d41237de7072a1238f45be0b47 100644 (file)
--- a/qosservice/impl/src/main/java/org/opendaylight/netvirt/qosservice/QosNeutronPortChangeListener.java
+++ b/qosservice/impl/src/main/java/org/opendaylight/netvirt/qosservice/QosNeutronPortChangeListener.java
@@ -68,6 +68,7 @@ public class QosNeutronPortChangeListener extends AsyncClusteredDataTreeChangeLi
 
     @Override
     protected void add(InstanceIdentifier<Port> instanceIdentifier, Port port) {
+        qosNeutronUtils.addToPortCache(port);
         if (qosNeutronUtils.hasBandwidthLimitRule(port)) {
             qosAlertManager.addToQosAlertCache(port);
         }
@@ -75,6 +76,7 @@ public class QosNeutronPortChangeListener extends AsyncClusteredDataTreeChangeLi
 
     @Override
     protected void remove(InstanceIdentifier<Port> instanceIdentifier, Port port) {
+        qosNeutronUtils.removeFromPortCache(port);
         if (qosNeutronUtils.hasBandwidthLimitRule(port)) {
             qosAlertManager.removeFromQosAlertCache(port);
         }
@@ -82,6 +84,7 @@ public class QosNeutronPortChangeListener extends AsyncClusteredDataTreeChangeLi
 
     @Override
     protected void update(InstanceIdentifier<Port> instanceIdentifier, Port original, Port update) {
+        qosNeutronUtils.addToPortCache(update);
         // check for QoS updates
         QosPortExtension updateQos = update.getAugmentation(QosPortExtension.class);
         QosPortExtension originalQos = original.getAugmentation(QosPortExtension.class);