org.opendaylight.protocol.bgp.rib.impl

Class RIBImpl

java.lang.Object

org.opendaylight.protocol.bgp.rib.DefaultRibReference

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

org.opendaylight.protocol.bgp.rib.impl.RIBImpl

All Implemented Interfaces:

AutoCloseable, EventListener, org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener, org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService, org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider, RIB, RibReference, BGPRIBState, BGPRIBStateConsumer, InstanceReference<Rib>, org.opendaylight.yangtools.concepts.Identifiable<org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier>, org.opendaylight.yangtools.yang.model.api.SchemaContextListener

@ThreadSafe
public final class RIBImpl
extends BGPRIBStateImpl
implements org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService, RIB, org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener, org.opendaylight.yangtools.yang.model.api.SchemaContextListener, AutoCloseable

Constructor Summary

Constructors

Constructor and Description

RIBImpl(org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider provider, RibId ribId, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber localAs, BgpId localBgpId, ClusterIdentifier clusterId, RIBExtensionConsumerContext extensions, BGPDispatcher dispatcher, org.opendaylight.mdsal.binding.dom.codec.api.BindingCodecTreeFactory codecFactory, org.opendaylight.controller.md.sal.dom.api.DOMDataBroker domDataBroker, List<BgpTableType> localTables, Map<TablesKey,PathSelectionMode> bestPathSelectionStrategies, org.opendaylight.mdsal.binding.generator.impl.GeneratedClassLoadingStrategy classStrategy, BgpDeployer.WriteConfiguration configurationWriter)

Method Summary

Modifier and Type	Method and Description
protected com.google.common.base.MoreObjects.ToStringHelper	addToStringAttributes(com.google.common.base.MoreObjects.ToStringHelper toStringHelper)
void	close()
com.google.common.util.concurrent.ListenableFuture<Void>	closeServiceInstance()
org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain	createPeerChain(org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener listener) Allocate a new transaction chain for use with a peer.
BgpId	getBgpIdentifier()
CodecsRegistry	getCodecsRegistry()
BGPDispatcher	getDispatcher()
ExportPolicyPeerTracker	getExportPolicyPeerTracker(TablesKey tablesKey) Returns ExportPolicyPeerTracker for specific tableKey, where peer can register himself as supporting the table.
org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier	getIdentifier()
ImportPolicyPeerTracker	getImportPolicyPeerTracker()
org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber	getLocalAs()
Set<? extends BgpTableType>	getLocalTables() Return the set of table identifiers which are accepted and advertised by this RIB instance.
Set<TablesKey>	getLocalTablesKeys()
BGPRenderStats	getRenderStats()
RIBExtensionConsumerContext	getRibExtensions() Return the RIB extensions available to the RIB instance.
org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier	getRibIServiceGroupIdentifier() Return common ServiceGroupIdentifier to be used between same group cluster service
RIBSupportContextRegistry	getRibSupportContext() Return the RIB extensions available to the RIB instance with additional RIB specific context such as translation between DOM and Binding.
org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeService	getService() Return instance of DOMDataTreeChangeService, where consumer can register to listen on DOM data changes.
org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier	getYangRibId() Return YangInstanceIdentifier of BGP Rib with its RibId.
void	instantiateServiceInstance()
void	onGlobalContextUpdated(org.opendaylight.yangtools.yang.model.api.SchemaContext context)
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)
org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceRegistration	registerClusterSingletonService(org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService clusterSingletonService)
String	toString()

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

getAs, getPathCount, getPathsCount, getPrefixesCount, getPrefixesCount, getRIBState, getRouteId, getTotalPathsCount, getTotalPrefixesCount, registerTotalPathCounter, registerTotalPrefixesCounter

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

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

getInstanceIdentifier

Constructor Detail

RIBImpl

public RIBImpl(org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider provider,
               RibId ribId,
               org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber localAs,
               BgpId localBgpId,
               ClusterIdentifier clusterId,
               RIBExtensionConsumerContext extensions,
               BGPDispatcher dispatcher,
               org.opendaylight.mdsal.binding.dom.codec.api.BindingCodecTreeFactory codecFactory,
               org.opendaylight.controller.md.sal.dom.api.DOMDataBroker domDataBroker,
               List<BgpTableType> localTables,
               @Nonnull
               Map<TablesKey,PathSelectionMode> bestPathSelectionStrategies,
               org.opendaylight.mdsal.binding.generator.impl.GeneratedClassLoadingStrategy classStrategy,
               BgpDeployer.WriteConfiguration configurationWriter)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

