2 * Copyright (c) 2015 Cisco Systems, Inc. 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.groupbasedpolicy.neutron.ovsdb;
11 import static org.mockito.Matchers.any;
12 import static org.mockito.Mockito.doReturn;
13 import static org.mockito.Mockito.mock;
14 import static org.mockito.Mockito.never;
15 import static org.mockito.Mockito.verify;
16 import static org.mockito.Mockito.when;
18 import com.google.common.base.Optional;
19 import com.google.common.util.concurrent.CheckedFuture;
20 import java.util.Collection;
21 import java.util.Collections;
22 import java.util.UUID;
23 import org.junit.Before;
24 import org.junit.Test;
25 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
26 import org.opendaylight.controller.md.sal.binding.api.DataObjectModification;
27 import org.opendaylight.controller.md.sal.binding.api.DataTreeChangeListener;
28 import org.opendaylight.controller.md.sal.binding.api.DataTreeIdentifier;
29 import org.opendaylight.controller.md.sal.binding.api.DataTreeModification;
30 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
31 import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
32 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
33 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
34 import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
35 import org.opendaylight.ovsdb.southbound.SouthboundConstants;
36 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.MacAddress;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.L2BridgeDomainId;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.TenantId;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.EndpointService;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.endpoints.Endpoint;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.endpoints.EndpointBuilder;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.gbp.by.neutron.mappings.endpoints.by.ports.EndpointByPort;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.ofoverlay.rev140528.OfOverlayContext;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.ofoverlay.rev140528.OfOverlayNodeConfig;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.DatapathId;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentation;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeName;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentation;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbTerminationPointAugmentation;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.InterfaceExternalIds;
51 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
52 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
53 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
54 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
55 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint;
56 import org.opendaylight.yangtools.concepts.ListenerRegistration;
57 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
59 public class TerminationPointDataChangeListenerTest {
61 private TerminationPointDataChangeListener listener;
63 private DataBroker dataBroker;
64 private EndpointService epService;
65 private ListenerRegistration<?> registration;
67 private DataObjectModification<OvsdbTerminationPointAugmentation> mockModification;
68 private Collection<DataTreeModification<OvsdbTerminationPointAugmentation>> changeEvent;
71 private CheckedFuture<Optional<OvsdbBridgeAugmentation>, ReadFailedException> ovsdbBridgeFuture;
72 private CheckedFuture<Optional<Node>, ReadFailedException> nodeFuture;
73 private CheckedFuture<Optional<EndpointByPort>, ReadFailedException> endpointByPortFuture;
74 private CheckedFuture<Optional<Endpoint>, ReadFailedException> endpointFuture;
75 private CheckedFuture<Optional<OfOverlayNodeConfig>, ReadFailedException> ofOverlayNodeConfigFuture;
76 private ReadOnlyTransaction readTransaction;
77 private ReadWriteTransaction readWriteTransaction;
79 private OvsdbTerminationPointAugmentation ovsdbTp;
81 @SuppressWarnings({"unchecked", "rawtypes"})
83 public void init() throws Exception {
84 dataBroker = mock(DataBroker.class);
85 epService = mock(EndpointService.class);
86 registration = mock(ListenerRegistration.class);
87 when(dataBroker.registerDataTreeChangeListener(any(DataTreeIdentifier.class),
88 any(DataTreeChangeListener.class))).thenReturn(registration);
90 InstanceIdentifier<OvsdbTerminationPointAugmentation> ovsdbTpIid = InstanceIdentifier.create(
91 NetworkTopology.class)
92 .child(Topology.class, new TopologyKey(SouthboundConstants.OVSDB_TOPOLOGY_ID))
94 .child(TerminationPoint.class)
95 .augmentation(OvsdbTerminationPointAugmentation.class);
96 ovsdbTp = mock(OvsdbTerminationPointAugmentation.class);
97 when(ovsdbTp.getInterfaceType()).thenReturn((Class) Object.class);
98 InterfaceExternalIds externalId = mock(InterfaceExternalIds.class);
99 when(ovsdbTp.getInterfaceExternalIds()).thenReturn(Collections.singletonList(externalId));
100 when(externalId.getExternalIdKey()).thenReturn("iface-id");
101 when(externalId.getExternalIdValue()).thenReturn(UUID.randomUUID().toString());
103 readTransaction = mock(ReadOnlyTransaction.class);
104 when(dataBroker.newReadOnlyTransaction()).thenReturn(readTransaction);
105 readWriteTransaction = mock(ReadWriteTransaction.class);
106 when(dataBroker.newReadWriteTransaction()).thenReturn(readWriteTransaction);
107 CheckedFuture<Void, TransactionCommitFailedException> submitFuture = mock(CheckedFuture.class);
108 when(readWriteTransaction.submit()).thenReturn(submitFuture);
110 // OvsdbBridgeAugmentation
111 ovsdbBridgeFuture = mock(CheckedFuture.class);
112 Optional<OvsdbBridgeAugmentation> ovsdbOptional = mock(Optional.class);
113 when(ovsdbBridgeFuture.checkedGet()).thenReturn(ovsdbOptional);
114 when(ovsdbOptional.isPresent()).thenReturn(true);
115 OvsdbBridgeAugmentation ovsdbBridge = mock(OvsdbBridgeAugmentation.class);
116 when(ovsdbOptional.get()).thenReturn(ovsdbBridge);
118 DatapathId dpid = mock(DatapathId.class);
119 when(ovsdbBridge.getDatapathId()).thenReturn(dpid);
120 when(dpid.getValue()).thenReturn("FF:FF:FF:FF:FF:FF:FF:FF");
122 OvsdbBridgeName bridgeName = mock(OvsdbBridgeName.class);
123 when(ovsdbBridge.getBridgeName()).thenReturn(bridgeName);
124 when(bridgeName.getValue()).thenReturn("bridgeName");
127 nodeFuture = mock(CheckedFuture.class);
128 Optional<Node> nodeOptional = mock(Optional.class);
129 when(nodeFuture.checkedGet()).thenReturn(nodeOptional);
130 when(nodeOptional.isPresent()).thenReturn(true);
131 node = mock(Node.class);
132 when(nodeOptional.get()).thenReturn(node);
133 OvsdbNodeAugmentation ovsdbNode = mock(OvsdbNodeAugmentation.class);
134 when(node.getAugmentation(OvsdbNodeAugmentation.class)).thenReturn(ovsdbNode);
137 endpointByPortFuture = mock(CheckedFuture.class);
138 Optional<EndpointByPort> endpointByPortOptional = mock(Optional.class);
139 when(endpointByPortFuture.checkedGet()).thenReturn(endpointByPortOptional);
140 when(endpointByPortOptional.isPresent()).thenReturn(true);
141 EndpointByPort endpointByPort = mock(EndpointByPort.class);
142 when(endpointByPortOptional.get()).thenReturn(endpointByPort);
143 L2BridgeDomainId l2BridgeDomainId = mock(L2BridgeDomainId.class);
144 MacAddress macAddress = mock(MacAddress.class);
145 when(endpointByPort.getL2Context()).thenReturn(l2BridgeDomainId);
146 when(endpointByPort.getMacAddress()).thenReturn(macAddress);
149 endpointFuture = mock(CheckedFuture.class);
150 Optional<Endpoint> endpointOptional = mock(Optional.class);
151 when(endpointFuture.checkedGet()).thenReturn(endpointOptional);
152 when(endpointOptional.isPresent()).thenReturn(true);
153 OfOverlayContext ofc = mock(OfOverlayContext.class);
154 Endpoint endpoint = new EndpointBuilder().setL2Context(new L2BridgeDomainId("foo"))
155 .setMacAddress(new MacAddress("01:23:45:67:89:AB"))
156 .setTenant(new TenantId("fooTenant"))
157 .addAugmentation(OfOverlayContext.class, ofc)
159 when(endpointOptional.get()).thenReturn(endpoint);
161 // OfOverlayNodeConfig
162 ofOverlayNodeConfigFuture = mock(CheckedFuture.class);
163 Optional<OfOverlayNodeConfig> ofOverlayNodeConfigOptional = mock(Optional.class);
164 when(ofOverlayNodeConfigFuture.checkedGet()).thenReturn(ofOverlayNodeConfigOptional);
165 when(ofOverlayNodeConfigOptional.isPresent()).thenReturn(true);
166 OfOverlayNodeConfig ofOverlayNodeConfig = mock(OfOverlayNodeConfig.class);
167 when(ofOverlayNodeConfigOptional.get()).thenReturn(ofOverlayNodeConfig);
169 listener = new TerminationPointDataChangeListener(dataBroker, epService);
171 DataTreeModification<OvsdbTerminationPointAugmentation> mockDataTreeModification =
172 mock(DataTreeModification.class);
173 mockModification = mock(DataObjectModification.class);
174 doReturn(mockModification).when(mockDataTreeModification).getRootNode();
175 doReturn(new DataTreeIdentifier<>(LogicalDatastoreType.OPERATIONAL, ovsdbTpIid))
176 .when(mockDataTreeModification).getRootPath();
177 changeEvent = Collections.singletonList(mockDataTreeModification);
181 public void testConstructor() throws Exception {
183 verify(registration).close();
186 @SuppressWarnings("unchecked")
188 public void testOnDataChanged_Creation() {
189 doReturn(DataObjectModification.ModificationType.WRITE).when(mockModification).getModificationType();
190 doReturn(ovsdbTp).when(mockModification).getDataAfter();
192 when(readTransaction.read(any(LogicalDatastoreType.class), any(InstanceIdentifier.class))).thenReturn(
194 .thenReturn(endpointFuture)
195 .thenReturn(nodeFuture);
197 when(readWriteTransaction.read(any(LogicalDatastoreType.class), any(InstanceIdentifier.class))).thenReturn(
198 endpointByPortFuture).thenReturn(ofOverlayNodeConfigFuture);
200 listener.onDataTreeChanged(changeEvent);
201 verify(readWriteTransaction).submit();
204 @SuppressWarnings("unchecked")
206 public void testOnDataChanged_CreationExternalIdNull() {
207 doReturn(DataObjectModification.ModificationType.WRITE).when(mockModification).getModificationType();
208 doReturn(ovsdbTp).when(mockModification).getDataAfter();
210 when(readTransaction.read(any(LogicalDatastoreType.class), any(InstanceIdentifier.class))).thenReturn(
211 ovsdbBridgeFuture).thenReturn(nodeFuture);
212 when(ovsdbTp.getInterfaceExternalIds()).thenReturn(null);
214 listener.onDataTreeChanged(changeEvent);
215 verify(readWriteTransaction, never()).submit();
218 @SuppressWarnings("unchecked")
220 public void testOnDataChanged_Update() {
221 doReturn(DataObjectModification.ModificationType.WRITE).when(mockModification).getModificationType();
222 doReturn(ovsdbTp).when(mockModification).getDataBefore();
223 doReturn(ovsdbTp).when(mockModification).getDataAfter();
225 when(readTransaction.read(any(LogicalDatastoreType.class), any(InstanceIdentifier.class))).thenReturn(
227 .thenReturn(endpointFuture)
228 .thenReturn(nodeFuture);
229 when(readWriteTransaction.read(any(LogicalDatastoreType.class), any(InstanceIdentifier.class))).thenReturn(
230 endpointByPortFuture).thenReturn(ofOverlayNodeConfigFuture);
232 listener.onDataTreeChanged(changeEvent);
233 verify(readWriteTransaction).submit();
236 @SuppressWarnings("unchecked")
238 public void testOnDataChanged_Removal() {
239 doReturn(DataObjectModification.ModificationType.DELETE).when(mockModification).getModificationType();
240 doReturn(ovsdbTp).when(mockModification).getDataBefore();
242 when(readWriteTransaction.read(any(LogicalDatastoreType.class), any(InstanceIdentifier.class))).thenReturn(
243 endpointByPortFuture);
244 when(readTransaction.read(any(LogicalDatastoreType.class), any(InstanceIdentifier.class))).thenReturn(
247 listener.onDataTreeChanged(changeEvent);
248 verify(readWriteTransaction).submit();