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