fibmanager/impl/src/main/java/org/opendaylight/netvirt/fibmanager/FibManagerImpl.java

   1 /*
   2  * Copyright (c) 2015 - 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.fibmanager;
   9
  10 import com.google.common.base.Optional;
  11 import com.google.common.base.Preconditions;
  12 import com.google.common.util.concurrent.FutureCallback;
  13 import io.netty.util.concurrent.GlobalEventExecutor;
  14 import java.math.BigInteger;
  15 import java.util.List;
  16 import java.util.concurrent.TimeUnit;
  17 import javax.inject.Inject;
  18 import javax.inject.Singleton;
  19 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
  20 import org.opendaylight.genius.infra.Datastore.Configuration;
  21 import org.opendaylight.genius.infra.TypedWriteTransaction;
  22 import org.opendaylight.netvirt.fibmanager.api.IFibManager;
  23 import org.opendaylight.netvirt.fibmanager.api.RouteOrigin;
  24 import org.opendaylight.netvirt.vpnmanager.api.IVpnManager;
  25 import org.opendaylight.netvirt.vpnmanager.api.intervpnlink.InterVpnLinkCache;
  26 import org.opendaylight.netvirt.vpnmanager.api.intervpnlink.InterVpnLinkDataComposite;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.fibmanager.rev150330.RouterInterface;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.fibmanager.rev150330.vrfentries.VrfEntry;
  30 import org.osgi.framework.BundleContext;
  31 import org.osgi.util.tracker.ServiceTracker;
  32 import org.slf4j.Logger;
  33 import org.slf4j.LoggerFactory;
  34
  35 @Singleton
  36 public class FibManagerImpl implements IFibManager {
  37     private static final Logger LOG = LoggerFactory.getLogger(FibManagerImpl.class);
  38     private final NexthopManager nexthopManager;
  39     private final VrfEntryListener vrfEntryListener;
  40     private IVpnManager vpnmanager;
  41     private final FibUtil fibUtil;
  42     private final InterVpnLinkCache interVpnLinkCache;
  43
  44     @Inject
  45     public FibManagerImpl(final NexthopManager nexthopManager,
  46                           final VrfEntryListener vrfEntryListener,
  47                           final BundleContext bundleContext,
  48                           final FibUtil fibUtil,
  49                           final InterVpnLinkCache interVpnLinkCache) {
  50         this.nexthopManager = nexthopManager;
  51         this.vrfEntryListener = vrfEntryListener;
  52         this.fibUtil = fibUtil;
  53         this.interVpnLinkCache = interVpnLinkCache;
  54
  55         GlobalEventExecutor.INSTANCE.execute(() -> {
  56             ServiceTracker<IVpnManager, ?> tracker = null;
  57             try {
  58                 tracker = new ServiceTracker<>(bundleContext, IVpnManager.class, null);
  59                 tracker.open();
  60                 vpnmanager = (IVpnManager) tracker.waitForService(TimeUnit.MILLISECONDS.convert(5, TimeUnit.MINUTES));
  61                 Preconditions.checkState(vpnmanager != null, "IVpnManager service not found");
  62                 LOG.info("FibManagerImpl initialized. IVpnManager={}", vpnmanager);
  63             } catch (IllegalStateException | InterruptedException e) {
  64                 LOG.error("Error retrieving IVpnManager service", e);
  65             } finally {
  66                 if (tracker != null) {
  67                     tracker.close();
  68                 }
  69             }
  70         });
  71     }
  72
  73     @Override
  74     public void populateFibOnNewDpn(BigInteger dpnId, long vpnId, String rd,
  75                                     FutureCallback<List<Void>> callback) {
  76         vrfEntryListener.populateFibOnNewDpn(dpnId, vpnId, rd, callback);
  77     }
  78
  79     @Override
  80     public void populateExternalRoutesOnDpn(BigInteger localDpnId, long vpnId,
  81                                             String rd, String localNextHopIp,
  82                                             String remoteNextHopIp) {
  83         vrfEntryListener.populateExternalRoutesOnDpn(localDpnId, vpnId, rd,
  84             localNextHopIp, remoteNextHopIp);
  85     }
  86
  87     @Override
  88     public void cleanUpExternalRoutesOnDpn(BigInteger dpnId, long vpnId,
  89                                            String rd, String localNextHopIp,
  90                                            String remoteNextHopIp) {
  91         vrfEntryListener.cleanUpExternalRoutesOnDpn(dpnId, vpnId, rd,
  92             localNextHopIp, remoteNextHopIp);
  93     }
  94
  95     @Override
  96     public void cleanUpDpnForVpn(BigInteger dpnId, long vpnId, String rd,
  97                                  FutureCallback<List<Void>> callback) {
  98         vrfEntryListener.cleanUpDpnForVpn(dpnId, vpnId, rd, callback);
  99     }
 100
 101     @Override
 102     public void setConfTransType(String service, String transportType) {
 103         nexthopManager.setConfTransType(service, transportType);
 104     }
 105
 106     @Override
 107     public void writeConfTransTypeConfigDS() {
 108         nexthopManager.writeConfTransTypeConfigDS();
 109     }
 110
 111     @Override
 112     public String getConfTransType() {
 113         return nexthopManager.getConfiguredTransportTypeL3VPN().toString();
 114     }
 115
 116     @Override
 117     public String getReqTransType() {
 118         return nexthopManager.getReqTransType();
 119     }
 120
 121     @Override
 122     public String getTransportTypeStr(String tunType) {
 123         return nexthopManager.getTransportTypeStr(tunType);
 124     }
 125
 126     @Override
 127     public void manageRemoteRouteOnDPN(boolean action,
 128                                        BigInteger dpnId,
 129                                        long vpnId,
 130                                        String rd,
 131                                        String destPrefix,
 132                                        String destTepIp,
 133                                        long label) {
 134         vrfEntryListener.manageRemoteRouteOnDPN(action, dpnId, vpnId, rd, destPrefix, destTepIp, label);
 135     }
 136
 137     @Override
 138     public void addOrUpdateFibEntry(String rd, String macAddress, String prefix,
 139             List<String> nextHopList, VrfEntry.EncapType encapType, long label,
 140             long l3vni, String gwMacAddress, String parentVpnRd, RouteOrigin origin,
 141             TypedWriteTransaction<Configuration> writeConfigTxn) {
 142         fibUtil.addOrUpdateFibEntry(rd, macAddress, prefix, nextHopList , encapType, label, l3vni, gwMacAddress,
 143                 parentVpnRd, origin, writeConfigTxn);
 144     }
 145
 146     @Override
 147     public void addFibEntryForRouterInterface(String rd, String prefix,
 148             RouterInterface routerInterface, long label,
 149             TypedWriteTransaction<Configuration> writeConfigTxn) {
 150         fibUtil.addFibEntryForRouterInterface(rd, prefix, routerInterface, label, writeConfigTxn);
 151     }
 152
 153     @Override
 154     public void removeOrUpdateFibEntry(String rd, String prefix,
 155             String nextHopToRemove, TypedWriteTransaction<Configuration> writeConfigTxn) {
 156         fibUtil.removeOrUpdateFibEntry(rd, prefix, nextHopToRemove, writeConfigTxn);
 157     }
 158
 159     @Override
 160     public void removeFibEntry(String rd, String prefix, TypedWriteTransaction<Configuration> writeConfigTxn) {
 161         fibUtil.removeFibEntry(rd, prefix, writeConfigTxn);
 162     }
 163
 164     @Override
 165     public void updateRoutePathForFibEntry(String rd, String prefix, String nextHop,
 166             long label, boolean nextHopAdd, WriteTransaction writeConfigTxn) {
 167         fibUtil.updateRoutePathForFibEntry(rd, prefix, nextHop, label, nextHopAdd, writeConfigTxn);
 168     }
 169
 170     @Override
 171     public void removeVrfTable(String rd, TypedWriteTransaction<Configuration> writeConfigTxn) {
 172         fibUtil.removeVrfTable(rd, writeConfigTxn);
 173     }
 174
 175     @Override
 176     public void addVrfTable(String rd, WriteTransaction writeConfigTxn) {
 177         fibUtil.addVrfTable(rd, writeConfigTxn);
 178     }
 179
 180     @Override
 181     public boolean isVPNConfigured() {
 182         return this.vpnmanager.isVPNConfigured();
 183     }
 184
 185     @Override
 186     public void removeInterVPNLinkRouteFlows(final String interVpnLinkName,
 187                                              final boolean isVpnFirstEndPoint,
 188                                              final VrfEntry vrfEntry) {
 189         Optional<InterVpnLinkDataComposite> optInterVpnLink = interVpnLinkCache.getInterVpnLinkByName(interVpnLinkName);
 190         if (!optInterVpnLink.isPresent()) {
 191             LOG.warn("Could not find InterVpnLink with name {}. InterVpnLink route flows wont be removed",
 192                      interVpnLinkName);
 193             return;
 194         }
 195         InterVpnLinkDataComposite interVpnLink = optInterVpnLink.get();
 196         String vpnName = isVpnFirstEndPoint ? interVpnLink.getFirstEndpointVpnUuid().get()
 197                                               : interVpnLink.getSecondEndpointVpnUuid().get();
 198
 199         vrfEntryListener.removeInterVPNLinkRouteFlows(interVpnLink, vpnName, vrfEntry);
 200     }
 201
 202     @Override
 203     public void programDcGwLoadBalancingGroup(BigInteger dpnId, String destinationIp,
 204                                               int addRemoveOrUpdate, boolean isTunnelUp,
 205                                               Class<? extends TunnelTypeBase> tunnelType) {
 206         nexthopManager.programDcGwLoadBalancingGroup(dpnId, destinationIp,
 207             addRemoveOrUpdate, isTunnelUp, tunnelType);
 208     }
 209
 210     @Override
 211     public void refreshVrfEntry(String rd, String prefix) {
 212         vrfEntryListener.refreshFibTables(rd, prefix);
 213     }
 214 }