2 * Copyright (c) 2016 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.nodehandlertest;
10 import static org.opendaylight.mdsal.binding.util.Datastore.CONFIGURATION;
11 import static org.opendaylight.mdsal.binding.util.Datastore.OPERATIONAL;
13 import java.util.Optional;
14 import java.util.UUID;
15 import org.junit.Assert;
16 import org.junit.Before;
17 import org.junit.Ignore;
18 import org.junit.Test;
19 import org.opendaylight.mdsal.binding.api.ReadTransaction;
20 import org.opendaylight.mdsal.binding.dom.adapter.test.AbstractConcurrentDataBrokerTest;
21 import org.opendaylight.mdsal.binding.util.ManagedNewTransactionRunner;
22 import org.opendaylight.mdsal.binding.util.ManagedNewTransactionRunnerImpl;
23 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
24 import org.opendaylight.netvirt.elan.l2gw.ha.handlers.NodeConnectedHandler;
25 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Uri;
26 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
27 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
28 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
29 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
30 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
31 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
32 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;
33 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
34 import org.slf4j.Logger;
35 import org.slf4j.LoggerFactory;
38 * Created by eaksahu on 10/14/2016.
40 public class NodeConnectedHandlerTest extends AbstractConcurrentDataBrokerTest {
42 // Uncomment this to keep running this test indefinitely
43 // This is very useful to detect concurrency issues, respectively prove
44 // that the use of AbstractConcurrentDataBrokerTest instead of AbstractDataBrokerTest
45 // does NOT cause any concurrency issues and make this test flaky...
46 // public static @ClassRule RunUntilFailureClassRule classRepeater = new RunUntilFailureClassRule();
47 // public @Rule RunUntilFailureRule repeater = new RunUntilFailureRule(classRepeater);
49 static Logger LOG = LoggerFactory.getLogger(NodeConnectedHandlerTest.class);
51 NodeConnectedHandler nodeConnectedHandler;
52 NodeConnectedHandlerUtils handlerUtils = new NodeConnectedHandlerUtils();
57 Optional<Node> d1GlobalOpNode;
58 Optional<Node> d2GlobalOpNode;
59 Optional<Node> haGlobalOpNode;
61 Optional<Node> d1PsOpNode;
62 Optional<Node> d2PsOpNode;
63 Optional<Node> haPsOpNode;
65 Optional<Node> d1GlobalConfigNode;
66 Optional<Node> d2GlobalConfigNode;
67 Optional<Node> haGlobalConfigNode;
69 Optional<Node> d1PsConfigNode;
70 Optional<Node> d2PsConfigNode;
71 Optional<Node> haPsConfigNode;
73 static String managerHAId = "s3-clusterid";
74 static String switchName = "s3";
76 InstanceIdentifier<Node> d1NodePath;
77 InstanceIdentifier<Node> d2NodePath;
78 InstanceIdentifier<Node> haNodePath;
80 InstanceIdentifier<Node> d1PsNodePath;
81 InstanceIdentifier<Node> d2PsNodePath;
82 InstanceIdentifier<Node> haPsNodePath;
87 public void setupForHANode() {
88 d1UUID = java.util.UUID.nameUUIDFromBytes("d1uuid".getBytes()).toString();
89 d2UUID = java.util.UUID.nameUUIDFromBytes("d2uuid".getBytes()).toString();
90 d1NodePath = getInstanceIdentifier(d1UUID);
91 d2NodePath = getInstanceIdentifier(d2UUID);
92 haNodePath = getInstanceIdentifier(managerHAId);
94 haNodeId = getNodeId(managerHAId);
96 NodeId d1NodeId = d1NodePath.firstKeyOf(Node.class).getNodeId();
97 String d1PsNodeIdVal = d1NodeId.getValue() + "/physicalswitch/" + switchName;
98 d1PsNodePath = createInstanceIdentifier(d1PsNodeIdVal);
100 NodeId d2NodeId = d2NodePath.firstKeyOf(Node.class).getNodeId();
101 String d2PsNodeIdVal = d2NodeId.getValue() + "/physicalswitch/" + switchName;
102 d2PsNodePath = createInstanceIdentifier(d2PsNodeIdVal);
104 haPsNodePath = createInstanceIdentifier(haNodeId.getValue() + "/physicalswitch/" + switchName);
106 nodeConnectedHandler = new NodeConnectedHandler(getDataBroker());
110 @Ignore // need to fix this Test. Actual functionality is fine
111 public void testD1Connect() throws Exception {
112 ManagedNewTransactionRunner txRunner = new ManagedNewTransactionRunnerImpl(getDataBroker());
113 txRunner.callWithNewWriteOnlyTransactionAndSubmit(OPERATIONAL,
114 tx -> handlerUtils.addPsNode(d1PsNodePath, d1NodePath, DataProvider.getPortNameListD1(), tx)).get();
116 txRunner.callWithNewWriteOnlyTransactionAndSubmit(OPERATIONAL,
117 tx -> handlerUtils.addNode(d1NodePath, d1PsNodePath, DataProvider.getLogicalSwitchDataD1(),
118 DataProvider.getLocalUcasMacDataD1(), DataProvider.getLocalMcastDataD1(),
119 DataProvider.getRemoteMcastDataD1(), DataProvider.getRemoteUcasteMacDataD1(),
120 DataProvider.getGlobalTerminationPointIpD1(), tx)).get();
123 txRunner.callWithNewReadWriteTransactionAndSubmit(CONFIGURATION,
124 confTx -> txRunner.callWithNewReadWriteTransactionAndSubmit(OPERATIONAL,
125 operTx -> nodeConnectedHandler.handleNodeConnected(d1GlobalOpNode.get(), d1NodePath, haNodePath,
126 haGlobalConfigNode, haPsConfigNode, confTx, operTx)).get()).get();
128 //verify global ha manager config should have ha_children
129 Assert.assertTrue(haGlobalConfigNode.isPresent());
130 Assert.assertTrue(d1GlobalOpNode.isPresent());
131 TestUtil.verifyHAconfigNode(haGlobalConfigNode.get(), d1GlobalOpNode.get());
133 Assert.assertTrue(d1GlobalOpNode.isPresent());
134 Assert.assertTrue(haGlobalOpNode.isPresent());
135 Assert.assertTrue(d1PsOpNode.isPresent());
136 Assert.assertTrue(haPsOpNode.isPresent());
137 TestUtil.verifyHAOpNode(d1GlobalOpNode.get(), haGlobalOpNode.get(),
138 d1PsOpNode.get(), haPsOpNode.get(), haNodePath, d1PsNodePath, haPsNodePath, getDataBroker());
141 public static InstanceIdentifier<Node> createInstanceIdentifier(String nodeIdString) {
142 NodeId nodeId = new NodeId(new Uri(nodeIdString));
143 NodeKey nodeKey = new NodeKey(nodeId);
144 TopologyKey topoKey = new TopologyKey(new TopologyId(new Uri("hwvtep:1")));
145 return InstanceIdentifier.builder(NetworkTopology.class)
146 .child(Topology.class, topoKey)
147 .child(Node.class, nodeKey)
151 public static InstanceIdentifier<Node> getInstanceIdentifier(String haUUidVal) {
152 String nodeString = "hwvtep://uuid/" + UUID.nameUUIDFromBytes(haUUidVal.getBytes()).toString();
153 NodeId nodeId = new NodeId(new Uri(nodeString));
154 NodeKey nodeKey = new NodeKey(nodeId);
155 TopologyKey topoKey = new TopologyKey(new TopologyId(new Uri("hwvtep:1")));
156 return InstanceIdentifier.builder(NetworkTopology.class).child(Topology.class, topoKey)
157 .child(Node.class, nodeKey).build();
160 public static NodeId getNodeId(String haId) {
161 String nodeString = "hwvtep://uuid/" + UUID.nameUUIDFromBytes(haId.getBytes()).toString();
162 NodeId nodeId = new NodeId(new Uri(nodeString));
166 public void readNodes() throws Exception {
167 ReadTransaction tx = getDataBroker().newReadOnlyTransaction();
168 d1GlobalOpNode = TestUtil.readNode(LogicalDatastoreType.OPERATIONAL, d1NodePath, tx);
169 d2GlobalOpNode = TestUtil.readNode(LogicalDatastoreType.OPERATIONAL, d2NodePath, tx);
170 haGlobalOpNode = TestUtil.readNode(LogicalDatastoreType.OPERATIONAL, haNodePath, tx);
172 d1PsOpNode = TestUtil.readNode(LogicalDatastoreType.OPERATIONAL, d1PsNodePath, tx);
173 d2PsOpNode = TestUtil.readNode(LogicalDatastoreType.OPERATIONAL, d2PsNodePath, tx);
174 haPsOpNode = TestUtil.readNode(LogicalDatastoreType.OPERATIONAL, haPsNodePath, tx);
176 haGlobalConfigNode = TestUtil.readNode(LogicalDatastoreType.CONFIGURATION, haNodePath, tx);
177 d1GlobalConfigNode = TestUtil.readNode(LogicalDatastoreType.CONFIGURATION, d1NodePath, tx);
178 d2GlobalConfigNode = TestUtil.readNode(LogicalDatastoreType.CONFIGURATION, d2NodePath, tx);
180 haPsConfigNode = TestUtil.readNode(LogicalDatastoreType.CONFIGURATION, haPsNodePath, tx);
181 d1PsConfigNode = TestUtil.readNode(LogicalDatastoreType.CONFIGURATION, d1PsNodePath, tx);
182 d2PsConfigNode = TestUtil.readNode(LogicalDatastoreType.CONFIGURATION, d2PsNodePath, tx);