org.opendaylight.netvirt.fibmanager

Class BgpRouteVrfEntryHandler

java.lang.Object

org.opendaylight.netvirt.fibmanager.BaseVrfEntryHandler

org.opendaylight.netvirt.fibmanager.BgpRouteVrfEntryHandler

All Implemented Interfaces:

AutoCloseable, org.opendaylight.genius.utils.batching.ResourceHandler, IVrfEntryHandler

@Singleton
public class BgpRouteVrfEntryHandler
extends BaseVrfEntryHandler
implements AutoCloseable, org.opendaylight.genius.utils.batching.ResourceHandler, IVrfEntryHandler

Constructor Summary

Constructors

Constructor and Description
BgpRouteVrfEntryHandler(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker, NexthopManager nexthopManager)

Method Summary

Modifier and Type	Method and Description
protected void	addRewriteDstMacAction(long vpnId, VrfEntry vrfEntry, Prefixes prefixInfo, List<org.opendaylight.genius.mdsalutil.ActionInfo> actionInfos)
protected void	addTunnelInterfaceActions(org.opendaylight.netvirt.fibmanager.NexthopManager.AdjacencyResult adjacencyResult, long vpnId, VrfEntry vrfEntry, List<org.opendaylight.genius.mdsalutil.ActionInfo> actionInfos, String rd)
void	close()
void	create(org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx, org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType datastoreType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier identifier, Object vrfEntry, List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)
void	createFlows(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VrfEntry> identifier, VrfEntry vrfEntry, String rd)
void	createRemoteFibEntry(BigInteger remoteDpnId, long vpnId, String rd, VrfEntry vrfEntry, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx, List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)
void	delete(org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx, org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType datastoreType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier identifier, Object vrfEntry, List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)
void	deleteRemoteRoute(BigInteger localDpnId, BigInteger remoteDpnId, long vpnId, VrfTablesKey vrfTableKey, VrfEntry vrfEntry, com.google.common.base.Optional<Routes> extraRouteOptional, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx, List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)
int	getBatchInterval()
int	getBatchSize()
Consumer<? super VrfEntry>	getConsumerForCreatingRemoteFib(BigInteger dpnId, long vpnId, String rd, String remoteNextHopIp, com.google.common.base.Optional<VrfTables> vrfTable, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeCfgTxn, List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)
Consumer<? super VrfEntry>	getConsumerForDeletingRemoteFib(BigInteger dpnId, long vpnId, String rd, String remoteNextHopIp, com.google.common.base.Optional<VrfTables> vrfTable, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeCfgTxn, List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)
org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType	getDatastoreType()
org.opendaylight.controller.md.sal.binding.api.DataBroker	getResourceBroker()
void	init()
void	programRemoteFibForBgpRoutes(BigInteger remoteDpnId, long vpnId, VrfEntry vrfEntry, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx, String rd, List<org.opendaylight.netvirt.fibmanager.NexthopManager.AdjacencyResult> adjacencyResults, List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)
void	removeFlows(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VrfEntry> identifier, VrfEntry vrfEntry, String rd)
void	update(org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx, org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType datastoreType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier identifier, Object original, Object update, List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)
void	updateFlows(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VrfEntry> identifier, VrfEntry original, VrfEntry update, String rd)

Methods inherited from class org.opendaylight.netvirt.fibmanager.BaseVrfEntryHandler

buildL3vpnGatewayFlow, checkDpnDeleteFibEntry, deleteLocalAdjacency, deleteRemoteRoute, getVpnToExtraroute, getVpnToExtrarouteIdentifier, installPingResponderFlowEntry, makeConnectedRoute, programRemoteFib, resolveAdjacency

Methods inherited from class java.lang.Object

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

Constructor Detail

BgpRouteVrfEntryHandler

@Inject
public BgpRouteVrfEntryHandler(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                                       NexthopManager nexthopManager)

Method Detail

init

@PostConstruct
public void init()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class BaseVrfEntryHandler

Throws:

Exception

getResourceBroker

public org.opendaylight.controller.md.sal.binding.api.DataBroker getResourceBroker()

Specified by:

getResourceBroker in interface org.opendaylight.genius.utils.batching.ResourceHandler

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in interface org.opendaylight.genius.utils.batching.ResourceHandler

getBatchInterval

