2 * Copyright (c) 2015 Inocybe Technologies. 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.ovsdb.transact;
10 import static org.junit.Assert.assertEquals;
11 import static org.junit.Assert.assertNotNull;
12 import static org.junit.Assert.assertTrue;
13 import static org.mockito.ArgumentMatchers.any;
14 import static org.mockito.Mockito.doReturn;
15 import static org.mockito.Mockito.mock;
16 import static org.mockito.Mockito.times;
17 import static org.mockito.Mockito.verify;
18 import static org.mockito.Mockito.when;
19 import static org.powermock.reflect.Whitebox.getField;
22 import java.util.Optional;
23 import org.junit.Before;
24 import org.junit.Test;
25 import org.junit.runner.RunWith;
26 import org.mockito.Mock;
27 import org.mockito.Mockito;
28 import org.mockito.junit.MockitoJUnitRunner;
29 import org.opendaylight.mdsal.binding.api.DataBroker;
30 import org.opendaylight.mdsal.binding.api.ReadTransaction;
31 import org.opendaylight.ovsdb.southbound.OvsdbOperGlobalListener;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentation;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbTerminationPointAugmentation;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ControllerEntry;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ProtocolEntry;
36 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
37 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
38 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
39 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TpId;
40 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
41 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
42 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
43 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeBuilder;
44 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;
45 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint;
46 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPointBuilder;
47 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
49 @RunWith(MockitoJUnitRunner.class)
50 public class BridgeOperationalStateTest {
51 private final Node nd = new NodeBuilder().setNodeId(new NodeId("foo")).build();
52 private final InstanceIdentifier<Node> nodeIid = InstanceIdentifier.create(NetworkTopology.class)
53 .child(Topology.class).child(Node.class);
54 private final Node brNode = new NodeBuilder().setNodeId(new NodeId("bar")).build();
56 @Mock private BridgeOperationalState briOperationState;
57 @Mock private DataBroker db;
58 @Mock ReadTransaction mockReadTx;
59 private InstanceIdentifier<ProtocolEntry> protocolEntry;
60 private InstanceIdentifier<Node> iidNode;
61 private Map<InstanceIdentifier<Node>, Node> operationalNodes;
64 public void setUp() throws Exception {
65 iidNode = InstanceIdentifier.create(NetworkTopology.class)
66 .child(Topology.class, new TopologyKey(new TopologyId("foo")))
67 .child(Node.class, new NodeKey(nd.getNodeId()));
68 protocolEntry = InstanceIdentifier.create(NetworkTopology.class).child(Topology.class).child(Node.class)
69 .augmentation(OvsdbBridgeAugmentation.class).child(ProtocolEntry.class);
71 briOperationState = mock(BridgeOperationalState.class, Mockito.CALLS_REAL_METHODS);
73 getField(BridgeOperationalState.class,"db").set(briOperationState, db);
74 doReturn(mockReadTx).when(db).newReadOnlyTransaction();
75 OvsdbOperGlobalListener.OPER_NODE_CACHE.put(nodeIid, brNode);
79 public void testGetBridgeNode() {
80 Optional<Node> optNodes = briOperationState.getBridgeNode(nodeIid);
81 assertEquals(brNode, optNodes.get());
85 public void testGetOvsdbBridgeAugmentation() throws Exception {
86 Optional<OvsdbBridgeAugmentation> optOvsdbBri = briOperationState.getOvsdbBridgeAugmentation(nodeIid);
87 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
88 assertNotNull(optOvsdbBri);
89 assertTrue(optOvsdbBri.equals(Optional.empty()));
91 Node node = mock(Node.class);
92 Optional<Node> optNode = Optional.of(node);
93 doReturn(optNode).when(briOperationState).getBridgeNode(any(InstanceIdentifier.class));
94 OvsdbBridgeAugmentation ovsdbBriAug = mock(OvsdbBridgeAugmentation.class);
95 doReturn(ovsdbBriAug).when(node).augmentation(OvsdbBridgeAugmentation.class);
96 Optional<OvsdbBridgeAugmentation> ovsdbBriAugOptional = briOperationState.getOvsdbBridgeAugmentation(
97 InstanceIdentifier.create(NetworkTopology.class));
98 assertNotNull(ovsdbBriAugOptional);
99 assertTrue(ovsdbBriAugOptional.get() instanceof OvsdbBridgeAugmentation);
103 public void testGetBridgeTerminationPoint() throws Exception {
104 Optional<TerminationPoint> optTerm = briOperationState.getBridgeTerminationPoint(nodeIid);
105 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
106 assertNotNull(optTerm);
107 assertTrue(optTerm.equals(Optional.empty()));
109 TerminationPoint termPnt = new TerminationPointBuilder().setTpId(new TpId("mockTp")).build();
111 Node node = mock(Node.class);
112 Optional<Node> optNode = Optional.of(node);
113 doReturn(optNode).when(briOperationState).getBridgeNode(any(InstanceIdentifier.class));
114 when(node.nonnullTerminationPoint()).thenCallRealMethod();
115 when(node.getTerminationPoint()).thenReturn(Map.of(termPnt.key(), termPnt));
117 Optional<TerminationPoint> optTermPnt = briOperationState.getBridgeTerminationPoint(
118 iidNode.child(TerminationPoint.class, termPnt.key()));
119 assertTrue(optTermPnt.isPresent());
123 public void testGetOvsdbTerminationPointAugmentation() {
124 Optional<OvsdbTerminationPointAugmentation> optOvsdbTermPoint = briOperationState
125 .getOvsdbTerminationPointAugmentation(nodeIid);
126 assertNotNull(optOvsdbTermPoint);
127 verify(briOperationState, times(1)).getBridgeTerminationPoint(any(InstanceIdentifier.class));
128 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
129 assertTrue(optOvsdbTermPoint.equals(Optional.empty()));
131 TerminationPoint termPoint = mock(TerminationPoint.class);
132 Optional<TerminationPoint> termPntOptional = Optional.of(termPoint);
133 doReturn(termPntOptional).when(briOperationState).getBridgeTerminationPoint(any(InstanceIdentifier.class));
134 OvsdbTerminationPointAugmentation ovsdbTermPntAug = mock(OvsdbTerminationPointAugmentation.class);
135 doReturn(ovsdbTermPntAug).when(termPoint).augmentation(OvsdbTerminationPointAugmentation.class);
136 Optional<OvsdbTerminationPointAugmentation> ovsdbTermPointOpt = briOperationState
137 .getOvsdbTerminationPointAugmentation(InstanceIdentifier.create(NetworkTopology.class));
138 assertNotNull(ovsdbTermPointOpt);
139 assertTrue(ovsdbTermPointOpt.get() instanceof OvsdbTerminationPointAugmentation);
143 public void testGetControllerEntry() {
144 Optional<ControllerEntry> optController = briOperationState.getControllerEntry(nodeIid);
145 verify(briOperationState, times(1)).getOvsdbBridgeAugmentation(any(InstanceIdentifier.class));
146 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
147 assertNotNull(optController);
148 assertTrue(optController.equals(Optional.empty()));
152 public void testGetProtocolEntry() throws Exception {
153 Optional<ProtocolEntry> optProtocolEntry = briOperationState.getProtocolEntry(protocolEntry);
154 verify(briOperationState, times(1)).getOvsdbBridgeAugmentation(any(InstanceIdentifier.class));
155 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
156 assertNotNull(optProtocolEntry);
157 assertTrue(optProtocolEntry.equals(Optional.empty()));