org.opendaylight.netvirt.fibmanager

Class NexthopManager

java.lang.Object

org.opendaylight.netvirt.fibmanager.NexthopManager

All Implemented Interfaces:

AutoCloseable

@Singleton
public class NexthopManager
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor and Description

NexthopManager(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker, org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalApiManager, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService idManager, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService odlInterfaceRpcService, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService itmManager, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.lockmanager.rev160413.LockManagerService lockManager, IElanService elanService, org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.SalGroupService salGroupService, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator, FibUtil fibUtil, org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager) Provides nexthop functions.

Method Summary

Modifier and Type	Method and Description
protected void	addVpnNexthopToDS(BigInteger dpnId, long vpnId, String primaryIpAddr, String currIpAddr, long egressPointer)
void	close()
void	createDcGwLoadBalancingGroup(List<String> availableDcGws, BigInteger dpnId, String destinationIp, Class<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase> tunnelType)
long	createLocalNextHop(long vpnId, BigInteger dpnId, String ifName, String primaryIpAddress, String currDestIpPrefix, String gwMacAddress)
protected long	createNextHopPointer(String nexthopKey)
protected void	deleteLoadBalancingNextHop(Long parentVpnId, BigInteger dpnId, String destPrefix)
L3VPNTransportTypes	getConfiguredTransportTypeL3VPN()
org.opendaylight.yangtools.yang.binding.InstanceIdentifier<ConfTransportTypeL3vpn>	getConfTransportTypeIdentifier()
BigInteger	getDpnForPrefix(long vpnId, String prefixIp)
protected List<org.opendaylight.genius.mdsalutil.ActionInfo>	getEgressActionsForInterface(String ifName, int actionKey, boolean isTunnelInterface)
org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService	getItmManager()
long	getLocalNextHopGroup(long vpnId, String ipNextHopAddress)
long	getLocalSelectGroup(long vpnId, String ipNextHopAddress)
org.opendaylight.netvirt.fibmanager.NexthopManager.AdjacencyResult	getRemoteNextHopPointer(BigInteger remoteDpnId, long vpnId, String prefixIp, String nextHopIp, Class<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase> tunnelType)
String	getReqTransType()
Class<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase>	getReqTunType(String transportType)
String	getTransportTypeStr(String tunType)
protected String	getTunnelInterfaceName(BigInteger srcDpId, BigInteger dstDpId)
protected String	getTunnelInterfaceName(BigInteger srcDpId, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress dstIp, Class<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase> tunnelType)
protected VpnNexthop	getVpnNexthop(long vpnId, String ipAddress)
protected org.opendaylight.yangtools.yang.binding.InstanceIdentifier<IpAdjacencies>	getVpnNextHopIpPrefixIdentifier(long vpnId, String primaryIpAddress, String ipPrefix)
void	programDcGwLoadBalancingGroup(List<String> availableDcGws, BigInteger dpnId, String destinationIp, int addRemoveOrUpdate, boolean isTunnelUp, Class<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase> tunnelType)
void	removeLocalNextHop(BigInteger dpnId, Long vpnId, String primaryIpAddress, String currDestIpPrefix)
protected void	removeNextHopPointer(String nexthopKey)
void	removeOrUpdateDcGwLoadBalancingGroup(List<String> availableDcGws, BigInteger dpnId, String destinationIp) This method is invoked when the tunnel state is removed from DS.
void	setConfTransType(String service, String transportType)
protected long	setupLoadBalancingNextHop(Long parentVpnId, BigInteger dpnId, String destPrefix, List<org.opendaylight.genius.mdsalutil.BucketInfo> localBucketInfo, List<org.opendaylight.genius.mdsalutil.BucketInfo> remoteBucketInfo)
void	updateDcGwLoadBalancingGroup(List<String> availableDcGws, BigInteger dpnId, String destinationIp, boolean isTunnelUp, Class<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase> tunnelType) This method is invoked when the tunnel status is updated.
void	writeConfTransTypeConfigDS()

Methods inherited from class java.lang.Object

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

Constructor Detail

NexthopManager

@Inject
public NexthopManager(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                              org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalApiManager,
                              org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService idManager,
                              org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService odlInterfaceRpcService,
                              org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService itmManager,
                              org.opendaylight.yang.gen.v1.urn.opendaylight.genius.lockmanager.rev160413.LockManagerService lockManager,
                              IElanService elanService,
                              org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.SalGroupService salGroupService,
                              org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator,
                              FibUtil fibUtil,
                              org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager)

Provides nexthop functions. Creates group ID pool

Parameters:

dataBroker - - dataBroker reference

mdsalApiManager - - mdsalApiManager reference

idManager - - idManager reference

odlInterfaceRpcService - - odlInterfaceRpcService reference

itmManager - - itmManager reference

Method Detail

getItmManager

public org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService getItmManager()

createNextHopPointer

