org.opendaylight.protocol.bgp.rib.impl

Class ApplicationPeer

java.lang.Object

org.opendaylight.protocol.bgp.rib.DefaultRibReference

org.opendaylight.protocol.bgp.rib.impl.state.BGPPeerStateImpl

org.opendaylight.protocol.bgp.rib.impl.ApplicationPeer

All Implemented Interfaces:

EventListener, org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener, org.opendaylight.controller.md.sal.dom.api.ClusteredDOMDataTreeChangeListener, org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeListener, BGPMessagesListener, PeerTransactionChain, RibReference, Peer, PeerTrackerInformation, BGPRouteEntryImportParameters, RouteTargetMembershipConsumer, BGPAfiSafiState, BGPErrorHandlingState, BGPGracelfulRestartState, BGPPeerMessagesState, BGPPeerState, BGPPeerStateConsumer, InstanceReference<Rib>

public class ApplicationPeer
extends BGPPeerStateImpl
implements org.opendaylight.controller.md.sal.dom.api.ClusteredDOMDataTreeChangeListener

Application Peer is a special case of BGP peer. It serves as an interface for user to advertise user routes to ODL and through ODL to other BGP peers. This peer has it's own RIB, where it stores all user routes. This RIB is located in configurational datastore. Routes are added through RESTCONF. They are then processed as routes from any other peer, through AdjRib, EffectiveRib,LocRib and if they are advertised further, through AdjRibOut. For purposed of import policies such as Best Path Selection, application peer needs to have a BGP-ID that is configurable.

Field Summary

Fields

Modifier and Type	Field and Description
protected RIB	rib

Constructor Summary

Constructors

Constructor and Description
ApplicationPeer(BGPTableTypeRegistryConsumer tableTypeRegistry, ApplicationRibId applicationRibId, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address ipAddress, RIB rib)

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.FluentFuture<? extends org.opendaylight.mdsal.common.api.CommitInfo>	close() Close Peers and performs asynchronously DS clean up.
BGPAfiSafiState	getBGPAfiSafiState() Afi Safi Operational State.
BGPErrorHandlingState	getBGPErrorHandlingState() Error Handling State.
BGPSessionState	getBGPSessionState() BGP Session Operational State.
BGPTimersState	getBGPTimersState() BGP Operation Timers State.
BGPTransportState	getBGPTransportState() BGP Operational Transport State.
ClusterIdentifier	getClusterId() Returns Cluster Id.
org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain	getDomChain() Returns Peer DOMTransactionChain.
ClusterIdentifier	getFromClusterId() Peer id of Peer route entry announcer.
PeerId	getFromPeerId() Peer id of Peer route entry announcer.
org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber	getFromPeerLocalAs() Peer local AS of route entry announcer.
PeerRole	getFromPeerRole() Peer id of Peer route entry announcer.
org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber	getLocalAs() Returns Local AS.
List<RouteTarget>	getMemberships() Returns list of Route target advertized per Peer.
String	getName() Return peer's symbolic name.
PeerId	getPeerId() Returns Peer id.
byte[]	getRawIdentifier() Return the peer's BGP identifier as raw byte array.
org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier<Tables,TablesKey>	getRibOutIId(TablesKey tablesKey) Creates Table Adj Rib Out Instance identifier.
PeerRole	getRole() Returns Peer Role.
SendReceive	getSupportedAddPathTables(TablesKey tableKey) Returns AddPath support configuration if supported, otherwise null.
<C extends Routes & org.opendaylight.yangtools.yang.binding.DataObject & org.opendaylight.yangtools.yang.binding.ChoiceIn<Tables>,S extends org.opendaylight.yangtools.yang.binding.ChildOf<? super C>,R extends Route & org.opendaylight.yangtools.yang.binding.ChildOf<? super S> & org.opendaylight.yangtools.yang.binding.Identifiable<I>,I extends org.opendaylight.yangtools.yang.binding.Identifier<R>> void	initializeRibOut(RouteEntryDependenciesContainer entryDep, List<ActualBestPathRoutes<C,S,R,I>> routesToStore) Stores under peers rib Out already present routes, before proceed to process any new route advertizement.
void	instantiateServiceInstance(org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeService dataTreeChangeService, org.opendaylight.controller.md.sal.dom.api.DOMDataTreeIdentifier appPeerDOMId)
void	onDataTreeChanged(Collection<org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeCandidate> changes) Routes come from application RIB that is identified by (configurable) name.
void	onTransactionChainFailed(org.opendaylight.controller.md.sal.common.api.data.TransactionChain<?,?> chain, org.opendaylight.controller.md.sal.common.api.data.AsyncTransaction<?,?> transaction, Throwable cause)
void	onTransactionChainSuccessful(org.opendaylight.controller.md.sal.common.api.data.TransactionChain<?,?> chain)
<C extends Routes & org.opendaylight.yangtools.yang.binding.DataObject & org.opendaylight.yangtools.yang.binding.ChoiceIn<Tables>,S extends org.opendaylight.yangtools.yang.binding.ChildOf<? super C>,R extends Route & org.opendaylight.yangtools.yang.binding.ChildOf<? super S> & org.opendaylight.yangtools.yang.binding.Identifiable<I>,I extends org.opendaylight.yangtools.yang.binding.Identifier<R>> void	reEvaluateAdvertizement(RouteEntryDependenciesContainer entryDep, List<ActualBestPathRoutes<C,S,R,I>> routesToStore) Applies all policies through all present routes, and advertize/withdraws based on new results.
<C extends Routes & org.opendaylight.yangtools.yang.binding.DataObject & org.opendaylight.yangtools.yang.binding.ChoiceIn<Tables>,S extends org.opendaylight.yangtools.yang.binding.ChildOf<? super C>,R extends Route & org.opendaylight.yangtools.yang.binding.ChildOf<? super S> & org.opendaylight.yangtools.yang.binding.Identifiable<I>,I extends org.opendaylight.yangtools.yang.binding.Identifier<R>> void	refreshRibOut(RouteEntryDependenciesContainer entryDep, List<StaleBestPathRoute<C,S,R,I>> staleRoutes, List<AdvertizedRoute<C,S,R,I>> newRoutes) Update peers ribout after path selection processing.
boolean	supportsAddPathSupported(TablesKey tableKey) Returns if peer supports Additional Path for specific table.
boolean	supportsTable(TablesKey tableKey) Returns true if peer supports table.

