* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-
package org.opendaylight.protocol.bgp.rib.impl.config;
-import com.google.common.base.Optional;
+import static org.opendaylight.protocol.bgp.rib.impl.config.OpenConfigMappingUtil.getAfiSafiWithDefault;
+import static org.opendaylight.protocol.bgp.rib.impl.config.OpenConfigMappingUtil.getGlobalClusterIdentifier;
+import static org.opendaylight.protocol.bgp.rib.impl.config.OpenConfigMappingUtil.toTableTypes;
+
import com.google.common.base.Preconditions;
+import com.google.common.util.concurrent.FluentFuture;
+import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
-import org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener;
-import org.opendaylight.controller.md.sal.dom.api.DOMDataBroker;
-import org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeService;
-import org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain;
-import org.opendaylight.controller.sal.core.api.model.SchemaService;
+import org.opendaylight.mdsal.binding.api.DataBroker;
+import org.opendaylight.mdsal.binding.api.TransactionChain;
+import org.opendaylight.mdsal.binding.api.TransactionChainListener;
import org.opendaylight.mdsal.binding.dom.codec.api.BindingCodecTreeFactory;
+import org.opendaylight.mdsal.common.api.CommitInfo;
+import org.opendaylight.mdsal.dom.api.DOMDataBroker;
+import org.opendaylight.mdsal.dom.api.DOMDataTreeChangeService;
+import org.opendaylight.mdsal.dom.api.DOMSchemaService;
+import org.opendaylight.mdsal.dom.api.DOMTransactionChain;
+import org.opendaylight.mdsal.dom.api.DOMTransactionChainListener;
import org.opendaylight.protocol.bgp.mode.api.PathSelectionMode;
-import org.opendaylight.protocol.bgp.openconfig.spi.BGPOpenConfigMappingService;
-import org.opendaylight.protocol.bgp.openconfig.spi.BGPOpenConfigProvider;
+import org.opendaylight.protocol.bgp.openconfig.routing.policy.spi.BGPRibRoutingPolicyFactory;
+import org.opendaylight.protocol.bgp.openconfig.spi.BGPTableTypeRegistryConsumer;
+import org.opendaylight.protocol.bgp.rib.impl.CodecsRegistryImpl;
import org.opendaylight.protocol.bgp.rib.impl.RIBImpl;
import org.opendaylight.protocol.bgp.rib.impl.spi.BGPDispatcher;
import org.opendaylight.protocol.bgp.rib.impl.spi.CodecsRegistry;
-import org.opendaylight.protocol.bgp.rib.impl.spi.ImportPolicyPeerTracker;
import org.opendaylight.protocol.bgp.rib.impl.spi.RIB;
import org.opendaylight.protocol.bgp.rib.impl.spi.RIBSupportContextRegistry;
-import org.opendaylight.protocol.bgp.rib.impl.stats.rib.impl.BGPRenderStats;
-import org.opendaylight.protocol.bgp.rib.spi.CacheDisconnectedPeers;
+import org.opendaylight.protocol.bgp.rib.spi.BGPPeerTracker;
import org.opendaylight.protocol.bgp.rib.spi.RIBExtensionConsumerContext;
+import org.opendaylight.protocol.bgp.rib.spi.policy.BGPRibRoutingPolicy;
+import org.opendaylight.protocol.bgp.rib.spi.state.BGPRibState;
+import org.opendaylight.protocol.bgp.rib.spi.state.BGPRibStateConsumer;
+import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.multiprotocol.rev151009.bgp.common.afi.safi.list.AfiSafi;
+import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.global.base.Config;
import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.top.bgp.Global;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.BgpTableType;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.RibId;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.bgp.rib.Rib;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.bgp.rib.RibKey;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.rib.TablesKey;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.BgpId;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.ClusterIdentifier;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IetfInetUtil;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4AddressNoZone;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.BgpTableType;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev180329.PeerId;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev180329.RibId;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev180329.bgp.rib.Rib;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev180329.bgp.rib.RibKey;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev180329.rib.TablesKey;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.BgpId;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.ClusterIdentifier;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public final class RibImpl implements RIB, AutoCloseable {
+public final class RibImpl implements RIB, BGPRibStateConsumer, AutoCloseable {
private static final Logger LOG = LoggerFactory.getLogger(RibImpl.class);
private final BGPDispatcher dispatcher;
private final BindingCodecTreeFactory codecTreeFactory;
private final DOMDataBroker domBroker;
- private final SchemaService schemaService;
+ private final DOMSchemaService domSchemaService;
+ private final BGPRibRoutingPolicyFactory policyProvider;
private RIBImpl ribImpl;
private ServiceRegistration<?> serviceRegistration;
private ListenerRegistration<SchemaContextListener> schemaContextRegistration;
+ private List<AfiSafi> afiSafi;
+ private AsNumber asNumber;
+ private Ipv4AddressNoZone routerId;
+
+ private ClusterIdentifier clusterId;
+ private final DataBroker dataBroker;
- @SuppressWarnings("deprecation")
- public RibImpl(final RIBExtensionConsumerContext contextProvider, final BGPDispatcher dispatcher,
- final BindingCodecTreeFactory codecTreeFactory, final DOMDataBroker domBroker, final SchemaService schemaService) {
+ public RibImpl(
+ final RIBExtensionConsumerContext contextProvider,
+ final BGPDispatcher dispatcher,
+ final BGPRibRoutingPolicyFactory policyProvider,
+ final BindingCodecTreeFactory codecTreeFactory,
+ final DOMDataBroker domBroker,
+ final DataBroker dataBroker,
+ final DOMSchemaService domSchemaService
+ ) {
this.extensions = contextProvider;
this.dispatcher = dispatcher;
this.codecTreeFactory = codecTreeFactory;
this.domBroker = domBroker;
- this.schemaService = schemaService;
+ this.dataBroker = dataBroker;
+ this.domSchemaService = domSchemaService;
+ this.policyProvider = policyProvider;
+ }
+
+ void start(final Global global, final String instanceName, final BGPTableTypeRegistryConsumer tableTypeRegistry) {
+ Preconditions.checkState(this.ribImpl == null,
+ "Previous instance %s was not closed.", this);
+ this.ribImpl = createRib(global, instanceName, tableTypeRegistry);
+ this.schemaContextRegistration = this.domSchemaService.registerSchemaContextListener(this.ribImpl);
}
- void start(final Global global, final String instanceName, final BGPOpenConfigMappingService mappingService) {
- Preconditions.checkState(this.ribImpl == null, "Previous instance %s was not closed.", this);
- this.ribImpl = createRib(global, instanceName, mappingService);
- this.schemaContextRegistration = this.schemaService.registerSchemaContextListener(this.ribImpl);
+ Boolean isGlobalEqual(final Global global) {
+ final List<AfiSafi> globalAfiSafi = getAfiSafiWithDefault(global.getAfiSafis(), true);
+ final Config globalConfig = global.getConfig();
+ final AsNumber globalAs = globalConfig.getAs();
+ final Ipv4Address globalRouterId = global.getConfig().getRouterId();
+ final ClusterIdentifier globalClusterId = getGlobalClusterIdentifier(globalConfig);
+ return this.afiSafi.containsAll(globalAfiSafi) && globalAfiSafi.containsAll(this.afiSafi)
+ && globalAs.equals(this.asNumber)
+ && globalRouterId.getValue().equals(this.routerId.getValue())
+ && globalClusterId.getValue().equals(this.clusterId.getValue());
}
@Override
}
@Override
- public DOMTransactionChain createPeerChain(final TransactionChainListener listener) {
+ public DOMTransactionChain createPeerDOMChain(final DOMTransactionChainListener listener) {
+ return this.ribImpl.createPeerDOMChain(listener);
+ }
+
+ @Override
+ public TransactionChain createPeerChain(final TransactionChainListener listener) {
return this.ribImpl.createPeerChain(listener);
}
}
@Override
- public Optional<BGPOpenConfigProvider> getOpenConfigProvider() {
- return this.ribImpl.getOpenConfigProvider();
+ public DOMDataTreeChangeService getService() {
+ return this.ribImpl.getService();
}
@Override
- public CacheDisconnectedPeers getCacheDisconnectedPeers() {
- return this.ribImpl.getCacheDisconnectedPeers();
+ public DataBroker getDataBroker() {
+ return this.ribImpl.getDataBroker();
}
- @Override
- public DOMDataTreeChangeService getService() {
- return this.ribImpl.getService();
+ FluentFuture<? extends CommitInfo> closeServiceInstance() {
+ if (this.ribImpl != null) {
+ return this.ribImpl.closeServiceInstance();
+ }
+ return CommitInfo.emptyFluentFuture();
}
@Override
if (this.serviceRegistration != null) {
try {
this.serviceRegistration.unregister();
- } catch(final IllegalStateException e) {
+ } catch (final IllegalStateException e) {
LOG.warn("Failed to unregister {} service instance", this, e);
}
this.serviceRegistration = null;
}
}
- public void setServiceRegistration(final ServiceRegistration<?> serviceRegistration) {
+ void setServiceRegistration(final ServiceRegistration<?> serviceRegistration) {
this.serviceRegistration = serviceRegistration;
}
@Override
- public BGPRenderStats getRenderStats() {
- return this.ribImpl.getRenderStats();
+ public Set<TablesKey> getLocalTablesKeys() {
+ return this.ribImpl.getLocalTablesKeys();
}
@Override
- public ImportPolicyPeerTracker getImportPolicyPeerTracker() {
- return this.ribImpl.getImportPolicyPeerTracker();
+ public boolean supportsTable(final TablesKey tableKey) {
+ return this.ribImpl.supportsTable(tableKey);
}
@Override
- public Set<TablesKey> getLocalTablesKeys() {
- return this.ribImpl.getLocalTablesKeys();
+ public BGPRibRoutingPolicy getRibPolicies() {
+ return this.ribImpl.getRibPolicies();
+ }
+
+ @Override
+ public BGPPeerTracker getPeerTracker() {
+ return this.ribImpl.getPeerTracker();
}
@Override
public String toString() {
- return this.ribImpl.toString();
+ return this.ribImpl != null ? this.ribImpl.toString() : "";
}
- private RIBImpl createRib(final Global global, final String bgpInstanceName, final BGPOpenConfigMappingService mappingService) {
- final Map<TablesKey, PathSelectionMode> pathSelectionModes = mappingService.toPathSelectionMode(global.getAfiSafis().getAfiSafi()).entrySet()
- .stream().collect(Collectors.toMap(entry -> new TablesKey(entry.getKey().getAfi(), entry.getKey().getSafi()), entry -> entry.getValue()));
- return new RIBImpl(new RibId(bgpInstanceName), new AsNumber(global.getConfig().getAs().getValue()),
- new BgpId(global.getConfig().getRouterId().getValue()), new ClusterIdentifier(global.getConfig().getRouterId().getValue()),
- this.extensions, this.dispatcher, this.codecTreeFactory, this.domBroker,
- mappingService.toTableTypes(global.getAfiSafis().getAfiSafi()), pathSelectionModes,
+ private RIBImpl createRib(
+ final Global global,
+ final String bgpInstanceName,
+ final BGPTableTypeRegistryConsumer tableTypeRegistry) {
+ this.afiSafi = getAfiSafiWithDefault(global.getAfiSafis(), true);
+ final Config globalConfig = global.getConfig();
+ this.asNumber = globalConfig.getAs();
+ this.routerId = IetfInetUtil.INSTANCE.ipv4AddressNoZoneFor(globalConfig.getRouterId());
+ this.clusterId = getGlobalClusterIdentifier(globalConfig);
+ final Map<TablesKey, PathSelectionMode> pathSelectionModes = OpenConfigMappingUtil
+ .toPathSelectionMode(this.afiSafi, tableTypeRegistry).entrySet()
+ .stream()
+ .collect(Collectors.toMap(entry ->
+ new TablesKey(entry.getKey().getAfi(), entry.getKey().getSafi()), Map.Entry::getValue));
+
+ final BGPRibRoutingPolicy ribPolicy = this.policyProvider.buildBGPRibPolicy(this.asNumber.getValue().toJava(),
+ this.routerId, this.clusterId, RoutingPolicyUtil.getApplyPolicy(global.getApplyPolicy()));
+ final CodecsRegistryImpl codecsRegistry = CodecsRegistryImpl.create(codecTreeFactory,
this.extensions.getClassLoadingStrategy());
+
+ return new RIBImpl(
+ tableTypeRegistry,
+ new RibId(bgpInstanceName),
+ this.asNumber,
+ new BgpId(this.routerId),
+ this.extensions,
+ this.dispatcher,
+ codecsRegistry,
+ this.domBroker,
+ this.dataBroker,
+ ribPolicy,
+ toTableTypes(this.afiSafi, tableTypeRegistry),
+ pathSelectionModes);
+ }
+
+ @Override
+ public BGPRibState getRIBState() {
+ return this.ribImpl.getRIBState();
+ }
+
+ public void instantiateServiceInstance() {
+ if (this.ribImpl != null) {
+ this.ribImpl.instantiateServiceInstance();
+ }
}
+ @Override
+ public void refreshTable(final TablesKey tk, final PeerId peerId) {
+ this.ribImpl.refreshTable(tk, peerId);
+ }
}
Code Review / bgpcep.git / blobdiff