org.opendaylight.netvirt.fibmanager

Class FibUtil

java.lang.Object

org.opendaylight.netvirt.fibmanager.FibUtil

@Singleton
public class FibUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
FibUtil(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker, IElanService elanManager, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService idManager, org.opendaylight.genius.itm.api.IITMProvider iitmProvider)

Method Summary

Modifier and Type	Method and Description
void	addFibEntryForRouterInterface(String rd, String prefix, RouterInterface routerInterface, long label, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)
void	addOrUpdateFibEntry(String rd, String macAddress, String prefix, List<String> nextHopList, VrfEntryBase.EncapType encapType, long label, long l3vni, String gwMacAddress, String parentVpnRd, RouteOrigin origin, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)
void	addVrfTable(String rd, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)
static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface>	buildStateInterfaceId(String interfaceName)
static String	getBroadcastAddressFromCidr(String cidr)
static String	getCreateLocalNextHopJobKey(Long vpnId, BigInteger dpnId, String prefix)
static String	getCreateRemoteNextHopJobKey(Long vpnId, BigInteger dpnId, String prefix)
com.google.common.base.Optional<DpnLbNexthops>	getDpnLbNexthops(BigInteger dpnId, String destinationIp)
static Optional<String>	getFirstNextHopAddress(VrfEntry vrfEntry)
static String	getGreLbGroupKey(List<String> availableDcGws)
org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface	getInterfaceStateFromOperDS(String interfaceName)
static String	getIpPrefix(String prefix)
static String	getJobKeyForRdPrefix(String rd, String prefix)
static String	getJobKeyForVpnIdDpnId(Long vpnId, BigInteger dpnId)
static Optional<Long>	getLabelForNextHop(VrfEntry vrfEntry, String nextHopIp)
static Optional<Long>	getLabelFromRoutePaths(VrfEntry vrfEntry)
List<String>	getNextHopAddresses(String rd, String prefix)
static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VrfEntry>	getNextHopIdentifier(String rd, String prefix)
com.google.common.base.Optional<Nexthops>	getNexthops(String nextHopKey)
org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnels_state.StateTunnelList	getTunnelState(String interfaceName)
long	getVpnId(String vpnName)
String	getVpnNameFromId(long vpnId)
com.google.common.base.Optional<String>	getVpnNameFromRd(String rd) Retrieves the VpnInstance name (typically the VPN Uuid) out from the route-distinguisher.
boolean	isInterfacePresentInDpn(String vpnName, BigInteger dpnId)
static boolean	isTunnelInterface(org.opendaylight.netvirt.fibmanager.NexthopManager.AdjacencyResult adjacencyResult)
static boolean	lockCluster(org.opendaylight.yang.gen.v1.urn.opendaylight.genius.lockmanager.rev160413.LockManagerService lockManager, String lockName, long tryLockPeriod)
static void	removeDpnIdToNextHopInfo(String destinationIp, BigInteger dpnId, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
void	removeFibEntry(String rd, String prefix, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)
void	removeOrUpdateFibEntry(String rd, String prefix, String nextHopToRemove, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn) Removes a specific Nexthop from a VrfEntry.
static void	removeOrUpdateNextHopInfo(BigInteger dpnId, String nextHopKey, String groupId, Nexthops nexthops, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
void	removeVrfTable(String rd, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)
static void	unlockCluster(org.opendaylight.yang.gen.v1.urn.opendaylight.genius.lockmanager.rev160413.LockManagerService lockManager, String lockName)
static void	updateLbGroupInfo(BigInteger dpnId, String destinationIp, String groupIdKey, String groupId, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
void	updateRoutePathForFibEntry(String rd, String prefix, String nextHop, long label, boolean nextHopAdd, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn) Adds or removes nextHop from routePath based on the flag nextHopAdd.
void	updateUsedRdAndVpnToExtraRoute(org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn, String tunnelIpRemoved, String primaryRd, String prefix)
void	writeFibEntryToDs(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VrfEntry> vrfEntryId, String prefix, List<String> nextHopList, long label, Long l3vni, VrfEntryBase.EncapType encapType, RouteOrigin origin, String macAddress, String gatewayMacAddress, String parentVpnRd, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FibUtil

@Inject
public FibUtil(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                       IElanService elanManager,
                       org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService idManager,
                       org.opendaylight.genius.itm.api.IITMProvider iitmProvider)

Method Detail

getVpnId

public long getVpnId(String vpnName)

getVpnNameFromRd

public com.google.common.base.Optional<String> getVpnNameFromRd(String rd)

Retrieves the VpnInstance name (typically the VPN Uuid) out from the route-distinguisher.

Parameters:

rd - The route-distinguisher

Returns:

The vpn instance

getVpnNameFromId

public String getVpnNameFromId(long vpnId)

addOrUpdateFibEntry

public void addOrUpdateFibEntry(String rd,
                                String macAddress,
                                String prefix,
                                List<String> nextHopList,
                                VrfEntryBase.EncapType encapType,
                                long label,
                                long l3vni,
                                String gwMacAddress,
                                String parentVpnRd,
                                RouteOrigin origin,
                                org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

writeFibEntryToDs

public void writeFibEntryToDs(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VrfEntry> vrfEntryId,
                              String prefix,
                              List<String> nextHopList,
                              long label,
                              Long l3vni,
                              VrfEntryBase.EncapType encapType,
                              RouteOrigin origin,
                              String macAddress,
                              String gatewayMacAddress,
                              String parentVpnRd,
                              org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

addFibEntryForRouterInterface

public void addFibEntryForRouterInterface(String rd,
                                          String prefix,
                                          RouterInterface routerInterface,
                                          long label,
                                          org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

removeFibEntry

public void removeFibEntry(String rd,
                           String prefix,
                           org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

removeOrUpdateFibEntry

public void removeOrUpdateFibEntry(String rd,
                                   String prefix,
                                   String nextHopToRemove,
                                   org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

Removes a specific Nexthop from a VrfEntry. If Nexthop to remove is the last one in the VrfEntry, then the VrfEntry is removed too.

Parameters:

rd - Route-Distinguisher to which the VrfEntry belongs to

prefix - Destination of the route

nextHopToRemove - Specific nexthop within the Route to be removed. If null or empty, then the whole VrfEntry is removed

updateRoutePathForFibEntry

public void updateRoutePathForFibEntry(String rd,
                                       String prefix,
                                       String nextHop,
                                       long label,
                                       boolean nextHopAdd,
                                       org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

Adds or removes nextHop from routePath based on the flag nextHopAdd.

addVrfTable

public void addVrfTable(String rd,
                        org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

removeVrfTable

public void removeVrfTable(String rd,
                           org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

getLabelFromRoutePaths

public static Optional<Long> getLabelFromRoutePaths(VrfEntry vrfEntry)

getFirstNextHopAddress

public static Optional<String> getFirstNextHopAddress(VrfEntry vrfEntry)

getLabelForNextHop

public static Optional<Long> getLabelForNextHop(VrfEntry vrfEntry,
                                                String nextHopIp)

getTunnelState

public org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnels_state.StateTunnelList getTunnelState(String interfaceName)
                                                                                                                   throws org.opendaylight.controller.md.sal.common.api.data.ReadFailedException

Throws:

org.opendaylight.controller.md.sal.common.api.data.ReadFailedException

buildStateInterfaceId

public static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface> buildStateInterfaceId(String interfaceName)

getInterfaceStateFromOperDS

public org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface getInterfaceStateFromOperDS(String interfaceName)

getCreateLocalNextHopJobKey

public static String getCreateLocalNextHopJobKey(Long vpnId,
                                                 BigInteger dpnId,
                                                 String prefix)

getCreateRemoteNextHopJobKey

public static String getCreateRemoteNextHopJobKey(Long vpnId,
                                                  BigInteger dpnId,
                                                  String prefix)

getJobKeyForRdPrefix

public static String getJobKeyForRdPrefix(String rd,
                                          String prefix)

getJobKeyForVpnIdDpnId

public static String getJobKeyForVpnIdDpnId(Long vpnId,
                                            BigInteger dpnId)

updateUsedRdAndVpnToExtraRoute

public void updateUsedRdAndVpnToExtraRoute(org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn,
                                           org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn,
                                           String tunnelIpRemoved,
                                           String primaryRd,
                                           String prefix)

getIpPrefix

public static String getIpPrefix(String prefix)

isTunnelInterface

public static boolean isTunnelInterface(org.opendaylight.netvirt.fibmanager.NexthopManager.AdjacencyResult adjacencyResult)

getNextHopIdentifier

public static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VrfEntry> getNextHopIdentifier(String rd,
                                                                                                        String prefix)

getNextHopAddresses

public List<String> getNextHopAddresses(String rd,
                                        String prefix)

getGreLbGroupKey

public static String getGreLbGroupKey(List<String> availableDcGws)

updateLbGroupInfo

public static void updateLbGroupInfo(BigInteger dpnId,
                                     String destinationIp,
                                     String groupIdKey,
                                     String groupId,
                                     org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

removeDpnIdToNextHopInfo

public static void removeDpnIdToNextHopInfo(String destinationIp,
                                            BigInteger dpnId,
                                            org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

removeOrUpdateNextHopInfo

public static void removeOrUpdateNextHopInfo(BigInteger dpnId,
                                             String nextHopKey,
                                             String groupId,
                                             Nexthops nexthops,
                                             org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

getNexthops

public com.google.common.base.Optional<Nexthops> getNexthops(String nextHopKey)

getDpnLbNexthops

public com.google.common.base.Optional<DpnLbNexthops> getDpnLbNexthops(BigInteger dpnId,
                                                                       String destinationIp)

getBroadcastAddressFromCidr

public static String getBroadcastAddressFromCidr(String cidr)

lockCluster

public static boolean lockCluster(org.opendaylight.yang.gen.v1.urn.opendaylight.genius.lockmanager.rev160413.LockManagerService lockManager,
                                  String lockName,
                                  long tryLockPeriod)

unlockCluster

public static void unlockCluster(org.opendaylight.yang.gen.v1.urn.opendaylight.genius.lockmanager.rev160413.LockManagerService lockManager,
                                 String lockName)

isInterfacePresentInDpn

public boolean isInterfacePresentInDpn(String vpnName,
                                       BigInteger dpnId)