Methods inherited from class org.opendaylight.protocol.bgp.rib.impl.state.BGPPeerStateImpl

getAfiSafisAdvertized, getAfiSafisReceived, getBGPGracelfulRestart, getBGPPeerMessagesState, getErroneousUpdateReceivedCount, getGroupId, getNeighborAddress, getNotificationMessagesReceivedCount, getNotificationMessagesSentCount, getPeerRestartTime, getPeerState, getPrefixesInstalledCount, getPrefixesReceivedCount, getPrefixesSentCount, getTotalPrefixes, getUpdateMessagesReceivedCount, getUpdateMessagesSentCount, isActive, isAfiSafiSupported, isGracefulRestartAdvertized, isGracefulRestartReceived, isLocalRestarting, isPeerRestarting, messageReceived, messageSent, registerPrefixesCounters, registerPrefixesSentCounter, resetState, setActive, setAdvertizedGracefulRestartTableTypes, setAfiSafiGracefulRestartState

Methods inherited from class org.opendaylight.protocol.bgp.rib.DefaultRibReference

getInstanceIdentifier

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opendaylight.protocol.bgp.rib.spi.state.BGPPeerState

getTotalPathsCount

Methods inherited from interface org.opendaylight.protocol.bgp.rib.RibReference

getInstanceIdentifier

Field Detail

rib

protected final RIB rib

Constructor Detail

ApplicationPeer

public ApplicationPeer(BGPTableTypeRegistryConsumer tableTypeRegistry,
                       ApplicationRibId applicationRibId,
                       org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address ipAddress,
                       RIB rib)

Method Detail

getMemberships

public List<RouteTarget> getMemberships()

Description copied from interface: RouteTargetMembershipConsumer

Returns list of Route target advertized per Peer.

Specified by:

getMemberships in interface RouteTargetMembershipConsumer

instantiateServiceInstance

public void instantiateServiceInstance(org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeService dataTreeChangeService,
                                       org.opendaylight.controller.md.sal.dom.api.DOMDataTreeIdentifier appPeerDOMId)

onDataTreeChanged

public void onDataTreeChanged(Collection<org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeCandidate> changes)

Routes come from application RIB that is identified by (configurable) name. Each route is pushed into AdjRibsInWriter with it's whole context. In this method, it doesn't matter if the routes are removed or added, this will be determined in LocRib.

Specified by:

onDataTreeChanged in interface org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeListener

close

public com.google.common.util.concurrent.FluentFuture<? extends org.opendaylight.mdsal.common.api.CommitInfo> close()

Description copied from interface: Peer

