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 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, FibUtil fibUtil)

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 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, getFibUtil, getNextHopManager, 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,
                                       FibUtil fibUtil)

Method Detail

init

@PostConstruct
public void init()

close

public void close()

Specified by:

close in interface AutoCloseable

Overrides:

close in class BaseVrfEntryHandler

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