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