2 * Copyright (c) 2020 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
9 package org.opendaylight.ovsdb.southbound.transactions.md;
11 import java.util.ArrayList;
12 import java.util.HashMap;
13 import java.util.List;
16 import org.opendaylight.mdsal.binding.api.ReadWriteTransaction;
17 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
18 import org.opendaylight.ovsdb.lib.message.TableUpdates;
19 import org.opendaylight.ovsdb.lib.schema.DatabaseSchema;
20 import org.opendaylight.ovsdb.southbound.InstanceIdentifierCodec;
21 import org.opendaylight.ovsdb.southbound.OvsdbConnectionInstance;
22 import org.opendaylight.ovsdb.southbound.SouthboundMapper;
23 import org.opendaylight.ovsdb.utils.mdsal.utils.TransactionType;
24 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
25 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
26 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeBuilder;
27 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint;
28 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPointBuilder;
29 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
30 import org.slf4j.Logger;
31 import org.slf4j.LoggerFactory;
34 public class OvsdbInitialPortUpdateCommand extends OvsdbPortUpdateCommand {
35 private static final Logger LOG = LoggerFactory.getLogger(OvsdbInitialPortUpdateCommand.class);
36 private final Map<NodeId, Node> updatedBridgeNodes;
37 private final Map<NodeId, List<TerminationPoint>> brigeToTerminationPointList = new HashMap<>();
39 public OvsdbInitialPortUpdateCommand(InstanceIdentifierCodec instanceIdentifierCodec, OvsdbConnectionInstance key,
40 TableUpdates updates, DatabaseSchema dbSchema,
41 Map<NodeId, Node> updatedBridgeNodes) {
42 super(instanceIdentifierCodec, key, updates, dbSchema);
43 this.updatedBridgeNodes = updatedBridgeNodes;
47 public void execute(ReadWriteTransaction transaction) {
48 super.execute(transaction);
49 mergeToBridgeNode(transaction);
52 @SuppressWarnings("checkstyle:IllegalCatch")
53 protected void updateToDataStore(ReadWriteTransaction transaction, TerminationPointBuilder tpBuilder,
54 InstanceIdentifier<TerminationPoint> tpPath, boolean merge) {
56 NodeId bridgeNodeId = tpPath.firstKeyOf(Node.class).getNodeId();
57 TerminationPoint terminationPoint = tpBuilder.build();
58 if (updatedBridgeNodes.containsKey(bridgeNodeId)) {
59 if (brigeToTerminationPointList.containsKey(bridgeNodeId)) {
60 brigeToTerminationPointList.get(bridgeNodeId).add(terminationPoint);
62 List<TerminationPoint> terminationPointList = new ArrayList<>();
63 terminationPointList.add(terminationPoint);
64 brigeToTerminationPointList.put(bridgeNodeId, terminationPointList);
66 LOG.debug("DEVICE - {} Initial TerminationPoint : {} to Bridge : {}", TransactionType.ADD,
67 terminationPoint.key().getTpId().getValue(), bridgeNodeId.getValue());
70 catch (RuntimeException exp) {
71 LOG.error("Exception in adding the terminationPoint {} to bridge ", tpPath);
76 private void mergeToBridgeNode(ReadWriteTransaction transaction) {
78 brigeToTerminationPointList.forEach((nodeId, terminationPoints) -> {
79 InstanceIdentifier<Node> bridgeIid = SouthboundMapper.createInstanceIdentifier(nodeId);
80 StringBuilder terminationPointList = new StringBuilder();
81 Node bridgeNode = updatedBridgeNodes.get(nodeId);
82 if (bridgeNode != null) {
83 NodeBuilder bridgeNodeBuilder = new NodeBuilder(bridgeNode);
84 bridgeNodeBuilder.setTerminationPoint(terminationPoints);
85 Node bridgeNodeWithTerminationPoints = bridgeNodeBuilder.build();
86 transaction.merge(LogicalDatastoreType.OPERATIONAL, bridgeIid, bridgeNodeWithTerminationPoints);
88 terminationPoints.forEach(terminationPoint -> {
89 terminationPointList.append(terminationPoint.key().getTpId().getValue() + ",");
91 LOG.info("DEVICE - {} Initial TerminationPoint List : {} to Bridge : {}", TransactionType.ADD,
92 terminationPointList.toString(), bridgeIid.firstKeyOf(Node.class).getNodeId().getValue());