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.ios_xe_provider.impl.manager;
11 import com.google.common.base.Preconditions;
12 import com.google.common.util.concurrent.Futures;
13 import com.google.common.util.concurrent.ListenableFuture;
14 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
15 import org.opendaylight.groupbasedpolicy.renderer.ios_xe_provider.api.manager.PolicyManager;
16 import org.opendaylight.groupbasedpolicy.renderer.ios_xe_provider.impl.util.PolicyManagerUtil;
17 import org.opendaylight.groupbasedpolicy.renderer.ios_xe_provider.impl.writer.PolicyWriter;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.Configuration;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.endpoints.AddressEndpointWithLocation;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.RendererEndpoint;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.renderer.endpoint.PeerEndpointWithPolicy;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.sxp.database.rev160308.Sgt;
23 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
24 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
25 import org.slf4j.Logger;
26 import org.slf4j.LoggerFactory;
28 import java.util.HashMap;
29 import java.util.List;
32 import static org.opendaylight.groupbasedpolicy.renderer.ios_xe_provider.impl.manager.PolicyManagerImpl.DsAction.Create;
33 import static org.opendaylight.groupbasedpolicy.renderer.ios_xe_provider.impl.manager.PolicyManagerImpl.DsAction.Delete;
35 public class PolicyManagerImpl implements PolicyManager {
37 private static final Logger LOG = LoggerFactory.getLogger(PolicyManagerImpl.class);
38 private static final String policyMapName = "service-chains";
39 private final DataBroker dataBroker;
40 private final NodeManager nodeManager;
42 public PolicyManagerImpl(final DataBroker dataBroker,
43 final NodeManager nodeManager) {
44 this.dataBroker = Preconditions.checkNotNull(dataBroker);
45 this.nodeManager = Preconditions.checkNotNull(nodeManager);
49 public ListenableFuture<Boolean> syncPolicy(final Configuration dataAfter, final Configuration dataBefore) {
50 if (dataBefore == null && dataAfter != null) {
51 return createPolicy(dataAfter);
53 if (dataBefore != null && dataAfter != null) {
54 return updatePolicy(dataAfter, dataBefore);
56 if (dataBefore != null) {
57 return deletePolicy(dataBefore);
59 return Futures.immediateFuture(false);
62 private ListenableFuture<Boolean> syncPolicy(final Configuration dataAfter, DsAction action) {
63 if (dataAfter.getRendererEndpoints() == null
64 || dataAfter.getRendererEndpoints().getRendererEndpoint() == null) {
65 LOG.debug("no configuration obtained - skipping");
66 return Futures.immediateFuture(true);
68 final Map<DataBroker, PolicyWriter> policyWriterPerDeviceCache = new HashMap<>();
69 for (RendererEndpoint rendererEndpoint : dataAfter.getRendererEndpoints().getRendererEndpoint()) {
70 if (dataAfter.getEndpoints() == null || dataAfter.getEndpoints().getAddressEndpointWithLocation() == null) {
71 LOG.debug("renderer-endpoint: missing address-endpoint-with-location");
74 final List<AddressEndpointWithLocation> endpointsWithLocation = dataAfter.getEndpoints()
75 .getAddressEndpointWithLocation();
76 final InstanceIdentifier mountpointIid = PolicyManagerUtil.getAbsoluteLocationMountpoint(rendererEndpoint, endpointsWithLocation);
77 final DataBroker mountpoint = nodeManager.getNodeMountPoint(mountpointIid);
78 if (mountpoint == null) {
79 LOG.debug("no data-broker for mount-point [{}] available", mountpointIid);
83 PolicyWriter policyWriter = policyWriterPerDeviceCache.get(mountpoint);
84 if (policyWriter == null) {
85 // Initialize new policy writer
86 final String interfaceName = PolicyManagerUtil.getInterfaceNameForPolicyMap(rendererEndpoint, endpointsWithLocation);
87 final NodeId nodeId = nodeManager.getNodeIdByMountpointIid(mountpointIid);
88 final String managementIpAddress = nodeManager.getNodeManagementIpByMountPointIid(mountpointIid);
89 if (interfaceName == null || managementIpAddress == null) {
90 LOG.debug("can not create policyWriter: interface={}, managementIpAddress={}",
91 interfaceName, managementIpAddress);
94 policyWriter = new PolicyWriter(mountpoint, interfaceName, managementIpAddress, policyMapName, nodeId);
95 policyWriterPerDeviceCache.put(mountpoint, policyWriter);
98 final Sgt sourceSgt = PolicyManagerUtil.findSgtTag(rendererEndpoint, dataAfter.getEndpoints()
99 .getAddressEndpointWithLocation());
101 for (PeerEndpointWithPolicy peerEndpoint : rendererEndpoint.getPeerEndpointWithPolicy()) {
102 final Sgt destinationSgt = PolicyManagerUtil.findSgtTag(peerEndpoint, dataAfter.getEndpoints()
103 .getAddressEndpointWithLocation());
104 if (sourceSgt == null || destinationSgt == null) {
105 LOG.debug("endpoint-policy: missing sgt value(sourceSgt={}, destinationSgt={})",
106 sourceSgt, destinationSgt);
109 PolicyManagerUtil.syncPolicyEntities(sourceSgt, destinationSgt, policyWriter, dataAfter, peerEndpoint);
112 if (action.equals(Create)) {
113 policyWriterPerDeviceCache.values().forEach(PolicyWriter::commitToDatastore);
114 return Futures.immediateFuture(true);
115 } else if (action.equals(Delete)) {
116 policyWriterPerDeviceCache.values().forEach(PolicyWriter::removeFromDatastore);
117 return Futures.immediateFuture(true);
119 return Futures.immediateFuture(false);
122 private ListenableFuture<Boolean> createPolicy(Configuration data) {
123 return syncPolicy(data, Create);
126 private ListenableFuture<Boolean> deletePolicy(Configuration data) {
127 return syncPolicy(data, Delete);
130 private ListenableFuture<Boolean> updatePolicy(Configuration dataAfter, Configuration dataBefore) {
136 public void close() {
140 enum DsAction {Create, Delete}
142 public enum ActionCase {ALLOW, CHAIN}