vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/intervpnlink/InterVpnLinkStateListener.java

   1 /*
   2  * Copyright (c) 2017 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.vpnmanager.intervpnlink;
   9
  10 import com.google.common.base.Optional;
  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.netvirt.vpnmanager.api.intervpnlink.IVpnLinkService;
  18 import org.opendaylight.netvirt.vpnmanager.api.intervpnlink.InterVpnLinkCache;
  19 import org.opendaylight.netvirt.vpnmanager.api.intervpnlink.InterVpnLinkDataComposite;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.netvirt.inter.vpn.link.rev160311.InterVpnLinkStates;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.netvirt.inter.vpn.link.rev160311.inter.vpn.link.states.InterVpnLinkState;
  22 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  23 import org.slf4j.Logger;
  24 import org.slf4j.LoggerFactory;
  25
  26 /**
  27  * Class responsible for listening to changes in the State of an InterVpnLink,
  28  * specially for when the InterVpnLink becomes active.
  29  */
  30 @Singleton
  31 public class InterVpnLinkStateListener
  32     extends AsyncDataTreeChangeListenerBase<InterVpnLinkState, InterVpnLinkStateListener> {
  33
  34     private static final Logger LOG = LoggerFactory.getLogger(InterVpnLinkStateListener.class);
  35
  36     private final DataBroker dataBroker;
  37     private final IVpnLinkService ivpnLinkService;
  38     private final InterVpnLinkCache interVpnLinkCache;
  39
  40     @Inject
  41     public InterVpnLinkStateListener(final DataBroker dataBroker, final IVpnLinkService interVpnLinkService,
  42             final InterVpnLinkCache interVpnLinkCache) {
  43         this.dataBroker = dataBroker;
  44         this.ivpnLinkService = interVpnLinkService;
  45         this.interVpnLinkCache = interVpnLinkCache;
  46     }
  47
  48     @PostConstruct
  49     public void start() {
  50         LOG.info("{} start", getClass().getSimpleName());
  51         registerListener(LogicalDatastoreType.CONFIGURATION, dataBroker);
  52     }
  53
  54     @Override
  55     protected InstanceIdentifier<InterVpnLinkState> getWildCardPath() {
  56         return InstanceIdentifier.create(InterVpnLinkStates.class).child(InterVpnLinkState.class);
  57     }
  58
  59     @Override
  60     protected InterVpnLinkStateListener getDataTreeChangeListener() {
  61         return InterVpnLinkStateListener.this;
  62     }
  63
  64
  65     @Override
  66     protected void remove(InstanceIdentifier<InterVpnLinkState> key, InterVpnLinkState dataObjectModification) {
  67     }
  68
  69     @Override
  70     protected void update(InstanceIdentifier<InterVpnLinkState> key, InterVpnLinkState before,
  71                           InterVpnLinkState after) {
  72         if (before.getState() == InterVpnLinkState.State.Error && after.getState() == InterVpnLinkState.State.Active) {
  73             Optional<InterVpnLinkDataComposite> optIVpnLink =
  74                     interVpnLinkCache.getInterVpnLinkByName(after.getInterVpnLinkName());
  75
  76             if (!optIVpnLink.isPresent()) {
  77                 LOG.warn("InterVpnLink became ACTIVE, but could not found its info in Cache");
  78                 interVpnLinkCache.addInterVpnLinkStateToCaches(after);
  79                 optIVpnLink = interVpnLinkCache.getInterVpnLinkByName(after.getInterVpnLinkName());
  80             }
  81             ivpnLinkService.handleStaticRoutes(optIVpnLink.get());
  82         }
  83     }
  84
  85
  86     @Override
  87     protected void add(InstanceIdentifier<InterVpnLinkState> key, InterVpnLinkState dataObjectModification) {
  88     }
  89 }