addToStringAttributes

protected com.google.common.base.MoreObjects.ToStringHelper addToStringAttributes(com.google.common.base.MoreObjects.ToStringHelper toStringHelper)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

getLocalAs

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

Specified by:

getLocalAs in interface RIB

getBgpIdentifier

public BgpId getBgpIdentifier()

Specified by:

getBgpIdentifier in interface RIB

getLocalTables

@Nonnull
public Set<? extends BgpTableType> getLocalTables()

Description copied from interface: RIB

Return the set of table identifiers which are accepted and advertised by this RIB instance.

Specified by:

getLocalTables in interface RIB

Returns:

A set of identifiers.

getDispatcher

public BGPDispatcher getDispatcher()

Specified by:

getDispatcher in interface RIB

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

onTransactionChainSuccessful

public 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

getLocalTablesKeys

public Set<TablesKey> getLocalTablesKeys()

Specified by:

getLocalTablesKeys in interface RIB

getService

public org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeService getService()

Description copied from interface: RIB

Return instance of DOMDataTreeChangeService, where consumer can register to listen on DOM data changes.

Specified by:

getService in interface RIB

Returns:

DOMDataTreeChangeService

getRenderStats

public BGPRenderStats getRenderStats()

Specified by:

getRenderStats in interface RIB

getYangRibId

public org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier getYangRibId()

Description copied from interface: RIB

Return YangInstanceIdentifier of BGP Rib with its RibId.

Specified by:

getYangRibId in interface RIB

Returns:

YangInstanceIdentifier

createPeerChain

public org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain createPeerChain(org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener listener)

Description copied from interface: RIB

Allocate a new transaction chain for use with a peer.

Specified by:

createPeerChain in interface RIB

Parameters:

listener - TransactionChainListener handling recovery

Returns:

A new transaction chain.

getRibExtensions

public RIBExtensionConsumerContext getRibExtensions()

Description copied from interface: RIB

Return the RIB extensions available to the RIB instance.

Specified by:

getRibExtensions in interface RIB

Returns:

RIB extensions handle.

getRibSupportContext

public RIBSupportContextRegistry getRibSupportContext()

Description copied from interface: RIB

Return the RIB extensions available to the RIB instance with additional RIB specific context such as translation between DOM and Binding.

Specified by:

getRibSupportContext in interface RIB

Returns:

RIB extensions handle.

onGlobalContextUpdated

public void onGlobalContextUpdated(org.opendaylight.yangtools.yang.model.api.SchemaContext context)

Specified by:

onGlobalContextUpdated in interface org.opendaylight.yangtools.yang.model.api.SchemaContextListener

getCodecsRegistry

public CodecsRegistry getCodecsRegistry()

Specified by:

getCodecsRegistry in interface RIB

getImportPolicyPeerTracker

public ImportPolicyPeerTracker getImportPolicyPeerTracker()

Specified by:

getImportPolicyPeerTracker in interface RIB

getExportPolicyPeerTracker

public ExportPolicyPeerTracker getExportPolicyPeerTracker(TablesKey tablesKey)

Description copied from interface: RIB

Returns ExportPolicyPeerTracker for specific tableKey, where peer can register himself as supporting the table. Same export policy can be used to check which peers support respective table and announce then routes if required.

Specified by:

getExportPolicyPeerTracker in interface RIB

Parameters:

tablesKey - supported table

Returns:

ExportPolicyPeerTracker

instantiateServiceInstance

public void instantiateServiceInstance()

Specified by:

instantiateServiceInstance in interface org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService

closeServiceInstance

public com.google.common.util.concurrent.ListenableFuture<Void> closeServiceInstance()

Specified by:

closeServiceInstance in interface org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService

getIdentifier

public org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier getIdentifier()

Specified by:

getIdentifier in interface org.opendaylight.yangtools.concepts.Identifiable<org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier>

registerClusterSingletonService

public org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceRegistration registerClusterSingletonService(org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService clusterSingletonService)

Specified by:

registerClusterSingletonService in interface org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider

getRibIServiceGroupIdentifier

public org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier getRibIServiceGroupIdentifier()

Description copied from interface: RIB

Return common ServiceGroupIdentifier to be used between same group cluster service

Specified by:

getRibIServiceGroupIdentifier in interface RIB

Returns:

ServiceGroupIdentifier