dhcpservice/impl/src/main/java/org/opendaylight/netvirt/dhcpservice/DhcpInterfaceEventListener.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.netvirt.dhcpservice;
   9
  10 import java.util.List;
  11 import javax.annotation.PreDestroy;
  12 import org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager;
  13 import org.opendaylight.infrautils.jobcoordinator.JobCoordinator;
  14 import org.opendaylight.infrautils.utils.concurrent.Executors;
  15 import org.opendaylight.mdsal.binding.api.DataBroker;
  16 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
  17 import org.opendaylight.netvirt.dhcpservice.api.DhcpMConstants;
  18 import org.opendaylight.netvirt.dhcpservice.jobs.DhcpInterfaceAddJob;
  19 import org.opendaylight.netvirt.dhcpservice.jobs.DhcpInterfaceRemoveJob;
  20 import org.opendaylight.netvirt.dhcpservice.jobs.DhcpInterfaceUpdateJob;
  21 import org.opendaylight.netvirt.elanmanager.api.IElanService;
  22 import org.opendaylight.netvirt.neutronvpn.api.utils.NeutronConstants;
  23 import org.opendaylight.serviceutils.tools.listener.AbstractAsyncDataTreeChangeListener;
  24 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.iana._if.type.rev170119.L2vlan;
  25 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.iana._if.type.rev170119.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.genius.itm.rpcs.rev160406.ItmRpcService;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;
  32 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  33 import org.opendaylight.yangtools.yang.common.Uint64;
  34 import org.slf4j.Logger;
  35 import org.slf4j.LoggerFactory;
  36
  37 public class DhcpInterfaceEventListener extends AbstractAsyncDataTreeChangeListener<Interface> {
  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 JobCoordinator jobCoordinator;
  45     private final IInterfaceManager interfaceManager;
  46     private final IElanService elanService;
  47     private final DhcpPortCache dhcpPortCache;
  48     private final ItmRpcService itmRpcService;
  49
  50     public DhcpInterfaceEventListener(DhcpManager dhcpManager, DataBroker dataBroker,
  51                                       DhcpExternalTunnelManager dhcpExternalTunnelManager,
  52                                       IInterfaceManager interfaceManager, IElanService elanService,
  53                                       DhcpPortCache dhcpPortCache, JobCoordinator jobCoordinator,
  54                                       ItmRpcService itmRpcService) {
  55         super(dataBroker, LogicalDatastoreType.OPERATIONAL, InstanceIdentifier.create(InterfacesState.class)
  56                 .child(Interface.class),
  57                 Executors.newListeningSingleThreadExecutor("DhcpInterfaceEventListener", LOG));
  58         this.dhcpManager = dhcpManager;
  59         this.dataBroker = dataBroker;
  60         this.dhcpExternalTunnelManager = dhcpExternalTunnelManager;
  61         this.interfaceManager = interfaceManager;
  62         this.elanService = elanService;
  63         this.dhcpPortCache = dhcpPortCache;
  64         this.jobCoordinator = jobCoordinator;
  65         this.itmRpcService = itmRpcService;
  66     }
  67
  68     @Override
  69     @PreDestroy
  70     public void close() {
  71         super.close();
  72         Executors.shutdownAndAwaitTermination(getExecutorService());
  73         LOG.info("DhcpInterfaceEventListener Closed");
  74     }
  75
  76     @Override
  77     public void remove(InstanceIdentifier<Interface> identifier, Interface del) {
  78         if (!L2vlan.class.equals(del.getType()) && !Tunnel.class.equals(del.getType())) {
  79             return;
  80         }
  81         List<String> ofportIds = del.getLowerLayerIf();
  82         if (ofportIds == null || ofportIds.isEmpty()) {
  83             return;
  84         }
  85         String interfaceName = del.getName();
  86         Port port = dhcpPortCache.get(interfaceName);
  87         if (NeutronConstants.IS_DHCP_PORT.test(port)) {
  88             return;
  89         }
  90         NodeConnectorId nodeConnectorId = new NodeConnectorId(ofportIds.get(0));
  91         Uint64 dpnId = DhcpServiceUtils.getDpnIdFromNodeConnectorId(nodeConnectorId);
  92
  93         DhcpInterfaceRemoveJob job = new DhcpInterfaceRemoveJob(dhcpManager, dhcpExternalTunnelManager,
  94                 dataBroker, del, dpnId, interfaceManager, elanService, port);
  95         jobCoordinator.enqueueJob(DhcpServiceUtils.getJobKey(interfaceName), job, DhcpMConstants.RETRY_COUNT);
  96         dhcpPortCache.remove(interfaceName);
  97     }
  98
  99     @Override
 100     public void update(InstanceIdentifier<Interface> identifier,
 101             Interface original, Interface update) {
 102         // We're only interested in Vlan and Tunnel ports
 103         if (!L2vlan.class.equals(update.getType()) && !Tunnel.class.equals(update.getType())) {
 104             return;
 105         }
 106         if ((original.getOperStatus().getIntValue() ^ update.getOperStatus().getIntValue()) == 0) {
 107             LOG.trace("Interface operstatus is same orig {} updated {}", original, update);
 108             return;
 109         }
 110         List<String> ofportIds = update.getLowerLayerIf();
 111         if (ofportIds == null || ofportIds.isEmpty()) {
 112             return;
 113         }
 114         NodeConnectorId nodeConnectorId = new NodeConnectorId(ofportIds.get(0));
 115         Uint64 dpnId = DhcpServiceUtils.getDpnIdFromNodeConnectorId(nodeConnectorId);
 116         String interfaceName = update.getName();
 117         OperStatus updatedOperStatus = update.getOperStatus();
 118         if (original.getOperStatus().equals(OperStatus.Up) && updatedOperStatus.equals(OperStatus.Unknown)) {
 119             updatedOperStatus = OperStatus.Down;
 120         }
 121         DhcpInterfaceUpdateJob job = new DhcpInterfaceUpdateJob(dhcpExternalTunnelManager, dataBroker,
 122                 interfaceName, dpnId, updatedOperStatus, interfaceManager);
 123         jobCoordinator.enqueueJob(DhcpServiceUtils.getJobKey(interfaceName), job, DhcpMConstants.RETRY_COUNT);
 124     }
 125
 126     @Override
 127     public void add(InstanceIdentifier<Interface> identifier, Interface add) {
 128         // We're only interested in Vlan and Tunnel ports
 129         if (!L2vlan.class.equals(add.getType()) && !Tunnel.class.equals(add.getType())) {
 130             return;
 131         }
 132         String interfaceName = add.getName();
 133         LOG.trace("DhcpInterfaceAddJob to be created for interface {}", interfaceName);
 134         List<String> ofportIds = add.getLowerLayerIf();
 135         if (ofportIds == null || ofportIds.isEmpty()) {
 136             return;
 137         }
 138         if (!Tunnel.class.equals(add.getType())) {
 139             Port port = dhcpManager.getNeutronPort(interfaceName);
 140             if (NeutronConstants.IS_DHCP_PORT.test(port)) {
 141                 return;
 142             }
 143             dhcpPortCache.put(interfaceName, port);
 144         }
 145         NodeConnectorId nodeConnectorId = new NodeConnectorId(ofportIds.get(0));
 146         Uint64 dpnId = DhcpServiceUtils.getDpnIdFromNodeConnectorId(nodeConnectorId);
 147         DhcpInterfaceAddJob job = new DhcpInterfaceAddJob(dhcpManager, dhcpExternalTunnelManager, dataBroker,
 148                 add, dpnId, interfaceManager, elanService, itmRpcService);
 149         jobCoordinator.enqueueJob(DhcpServiceUtils.getJobKey(interfaceName), job, DhcpMConstants.RETRY_COUNT);
 150     }
 151 }