2 * Copyright (c) 2016, 2017 Ericsson India Global Services Pvt Ltd. 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
8 package org.opendaylight.netvirt.elan.l2gw.ha.commands;
10 import java.io.Serializable;
11 import java.util.Comparator;
12 import java.util.List;
13 import java.util.stream.Collectors;
14 import org.opendaylight.netvirt.elan.l2gw.ha.HwvtepHAUtil;
15 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.HwvtepPhysicalPortAugmentation;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.HwvtepPhysicalPortAugmentationBuilder;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.physical.port.attributes.VlanBindings;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.physical.port.attributes.VlanBindingsBuilder;
19 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
20 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeBuilder;
21 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint;
22 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPointBuilder;
23 import org.opendaylight.yangtools.yang.binding.Identifier;
24 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
26 public class TerminationPointCmd extends MergeCommand<TerminationPoint, NodeBuilder, Node> {
28 public TerminationPointCmd() {
32 public List<TerminationPoint> getData(Node node) {
34 return node.getTerminationPoint();
40 public void setData(NodeBuilder builder, List<TerminationPoint> data) {
41 builder.setTerminationPoint(data);
45 public InstanceIdentifier<TerminationPoint> generateId(InstanceIdentifier<Node> id, TerminationPoint node) {
46 return id.child(TerminationPoint.class, node.getKey());
50 public TerminationPoint transform(InstanceIdentifier<Node> nodePath, TerminationPoint src) {
51 HwvtepPhysicalPortAugmentation augmentation = src.getAugmentation(HwvtepPhysicalPortAugmentation.class);
52 if (augmentation == null) {
53 return new TerminationPointBuilder(src).build();
55 String nodeIdVal = nodePath.firstKeyOf(Node.class).getNodeId().getValue();
56 int idx = nodeIdVal.indexOf("/physicalswitch");
58 nodeIdVal = nodeIdVal.substring(0, idx);
59 nodePath = HwvtepHAUtil.convertToInstanceIdentifier(nodeIdVal);
61 final InstanceIdentifier<Node> path = nodePath;
62 TerminationPointBuilder tpBuilder = new TerminationPointBuilder(src);
63 tpBuilder.removeAugmentation(HwvtepPhysicalPortAugmentation.class);
64 HwvtepPhysicalPortAugmentationBuilder tpAugmentationBuilder =
65 new HwvtepPhysicalPortAugmentationBuilder(augmentation);
67 if (augmentation.getVlanBindings() != null && augmentation.getVlanBindings().size() > 0) {
68 tpAugmentationBuilder.setVlanBindings(augmentation.getVlanBindings().stream().map(
70 VlanBindingsBuilder vlanBindingsBuilder = new VlanBindingsBuilder(vlanBindings);
71 vlanBindingsBuilder.setLogicalSwitchRef(
72 HwvtepHAUtil.convertLogicalSwitchRef(vlanBindings.getLogicalSwitchRef(), path));
73 return vlanBindingsBuilder.build();
74 }).collect(Collectors.toList()));
77 tpBuilder.addAugmentation(HwvtepPhysicalPortAugmentation.class, tpAugmentationBuilder.build());
78 return tpBuilder.build();
82 public Identifier getKey(TerminationPoint data) {
87 public String getDescription() {
88 return "vlanbindings";
92 public TerminationPoint withoutUuid(TerminationPoint data) {
97 public boolean areEqual(TerminationPoint updated, TerminationPoint orig) {
98 if (!updated.getKey().equals(orig.getKey())) {
101 HwvtepPhysicalPortAugmentation updatedAugmentation = updated
102 .getAugmentation(HwvtepPhysicalPortAugmentation.class);
103 HwvtepPhysicalPortAugmentation origAugmentation = orig.getAugmentation(HwvtepPhysicalPortAugmentation.class);
105 List<VlanBindings> up = updatedAugmentation != null ? updatedAugmentation.getVlanBindings() : null;
106 List<VlanBindings> or = origAugmentation != null ? origAugmentation.getVlanBindings() : null;
107 if (!areSameSize(up, or)) {
110 List<VlanBindings> added = diffOf(up, or, bindingsComparator);
111 if (added.size() != 0) {
114 List<VlanBindings> removed = diffOf(or, up, bindingsComparator);
115 if (removed.size() != 0) {
121 static BindingsComparator bindingsComparator = new BindingsComparator();
123 static class BindingsComparator implements Comparator<VlanBindings>, Serializable {
124 private static final long serialVersionUID = 1L;
127 public int compare(VlanBindings updated, VlanBindings orig) {
128 if (updated == null && orig == null) {
131 if (updated == null) {
137 if (updated.getKey().equals(orig.getKey())) {
146 public void transformUpdate(List<TerminationPoint> existing,
147 List<TerminationPoint> updated,
148 List<TerminationPoint> orig,
149 InstanceIdentifier<Node> nodePath,
150 LogicalDatastoreType datastoreType,
151 ReadWriteTransaction tx) {
153 if (updated == null) {
154 updated = new ArrayList<>();
157 orig = new ArrayList<>();
159 List<TerminationPoint> added = new ArrayList<>(updated);
161 added = diffOf(added, orig);
162 added = diffOf(added, existing);//do not add the existing data again
163 if (added != null && added.size() > 0) {
164 for (TerminationPoint addedItem : added) {
165 InstanceIdentifier<TerminationPoint> transformedId = generateId(nodePath, addedItem);
166 TerminationPoint transformedItem = transform(nodePath, addedItem);
167 LOG.trace("adding vlanbindings id {} ", transformedId
168 .firstKeyOf(TerminationPoint.class).getTpId().getValue());
169 tx.put(datastoreType, transformedId, transformedItem, true);
172 for (TerminationPoint origItem : orig) {
173 boolean found = false;
174 for (TerminationPoint newItem : updated) {
175 if (newItem.getKey().equals(origItem.getKey())) {
180 boolean existsInConfig = false;
181 for (TerminationPoint existingItem : existing) {
182 if (existingItem.getKey().equals(origItem.getKey())) {
183 existsInConfig = true;
186 if (existsInConfig) {
187 InstanceIdentifier<TerminationPoint> transformedId = generateId(nodePath, origItem);
188 LOG.trace("deleting vlanbindings id {} ", transformedId.firstKeyOf(TerminationPoint.class)
189 .getTpId().getValue());
190 tx.delete(datastoreType, transformedId);