2 * Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.protocol.bgp.openconfig.routing.policy.impl;
11 import static java.util.Objects.requireNonNull;
12 import static org.opendaylight.protocol.bgp.openconfig.routing.policy.spi.registry.RouteAttributeContainer.routeAttributeContainerFalse;
14 import com.google.common.cache.CacheBuilder;
15 import com.google.common.cache.CacheLoader;
16 import com.google.common.cache.LoadingCache;
17 import java.util.Collections;
18 import java.util.List;
19 import java.util.Optional;
20 import java.util.concurrent.ExecutionException;
21 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
22 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
23 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
24 import org.opendaylight.protocol.bgp.openconfig.routing.policy.spi.RouteEntryBaseAttributes;
25 import org.opendaylight.protocol.bgp.openconfig.routing.policy.spi.registry.RouteAttributeContainer;
26 import org.opendaylight.protocol.bgp.openconfig.routing.policy.spi.registry.StatementRegistryConsumer;
27 import org.opendaylight.protocol.bgp.rib.spi.policy.BGPRibRoutingPolicy;
28 import org.opendaylight.protocol.bgp.rib.spi.policy.BGPRouteEntryExportParameters;
29 import org.opendaylight.protocol.bgp.rib.spi.policy.BGPRouteEntryImportParameters;
30 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.types.rev151009.AfiSafiType;
31 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.routing.policy.rev151009.DefaultPolicyType;
32 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.routing.policy.rev151009.apply.policy.group.apply.policy.Config;
33 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.routing.policy.rev151009.routing.policy.top.RoutingPolicy;
34 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.routing.policy.rev151009.routing.policy.top.routing.policy.PolicyDefinitions;
35 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.routing.policy.rev151009.routing.policy.top.routing.policy.policy.definitions.PolicyDefinition;
36 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.routing.policy.rev151009.routing.policy.top.routing.policy.policy.definitions.PolicyDefinitionKey;
37 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.routing.policy.rev151009.routing.policy.top.routing.policy.policy.definitions.policy.definition.Statements;
38 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.routing.policy.rev151009.routing.policy.top.routing.policy.policy.definitions.policy.definition.statements.Statement;
39 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.Attributes;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.ClusterIdentifier;
42 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
44 final class BGPRibPolicyImpl implements BGPRibRoutingPolicy {
45 private static final InstanceIdentifier<RoutingPolicy> ROUTING_POLICY_IID
46 = InstanceIdentifier.create(RoutingPolicy.class);
47 private static final List<String> DEFAULT_IMPORT_POLICY = Collections.singletonList("default-odl-import-policy");
48 private static final List<String> DEFAULT_EXPORT_POLICY = Collections.singletonList("default-odl-export-policy");
49 private final DefaultPolicyType defaultExportPolicy;
50 private final DefaultPolicyType defaultImportPolicy;
51 private final List<String> exportPolicy;
52 private final List<String> importPolicy;
53 private final StatementRegistryConsumer policyRegistry;
54 private final RouteEntryBaseAttributes ribBaseParameters;
55 private final DataBroker databroker;
56 private final LoadingCache<String, List<Statement>> statements = CacheBuilder.newBuilder()
57 .build(new CacheLoader<String, List<Statement>>() {
59 public List<Statement> load(final String key) throws ExecutionException, InterruptedException {
60 return loadStatements(key);
64 BGPRibPolicyImpl(final DataBroker databroker, final StatementRegistryConsumer policyRegistry,
65 final long localAs, final Ipv4Address originatorId, final ClusterIdentifier clusterId,
66 final Config policyConfig) {
67 this.policyRegistry = requireNonNull(policyRegistry);
68 this.databroker = requireNonNull(databroker);
69 requireNonNull(policyConfig);
72 List<String> epolicy = policyConfig.getExportPolicy();
73 if (epolicy == null) {
74 epolicy = DEFAULT_EXPORT_POLICY;
76 List<String> ipolicy = policyConfig.getImportPolicy();
77 if (ipolicy == null) {
78 ipolicy = DEFAULT_IMPORT_POLICY;
81 this.defaultExportPolicy = requireNonNull(policyConfig.getDefaultExportPolicy());
82 this.defaultImportPolicy = requireNonNull(policyConfig.getDefaultImportPolicy());
83 this.exportPolicy = requireNonNull(epolicy);
84 this.importPolicy = requireNonNull(ipolicy);
85 this.ribBaseParameters = new PolicyRIBBaseParametersImpl(localAs, originatorId, clusterId);
88 private List<Statement> loadStatements(final String key) throws ExecutionException, InterruptedException {
89 final ReadOnlyTransaction tr = this.databroker.newReadOnlyTransaction();
90 final com.google.common.base.Optional<Statements> result =
91 tr.read(LogicalDatastoreType.CONFIGURATION, ROUTING_POLICY_IID.child(PolicyDefinitions.class)
92 .child(PolicyDefinition.class, new PolicyDefinitionKey(key)).child(Statements.class)).get();
93 if (!result.isPresent()) {
94 return Collections.emptyList();
96 return result.get().getStatement();
100 public Optional<Attributes> applyImportPolicies(final BGPRouteEntryImportParameters policyParameters,
101 final Attributes attributes, final Class<? extends AfiSafiType> afiSafi) {
102 RouteAttributeContainer currentAttributes = routeAttributeContainerFalse(attributes);
103 for (final String policyName : this.importPolicy) {
104 for (final Statement statement : this.statements.getUnchecked(policyName)) {
105 currentAttributes = this.policyRegistry
106 .applyImportStatement(this.ribBaseParameters, afiSafi, policyParameters, currentAttributes,
110 if (!currentAttributes.anyConditionSatisfied()) {
111 if (DefaultPolicyType.REJECTROUTE.equals(this.defaultImportPolicy)) {
112 return Optional.empty();
115 return Optional.ofNullable(currentAttributes.getAttributes());
119 public Optional<Attributes> applyExportPolicies(final BGPRouteEntryExportParameters policyParameters,
120 final Attributes attributes, final Class<? extends AfiSafiType> afiSafi) {
121 RouteAttributeContainer currentAttributes = routeAttributeContainerFalse(attributes);
122 for (final String policyName : this.exportPolicy) {
123 for (final Statement statement : this.statements.getUnchecked(policyName)) {
124 currentAttributes = this.policyRegistry.applyExportStatement(
125 this.ribBaseParameters, afiSafi, policyParameters, currentAttributes, statement);
128 if (!currentAttributes.anyConditionSatisfied()) {
129 if (DefaultPolicyType.REJECTROUTE.equals(this.defaultExportPolicy)) {
130 return Optional.empty();
134 return Optional.ofNullable(currentAttributes.getAttributes());