protected long createNextHopPointer(String nexthopKey)

removeNextHopPointer

protected void removeNextHopPointer(String nexthopKey)

getEgressActionsForInterface

protected List<org.opendaylight.genius.mdsalutil.ActionInfo> getEgressActionsForInterface(String ifName,
                                                                                          int actionKey,
                                                                                          boolean isTunnelInterface)

getTunnelInterfaceName

protected String getTunnelInterfaceName(BigInteger srcDpId,
                                        BigInteger dstDpId)

getTunnelInterfaceName

protected String getTunnelInterfaceName(BigInteger srcDpId,
                                        org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress dstIp,
                                        Class<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase> tunnelType)

getLocalNextHopGroup

public long getLocalNextHopGroup(long vpnId,
                                 String ipNextHopAddress)

getLocalSelectGroup

public long getLocalSelectGroup(long vpnId,
                                String ipNextHopAddress)

createLocalNextHop

public long createLocalNextHop(long vpnId,
                               BigInteger dpnId,
                               String ifName,
                               String primaryIpAddress,
                               String currDestIpPrefix,
                               String gwMacAddress)

addVpnNexthopToDS

protected void addVpnNexthopToDS(BigInteger dpnId,
                                 long vpnId,
                                 String primaryIpAddr,
                                 String currIpAddr,
                                 long egressPointer)

getVpnNextHopIpPrefixIdentifier

protected org.opendaylight.yangtools.yang.binding.InstanceIdentifier<IpAdjacencies> getVpnNextHopIpPrefixIdentifier(long vpnId,
                                                                                                                    String primaryIpAddress,
                                                                                                                    String ipPrefix)

getVpnNexthop

protected VpnNexthop getVpnNexthop(long vpnId,
                                   String ipAddress)

getRemoteNextHopPointer

public org.opendaylight.netvirt.fibmanager.NexthopManager.AdjacencyResult getRemoteNextHopPointer(BigInteger remoteDpnId,
                                                                                                  long vpnId,
                                                                                                  String prefixIp,
                                                                                                  String nextHopIp,
                                                                                                  Class<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase> tunnelType)

getDpnForPrefix

public BigInteger getDpnForPrefix(long vpnId,
                                  String prefixIp)

removeLocalNextHop

public void removeLocalNextHop(BigInteger dpnId,
                               Long vpnId,
                               String primaryIpAddress,
                               String currDestIpPrefix)

setConfTransType

public void setConfTransType(String service,
                             String transportType)

writeConfTransTypeConfigDS

public void writeConfTransTypeConfigDS()

getConfiguredTransportTypeL3VPN

public L3VPNTransportTypes getConfiguredTransportTypeL3VPN()

getReqTransType

public String getReqTransType()

getConfTransportTypeIdentifier

public org.opendaylight.yangtools.yang.binding.InstanceIdentifier<ConfTransportTypeL3vpn> getConfTransportTypeIdentifier()

getReqTunType

public Class<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase> getReqTunType(String transportType)

getTransportTypeStr

public String getTransportTypeStr(String tunType)

close

@PreDestroy
public void close()

Specified by:

close in interface AutoCloseable

setupLoadBalancingNextHop

protected long setupLoadBalancingNextHop(Long parentVpnId,
                                         BigInteger dpnId,
                                         String destPrefix,
                                         List<org.opendaylight.genius.mdsalutil.BucketInfo> localBucketInfo,
                                         List<org.opendaylight.genius.mdsalutil.BucketInfo> remoteBucketInfo)

deleteLoadBalancingNextHop

protected void deleteLoadBalancingNextHop(Long parentVpnId,
                                          BigInteger dpnId,
                                          String destPrefix)

createDcGwLoadBalancingGroup

public void createDcGwLoadBalancingGroup(List<String> availableDcGws,
                                         BigInteger dpnId,
                                         String destinationIp,
                                         Class<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase> tunnelType)

removeOrUpdateDcGwLoadBalancingGroup

public void removeOrUpdateDcGwLoadBalancingGroup(List<String> availableDcGws,
                                                 BigInteger dpnId,
                                                 String destinationIp)

This method is invoked when the tunnel state is removed from DS. If the there is just one DC-GW left in configuration then the LB groups can be deleted. Otherwise, the groups are just updated.

updateDcGwLoadBalancingGroup

public void updateDcGwLoadBalancingGroup(List<String> availableDcGws,
                                         BigInteger dpnId,
                                         String destinationIp,
                                         boolean isTunnelUp,
                                         Class<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase> tunnelType)

This method is invoked when the tunnel status is updated. The bucket is directly removed/added based on the operational status of the tunnel.

programDcGwLoadBalancingGroup

public void programDcGwLoadBalancingGroup(List<String> availableDcGws,
                                          BigInteger dpnId,
                                          String destinationIp,
                                          int addRemoveOrUpdate,
                                          boolean isTunnelUp,
                                          Class<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase> tunnelType)