2 * Copyright (c) 2016 Hewlett Packard Enterprise, Co. and others. All rights reserved.
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
9 package org.opendaylight.netvirt.vpnmanager;
11 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
12 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
13 import org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase;
14 import org.opendaylight.netvirt.elanmanager.api.IElanService;
15 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.interfaces.VpnInterface;
16 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.ElanInterfaces;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.interfaces.ElanInterface;
19 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
20 import org.slf4j.Logger;
21 import org.slf4j.LoggerFactory;
23 public class VpnElanInterfaceChangeListener
24 extends AsyncDataTreeChangeListenerBase<ElanInterface, VpnElanInterfaceChangeListener> {
25 private static final Logger LOG = LoggerFactory.getLogger(VpnElanInterfaceChangeListener.class);
27 private final DataBroker broker;
28 private final IElanService elanService;
30 public VpnElanInterfaceChangeListener(final DataBroker broker, final IElanService elanService) {
31 super(ElanInterface.class, VpnElanInterfaceChangeListener.class);
33 this.elanService = elanService;
37 LOG.info("{} start", getClass().getSimpleName());
38 registerListener(LogicalDatastoreType.CONFIGURATION, broker);
42 protected InstanceIdentifier<ElanInterface> getWildCardPath() {
43 return InstanceIdentifier.create(ElanInterfaces.class).child(ElanInterface.class);
47 protected void remove(InstanceIdentifier<ElanInterface> key, ElanInterface elanInterface) {
48 String interfaceName = elanInterface.getName();
49 if (!elanService.isExternalInterface(interfaceName)) {
50 LOG.trace("Interface {} is not external. Ignoring interface removal", interfaceName);
54 if (!VpnUtil.isVpnInterfaceConfigured(broker, interfaceName)) {
55 LOG.trace("VpnInterface was never configured for {}. Ignoring interface removal", interfaceName);
59 LOG.info("Removing VPN interface {}", interfaceName);
60 InstanceIdentifier<VpnInterface> vpnInterfaceIdentifier = VpnUtil.getVpnInterfaceIdentifier(interfaceName);
61 VpnUtil.delete(broker, LogicalDatastoreType.CONFIGURATION, vpnInterfaceIdentifier);
65 protected void update(InstanceIdentifier<ElanInterface> key, ElanInterface origElanInterface,
66 ElanInterface updatedElanInterface) {
71 protected void add(InstanceIdentifier<ElanInterface> key, ElanInterface elanInterface) {
72 String interfaceName = elanInterface.getName();
73 if (!elanService.isExternalInterface(interfaceName)) {
74 LOG.trace("Interface {} is not external. Ignoring", interfaceName);
80 networkId = new Uuid(elanInterface.getElanInstanceName());
81 } catch (IllegalArgumentException e) {
82 LOG.debug("ELAN instance {} is not Uuid", elanInterface.getElanInstanceName());
86 Uuid vpnId = VpnUtil.getExternalNetworkVpnId(broker, networkId);
88 LOG.trace("Network {} is not external or vpn-id missing. Ignoring", networkId.getValue());
92 LOG.info("Adding VPN interface {} with VPN-id {}", interfaceName, vpnId.getValue());
93 VpnInterface vpnInterface = VpnUtil.getVpnInterface(interfaceName, vpnId.getValue(), null, null, Boolean.FALSE);
94 InstanceIdentifier<VpnInterface> vpnInterfaceIdentifier = VpnUtil.getVpnInterfaceIdentifier(interfaceName);
95 VpnUtil.syncWrite(broker, LogicalDatastoreType.CONFIGURATION, vpnInterfaceIdentifier, vpnInterface);
99 protected VpnElanInterfaceChangeListener getDataTreeChangeListener() {