Close Peers and performs asynchronously DS clean up.

Specified by:

close in interface Peer

Returns:

future

supportsAddPathSupported

public boolean supportsAddPathSupported(TablesKey tableKey)

Description copied from interface: PeerTrackerInformation

Returns if peer supports Additional Path for specific table.

Specified by:

supportsAddPathSupported in interface PeerTrackerInformation

Parameters:

tableKey - table

Returns:

true if Additional Path is supported for defined table

getSupportedAddPathTables

public SendReceive getSupportedAddPathTables(TablesKey tableKey)

Description copied from interface: PeerTrackerInformation

Returns AddPath support configuration if supported, otherwise null.

Specified by:

getSupportedAddPathTables in interface PeerTrackerInformation

Parameters:

tableKey - table

Returns:

AddPath support configuration if supported, otherwise null

supportsTable

public boolean supportsTable(TablesKey tableKey)

Description copied from interface: PeerTrackerInformation

Returns true if peer supports table.

Specified by:

supportsTable in interface PeerTrackerInformation

Parameters:

tableKey - table

Returns:

true if Additional Path is supported for defined table

getRibOutIId

public org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier<Tables,TablesKey> getRibOutIId(TablesKey tablesKey)

Description copied from interface: PeerTrackerInformation

Creates Table Adj Rib Out Instance identifier.

Specified by:

getRibOutIId in interface PeerTrackerInformation

Parameters:

tablesKey - table key

Returns:

instance identifier.

onTransactionChainFailed

public void onTransactionChainFailed(org.opendaylight.controller.md.sal.common.api.data.TransactionChain<?,?> chain,
                                     org.opendaylight.controller.md.sal.common.api.data.AsyncTransaction<?,?> transaction,
                                     Throwable cause)

Specified by:

onTransactionChainFailed in interface org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener

getBGPSessionState

public BGPSessionState getBGPSessionState()

Description copied from interface: BGPPeerState

BGP Session Operational State.

Specified by:

getBGPSessionState in interface BGPPeerState

Returns:

BGPSessionState

getBGPTimersState

public BGPTimersState getBGPTimersState()

Description copied from interface: BGPPeerState

BGP Operation Timers State.

Specified by:

getBGPTimersState in interface BGPPeerState

Returns:

BGPTimersState

getBGPTransportState

public BGPTransportState getBGPTransportState()

Description copied from interface: BGPPeerState

BGP Operational Transport State.

Specified by:

getBGPTransportState in interface BGPPeerState

Returns:

BGPTransportState

getPeerId

public final PeerId getPeerId()

Description copied from interface: PeerTrackerInformation

Returns Peer id.

Specified by:

getPeerId in interface PeerTrackerInformation

Returns:

PeerID

getRole

public final PeerRole getRole()

Description copied from interface: PeerTrackerInformation

Returns Peer Role.

Specified by:

getRole in interface PeerTrackerInformation

Returns:

PeerRole

getRawIdentifier

public final byte[] getRawIdentifier()

Description copied from interface: Peer

Return the peer's BGP identifier as raw byte array.

Specified by:

getRawIdentifier in interface Peer

Returns:

byte[] raw identifier

getFromPeerRole

public final PeerRole getFromPeerRole()

Description copied from interface: BGPRouteEntryImportParameters

Peer id of Peer route entry announcer.

Specified by:

getFromPeerRole in interface BGPRouteEntryImportParameters

Returns:

peer Role of announcer Peer

getFromPeerId

public final PeerId getFromPeerId()

Description copied from interface: BGPRouteEntryImportParameters

Peer id of Peer route entry announcer.

Specified by:

getFromPeerId in interface BGPRouteEntryImportParameters

Returns:

peer Id of announcer Peer

getFromClusterId

public final ClusterIdentifier getFromClusterId()

Description copied from interface: BGPRouteEntryImportParameters

Peer id of Peer route entry announcer.

Specified by:

getFromClusterId in interface BGPRouteEntryImportParameters

Returns:

peer Id of announcer Peer

onTransactionChainSuccessful

public final void onTransactionChainSuccessful(org.opendaylight.controller.md.sal.common.api.data.TransactionChain<?,?> chain)

Specified by:

onTransactionChainSuccessful in interface org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener

getBGPErrorHandlingState

public final BGPErrorHandlingState getBGPErrorHandlingState()

Description copied from interface: BGPPeerState

Error Handling State.

Specified by:

getBGPErrorHandlingState in interface BGPPeerState

Returns:

ErrorHandlingState

getBGPAfiSafiState

