vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/VpnElanInterfaceChangeListener.java

   1 /*
   2  * Copyright (c) 2016 Hewlett Packard Enterprise, Co. 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
   9 package org.opendaylight.netvirt.vpnmanager;
  10
  11 import static org.opendaylight.genius.infra.Datastore.CONFIGURATION;
  12
  13 import java.util.ArrayList;
  14 import java.util.List;
  15 import javax.annotation.PreDestroy;
  16 import javax.inject.Inject;
  17 import javax.inject.Singleton;
  18 import org.opendaylight.genius.infra.ManagedNewTransactionRunner;
  19 import org.opendaylight.genius.infra.ManagedNewTransactionRunnerImpl;
  20 import org.opendaylight.infrautils.utils.concurrent.Executors;
  21 import org.opendaylight.infrautils.utils.concurrent.ListenableFutures;
  22 import org.opendaylight.mdsal.binding.api.DataBroker;
  23 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
  24 import org.opendaylight.netvirt.elanmanager.api.IElanService;
  25 import org.opendaylight.netvirt.vpnmanager.api.VpnHelper;
  26 import org.opendaylight.serviceutils.tools.listener.AbstractAsyncDataTreeChangeListener;
  27 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.ElanInterfaces;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.interfaces.ElanInterface;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn.rev200204.vpn.interfaces.VpnInterface;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn.rev200204.vpn.interfaces.VpnInterfaceBuilder;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn.rev200204.vpn.interfaces.VpnInterfaceKey;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn.rev200204.vpn.interfaces.vpn._interface.VpnInstanceNames;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn.rev200204.vpn.interfaces.vpn._interface.VpnInstanceNames.AssociatedSubnetType;
  35 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  36 import org.slf4j.Logger;
  37 import org.slf4j.LoggerFactory;
  38
  39 @Singleton
  40 public class VpnElanInterfaceChangeListener extends AbstractAsyncDataTreeChangeListener<ElanInterface> {
  41     private static final Logger LOG = LoggerFactory.getLogger(VpnElanInterfaceChangeListener.class);
  42
  43     private final DataBroker broker;
  44     private final ManagedNewTransactionRunner txRunner;
  45     private final IElanService elanService;
  46     private final VpnUtil vpnUtil;
  47
  48     @Inject
  49     public VpnElanInterfaceChangeListener(final DataBroker broker, final IElanService elanService,
  50                                           final VpnUtil vpnUtil) {
  51         super(broker, LogicalDatastoreType.CONFIGURATION,
  52                 InstanceIdentifier.create(ElanInterfaces.class).child(ElanInterface.class),
  53                 Executors.newListeningSingleThreadExecutor("VpnElanInterfaceChangeListener", LOG));
  54         this.broker = broker;
  55         this.txRunner = new ManagedNewTransactionRunnerImpl(broker);
  56         this.elanService = elanService;
  57         this.vpnUtil = vpnUtil;
  58         start();
  59     }
  60
  61     public void start() {
  62         LOG.info("{} start", getClass().getSimpleName());
  63     }
  64
  65     @Override
  66     @PreDestroy
  67     public void close() {
  68         super.close();
  69         Executors.shutdownAndAwaitTermination(getExecutorService());
  70     }
  71
  72
  73     @Override
  74     public void remove(InstanceIdentifier<ElanInterface> key, ElanInterface elanInterface) {
  75         String interfaceName = elanInterface.getName();
  76         if (!elanService.isExternalInterface(interfaceName)) {
  77             LOG.debug("remove: Interface {} is not external. Ignoring interface removal", interfaceName);
  78             return;
  79         }
  80
  81         if (!vpnUtil.isVpnInterfaceConfigured(interfaceName)) {
  82             LOG.debug("remove: VpnInterface was never configured for {}. Ignoring interface removal", interfaceName);
  83             return;
  84         }
  85
  86         InstanceIdentifier<VpnInterface> vpnInterfaceIdentifier = VpnUtil.getVpnInterfaceIdentifier(interfaceName);
  87         ListenableFutures.addErrorLogging(txRunner.callWithNewWriteOnlyTransactionAndSubmit(CONFIGURATION, tx ->
  88             tx.delete(vpnInterfaceIdentifier)), LOG, "Error removing VPN interface {}", vpnInterfaceIdentifier);
  89         LOG.info("remove: Removed VPN interface {}", interfaceName);
  90     }
  91
  92     @Override
  93     public void update(InstanceIdentifier<ElanInterface> key, ElanInterface origElanInterface,
  94         ElanInterface updatedElanInterface) {
  95
  96     }
  97
  98     @Override
  99     public void add(InstanceIdentifier<ElanInterface> key, ElanInterface elanInterface) {
 100         String interfaceName = elanInterface.getName();
 101         if (!elanService.isExternalInterface(interfaceName)) {
 102             LOG.debug("add: Interface {} is not external. Ignoring", interfaceName);
 103             return;
 104         }
 105
 106         Uuid networkId;
 107         try {
 108             networkId = new Uuid(elanInterface.getElanInstanceName());
 109         } catch (IllegalArgumentException e) {
 110             LOG.debug("add: ELAN instance {} for interface {} is not Uuid", elanInterface.getElanInstanceName(),
 111                     elanInterface.getName());
 112             return;
 113         }
 114
 115         Uuid vpnId = vpnUtil.getExternalNetworkVpnId(networkId);
 116         if (vpnId == null) {
 117             LOG.debug("add: Network {} is not external or vpn-id missing. Ignoring interface {} on elan {}",
 118                     networkId.getValue(), elanInterface.getName(), elanInterface.getElanInstanceName());
 119             return;
 120         }
 121         VpnInstanceNames vpnInstance = VpnHelper
 122             .getVpnInterfaceVpnInstanceNames(vpnId.getValue(), AssociatedSubnetType.V4AndV6Subnets);
 123         List<VpnInstanceNames> listVpn = new ArrayList<>();
 124         listVpn.add(vpnInstance);
 125         VpnInterface vpnInterface = new VpnInterfaceBuilder().withKey(new VpnInterfaceKey(interfaceName))
 126             .setVpnInstanceNames(listVpn)
 127             .build();
 128         InstanceIdentifier<VpnInterface> vpnInterfaceIdentifier = VpnUtil.getVpnInterfaceIdentifier(interfaceName);
 129         vpnUtil.syncWrite(LogicalDatastoreType.CONFIGURATION, vpnInterfaceIdentifier, vpnInterface);
 130         LOG.info("add: Added VPN interface {} with VPN-id {} elanInstance {}", interfaceName, vpnId.getValue(),
 131                 elanInterface.getElanInstanceName());
 132     }
 133
 134 }