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.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> 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.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> 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)
boolean	checkFibEntryExist(String rd, String prefix, String nextHopIp)
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.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Operational> tx)
void	removeFibEntry(String rd, String prefix, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> writeConfigTxn)
void	removeOrUpdateFibEntry(String rd, String prefix, String nextHopToRemove, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> writeConfigTxn) Removes a specific Nexthop from a VrfEntry.
static void	removeOrUpdateNextHopInfo(BigInteger dpnId, String nextHopKey, String groupId, Nexthops nexthops, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Operational> tx)
void	removeVrfTable(String rd, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> 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.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Operational> 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.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Operational> operTx, 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.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> 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

@Nullable
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.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> 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.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> writeConfigTxn)

addFibEntryForRouterInterface

public void addFibEntryForRouterInterface(String rd,
                                          String prefix,
                                          RouterInterface routerInterface,
                                          long label,
                                          org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> writeConfigTxn)

removeFibEntry

public void removeFibEntry(String rd,
                           String prefix,
                           org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> writeConfigTxn)

removeOrUpdateFibEntry

public void removeOrUpdateFibEntry(String rd,
                                   String prefix,
                                   String nextHopToRemove,
                                   org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> 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.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> 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

@Nullable
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

@Nullable
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.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                           org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Operational> operTx,
                                           String tunnelIpRemoved,
                                           String primaryRd,
                                           String prefix)
                                    throws ExecutionException,
                                           InterruptedException

Throws:

ExecutionException

InterruptedException

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.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Operational> tx)

removeDpnIdToNextHopInfo

public static void removeDpnIdToNextHopInfo(String destinationIp,
                                            BigInteger dpnId,
                                            org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Operational> tx)

removeOrUpdateNextHopInfo

public static void removeOrUpdateNextHopInfo(BigInteger dpnId,
                                             String nextHopKey,
                                             String groupId,
                                             Nexthops nexthops,
                                             org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Operational> 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)

checkFibEntryExist

public boolean checkFibEntryExist(String rd,
                                  String prefix,
                                  String nextHopIp)

isInterfacePresentInDpn

public boolean isInterfacePresentInDpn(String vpnName,
                                       BigInteger dpnId)