public int getBatchInterval()

Specified by:

getBatchInterval in interface org.opendaylight.genius.utils.batching.ResourceHandler

getDatastoreType

public org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType getDatastoreType()

Specified by:

getDatastoreType in interface org.opendaylight.genius.utils.batching.ResourceHandler

update

public void update(org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx,
                   org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType datastoreType,
                   org.opendaylight.yangtools.yang.binding.InstanceIdentifier identifier,
                   Object original,
                   Object update,
                   List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)

Specified by:

update in interface org.opendaylight.genius.utils.batching.ResourceHandler

create

public void create(org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx,
                   org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType datastoreType,
                   org.opendaylight.yangtools.yang.binding.InstanceIdentifier identifier,
                   Object vrfEntry,
                   List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)

Specified by:

create in interface org.opendaylight.genius.utils.batching.ResourceHandler

delete

public void delete(org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx,
                   org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType datastoreType,
                   org.opendaylight.yangtools.yang.binding.InstanceIdentifier identifier,
                   Object vrfEntry,
                   List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)

Specified by:

delete in interface org.opendaylight.genius.utils.batching.ResourceHandler

createFlows

public void createFlows(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VrfEntry> identifier,
                        VrfEntry vrfEntry,
                        String rd)

Specified by:

createFlows in interface IVrfEntryHandler

removeFlows

public void removeFlows(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VrfEntry> identifier,
                        VrfEntry vrfEntry,
                        String rd)

Specified by:

removeFlows in interface IVrfEntryHandler

updateFlows

public void updateFlows(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VrfEntry> identifier,
                        VrfEntry original,
                        VrfEntry update,
                        String rd)

Specified by:

updateFlows in interface IVrfEntryHandler

programRemoteFibForBgpRoutes

public void programRemoteFibForBgpRoutes(BigInteger remoteDpnId,
                                         long vpnId,
                                         VrfEntry vrfEntry,
                                         org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx,
                                         String rd,
                                         List<org.opendaylight.netvirt.fibmanager.NexthopManager.AdjacencyResult> adjacencyResults,
                                         List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)

createRemoteFibEntry

public void createRemoteFibEntry(BigInteger remoteDpnId,
                                 long vpnId,
                                 String rd,
                                 VrfEntry vrfEntry,
                                 org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx,
                                 List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)

deleteRemoteRoute

public void deleteRemoteRoute(BigInteger localDpnId,
                              BigInteger remoteDpnId,
                              long vpnId,
                              VrfTablesKey vrfTableKey,
                              VrfEntry vrfEntry,
                              com.google.common.base.Optional<Routes> extraRouteOptional,
                              org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx,
                              List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)

getConsumerForCreatingRemoteFib

public Consumer<? super VrfEntry> getConsumerForCreatingRemoteFib(BigInteger dpnId,
                                                                  long vpnId,
                                                                  String rd,
                                                                  String remoteNextHopIp,
                                                                  com.google.common.base.Optional<VrfTables> vrfTable,
                                                                  org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeCfgTxn,
                                                                  List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)

getConsumerForDeletingRemoteFib

public Consumer<? super VrfEntry> getConsumerForDeletingRemoteFib(BigInteger dpnId,
                                                                  long vpnId,
                                                                  String rd,
                                                                  String remoteNextHopIp,
                                                                  com.google.common.base.Optional<VrfTables> vrfTable,
                                                                  org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeCfgTxn,
                                                                  List<org.opendaylight.genius.utils.batching.SubTransaction> subTxns)

addTunnelInterfaceActions

protected void addTunnelInterfaceActions(org.opendaylight.netvirt.fibmanager.NexthopManager.AdjacencyResult adjacencyResult,
                                         long vpnId,
                                         VrfEntry vrfEntry,
                                         List<org.opendaylight.genius.mdsalutil.ActionInfo> actionInfos,
                                         String rd)

Overrides:

addTunnelInterfaceActions in class BaseVrfEntryHandler

addRewriteDstMacAction

protected void addRewriteDstMacAction(long vpnId,
                                      VrfEntry vrfEntry,
                                      Prefixes prefixInfo,
                                      List<org.opendaylight.genius.mdsalutil.ActionInfo> actionInfos)

Overrides:

addRewriteDstMacAction in class BaseVrfEntryHandler