2 * Copyright (c) 2014 Intel Corp. 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.ovsdb.southbound.transactions.md;
11 import java.util.ArrayList;
12 import java.util.Collection;
13 import java.util.Iterator;
14 import java.util.List;
16 import java.util.Map.Entry;
19 import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
20 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
21 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
22 import org.opendaylight.ovsdb.lib.error.ColumnSchemaNotFoundException;
23 import org.opendaylight.ovsdb.lib.message.TableUpdates;
24 import org.opendaylight.ovsdb.lib.notation.Column;
25 import org.opendaylight.ovsdb.lib.notation.UUID;
26 import org.opendaylight.ovsdb.lib.schema.DatabaseSchema;
27 import org.opendaylight.ovsdb.lib.schema.GenericTableSchema;
28 import org.opendaylight.ovsdb.lib.schema.typed.TyperUtils;
29 import org.opendaylight.ovsdb.schema.openvswitch.Bridge;
30 import org.opendaylight.ovsdb.schema.openvswitch.Interface;
31 import org.opendaylight.ovsdb.schema.openvswitch.Port;
32 import org.opendaylight.ovsdb.southbound.SouthboundConstants;
33 import org.opendaylight.ovsdb.southbound.SouthboundMapper;
34 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanId;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentation;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeName;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentation;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbPortInterfaceAttributes;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbTerminationPointAugmentation;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbTerminationPointAugmentationBuilder;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.node.attributes.ConnectionInfo;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.node.attributes.ManagedNodeEntry;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.InterfaceExternalIds;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.InterfaceExternalIdsBuilder;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.InterfaceOtherConfigs;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.InterfaceOtherConfigsBuilder;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.Options;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.OptionsBuilder;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.OptionsKey;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.PortExternalIds;
52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.PortExternalIdsBuilder;
53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.PortOtherConfigs;
54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.PortOtherConfigsBuilder;
55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.Trunks;
56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.TrunksBuilder;
57 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
58 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
59 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TpId;
60 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
61 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
62 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
63 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;
64 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint;
65 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPointBuilder;
66 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPointKey;
67 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
68 import org.slf4j.Logger;
69 import org.slf4j.LoggerFactory;
71 import com.google.common.base.Optional;
73 public class OvsdbPortUpdateCommand extends AbstractTransactionCommand {
74 private static final Logger LOG = LoggerFactory.getLogger(OvsdbPortUpdateCommand.class);
75 private Map<UUID, Port> portUpdatedRows;
76 private Map<UUID, Port> portOldRows;
77 private Map<UUID, Interface> interfaceUpdatedRows;
78 private Map<UUID, Interface> interfaceOldRows;
79 private Map<UUID, Bridge> bridgeUpdatedRows;
80 public OvsdbPortUpdateCommand(ConnectionInfo key, TableUpdates updates,
81 DatabaseSchema dbSchema) {
82 super(key, updates, dbSchema);
83 portUpdatedRows = TyperUtils.extractRowsUpdated(Port.class, updates, dbSchema);
84 portOldRows = TyperUtils.extractRowsOld(Port.class, updates, dbSchema);
85 interfaceUpdatedRows = TyperUtils.extractRowsUpdated(Interface.class, updates, dbSchema);
86 interfaceOldRows = TyperUtils.extractRowsOld(Interface.class, updates, dbSchema);
87 bridgeUpdatedRows = TyperUtils.extractRowsUpdated(Bridge.class, updates, dbSchema);
91 public void execute(ReadWriteTransaction transaction) {
92 final InstanceIdentifier<Node> connectionIId = SouthboundMapper.createInstanceIdentifier(getConnectionInfo());
93 if ( (portUpdatedRows == null && interfaceOldRows == null )
94 || ( interfaceOldRows.isEmpty() && portUpdatedRows.isEmpty())) {
97 Optional<Node> node = readNode(transaction, connectionIId);
98 if (node.isPresent()) {
99 updateTerminationPoints(transaction, node.get());
102 private void updateTerminationPoints(ReadWriteTransaction transaction, Node node) {
103 for (Entry<UUID, Port> portUpdate : portUpdatedRows.entrySet()) {
104 String portName = null;
105 portName = portUpdate.getValue().getNameColumn().getData();
106 Optional<String> bridgeName = getTerminationPointBridge(portUpdate.getKey());
107 if (!bridgeName.isPresent()) {
108 bridgeName = getTerminationPointBridge( transaction, node, portName);
110 if (bridgeName.isPresent()) {
111 NodeId bridgeId = SouthboundMapper.createManagedNodeId(
112 getConnectionInfo(), new OvsdbBridgeName(bridgeName.get()));
113 TerminationPointKey tpKey = new TerminationPointKey(new TpId(portName));
114 InstanceIdentifier<TerminationPoint> tpPath = InstanceIdentifier
115 .create(NetworkTopology.class)
116 .child(Topology.class, new TopologyKey(SouthboundConstants.OVSDB_TOPOLOGY_ID))
117 .child(Node.class,new NodeKey(bridgeId))
118 .child(TerminationPoint.class,tpKey);
119 TerminationPointBuilder tpBuilder = new TerminationPointBuilder();
120 tpBuilder.setKey(tpKey);
121 tpBuilder.setTpId(tpKey.getTpId());
122 OvsdbTerminationPointAugmentationBuilder tpAugmentationBuilder =
123 new OvsdbTerminationPointAugmentationBuilder();
124 buildTerminationPoint(tpAugmentationBuilder,portUpdate.getValue(),bridgeName.get());
125 UUID interfaceUUID = (UUID)portUpdate.getValue().getInterfacesColumn().getData().toArray()[0];
126 if (interfaceUpdatedRows.containsKey(interfaceUUID)) {
127 buildTerminationPoint(tpAugmentationBuilder,
128 interfaceUpdatedRows.get(interfaceUUID), bridgeName.get());
129 interfaceUpdatedRows.remove(interfaceUUID);
130 interfaceOldRows.remove(interfaceUUID);
132 tpBuilder.addAugmentation(OvsdbTerminationPointAugmentation.class, tpAugmentationBuilder.build());
133 if (portOldRows.containsKey(portUpdate.getKey())) {
134 transaction.merge(LogicalDatastoreType.OPERATIONAL,
135 tpPath, tpBuilder.build());
137 transaction.put(LogicalDatastoreType.OPERATIONAL,
138 tpPath, tpBuilder.build());
142 for (Entry<UUID, Interface> interfaceUpdate : interfaceUpdatedRows.entrySet()) {
143 String interfaceName = null;
144 interfaceName = interfaceUpdatedRows.get(interfaceUpdate.getKey()).getNameColumn().getData();
145 Optional<String> bridgeName = getTerminationPointBridge( transaction, node, interfaceName);
146 if (bridgeName.isPresent()) {
147 NodeId bridgeId = SouthboundMapper.createManagedNodeId(
148 getConnectionInfo(), new OvsdbBridgeName(bridgeName.get()));
149 TerminationPointKey tpKey = new TerminationPointKey(new TpId(interfaceName));
150 InstanceIdentifier<TerminationPoint> tpPath = InstanceIdentifier
151 .create(NetworkTopology.class)
152 .child(Topology.class, new TopologyKey(SouthboundConstants.OVSDB_TOPOLOGY_ID))
153 .child(Node.class,new NodeKey(bridgeId))
154 .child(TerminationPoint.class,tpKey);
155 TerminationPointBuilder tpBuilder = new TerminationPointBuilder();
156 tpBuilder.setKey(tpKey);
157 tpBuilder.setTpId(tpKey.getTpId());
158 OvsdbTerminationPointAugmentationBuilder tpAugmentationBuilder =
159 new OvsdbTerminationPointAugmentationBuilder();
160 buildTerminationPoint(tpAugmentationBuilder, interfaceUpdate.getValue(),bridgeName.get());
161 tpBuilder.addAugmentation(OvsdbTerminationPointAugmentation.class, tpAugmentationBuilder.build());
162 transaction.merge(LogicalDatastoreType.OPERATIONAL,
163 tpPath, tpBuilder.build());
168 private void buildTerminationPoint(OvsdbTerminationPointAugmentationBuilder tpAugmentationBuilder,
169 Port portUpdate, String bridgeName) {
171 tpAugmentationBuilder
172 .setName(portUpdate.getName());
173 tpAugmentationBuilder.setPortUuid(new Uuid(
174 portUpdate.getUuid().toString()));
175 updatePort(portUpdate, tpAugmentationBuilder);
178 private void buildTerminationPoint(OvsdbTerminationPointAugmentationBuilder tpAugmentationBuilder,
179 Interface interfaceUpdate, String bridgeName) {
181 tpAugmentationBuilder
182 .setName(interfaceUpdate.getName());
183 tpAugmentationBuilder.setPortUuid(new Uuid(
184 interfaceUpdate.getUuid().toString()));
185 updateInterfaces(interfaceUpdate, bridgeName, tpAugmentationBuilder);
188 private Optional<Node> readNode(final ReadWriteTransaction transaction, final InstanceIdentifier<Node> nodePath) {
189 Optional<Node> node = Optional.absent();
191 node = transaction.read(
192 LogicalDatastoreType.OPERATIONAL, nodePath)
194 } catch (final ReadFailedException e) {
195 LOG.warn("Read Operational/DS for Node fail! {}",
201 private Optional<String> getTerminationPointBridge( UUID portUUID) {
202 for (UUID bridgeUUID : this.bridgeUpdatedRows.keySet()) {
203 if (this.bridgeUpdatedRows.get(bridgeUUID).getPortsColumn().getData().contains(portUUID)) {
204 return Optional.of(this.bridgeUpdatedRows.get(bridgeUUID).getNameColumn().getData());
207 return Optional.absent();
209 private Optional<String> getTerminationPointBridge(
210 final ReadWriteTransaction transaction, Node node, String tpName) {
211 OvsdbNodeAugmentation ovsdbNode = node.getAugmentation(OvsdbNodeAugmentation.class);
212 List<ManagedNodeEntry> managedNodes = ovsdbNode.getManagedNodeEntry();
213 for ( ManagedNodeEntry managedNodeEntry : managedNodes ) {
214 @SuppressWarnings("unchecked")
215 Node managedNode = readNode(transaction
216 ,(InstanceIdentifier<Node>)managedNodeEntry.getBridgeRef().getValue()).get();
217 TerminationPointBuilder tpBuilder = new TerminationPointBuilder();
218 TerminationPointKey tpKey = new TerminationPointKey(new TpId(tpName));
219 tpBuilder.setKey(tpKey);
220 if (managedNode.getTerminationPoint().contains(tpBuilder.build())) {
221 OvsdbBridgeAugmentation ovsdbNodeAugment
222 = managedNode.getAugmentation(OvsdbBridgeAugmentation.class);
223 return Optional.of(ovsdbNodeAugment.getBridgeName().getValue());
226 return Optional.absent();
229 private void updateInterfaces(Interface interfaceUpdate,
230 final String bridge, final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
232 Column<GenericTableSchema, String> typeColumn = interfaceUpdate.getTypeColumn();
233 String type = typeColumn.getData();
234 updateInterface(interfaceUpdate, bridge, type, ovsdbTerminationPointBuilder);
237 private void updatePort(final Port port,
238 final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
240 updateVlan(port, ovsdbTerminationPointBuilder);
241 updateVlanTrunks(port, ovsdbTerminationPointBuilder);
242 updateVlanMode(port, ovsdbTerminationPointBuilder);
243 updatePortExternalIds(port, ovsdbTerminationPointBuilder);
244 updatePortOtherConfig(port, ovsdbTerminationPointBuilder);
247 private void updateInterface(final Interface interf,
248 final String bridge, final String type,
249 final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
251 ovsdbTerminationPointBuilder.setInterfaceUuid(
252 new Uuid(interf.getUuid().toString()));
253 ovsdbTerminationPointBuilder.setInterfaceType(
254 SouthboundMapper.createInterfaceType(type));
255 updateOfPort(interf, bridge, ovsdbTerminationPointBuilder);
256 updateOfPortRequest(interf, bridge, ovsdbTerminationPointBuilder);
257 updateInterfaceExternalIds(interf, ovsdbTerminationPointBuilder);
258 updateOptions(interf, ovsdbTerminationPointBuilder);
259 updateInterfaceOtherConfig(interf, ovsdbTerminationPointBuilder);
262 private void updateVlan(final Port port,
263 final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
265 Collection<Long> vlanId = port.getTagColumn().getData();
266 if (vlanId.size() > 0) {
267 Iterator<Long> itr = vlanId.iterator();
268 // There are no loops here, just get the first element.
269 int id = itr.next().intValue();
270 ovsdbTerminationPointBuilder.setVlanTag(new VlanId(id));
274 private void updateVlanTrunks(final Port port,
275 final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
277 Set<Long> portTrunks = port.getTrunksColumn().getData();
278 List<Trunks> modelTrunks = new ArrayList<Trunks>();
279 if (!portTrunks.isEmpty()) {
280 for (Long trunk: portTrunks) {
282 modelTrunks.add(new TrunksBuilder()
283 .setTrunk(new VlanId(trunk.intValue())).build());
286 ovsdbTerminationPointBuilder.setTrunks(modelTrunks);
290 private void updateVlanMode(final Port port,
291 final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
293 Collection<String> vlanMode = port.getVlanModeColumn().getData();
294 if (!vlanMode.isEmpty()) {
295 Iterator<String> itr = vlanMode.iterator();
296 String vlanType = itr.next();
297 if (vlanType.equals(SouthboundConstants.VLANMODES.ACCESS.getMode())) {
298 ovsdbTerminationPointBuilder
299 .setVlanMode(OvsdbPortInterfaceAttributes.VlanMode.Access);
300 } else if (vlanType.equals(SouthboundConstants.VLANMODES.NATIVE_TAGGED.getMode())) {
301 ovsdbTerminationPointBuilder
302 .setVlanMode(OvsdbPortInterfaceAttributes.VlanMode.NativeTagged);
303 } else if (vlanType.equals(SouthboundConstants.VLANMODES.NATIVE_UNTAGGED.getMode())) {
304 ovsdbTerminationPointBuilder
305 .setVlanMode(OvsdbPortInterfaceAttributes.VlanMode.NativeUntagged);
306 } else if (vlanType.equals(SouthboundConstants.VLANMODES.TRUNK.getMode())) {
307 ovsdbTerminationPointBuilder
308 .setVlanMode(OvsdbPortInterfaceAttributes.VlanMode.Trunk);
310 LOG.debug("Invalid vlan mode {}.", vlanType);
315 private void updateOfPort(final Interface interf,
317 final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
319 Set<Long> ofPorts = interf.getOpenFlowPortColumn().getData();
320 if (ofPorts != null && !ofPorts.isEmpty()) {
321 Iterator<Long> ofPortsIter = ofPorts.iterator();
322 long ofPort = ofPortsIter.next();
324 ovsdbTerminationPointBuilder
327 LOG.debug("Received negative value for ofPort from ovsdb for {} {} {}",
328 bridge, interf.getName(),ofPort);
333 private void updateOfPortRequest(final Interface interf,
335 final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
337 Set<Long> ofPortRequests = null;
339 ofPortRequests = interf.getOpenFlowPortRequestColumn().getData();
340 } catch (ColumnSchemaNotFoundException e) {
341 LOG.warn("Cannot find openflow column", e);
343 if (ofPortRequests != null && !ofPortRequests.isEmpty()) {
344 Iterator<Long> ofPortRequestsIter = ofPortRequests.iterator();
345 int ofPort = ofPortRequestsIter.next().intValue();
347 ovsdbTerminationPointBuilder
348 .setOfportRequest(ofPort);
350 LOG.debug("Received negative value for ofPort from ovsdb for {} {} {}",
351 bridge, interf.getName(),ofPort);
356 private void updateInterfaceExternalIds(final Interface interf,
357 final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
359 Map<String, String> interfaceExternalIds =
360 interf.getExternalIdsColumn().getData();
361 if (interfaceExternalIds != null && !interfaceExternalIds.isEmpty()) {
362 Set<String> externalIdKeys = interfaceExternalIds.keySet();
363 List<InterfaceExternalIds> externalIdsList =
364 new ArrayList<InterfaceExternalIds>();
365 String externalIdValue;
366 for (String externalIdKey : externalIdKeys) {
367 externalIdValue = interfaceExternalIds.get(externalIdKey);
368 if (externalIdKey != null && externalIdValue != null) {
369 externalIdsList.add(new InterfaceExternalIdsBuilder()
370 .setExternalIdKey(externalIdKey)
371 .setExternalIdValue(externalIdValue).build());
374 ovsdbTerminationPointBuilder.setInterfaceExternalIds(externalIdsList);
378 private void updatePortExternalIds(final Port port,
379 final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
381 Map<String, String> portExternalIds = port.getExternalIdsColumn().getData();
382 if (portExternalIds != null && !portExternalIds.isEmpty()) {
383 Set<String> externalIdKeys = portExternalIds.keySet();
384 List<PortExternalIds> externalIdsList = new ArrayList<PortExternalIds>();
385 String externalIdValue;
386 for (String externalIdKey : externalIdKeys) {
387 externalIdValue = portExternalIds.get(externalIdKey);
388 if (externalIdKey != null && externalIdValue != null) {
389 externalIdsList.add(new PortExternalIdsBuilder()
390 .setExternalIdKey(externalIdKey)
391 .setExternalIdValue(externalIdValue).build());
394 ovsdbTerminationPointBuilder.setPortExternalIds(externalIdsList);
398 private void updateOptions(final Interface interf,
399 final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
401 Map<String, String> optionsMap = interf.getOptionsColumn().getData();
402 if (optionsMap != null && !optionsMap.isEmpty()) {
403 List<Options> options = new ArrayList<Options>();
404 String optionsValueString;
405 OptionsKey optionsKey;
406 for (String optionsKeyString : optionsMap.keySet()) {
407 optionsValueString = optionsMap.get(optionsKeyString);
408 if (optionsKeyString != null && optionsValueString != null) {
409 optionsKey = new OptionsKey(optionsKeyString);
410 options.add(new OptionsBuilder()
412 .setValue(optionsValueString).build());
415 ovsdbTerminationPointBuilder.setOptions(options);
419 private void updatePortOtherConfig(final Port port,
420 final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
422 Map<String, String> portOtherConfigMap = port.getOtherConfigColumn().getData();
423 if (portOtherConfigMap != null && !portOtherConfigMap.isEmpty()) {
424 List<PortOtherConfigs> portOtherConfigs = new ArrayList<PortOtherConfigs>();
425 String portOtherConfigValueString;
426 for (String portOtherConfigKeyString : portOtherConfigMap.keySet()) {
427 portOtherConfigValueString = portOtherConfigMap.get(portOtherConfigKeyString);
428 if (portOtherConfigKeyString != null && portOtherConfigValueString != null) {
429 portOtherConfigs.add(new PortOtherConfigsBuilder()
430 .setOtherConfigKey(portOtherConfigKeyString)
431 .setOtherConfigValue(portOtherConfigValueString).build());
434 ovsdbTerminationPointBuilder.setPortOtherConfigs(portOtherConfigs);
438 private void updateInterfaceOtherConfig(final Interface interf,
439 final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
441 Map<String, String> interfaceOtherConfigMap = interf.getOtherConfigColumn().getData();
442 if (interfaceOtherConfigMap != null && !interfaceOtherConfigMap.isEmpty()) {
443 List<InterfaceOtherConfigs> interfaceOtherConfigs = new ArrayList<InterfaceOtherConfigs>();
444 String interfaceOtherConfigValueString;
445 for (String interfaceOtherConfigKeyString : interfaceOtherConfigMap.keySet()) {
446 interfaceOtherConfigValueString = interfaceOtherConfigMap.get(interfaceOtherConfigKeyString);
447 if (interfaceOtherConfigKeyString != null && interfaceOtherConfigValueString != null) {
448 interfaceOtherConfigs.add(new InterfaceOtherConfigsBuilder()
449 .setOtherConfigKey(interfaceOtherConfigKeyString)
450 .setOtherConfigValue(interfaceOtherConfigValueString).build());
453 ovsdbTerminationPointBuilder.setInterfaceOtherConfigs(interfaceOtherConfigs);