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

   1 /*
   2  * Copyright (c) 2016 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.elan.internal;
   9
  10 import java.util.Collections;
  11 import javax.annotation.PreDestroy;
  12 import javax.inject.Inject;
  13 import javax.inject.Singleton;
  14 import org.opendaylight.infrautils.jobcoordinator.JobCoordinator;
  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.ElanConstants;
  19 import org.opendaylight.netvirt.elan.utils.ElanUtils;
  20 import org.opendaylight.serviceutils.tools.listener.AbstractAsyncDataTreeChangeListener;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.TepTypeInternal;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.TunnelOperStatus;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.TunnelsState;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnels_state.StateTunnelList;
  25 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  26 import org.opendaylight.yangtools.yang.common.Uint64;
  27 import org.slf4j.Logger;
  28 import org.slf4j.LoggerFactory;
  29
  30 @Singleton
  31 public class ElanTunnelInterfaceStateListener extends AbstractAsyncDataTreeChangeListener<StateTunnelList> {
  32     private static final Logger LOG = LoggerFactory.getLogger(ElanTunnelInterfaceStateListener.class);
  33     private final DataBroker dataBroker;
  34     private final ElanInterfaceManager elanInterfaceManager;
  35     private final ElanUtils elanUtils;
  36     private final JobCoordinator jobCoordinator;
  37
  38     @Inject
  39     public ElanTunnelInterfaceStateListener(final DataBroker dataBroker,
  40             final ElanInterfaceManager elanInterfaceManager, final ElanUtils elanUtils,
  41             final JobCoordinator jobCoordinator) {
  42         super(dataBroker, LogicalDatastoreType.OPERATIONAL, InstanceIdentifier.create(TunnelsState.class)
  43                 .child(StateTunnelList.class),
  44                 Executors.newListeningSingleThreadExecutor("ElanTunnelInterfaceStateListener", LOG));
  45         this.dataBroker = dataBroker;
  46         this.elanInterfaceManager = elanInterfaceManager;
  47         this.elanUtils = elanUtils;
  48         this.jobCoordinator = jobCoordinator;
  49     }
  50
  51     public void init() {
  52         LOG.info("{} init", getClass().getSimpleName());
  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<StateTunnelList> key, StateTunnelList delete) {
  64     }
  65
  66     @Override
  67     public void update(InstanceIdentifier<StateTunnelList> key, StateTunnelList original,
  68             StateTunnelList update) {
  69     }
  70
  71     @Override
  72     public void add(InstanceIdentifier<StateTunnelList> key, StateTunnelList add) {
  73         LOG.info("processing add state for StateTunnelList {}", add);
  74         if (!isInternalTunnel(add)) {
  75             LOG.trace("tunnel {} is not a internal vxlan tunnel", add);
  76             return;
  77         }
  78         if (elanUtils.isTunnelInLogicalGroup(add.getTunnelInterfaceName())) {
  79             LOG.trace("MULTIPLE_VxLAN_TUNNELS: ignoring the tunnel event for {}", add.getTunnelInterfaceName());
  80             return;
  81         }
  82         TunnelOperStatus tunOpStatus = add.getOperState();
  83         if (tunOpStatus != TunnelOperStatus.Down && tunOpStatus != TunnelOperStatus.Up) {
  84             LOG.trace("Returning because unsupported tunnelOperStatus {}", tunOpStatus);
  85             return;
  86         }
  87         try {
  88             Uint64 srcDpId = Uint64.valueOf(add.getSrcInfo().getTepDeviceId());
  89             Uint64 dstDpId = Uint64.valueOf(add.getDstInfo().getTepDeviceId());
  90             jobCoordinator.enqueueJob(add.getTunnelInterfaceName(), () -> {
  91                 LOG.info("Handling tunnel state event for srcDpId {} and dstDpId {} ",
  92                         srcDpId, dstDpId);
  93                 elanInterfaceManager.handleInternalTunnelStateEvent(srcDpId, dstDpId);
  94                 return Collections.emptyList();
  95             }, ElanConstants.JOB_MAX_RETRIES);
  96         } catch (NumberFormatException e) {
  97             LOG.error("Invalid source TepDeviceId {} or destination TepDeviceId {}", add.getSrcInfo().getTepDeviceId(),
  98                 add.getDstInfo().getTepDeviceId());
  99         }
 100     }
 101
 102     private static boolean isInternalTunnel(StateTunnelList stateTunnelList) {
 103         return stateTunnelList.getDstInfo() != null
 104                 ? stateTunnelList.getDstInfo().getTepDeviceType() == TepTypeInternal.class : false;
 105     }
 106
 107 }