public final BGPAfiSafiState getBGPAfiSafiState()

Description copied from interface: BGPPeerState

Afi Safi Operational State.

Specified by:

getBGPAfiSafiState in interface BGPPeerState

Returns:

AfiSafiState

getFromPeerLocalAs

public final org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber getFromPeerLocalAs()

Description copied from interface: BGPRouteEntryImportParameters

Peer local AS of route entry announcer.

Specified by:

getFromPeerLocalAs in interface BGPRouteEntryImportParameters

Returns:

peer Local AS

getName

public final String getName()

Description copied from interface: Peer

Return peer's symbolic name.

Specified by:

getName in interface Peer

Returns:

symbolic name.

getClusterId

public final ClusterIdentifier getClusterId()

Description copied from interface: PeerTrackerInformation

Returns Cluster Id.

Specified by:

getClusterId in interface PeerTrackerInformation

Returns:

Cluster Id

getLocalAs

public final org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber getLocalAs()

Description copied from interface: PeerTrackerInformation

Returns Local AS.

Specified by:

getLocalAs in interface PeerTrackerInformation

Returns:

AS

getDomChain

public org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain getDomChain()

Description copied from interface: PeerTransactionChain

Returns Peer DOMTransactionChain.

Specified by:

getDomChain in interface PeerTransactionChain

Returns:

DOMTransactionChain

initializeRibOut

public final <C extends Routes & org.opendaylight.yangtools.yang.binding.DataObject & org.opendaylight.yangtools.yang.binding.ChoiceIn<Tables>,S extends org.opendaylight.yangtools.yang.binding.ChildOf<? super C>,R extends Route & org.opendaylight.yangtools.yang.binding.ChildOf<? super S> & org.opendaylight.yangtools.yang.binding.Identifiable<I>,I extends org.opendaylight.yangtools.yang.binding.Identifier<R>> void initializeRibOut(RouteEntryDependenciesContainer entryDep,
                                                                                                                                                                                                                                                                                                                                                                                                                                                  List<ActualBestPathRoutes<C,S,R,I>> routesToStore)

Description copied from interface: Peer

Stores under peers rib Out already present routes, before proceed to process any new route advertizement.

Specified by:

initializeRibOut in interface Peer

Parameters:

entryDep - RouteEntryDependenciesContainer

routesToStore - routes to be advertized.

refreshRibOut

public final <C extends Routes & org.opendaylight.yangtools.yang.binding.DataObject & org.opendaylight.yangtools.yang.binding.ChoiceIn<Tables>,S extends org.opendaylight.yangtools.yang.binding.ChildOf<? super C>,R extends Route & org.opendaylight.yangtools.yang.binding.ChildOf<? super S> & org.opendaylight.yangtools.yang.binding.Identifiable<I>,I extends org.opendaylight.yangtools.yang.binding.Identifier<R>> void refreshRibOut(RouteEntryDependenciesContainer entryDep,
                                                                                                                                                                                                                                                                                                                                                                                                                                               List<StaleBestPathRoute<C,S,R,I>> staleRoutes,
                                                                                                                                                                                                                                                                                                                                                                                                                                               List<AdvertizedRoute<C,S,R,I>> newRoutes)

Description copied from interface: Peer

Update peers ribout after path selection processing.

Specified by:

refreshRibOut in interface Peer

Parameters:

entryDep - RouteEntryDependenciesContainer

staleRoutes - routes to be removed.

newRoutes - routes to be advertized.

reEvaluateAdvertizement

public final <C extends Routes & org.opendaylight.yangtools.yang.binding.DataObject & org.opendaylight.yangtools.yang.binding.ChoiceIn<Tables>,S extends org.opendaylight.yangtools.yang.binding.ChildOf<? super C>,R extends Route & org.opendaylight.yangtools.yang.binding.ChildOf<? super S> & org.opendaylight.yangtools.yang.binding.Identifiable<I>,I extends org.opendaylight.yangtools.yang.binding.Identifier<R>> void reEvaluateAdvertizement(RouteEntryDependenciesContainer entryDep,
                                                                                                                                                                                                                                                                                                                                                                                                                                                         List<ActualBestPathRoutes<C,S,R,I>> routesToStore)

Description copied from interface: Peer

Applies all policies through all present routes, and advertize/withdraws based on new results. Scenario would be for example a removal of RT membership. And reprocess VPN routes.

Specified by:

reEvaluateAdvertizement in interface Peer

Parameters:

entryDep - RouteEntryDependenciesContainer

routesToStore - routes to be updated.