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.PostConstruct;
  12 import javax.inject.Inject;
  13 import javax.inject.Singleton;
  14 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  15 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  16 import org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase;
  17 import org.opendaylight.infrautils.jobcoordinator.JobCoordinator;
  18 import org.opendaylight.netvirt.elan.utils.ElanConstants;
  19 import org.opendaylight.netvirt.elan.utils.ElanUtils;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.TepTypeInternal;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.TunnelOperStatus;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.TunnelsState;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnels_state.StateTunnelList;
  24 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  25 import org.opendaylight.yangtools.yang.common.Uint64;
  26 import org.slf4j.Logger;
  27 import org.slf4j.LoggerFactory;
  28
  29 @Singleton
  30 public class ElanTunnelInterfaceStateListener extends AsyncDataTreeChangeListenerBase<StateTunnelList,
  31     ElanTunnelInterfaceStateListener> {
  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(StateTunnelList.class, ElanTunnelInterfaceStateListener.class);
  43         this.dataBroker = dataBroker;
  44         this.elanInterfaceManager = elanInterfaceManager;
  45         this.elanUtils = elanUtils;
  46         this.jobCoordinator = jobCoordinator;
  47     }
  48
  49     @Override
  50     @PostConstruct
  51     public void init() {
  52         registerListener(LogicalDatastoreType.OPERATIONAL, dataBroker);
  53     }
  54
  55     @Override
  56     protected InstanceIdentifier<StateTunnelList> getWildCardPath() {
  57         return InstanceIdentifier.create(TunnelsState.class).child(StateTunnelList.class);
  58     }
  59
  60     @Override
  61     protected void remove(InstanceIdentifier<StateTunnelList> key, StateTunnelList delete) {
  62     }
  63
  64     @Override
  65     protected void update(InstanceIdentifier<StateTunnelList> key, StateTunnelList original,
  66             StateTunnelList update) {
  67     }
  68
  69     @Override
  70     protected void add(InstanceIdentifier<StateTunnelList> key, StateTunnelList add) {
  71         LOG.info("processing add state for StateTunnelList {}", add);
  72         if (!isInternalTunnel(add)) {
  73             LOG.trace("tunnel {} is not a internal vxlan tunnel", add);
  74             return;
  75         }
  76         if (elanUtils.isTunnelInLogicalGroup(add.getTunnelInterfaceName())) {
  77             LOG.trace("MULTIPLE_VxLAN_TUNNELS: ignoring the tunnel event for {}", add.getTunnelInterfaceName());
  78             return;
  79         }
  80         TunnelOperStatus tunOpStatus = add.getOperState();
  81         if (tunOpStatus != TunnelOperStatus.Down && tunOpStatus != TunnelOperStatus.Up) {
  82             LOG.trace("Returning because unsupported tunnelOperStatus {}", tunOpStatus);
  83             return;
  84         }
  85         try {
  86             Uint64 srcDpId = Uint64.valueOf(add.getSrcInfo().getTepDeviceId());
  87             Uint64 dstDpId = Uint64.valueOf(add.getDstInfo().getTepDeviceId());
  88             jobCoordinator.enqueueJob(add.getTunnelInterfaceName(), () -> {
  89                 LOG.info("Handling tunnel state event for srcDpId {} and dstDpId {} ",
  90                         srcDpId, dstDpId);
  91                 elanInterfaceManager.handleInternalTunnelStateEvent(srcDpId, dstDpId);
  92                 return Collections.emptyList();
  93             }, ElanConstants.JOB_MAX_RETRIES);
  94         } catch (NumberFormatException e) {
  95             LOG.error("Invalid source TepDeviceId {} or destination TepDeviceId {}", add.getSrcInfo().getTepDeviceId(),
  96                 add.getDstInfo().getTepDeviceId());
  97         }
  98     }
  99
 100     @Override
 101     protected ElanTunnelInterfaceStateListener getDataTreeChangeListener() {
 102         return this;
 103     }
 104
 105     private static boolean isInternalTunnel(StateTunnelList stateTunnelList) {
 106         return stateTunnelList.getDstInfo() != null
 107                 ? stateTunnelList.getDstInfo().getTepDeviceType() == TepTypeInternal.class : false;
 108     }
 109
 110 }