2 * Copyright (c) 2015 - 2016 Ericsson India Global Services Pvt Ltd. and others. All rights reserved.
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
8 package org.opendaylight.netvirt.fibmanager;
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.netvirt.fibmanager.api.IFibManager;
21 import org.opendaylight.netvirt.fibmanager.api.RouteOrigin;
22 import org.opendaylight.netvirt.vpnmanager.api.IVpnManager;
23 import org.opendaylight.netvirt.vpnmanager.api.intervpnlink.InterVpnLinkCache;
24 import org.opendaylight.netvirt.vpnmanager.api.intervpnlink.InterVpnLinkDataComposite;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.fibmanager.rev150330.RouterInterface;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.fibmanager.rev150330.vrfentries.VrfEntry;
27 import org.osgi.framework.BundleContext;
28 import org.osgi.util.tracker.ServiceTracker;
29 import org.slf4j.Logger;
30 import org.slf4j.LoggerFactory;
33 public class FibManagerImpl implements IFibManager {
34 private static final Logger LOG = LoggerFactory.getLogger(FibManagerImpl.class);
35 private final NexthopManager nexthopManager;
36 private final VrfEntryListener vrfEntryListener;
37 private IVpnManager vpnmanager;
38 private final FibUtil fibUtil;
39 private final InterVpnLinkCache interVpnLinkCache;
42 public FibManagerImpl(final NexthopManager nexthopManager,
43 final VrfEntryListener vrfEntryListener,
44 final BundleContext bundleContext,
45 final FibUtil fibUtil,
46 final InterVpnLinkCache interVpnLinkCache) {
47 this.nexthopManager = nexthopManager;
48 this.vrfEntryListener = vrfEntryListener;
49 this.fibUtil = fibUtil;
50 this.interVpnLinkCache = interVpnLinkCache;
52 GlobalEventExecutor.INSTANCE.execute(() -> {
53 ServiceTracker<IVpnManager, ?> tracker = null;
55 tracker = new ServiceTracker<>(bundleContext, IVpnManager.class, null);
57 vpnmanager = (IVpnManager) tracker.waitForService(TimeUnit.MILLISECONDS.convert(5, TimeUnit.MINUTES));
58 Preconditions.checkState(vpnmanager != null, "IVpnManager service not found");
59 LOG.info("FibManagerImpl initialized. IVpnManager={}", vpnmanager);
60 } catch (IllegalStateException | InterruptedException e) {
61 LOG.error("Error retrieving IVpnManager service", e);
63 if (tracker != null) {
71 public void populateFibOnNewDpn(BigInteger dpnId, long vpnId, String rd,
72 FutureCallback<List<Void>> callback) {
73 vrfEntryListener.populateFibOnNewDpn(dpnId, vpnId, rd, callback);
77 public void populateExternalRoutesOnDpn(BigInteger localDpnId, long vpnId,
78 String rd, String localNextHopIp,
79 String remoteNextHopIp) {
80 vrfEntryListener.populateExternalRoutesOnDpn(localDpnId, vpnId, rd,
81 localNextHopIp, remoteNextHopIp);
85 public void cleanUpExternalRoutesOnDpn(BigInteger dpnId, long vpnId,
86 String rd, String localNextHopIp,
87 String remoteNextHopIp) {
88 vrfEntryListener.cleanUpExternalRoutesOnDpn(dpnId, vpnId, rd,
89 localNextHopIp, remoteNextHopIp);
93 public void cleanUpDpnForVpn(BigInteger dpnId, long vpnId, String rd,
94 FutureCallback<List<Void>> callback) {
95 vrfEntryListener.cleanUpDpnForVpn(dpnId, vpnId, rd, callback);
99 public void setConfTransType(String service, String transportType) {
100 nexthopManager.setConfTransType(service, transportType);
104 public void writeConfTransTypeConfigDS() {
105 nexthopManager.writeConfTransTypeConfigDS();
109 public String getConfTransType() {
110 return nexthopManager.getConfiguredTransportTypeL3VPN().toString();
114 public String getReqTransType() {
115 return nexthopManager.getReqTransType();
119 public String getTransportTypeStr(String tunType) {
120 return nexthopManager.getTransportTypeStr(tunType);
124 public void manageRemoteRouteOnDPN(boolean action,
131 vrfEntryListener.manageRemoteRouteOnDPN(action, dpnId, vpnId, rd, destPrefix, destTepIp, label);
135 public void addOrUpdateFibEntry(String rd, String macAddress, String prefix,
136 List<String> nextHopList, VrfEntry.EncapType encapType, long label,
137 long l3vni, String gwMacAddress, String parentVpnRd, RouteOrigin origin,
138 WriteTransaction writeConfigTxn) {
139 fibUtil.addOrUpdateFibEntry(rd, macAddress, prefix, nextHopList , encapType, label, l3vni, gwMacAddress,
140 parentVpnRd, origin, writeConfigTxn);
144 public void addFibEntryForRouterInterface(String rd, String prefix,
145 RouterInterface routerInterface, long label,
146 WriteTransaction writeConfigTxn) {
147 fibUtil.addFibEntryForRouterInterface(rd, prefix, routerInterface, label, writeConfigTxn);
151 public void removeOrUpdateFibEntry(String rd, String prefix,
152 String nextHopToRemove, WriteTransaction writeConfigTxn) {
153 fibUtil.removeOrUpdateFibEntry(rd, prefix, nextHopToRemove, writeConfigTxn);
157 public void removeFibEntry(String rd, String prefix, WriteTransaction writeConfigTxn) {
158 fibUtil.removeFibEntry(rd, prefix, writeConfigTxn);
162 public void updateRoutePathForFibEntry(String rd, String prefix, String nextHop,
163 long label, boolean nextHopAdd, WriteTransaction writeConfigTxn) {
164 fibUtil.updateRoutePathForFibEntry(rd, prefix, nextHop, label, nextHopAdd, writeConfigTxn);
168 public void removeVrfTable(String rd, WriteTransaction writeConfigTxn) {
169 fibUtil.removeVrfTable(rd, writeConfigTxn);
173 public void addVrfTable(String rd, WriteTransaction writeConfigTxn) {
174 fibUtil.addVrfTable(rd, writeConfigTxn);
178 public boolean isVPNConfigured() {
179 return this.vpnmanager.isVPNConfigured();
183 public void removeInterVPNLinkRouteFlows(final String interVpnLinkName,
184 final boolean isVpnFirstEndPoint,
185 final VrfEntry vrfEntry) {
186 Optional<InterVpnLinkDataComposite> optInterVpnLink = interVpnLinkCache.getInterVpnLinkByName(interVpnLinkName);
187 if (!optInterVpnLink.isPresent()) {
188 LOG.warn("Could not find InterVpnLink with name {}. InterVpnLink route flows wont be removed",
192 InterVpnLinkDataComposite interVpnLink = optInterVpnLink.get();
193 String vpnName = isVpnFirstEndPoint ? interVpnLink.getFirstEndpointVpnUuid().get()
194 : interVpnLink.getSecondEndpointVpnUuid().get();
196 vrfEntryListener.removeInterVPNLinkRouteFlows(interVpnLink, vpnName, vrfEntry);
200 public void programDcGwLoadBalancingGroup(List<String> availableDcGws, BigInteger dpnId,
201 String destinationIp, int addRemoveOrUpdate, boolean isTunnelUp) {
202 nexthopManager.programDcGwLoadBalancingGroup(availableDcGws, dpnId, destinationIp,
203 addRemoveOrUpdate, isTunnelUp);
207 public void refreshVrfEntry(String rd, String prefix) {
208 vrfEntryListener.refreshFibTables(rd, prefix);