git.opendaylight Code Review - netvirt.git/blob

   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.netvirt.dhcpservice;
   9
  10 import java.math.BigInteger;
  11 import java.util.List;
  12 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  13 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  14 import org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase;
  15 import org.opendaylight.genius.datastoreutils.DataStoreJobCoordinator;
  16 import org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager;
  17 import org.opendaylight.genius.mdsalutil.MDSALUtil;
  18 import org.opendaylight.netvirt.dhcpservice.api.DhcpMConstants;
  19 import org.opendaylight.netvirt.dhcpservice.jobs.DhcpInterfaceAddJob;
  20 import org.opendaylight.netvirt.dhcpservice.jobs.DhcpInterfaceRemoveJob;
  21 import org.opendaylight.netvirt.dhcpservice.jobs.DhcpInterfaceUpdateJob;
  22 import org.opendaylight.netvirt.elanmanager.api.IElanService;
  23 import org.opendaylight.netvirt.neutronvpn.api.utils.NeutronConstants;
  24 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.iana._if.type.rev140508.L2vlan;
  25 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.iana._if.type.rev140508.Tunnel;
  26 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.InterfacesState;
  27 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface;
  28 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface.OperStatus;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;
  31 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  32 import org.slf4j.Logger;
  33 import org.slf4j.LoggerFactory;
  34
  35 public class DhcpInterfaceEventListener
  36         extends AsyncDataTreeChangeListenerBase<Interface, DhcpInterfaceEventListener>
  37         implements AutoCloseable {
  38
  39     private static final Logger LOG = LoggerFactory.getLogger(DhcpInterfaceEventListener.class);
  40
  41     private final DataBroker dataBroker;
  42     private final DhcpManager dhcpManager;
  43     private final DhcpExternalTunnelManager dhcpExternalTunnelManager;
  44     private final DataStoreJobCoordinator dataStoreJobCoordinator;
  45     private final IInterfaceManager interfaceManager;
  46     private final IElanService elanService;
  47
  48     public DhcpInterfaceEventListener(DhcpManager dhcpManager, DataBroker dataBroker,
  49                                       DhcpExternalTunnelManager dhcpExternalTunnelManager,
  50                                       IInterfaceManager interfaceManager, IElanService elanService) {
  51         super(Interface.class, DhcpInterfaceEventListener.class);
  52         this.dhcpManager = dhcpManager;
  53         this.dataBroker = dataBroker;
  54         this.dhcpExternalTunnelManager = dhcpExternalTunnelManager;
  55         this.interfaceManager = interfaceManager;
  56         this.elanService = elanService;
  57         registerListener(LogicalDatastoreType.OPERATIONAL, dataBroker);
  58         dataStoreJobCoordinator = DataStoreJobCoordinator.getInstance();
  59     }
  60
  61     @Override
  62     public void close() {
  63         super.close();
  64         LOG.info("DhcpInterfaceEventListener Closed");
  65     }
  66
  67     @Override
  68     protected void remove(InstanceIdentifier<Interface> identifier, Interface del) {
  69         if (!L2vlan.class.equals(del.getType()) && !Tunnel.class.equals(del.getType())) {
  70             return;
  71         }
  72         List<String> ofportIds = del.getLowerLayerIf();
  73         if (ofportIds == null || ofportIds.isEmpty()) {
  74             return;
  75         }
  76         String interfaceName = del.getName();
  77         Port port = dhcpManager.getNeutronPort(interfaceName);
  78         if (NeutronConstants.IS_DHCP_PORT.test(port)) {
  79             return;
  80         }
  81         NodeConnectorId nodeConnectorId = new NodeConnectorId(ofportIds.get(0));
  82         BigInteger dpnId = BigInteger.valueOf(MDSALUtil.getDpnIdFromPortName(nodeConnectorId));
  83         DhcpInterfaceRemoveJob job = new DhcpInterfaceRemoveJob(dhcpManager, dhcpExternalTunnelManager,
  84                 dataBroker, del, dpnId, interfaceManager, elanService);
  85         dataStoreJobCoordinator.enqueueJob(DhcpServiceUtils.getJobKey(interfaceName), job, DhcpMConstants.RETRY_COUNT);
  86     }
  87
  88     @Override
  89     protected void update(InstanceIdentifier<Interface> identifier,
  90             Interface original, Interface update) {
  91         // We're only interested in Vlan and Tunnel ports
  92         if (!L2vlan.class.equals(update.getType()) && !Tunnel.class.equals(update.getType())) {
  93             return;
  94         }
  95         if ((original.getOperStatus().getIntValue() ^ update.getOperStatus().getIntValue()) == 0) {
  96             LOG.trace("Interface operstatus {} is same", update.getOperStatus());
  97             return;
  98         }
  99
 100         if (original.getOperStatus().equals(OperStatus.Unknown) || update.getOperStatus().equals(OperStatus.Unknown)) {
 101             LOG.trace("New/old interface state is unknown not handling");
 102             return;
 103         }
 104
 105         List<String> ofportIds = update.getLowerLayerIf();
 106         if (ofportIds == null || ofportIds.isEmpty()) {
 107             return;
 108         }
 109         NodeConnectorId nodeConnectorId = new NodeConnectorId(ofportIds.get(0));
 110         BigInteger dpnId = BigInteger.valueOf(MDSALUtil.getDpnIdFromPortName(nodeConnectorId));
 111         String interfaceName = update.getName();
 112         DhcpInterfaceUpdateJob job = new DhcpInterfaceUpdateJob(dhcpManager, dhcpExternalTunnelManager, dataBroker,
 113                 interfaceName, dpnId, update.getOperStatus(), interfaceManager);
 114         dataStoreJobCoordinator.enqueueJob(DhcpServiceUtils.getJobKey(interfaceName), job, DhcpMConstants.RETRY_COUNT);
 115     }
 116
 117     @Override
 118     protected void add(InstanceIdentifier<Interface> identifier, Interface add) {
 119         // We're only interested in Vlan and Tunnel ports
 120         if (!L2vlan.class.equals(add.getType()) && !Tunnel.class.equals(add.getType())) {
 121             return;
 122         }
 123         String interfaceName = add.getName();
 124         LOG.trace("DhcpInterfaceAddJob to be created for interface {}", interfaceName);
 125         List<String> ofportIds = add.getLowerLayerIf();
 126         if (ofportIds == null || ofportIds.isEmpty()) {
 127             return;
 128         }
 129         Port port = dhcpManager.getNeutronPort(interfaceName);
 130         if (NeutronConstants.IS_DHCP_PORT.test(port)) {
 131             return;
 132         }
 133
 134         NodeConnectorId nodeConnectorId = new NodeConnectorId(ofportIds.get(0));
 135         BigInteger dpnId = BigInteger.valueOf(MDSALUtil.getDpnIdFromPortName(nodeConnectorId));
 136         DhcpInterfaceAddJob job = new DhcpInterfaceAddJob(dhcpManager, dhcpExternalTunnelManager, dataBroker,
 137                 add, dpnId, interfaceManager, elanService);
 138         dataStoreJobCoordinator.enqueueJob(DhcpServiceUtils.getJobKey(interfaceName), job, DhcpMConstants.RETRY_COUNT);
 139     }
 140
 141     @Override
 142     protected InstanceIdentifier<Interface> getWildCardPath() {
 143         return InstanceIdentifier.create(InterfacesState.class).child(Interface.class);
 144     }
 145
 146     @Override
 147     protected DhcpInterfaceEventListener getDataTreeChangeListener() {
 148         return DhcpInterfaceEventListener.this;
 149     }
 150 }