interfacemanager/interfacemanager-impl/src/main/java/org/opendaylight/genius/interfacemanager/listeners/VlanMemberConfigListener.java

   1 /*
   2  * Copyright (c) 2016, 2017 Ericsson India Global Services Pvt Ltd. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.genius.interfacemanager.listeners;
   9
  10 import javax.annotation.Nonnull;
  11 import javax.inject.Inject;
  12 import javax.inject.Singleton;
  13 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  14 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  15 import org.opendaylight.genius.datastoreutils.listeners.AbstractSyncDataTreeChangeListener;
  16 import org.opendaylight.genius.interfacemanager.IfmConstants;
  17 import org.opendaylight.genius.interfacemanager.renderer.ovs.confighelpers.OvsVlanMemberConfigAddHelper;
  18 import org.opendaylight.genius.interfacemanager.renderer.ovs.confighelpers.OvsVlanMemberConfigRemoveHelper;
  19 import org.opendaylight.genius.interfacemanager.renderer.ovs.confighelpers.OvsVlanMemberConfigUpdateHelper;
  20 import org.opendaylight.infrautils.jobcoordinator.JobCoordinator;
  21 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.Interfaces;
  22 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfL2vlan;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.ParentRefs;
  25 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  26 import org.slf4j.Logger;
  27 import org.slf4j.LoggerFactory;
  28
  29 @Singleton
  30 public class VlanMemberConfigListener extends AbstractSyncDataTreeChangeListener<Interface> {
  31
  32     private static final Logger LOG = LoggerFactory.getLogger(VlanMemberConfigListener.class);
  33
  34     private final JobCoordinator coordinator;
  35     private final OvsVlanMemberConfigAddHelper ovsVlanMemberConfigAddHelper;
  36     private final OvsVlanMemberConfigRemoveHelper ovsVlanMemberConfigRemoveHelper;
  37     private final OvsVlanMemberConfigUpdateHelper ovsVlanMemberConfigUpdateHelper;
  38
  39     @Inject
  40     public VlanMemberConfigListener(final DataBroker dataBroker,
  41             final JobCoordinator coordinator,
  42             final OvsVlanMemberConfigAddHelper ovsVlanMemberConfigAddHelper,
  43             final OvsVlanMemberConfigRemoveHelper ovsVlanMemberConfigRemoveHelper,
  44             final OvsVlanMemberConfigUpdateHelper ovsVlanMemberConfigUpdateHelper) {
  45         super(dataBroker, LogicalDatastoreType.CONFIGURATION,
  46               InstanceIdentifier.create(Interfaces.class).child(Interface.class));
  47         this.coordinator = coordinator;
  48         this.ovsVlanMemberConfigAddHelper = ovsVlanMemberConfigAddHelper;
  49         this.ovsVlanMemberConfigRemoveHelper = ovsVlanMemberConfigRemoveHelper;
  50         this.ovsVlanMemberConfigUpdateHelper = ovsVlanMemberConfigUpdateHelper;
  51     }
  52
  53     @Override
  54     public void remove(@Nonnull InstanceIdentifier<Interface> instanceIdentifier, @Nonnull Interface removedInterface) {
  55         IfL2vlan ifL2vlan = removedInterface.getAugmentation(IfL2vlan.class);
  56         if (ifL2vlan == null || IfL2vlan.L2vlanMode.TrunkMember != ifL2vlan.getL2vlanMode()) {
  57             return;
  58         }
  59         removeVlanMember(removedInterface);
  60     }
  61
  62     private void removeVlanMember(Interface removedInterface) {
  63         ParentRefs parentRefs = removedInterface.getAugmentation(ParentRefs.class);
  64         if (parentRefs == null) {
  65             LOG.error("Attempt to remove Vlan Trunk-Member {} without a parent interface", removedInterface);
  66             return;
  67         }
  68
  69         String lowerLayerIf = parentRefs.getParentInterface();
  70         if (lowerLayerIf.equals(removedInterface.getName())) {
  71             LOG.error("Attempt to remove Vlan Trunk-Member {} with same parent interface name.", removedInterface);
  72             return;
  73         }
  74         coordinator.enqueueJob(lowerLayerIf,
  75             () -> ovsVlanMemberConfigRemoveHelper.removeConfiguration(parentRefs, removedInterface),
  76                                IfmConstants.JOB_MAX_RETRIES);
  77     }
  78
  79     @Override
  80     public void update(@Nonnull InstanceIdentifier<Interface> instanceIdentifier,
  81                        @Nonnull Interface originalInterface, @Nonnull Interface updatedInterface) {
  82         IfL2vlan ifL2vlanNew = updatedInterface.getAugmentation(IfL2vlan.class);
  83         if (ifL2vlanNew == null) {
  84             return;
  85         }
  86         IfL2vlan ifL2vlanOld = originalInterface.getAugmentation(IfL2vlan.class);
  87         if (IfL2vlan.L2vlanMode.TrunkMember == ifL2vlanNew.getL2vlanMode()
  88                 && IfL2vlan.L2vlanMode.Trunk == ifL2vlanOld.getL2vlanMode()) {
  89             // Trunk subport add use case
  90             addVlanMember(updatedInterface);
  91             return;
  92         } else if (IfL2vlan.L2vlanMode.Trunk == ifL2vlanNew.getL2vlanMode()
  93                 && IfL2vlan.L2vlanMode.TrunkMember == ifL2vlanOld.getL2vlanMode()) {
  94             // Trunk subport remove use case
  95             removeVlanMember(originalInterface);
  96         } else if (IfL2vlan.L2vlanMode.TrunkMember != ifL2vlanNew.getL2vlanMode()) {
  97             return;
  98         }
  99
 100         ParentRefs parentRefsNew = updatedInterface.getAugmentation(ParentRefs.class);
 101         if (parentRefsNew == null) {
 102             LOG.error("Configuration Error. Attempt to update Vlan Trunk-Member {} without a " + "parent interface",
 103                       updatedInterface);
 104             return;
 105         }
 106
 107         String lowerLayerIf = parentRefsNew.getParentInterface();
 108         if (lowerLayerIf.equals(updatedInterface.getName())) {
 109             LOG.error(
 110                     "Configuration Error. Attempt to update Vlan Trunk-Member {} with same parent " + "interface name.",
 111                     updatedInterface);
 112             return;
 113         }
 114         coordinator.enqueueJob(lowerLayerIf, () -> ovsVlanMemberConfigUpdateHelper
 115                                        .updateConfiguration(parentRefsNew, originalInterface, ifL2vlanNew,
 116                                                             updatedInterface),
 117                                IfmConstants.JOB_MAX_RETRIES);
 118     }
 119
 120     @Override
 121     public void add(@Nonnull InstanceIdentifier<Interface> instanceIdentifier,
 122                     @Nonnull Interface newInterface) {
 123         IfL2vlan ifL2vlan = newInterface.getAugmentation(IfL2vlan.class);
 124         if (ifL2vlan == null || IfL2vlan.L2vlanMode.TrunkMember != ifL2vlan.getL2vlanMode()) {
 125             return;
 126         }
 127         addVlanMember(newInterface);
 128     }
 129
 130     private void addVlanMember(Interface added) {
 131         ParentRefs parentRefs = added.getAugmentation(ParentRefs.class);
 132         if (parentRefs == null) {
 133             return;
 134         }
 135
 136         String lowerLayerIf = parentRefs.getParentInterface();
 137         if (lowerLayerIf.equals(added.getName())) {
 138             LOG.error("Attempt to add Vlan Trunk-Member {} with same parent interface name.", added);
 139             return;
 140         }
 141         coordinator.enqueueJob(lowerLayerIf, () -> ovsVlanMemberConfigAddHelper.addConfiguration(parentRefs, added),
 142                                IfmConstants.JOB_MAX_RETRIES);
 143     }
 144 }