2 * Copyright (c) 2016 Cisco Systems, Inc. and others. 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.groupbasedpolicy.renderer.vpp.policy;
11 import javax.annotation.Nonnull;
13 import org.opendaylight.controller.config.yang.config.vpp_provider.impl.VppRenderer;
14 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
15 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
16 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
17 import org.opendaylight.groupbasedpolicy.renderer.vpp.event.NodeOperEvent;
18 import org.opendaylight.groupbasedpolicy.renderer.vpp.event.RendererPolicyConfEvent;
19 import org.opendaylight.groupbasedpolicy.renderer.vpp.iface.InterfaceManager;
20 import org.opendaylight.groupbasedpolicy.renderer.vpp.util.KeyFactory;
21 import org.opendaylight.groupbasedpolicy.util.IidFactory;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.common.endpoint.fields.NetworkContainment;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.common.endpoint.fields.network.containment.Containment;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.common.endpoint.fields.network.containment.containment.ForwardingContextContainment;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.common.endpoint.fields.network.containment.containment.NetworkDomainContainment;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.has.absolute.location.absolute.location.LocationType;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.has.absolute.location.absolute.location.location.type.ExternalLocationCase;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.l2_l3.rev160427.L2FloodDomain;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.RendererPolicy;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.RendererPolicyBuilder;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.endpoints.AddressEndpointWithLocation;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.RendererEndpointKey;
33 import org.slf4j.Logger;
34 import org.slf4j.LoggerFactory;
36 import com.google.common.base.Preconditions;
37 import com.google.common.base.Strings;
38 import com.google.common.collect.ImmutableSet;
39 import com.google.common.collect.Sets;
40 import com.google.common.collect.Sets.SetView;
41 import com.google.common.eventbus.Subscribe;
42 import com.google.common.util.concurrent.FutureCallback;
43 import com.google.common.util.concurrent.Futures;
44 import com.google.common.util.concurrent.ListenableFuture;
46 public class VppRendererPolicyManager {
48 private static final Logger LOG = LoggerFactory.getLogger(VppRendererPolicyManager.class);
49 private final InterfaceManager ifaceManager;
50 private final DataBroker dataProvider;
52 public VppRendererPolicyManager(@Nonnull InterfaceManager ifaceManager, @Nonnull DataBroker dataProvider) {
53 this.ifaceManager = Preconditions.checkNotNull(ifaceManager);
54 this.dataProvider = Preconditions.checkNotNull(dataProvider);
58 public void rendererPolicyChanged(RendererPolicyConfEvent event) {
59 RendererPolicyBuilder responseBulder = new RendererPolicyBuilder();
60 switch (event.getDtoModificationType()) {
62 responseBulder.setVersion(event.getAfter().get().getVersion());
63 rendererPolicyCreated(event.getAfter().get());
66 RendererPolicy rPolicyBefore = event.getBefore().get();
67 RendererPolicy rPolicyAfter = event.getAfter().get();
68 responseBulder.setVersion(rPolicyAfter.getVersion());
69 if (!isConfigurationChanged(rPolicyBefore, rPolicyAfter)) {
70 LOG.debug("Configuration is not changed only updating config version from {} to {}",
71 rPolicyBefore.getVersion(), rPolicyAfter.getVersion());
73 // TODO collect unconfigured rules and put them to responseBuilder
74 rendererPolicyUpdated(rPolicyBefore, rPolicyAfter);
78 responseBulder.setVersion(event.getBefore().get().getVersion());
79 rendererPolicyDeleted(event.getBefore().get());
82 WriteTransaction wTx = dataProvider.newWriteOnlyTransaction();
83 RendererPolicy response = responseBulder.build();
84 wTx.put(LogicalDatastoreType.OPERATIONAL, IidFactory.rendererIid(VppRenderer.NAME).child(RendererPolicy.class),
86 Futures.addCallback(wTx.submit(), new FutureCallback<Void>() {
89 public void onSuccess(Void result) {
90 LOG.debug("Renderer updated renderer policy {}", response);
94 public void onFailure(Throwable t) {
95 LOG.warn("Renderer DIDN'T update renderer-policy {}", response);
100 private boolean isConfigurationChanged(RendererPolicy before, RendererPolicy after) {
101 if (before.getConfiguration() == null && after.getConfiguration() == null) {
107 private void rendererPolicyUpdated(RendererPolicy rPolicyBefore, RendererPolicy rPolicyAfter) {
108 PolicyContext policyCtxBefore = new PolicyContext(rPolicyBefore);
109 PolicyContext policyCtxAfter = new PolicyContext(rPolicyAfter);
110 ImmutableSet<RendererEndpointKey> rendEpsBefore = policyCtxBefore.getPolicyTable().rowKeySet();
111 ImmutableSet<RendererEndpointKey> rendEpsAfter = policyCtxAfter.getPolicyTable().rowKeySet();
113 SetView<RendererEndpointKey> removedRendEps = Sets.difference(rendEpsBefore, rendEpsAfter);
114 removedRendEps.forEach(rEpKey -> rendererEndpointDeleted(rEpKey, policyCtxBefore));
116 SetView<RendererEndpointKey> createdRendEps = Sets.difference(rendEpsAfter, rendEpsBefore);
117 createdRendEps.forEach(rEpKey -> rendererEndpointCreated(rEpKey, policyCtxAfter));
119 SetView<RendererEndpointKey> updatedRendEps = Sets.intersection(rendEpsBefore, rendEpsAfter);
120 // TODO think about all cases, but keep it simple for now
121 updatedRendEps.forEach(rEpKey -> rendererEndpointDeleted(rEpKey, policyCtxBefore));
122 updatedRendEps.forEach(rEpKey -> rendererEndpointCreated(rEpKey, policyCtxAfter));
125 private void rendererPolicyCreated(RendererPolicy rPolicy) {
126 PolicyContext policyCtx = new PolicyContext(rPolicy);
128 // TODO create topology for each L2FloodDomain in RendererForwarding
130 policyCtx.getPolicyTable().rowKeySet().forEach(rEpKey -> rendererEndpointCreated(rEpKey, policyCtx));
133 private void rendererEndpointCreated(RendererEndpointKey rEpKey, PolicyContext policyCtx) {
134 AddressEndpointWithLocation rEp = policyCtx.getAddrEpByKey().get(KeyFactory.addressEndpointKey(rEpKey));
135 ExternalLocationCase rEpLoc = resolveAndValidateLocation(rEp);
136 if (Strings.isNullOrEmpty(rEpLoc.getExternalNodeConnector())) {
137 // TODO add it to the status for renderer manager
138 LOG.info("Rednerer endpoint does not have external-node-connector therefore it is ignored {}", rEp);
142 // TODO add rEpLoc.getExternalNodeMountPoint() to VBD as node
144 if (Strings.isNullOrEmpty(rEpLoc.getExternalNode())) {
145 String l2FloodDomain = resolveL2FloodDomain(rEp.getNetworkContainment());
146 if (Strings.isNullOrEmpty(l2FloodDomain)) {
147 // TODO add it to the status for renderer manager
148 LOG.info("Rednerer endpoint does not have l2FloodDomain as network containment {}", rEp);
151 ListenableFuture<Void> futureAddBridgeDomainToInterface =
152 ifaceManager.addBridgeDomainToInterface(l2FloodDomain, rEp);
153 Futures.addCallback(futureAddBridgeDomainToInterface, new FutureCallback<Void>() {
156 public void onSuccess(Void result) {
157 LOG.debug("Interface added to bridge-domain {} for endpoint {}", l2FloodDomain, rEp);
161 public void onFailure(Throwable t) {
162 // TODO add it to the status for renderer manager
163 LOG.warn("Interface was not added to bridge-domain {} for endpoint {}", l2FloodDomain, rEp, t);
169 private void rendererPolicyDeleted(RendererPolicy rendererPolicy) {
170 PolicyContext policyCtx = new PolicyContext(rendererPolicy);
172 // TODO delete topology for each L2FloodDomain in RendererForwarding
174 policyCtx.getPolicyTable().rowKeySet().forEach(rEpKey -> rendererEndpointDeleted(rEpKey, policyCtx));
177 private void rendererEndpointDeleted(RendererEndpointKey rEpKey, PolicyContext policyCtx) {
178 AddressEndpointWithLocation rEp = policyCtx.getAddrEpByKey().get(KeyFactory.addressEndpointKey(rEpKey));
179 ExternalLocationCase rEpLoc = resolveAndValidateLocation(rEp);
180 if (Strings.isNullOrEmpty(rEpLoc.getExternalNodeConnector())) {
181 // nothing was created for endpoint therefore nothing is removed
185 // TODO remove rEpLoc.getExternalNodeMountPoint() to VBD as node
187 if (!Strings.isNullOrEmpty(rEpLoc.getExternalNode())) {
188 ListenableFuture<Void> futureAddBridgeDomainToInterface = ifaceManager.deleteBridgeDomainFromInterface(rEp);
189 Futures.addCallback(futureAddBridgeDomainToInterface, new FutureCallback<Void>() {
192 public void onSuccess(Void result) {
193 LOG.debug("bridge-domain was deleted from interface for endpoint {}", rEp);
197 public void onFailure(Throwable t) {
198 // TODO add it to the status for renderer manager
199 LOG.warn("bridge-domain was not deleted from interface for endpoint {}", rEp, t);
205 private static String resolveL2FloodDomain(NetworkContainment netCont) {
206 if (netCont == null) {
209 Containment containment = netCont.getContainment();
210 if (containment instanceof ForwardingContextContainment) {
211 ForwardingContextContainment fwCtxCont = (ForwardingContextContainment) containment;
212 if (fwCtxCont.getContextType().isAssignableFrom(L2FloodDomain.class)) {
213 return fwCtxCont.getContextId() == null ? null : fwCtxCont.getContextId().getValue();
216 if (containment instanceof NetworkDomainContainment) {
217 // TODO address missing impl
218 LOG.info("Network domain containment in endpoint is not supported yet. {}", netCont);
224 private static ExternalLocationCase resolveAndValidateLocation(AddressEndpointWithLocation addrEpWithLoc) {
225 LocationType locationType = addrEpWithLoc.getAbsoluteLocation().getLocationType();
226 if (!(locationType instanceof ExternalLocationCase)) {
227 throw new IllegalStateException("Endpoint does not have external location " + addrEpWithLoc);
229 ExternalLocationCase result = (ExternalLocationCase) locationType;
230 if (result.getExternalNodeMountPoint() == null) {
231 throw new IllegalStateException("Endpoint does not have external-node-mount-point " + addrEpWithLoc);
237 public void vppNodeChanged(NodeOperEvent event) {
238 switch (event.getDtoModificationType()) {
240 if (event.isAfterConnected()) {
245 if (!event.isBeforeConnected() && event.isAfterConnected()) {
250 if (event.isBeforeConnected()) {