elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/internal/VpnDpnToTransportZoneListener.java

   1 /*
   2  * Copyright (c) 2017, 2019 HPE 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.elan.internal;
   9
  10 import java.util.stream.Collectors;
  11 import javax.annotation.PreDestroy;
  12 import javax.inject.Inject;
  13 import javax.inject.Singleton;
  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.elan.utils.TransportZoneNotificationUtil;
  18 import org.opendaylight.serviceutils.tools.listener.AbstractAsyncDataTreeChangeListener;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.config.rev150710.ElanConfig;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.VpnInstanceOpData;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.op.data.VpnInstanceOpDataEntry;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.op.data.vpn.instance.op.data.entry.VpnToDpnList;
  23 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  24 import org.slf4j.Logger;
  25 import org.slf4j.LoggerFactory;
  26
  27 @Singleton
  28 public class VpnDpnToTransportZoneListener
  29         extends AbstractAsyncDataTreeChangeListener<VpnToDpnList> {
  30
  31     private static final Logger LOG = LoggerFactory.getLogger(VpnDpnToTransportZoneListener.class);
  32     private final TransportZoneNotificationUtil transportZoneNotificationUtil;
  33     private final DataBroker dbx;
  34     private final Boolean useTransportZone;
  35
  36     @Inject
  37     public VpnDpnToTransportZoneListener(final DataBroker dbx,
  38             final ElanConfig elanConfig, final TransportZoneNotificationUtil tznu) {
  39         super(dbx, LogicalDatastoreType.OPERATIONAL, InstanceIdentifier.create(VpnInstanceOpData.class)
  40                 .child(VpnInstanceOpDataEntry.class).child(VpnToDpnList.class),
  41                 Executors.newListeningSingleThreadExecutor("VpnDpnToTransportZoneListener", LOG));
  42         useTransportZone = elanConfig.isAutoConfigTransportZones();
  43         transportZoneNotificationUtil = tznu;
  44         this.dbx = dbx;
  45         start();
  46     }
  47
  48     public void start() {
  49         if (useTransportZone) {
  50             LOG.info("{} registered", getClass().getSimpleName());
  51         }
  52     }
  53
  54     @Override
  55     @PreDestroy
  56     public void close() {
  57         super.close();
  58         Executors.shutdownAndAwaitTermination(getExecutorService());
  59     }
  60
  61     @Override
  62     public void remove(InstanceIdentifier<VpnToDpnList> identifier, VpnToDpnList del) {
  63         if (!useTransportZone) {
  64             return;
  65         }
  66         LOG.debug("Vpn dpn {} remove detected, SHOULD BE deleting transport zones", del.getDpnId());
  67     }
  68
  69     @Override
  70     public void update(InstanceIdentifier<VpnToDpnList> identifier, VpnToDpnList original, VpnToDpnList update) {
  71         if (!useTransportZone) {
  72             return;
  73         }
  74         LOG.debug("Vpn dpn {} update detected, updating transport zones", update.getDpnId());
  75
  76         if (update.getVpnInterfaces() == null || update.getVpnInterfaces().isEmpty()) {
  77             LOG.debug("Vpn dpn {} doesn't contain any vpn interfaces", update.getDpnId());
  78             return;
  79         }
  80
  81         boolean shouldCreateVtep;
  82         if (original.getVpnInterfaces() != null && !original.getVpnInterfaces().isEmpty()) {
  83             shouldCreateVtep = transportZoneNotificationUtil.shouldCreateVtep(update.getVpnInterfaces().stream()
  84                     .filter(vi -> !original.getVpnInterfaces().contains(vi)).collect(Collectors.toList()));
  85         } else {
  86             shouldCreateVtep = transportZoneNotificationUtil.shouldCreateVtep(update.getVpnInterfaces());
  87         }
  88
  89         if (shouldCreateVtep) {
  90             String vrfId = identifier.firstKeyOf(VpnInstanceOpDataEntry.class).getVrfId();
  91             transportZoneNotificationUtil.updateTransportZone(vrfId, update.getDpnId());
  92         }
  93     }
  94
  95     @Override
  96     public void add(InstanceIdentifier<VpnToDpnList> identifier, VpnToDpnList add) {
  97         if (!useTransportZone) {
  98             return;
  99         }
 100         LOG.debug("Vpn dpn {} add detected, updating transport zones", add.getDpnId());
 101
 102         boolean shouldCreateVtep = transportZoneNotificationUtil.shouldCreateVtep(add.getVpnInterfaces());
 103         if (shouldCreateVtep) {
 104             String vrfId = identifier.firstKeyOf(VpnInstanceOpDataEntry.class).getVrfId();
 105             transportZoneNotificationUtil.updateTransportZone(vrfId, add.getDpnId());
 106         }
 107     }
 108 }