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.Test;
18 import org.mockito.Mockito;
19 import org.opendaylight.genius.utils.hwvtep.HwvtepNodeHACache;
20 import org.opendaylight.mdsal.binding.api.ReadTransaction;
21 import org.opendaylight.mdsal.binding.dom.adapter.test.AbstractConcurrentDataBrokerTest;
22 import org.opendaylight.mdsal.binding.util.ManagedNewTransactionRunner;
23 import org.opendaylight.mdsal.binding.util.ManagedNewTransactionRunnerImpl;
24 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
25 import org.opendaylight.netvirt.elan.l2gw.ha.handlers.NodeConnectedHandler;
26 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Uri;
27 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
28 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
29 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
30 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
31 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
32 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
33 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;
34 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
35 import org.slf4j.Logger;
36 import org.slf4j.LoggerFactory;
39 * Created by eaksahu on 10/14/2016.
41 public class NodeConnectedHandlerTest extends AbstractConcurrentDataBrokerTest {
43 // Uncomment this to keep running this test indefinitely
44 // This is very useful to detect concurrency issues, respectively prove
45 // that the use of AbstractConcurrentDataBrokerTest instead of AbstractDataBrokerTest
46 // does NOT cause any concurrency issues and make this test flaky...
47 // public static @ClassRule RunUntilFailureClassRule classRepeater = new RunUntilFailureClassRule();
48 // public @Rule RunUntilFailureRule repeater = new RunUntilFailureRule(classRepeater);
50 static Logger LOG = LoggerFactory.getLogger(NodeConnectedHandlerTest.class);
52 NodeConnectedHandler nodeConnectedHandler;
53 NodeConnectedHandlerUtils handlerUtils = new NodeConnectedHandlerUtils();
58 Optional<Node> d1GlobalOpNode;
59 Optional<Node> d2GlobalOpNode;
60 Optional<Node> haGlobalOpNode;
62 Optional<Node> d1PsOpNode;
63 Optional<Node> d2PsOpNode;
64 Optional<Node> haPsOpNode;
66 Optional<Node> d1GlobalConfigNode;
67 Optional<Node> d2GlobalConfigNode;
68 Optional<Node> haGlobalConfigNode;
70 Optional<Node> d1PsConfigNode;
71 Optional<Node> d2PsConfigNode;
72 Optional<Node> haPsConfigNode;
74 static String managerHAId = "s3-clusterid";
75 static String switchName = "s3";
77 InstanceIdentifier<Node> d1NodePath;
78 InstanceIdentifier<Node> d2NodePath;
79 InstanceIdentifier<Node> haNodePath;
81 InstanceIdentifier<Node> d1PsNodePath;
82 InstanceIdentifier<Node> d2PsNodePath;
83 InstanceIdentifier<Node> haPsNodePath;
88 public void setupForHANode() {
89 d1UUID = java.util.UUID.nameUUIDFromBytes("d1uuid".getBytes()).toString();
90 d2UUID = java.util.UUID.nameUUIDFromBytes("d2uuid".getBytes()).toString();
91 d1NodePath = getInstanceIdentifier(d1UUID);
92 d2NodePath = getInstanceIdentifier(d2UUID);
93 haNodePath = getInstanceIdentifier(managerHAId);
95 haNodeId = getNodeId(managerHAId);
97 NodeId d1NodeId = d1NodePath.firstKeyOf(Node.class).getNodeId();
98 String d1PsNodeIdVal = d1NodeId.getValue() + "/physicalswitch/" + switchName;
99 d1PsNodePath = createInstanceIdentifier(d1PsNodeIdVal);
101 NodeId d2NodeId = d2NodePath.firstKeyOf(Node.class).getNodeId();
102 String d2PsNodeIdVal = d2NodeId.getValue() + "/physicalswitch/" + switchName;
103 d2PsNodePath = createInstanceIdentifier(d2PsNodeIdVal);
105 haPsNodePath = createInstanceIdentifier(haNodeId.getValue() + "/physicalswitch/" + switchName);
107 nodeConnectedHandler = new NodeConnectedHandler(getDataBroker(), Mockito.mock(HwvtepNodeHACache.class));
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);