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 interfaceManager, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService itmManager, IElanService elanService, org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.SalGroupService salGroupService) Provides nexthop functions.

Method Summary

Modifier and Type	Method and Description
protected void	addVpnNexthopToDS(BigInteger dpnId, long vpnId, String ipPrefix, long egressPointer)
void	close()
void	createDcGwLoadBalancingGroup(List<String> availableDcGws, BigInteger dpnId, String destinationIp)
long	createLocalNextHop(long vpnId, BigInteger dpnId, String ifName, String ipNextHopAddress, String ipPrefixAddress, String gwMacAddress, String jobKey)
protected long	createNextHopPointer(String nexthopKey)
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)
org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService	getInterfaceManager()
long	getLocalNextHopGroup(long vpnId, String ipNextHopAddress)
org.opendaylight.netvirt.fibmanager.NexthopManager.AdjacencyResult	getRemoteNextHopPointer(BigInteger remoteDpnId, long vpnId, String prefixIp, String nextHopIp)
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)
protected VpnNexthop	getVpnNexthop(long vpnId, String ipAddress)
protected org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnNexthop>	getVpnNextHopIdentifier(long vpnId, String ipAddress)
void	programDcGwLoadBalancingGroup(List<String> availableDcGws, BigInteger dpnId, String destinationIp, int addRemoveOrUpdate, boolean isTunnelUp)
void	removeLocalNextHop(BigInteger dpnId, Long vpnId, String ipNextHopAddress, String ipPrefixAddress)
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> listBucketInfo, boolean addOrRemove)
void	updateDcGwLoadBalancingGroup(List<String> availableDcGws, BigInteger dpnId, String destinationIp, boolean isTunnelUp) 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 interfaceManager,
                              org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService itmManager,
                              IElanService elanService,
                              org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.SalGroupService salGroupService)

Provides nexthop functions. Creates group ID pool

Parameters:

dataBroker - - dataBroker reference

mdsalApiManager - - mdsalApiManager reference

idManager - - idManager reference

interfaceManager - - interfaceManager reference

itmManager - - itmManager reference

Method Detail

getInterfaceManager

public org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService getInterfaceManager()

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)

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)

getLocalNextHopGroup

public long getLocalNextHopGroup(long vpnId,
                                 String ipNextHopAddress)

createLocalNextHop

public long createLocalNextHop(long vpnId,
                               BigInteger dpnId,
                               String ifName,
                               String ipNextHopAddress,
                               String ipPrefixAddress,
                               String gwMacAddress,
                               String jobKey)

addVpnNexthopToDS

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

getVpnNextHopIdentifier

protected org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnNexthop> getVpnNextHopIdentifier(long vpnId,
                                                                                                         String ipAddress)

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)

getDpnForPrefix

public BigInteger getDpnForPrefix(long vpnId,
                                  String prefixIp)

removeLocalNextHop

public void removeLocalNextHop(BigInteger dpnId,
                               Long vpnId,
                               String ipNextHopAddress,
                               String ipPrefixAddress)

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()
                       throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

setupLoadBalancingNextHop

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

createDcGwLoadBalancingGroup

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

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)

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)