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.genius.itm.impl;
10 import static org.mockito.Mockito.doReturn;
11 import static org.mockito.Mockito.verify;
13 import com.google.common.base.Optional;
14 import com.google.common.util.concurrent.Futures;
15 import java.math.BigInteger;
16 import java.util.ArrayList;
17 import java.util.Collections;
18 import java.util.List;
19 import org.junit.After;
20 import org.junit.Before;
21 import org.junit.Ignore;
22 import org.junit.Test;
23 import org.junit.runner.RunWith;
24 import org.mockito.Mock;
25 import org.mockito.runners.MockitoJUnitRunner;
26 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
27 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
28 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
29 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
30 import org.opendaylight.genius.itm.cache.DPNTEPsInfoCache;
31 import org.opendaylight.genius.itm.globals.ITMConstants;
32 import org.opendaylight.genius.itm.rpc.ItmManagerRpcService;
33 import org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager;
34 import org.opendaylight.infrautils.caches.baseimpl.internal.CacheManagersRegistryImpl;
35 import org.opendaylight.infrautils.caches.guava.internal.GuavaCacheProvider;
36 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
37 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddressBuilder;
38 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefix;
39 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefixBuilder;
40 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelMonitoringTypeBase;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeMplsOverGre;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeVxlan;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.config.rev160406.ItmConfig;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.DpnEndpoints;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.DpnEndpointsBuilder;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.ExternalTunnelList;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.TunnelList;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfo;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfoBuilder;
52 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfoKey;
53 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.dpn.teps.info.TunnelEndPoints;
54 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.dpn.teps.info.TunnelEndPointsBuilder;
55 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.dpn.teps.info.TunnelEndPointsKey;
56 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.external.tunnel.list.ExternalTunnel;
57 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.external.tunnel.list.ExternalTunnelBuilder;
58 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.external.tunnel.list.ExternalTunnelKey;
59 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnel.list.InternalTunnel;
60 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnel.list.InternalTunnelBuilder;
61 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnel.list.InternalTunnelKey;
62 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.TransportZones;
63 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.TransportZonesBuilder;
64 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZone;
65 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZoneBuilder;
66 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZoneKey;
67 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.Subnets;
68 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.SubnetsBuilder;
69 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.SubnetsKey;
70 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.subnets.DeviceVteps;
71 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.subnets.DeviceVtepsBuilder;
72 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.subnets.DeviceVtepsKey;
73 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.AddExternalTunnelEndpointInput;
74 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.AddExternalTunnelEndpointInputBuilder;
75 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.AddL2GwDeviceInput;
76 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.AddL2GwDeviceInputBuilder;
77 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.AddL2GwMlagDeviceInput;
78 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.AddL2GwMlagDeviceInputBuilder;
79 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.BuildExternalTunnelFromDpnsInput;
80 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.BuildExternalTunnelFromDpnsInputBuilder;
81 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.DeleteL2GwDeviceInput;
82 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.DeleteL2GwDeviceInputBuilder;
83 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.DeleteL2GwMlagDeviceInput;
84 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.DeleteL2GwMlagDeviceInputBuilder;
85 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetExternalTunnelInterfaceNameInput;
86 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetExternalTunnelInterfaceNameInputBuilder;
87 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetInternalOrExternalInterfaceNameInput;
88 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetInternalOrExternalInterfaceNameInputBuilder;
89 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetTunnelInterfaceNameInput;
90 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetTunnelInterfaceNameInputBuilder;
91 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.RemoveExternalTunnelEndpointInput;
92 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.RemoveExternalTunnelEndpointInputBuilder;
93 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.RemoveExternalTunnelFromDpnsInput;
94 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.RemoveExternalTunnelFromDpnsInputBuilder;
95 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.RemoveTerminatingServiceActionsInput;
96 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.RemoveTerminatingServiceActionsInputBuilder;
97 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
99 @RunWith(MockitoJUnitRunner.class)
100 public class ItmManagerRpcServiceTest {
103 String portName1 = "phy0";
104 String sourceDevice = "abc";
105 String destinationDevice = "xyz";
106 String tepIp1 = "192.168.56.101";
107 String gwyIp1 = "0.0.0.0";
108 String subnetIp = "10.1.1.24";
109 String tunnelInterfaceName = "1:phy0:100" ;
110 String transportZone1 = "TZA" ;
111 String trunkInterfaceName = null;
112 IpAddress ipAddress1 = IpAddressBuilder.getDefaultInstance(tepIp1);
113 IpAddress gtwyIp1 = IpAddressBuilder.getDefaultInstance(gwyIp1);
114 IpPrefix ipPrefixTest = IpPrefixBuilder.getDefaultInstance(subnetIp + "/24");
115 BigInteger dpId1 = BigInteger.valueOf(1);
116 BigInteger dpId2 = BigInteger.valueOf(2);
117 ExternalTunnel externalTunnel = null;
118 ExternalTunnel externalTunnelNew = null;
119 InternalTunnel internalTunnel = null;
120 DpnEndpoints dpnEndpoints = null;
121 DPNTEPsInfo dpntePsInfoVxlan = null;
122 TunnelEndPoints tunnelEndPointsVxlan = null;
123 Interface iface = null;
124 Subnets subnetsTest = null;
125 TransportZones transportZones = null;
126 TransportZone transportZone = null;
127 DeviceVteps deviceVteps = null;
128 List<DPNTEPsInfo> cfgdDpnListVxlan = new ArrayList<>() ;
129 List<TunnelEndPoints> tunnelEndPointsListVxlan = new ArrayList<>();
130 List<TransportZone> transportZoneList = new ArrayList<>() ;
131 List<Subnets> subnetsList = new ArrayList<>() ;
132 List<DeviceVteps> deviceVtepsList = new ArrayList<>();
133 List<String> stringList = new ArrayList<>();
134 List<BigInteger> dpId1List = new ArrayList<>();
135 DeviceVtepsKey deviceVtepKey = new DeviceVtepsKey(ipAddress1, sourceDevice);
136 AddExternalTunnelEndpointInput addExternalTunnelEndpointInput = null;
137 GetInternalOrExternalInterfaceNameInput getInternalOrExternalInterfaceNameInput = null;
138 BuildExternalTunnelFromDpnsInput buildExternalTunnelFromDpnsInput = null;
139 RemoveExternalTunnelFromDpnsInput removeExternalTunnelFromDpnsInput = null;
140 RemoveExternalTunnelEndpointInput removeExternalTunnelEndpointInput = null;
141 RemoveTerminatingServiceActionsInput removeTerminatingServiceActionsInput = null;
142 GetExternalTunnelInterfaceNameInput getExternalTunnelInterfaceNameInput = null;
143 AddL2GwDeviceInput addL2GwDeviceInput = null;
144 DeleteL2GwDeviceInput deleteL2GwDeviceInput = null;
145 AddL2GwMlagDeviceInput addL2GwMlagDeviceInput = null;
146 DeleteL2GwMlagDeviceInput deleteL2GwMlagDeviceInput = null;
147 GetTunnelInterfaceNameInput getTunnelInterfaceNameInput = null;
148 java.lang.Class<? extends TunnelTypeBase> tunnelType1 = TunnelTypeVxlan.class;
149 Class<? extends TunnelMonitoringTypeBase> monitorProtocol = ITMConstants.DEFAULT_MONITOR_PROTOCOL;
151 InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier = InstanceIdentifier.create(ExternalTunnelList.class)
152 .child(ExternalTunnel.class, new ExternalTunnelKey(String.valueOf(ipAddress1), dpId1.toString(),
153 TunnelTypeMplsOverGre.class));
154 InstanceIdentifier<ExternalTunnel> externalTunnelIdentifierNew = InstanceIdentifier.create(ExternalTunnelList.class)
155 .child(ExternalTunnel.class, new ExternalTunnelKey(String.valueOf(ipAddress1), dpId1.toString(),
157 InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier1 = InstanceIdentifier.create(ExternalTunnelList.class)
158 .child(ExternalTunnel.class, new ExternalTunnelKey(destinationDevice, sourceDevice,
160 InstanceIdentifier<InternalTunnel> internalTunnelIdentifier = InstanceIdentifier.create(TunnelList.class)
161 .child(InternalTunnel.class, new InternalTunnelKey(dpId2, dpId1, tunnelType1));
162 InstanceIdentifier<InternalTunnel> internalTunnelIdentifierNew = InstanceIdentifier.create(TunnelList.class)
163 .child(InternalTunnel.class, new InternalTunnelKey(dpId1, dpId1, tunnelType1));
164 InstanceIdentifier<DpnEndpoints> dpnEndpointsIdentifier = InstanceIdentifier.builder(DpnEndpoints.class).build();
165 InstanceIdentifier<Interface> interfaceIdentifier = null;
166 InstanceIdentifier<TransportZones> transportZonesIdentifier = InstanceIdentifier.create(TransportZones.class);
167 InstanceIdentifier<DeviceVteps> deviceVtepsIdentifier = InstanceIdentifier.builder(TransportZones.class)
168 .child(TransportZone.class, new TransportZoneKey(transportZone1))
169 .child(Subnets.class, new SubnetsKey(ipPrefixTest)).child(DeviceVteps.class, deviceVtepKey).build();
171 @Mock DataBroker dataBroker;
172 @Mock ReadOnlyTransaction mockReadTx;
173 @Mock WriteTransaction mockWriteTx;
174 @Mock IMdsalApiManager mdsalApiManager;
175 @Mock ItmConfig itmConfig;
177 ItmManagerRpcService itmManagerRpcService ;
179 Optional<ExternalTunnel> externalTunnelOptional ;
180 Optional<InternalTunnel> internalTunnelOptional;
181 Optional<DpnEndpoints> dpnEndpointsOptional ;
182 Optional<TransportZones> transportZonesOptional ;
185 public void setUp() {
188 externalTunnelOptional = Optional.of(externalTunnel);
189 internalTunnelOptional = Optional.of(internalTunnel);
190 dpnEndpointsOptional = Optional.of(dpnEndpoints);
191 transportZonesOptional = Optional.of(transportZones);
193 doReturn(Futures.immediateCheckedFuture(externalTunnelOptional)).when(mockReadTx).read(LogicalDatastoreType
194 .CONFIGURATION,externalTunnelIdentifier);
195 doReturn(Futures.immediateCheckedFuture(externalTunnelOptional)).when(mockReadTx).read(LogicalDatastoreType
196 .CONFIGURATION,externalTunnelIdentifier1);
197 doReturn(Futures.immediateCheckedFuture(internalTunnelOptional)).when(mockReadTx).read(LogicalDatastoreType
198 .CONFIGURATION,internalTunnelIdentifier);
199 doReturn(Futures.immediateCheckedFuture(internalTunnelOptional)).when(mockReadTx).read(LogicalDatastoreType
200 .CONFIGURATION,internalTunnelIdentifierNew);
201 doReturn(Futures.immediateCheckedFuture(dpnEndpointsOptional)).when(mockReadTx).read(LogicalDatastoreType
202 .CONFIGURATION,dpnEndpointsIdentifier);
203 doReturn(Futures.immediateCheckedFuture(transportZonesOptional)).when(mockReadTx).read(LogicalDatastoreType
204 .CONFIGURATION,transportZonesIdentifier);
206 itmManagerRpcService = new ItmManagerRpcService(dataBroker, mdsalApiManager, itmConfig,
207 new DPNTEPsInfoCache(dataBroker, new GuavaCacheProvider(new CacheManagersRegistryImpl())));
211 public void cleanUp() {
214 private void setupMocks() {
215 deviceVteps = new DeviceVtepsBuilder().setIpAddress(ipAddress1).setKey(new DeviceVtepsKey(ipAddress1,"abc"))
216 .setNodeId(sourceDevice).setTopologyId(destinationDevice).build();
217 deviceVtepsList.add(deviceVteps);
218 stringList.add(sourceDevice);
219 dpId1List.add(dpId1);
220 stringList.add("def");
221 trunkInterfaceName = ItmUtils.getTrunkInterfaceName(tunnelInterfaceName, ipAddress1
222 .getIpv4Address().getValue(), ipAddress1.getIpv4Address().getValue(), tunnelType1.getName());
223 interfaceIdentifier = ItmUtils.buildId(trunkInterfaceName);
224 tunnelEndPointsVxlan = new TunnelEndPointsBuilder().setVLANID(vlanId).setPortname(portName1)
225 .setIpAddress(ipAddress1).setGwIpAddress(gtwyIp1).setInterfaceName(tunnelInterfaceName)
226 .setTzMembership(ItmUtils.createTransportZoneMembership(transportZone1)).setTunnelType(tunnelType1)
227 .setSubnetMask(ipPrefixTest)
228 .setKey(new TunnelEndPointsKey(ipAddress1,portName1,tunnelType1,vlanId)).build();
229 tunnelEndPointsListVxlan.add(tunnelEndPointsVxlan);
230 dpntePsInfoVxlan = new DPNTEPsInfoBuilder().setDPNID(dpId1).setKey(new DPNTEPsInfoKey(dpId1)).setUp(true)
231 .setTunnelEndPoints(tunnelEndPointsListVxlan).build();
232 cfgdDpnListVxlan.add(dpntePsInfoVxlan);
233 dpnEndpoints = new DpnEndpointsBuilder().setDPNTEPsInfo(cfgdDpnListVxlan).build();
234 externalTunnel = new ExternalTunnelBuilder().setSourceDevice(sourceDevice)
235 .setDestinationDevice(destinationDevice).setTransportType(tunnelType1)
236 .setTunnelInterfaceName(tunnelInterfaceName)
237 .setKey(new ExternalTunnelKey(destinationDevice,sourceDevice,tunnelType1)).build();
238 internalTunnel = new InternalTunnelBuilder()
239 .setTunnelInterfaceNames(Collections.singletonList(tunnelInterfaceName)).setDestinationDPN(dpId2)
240 .setSourceDPN(dpId1).setTransportType(tunnelType1)
241 .setKey(new InternalTunnelKey(dpId2, dpId1, tunnelType1)).build();
242 getInternalOrExternalInterfaceNameInput = new GetInternalOrExternalInterfaceNameInputBuilder()
243 .setDestinationIp(ipAddress1).setSourceDpid(dpId1).setTunnelType(tunnelType1).build();
244 addExternalTunnelEndpointInput = new AddExternalTunnelEndpointInputBuilder().setTunnelType(tunnelType1)
245 .setDestinationIp(ipAddress1).build();
246 addL2GwDeviceInput = new AddL2GwDeviceInputBuilder().setIpAddress(ipAddress1).setNodeId(sourceDevice)
247 .setTopologyId(destinationDevice).build();
248 deleteL2GwDeviceInput = new DeleteL2GwDeviceInputBuilder().setIpAddress(ipAddress1).setNodeId(sourceDevice)
249 .setTopologyId(destinationDevice).build();
250 addL2GwMlagDeviceInput = new AddL2GwMlagDeviceInputBuilder().setIpAddress(ipAddress1).setNodeId(stringList)
251 .setTopologyId(destinationDevice).build();
252 deleteL2GwMlagDeviceInput = new DeleteL2GwMlagDeviceInputBuilder().setIpAddress(ipAddress1)
253 .setNodeId(stringList).setTopologyId(destinationDevice).build();
254 buildExternalTunnelFromDpnsInput = new BuildExternalTunnelFromDpnsInputBuilder().setTunnelType(tunnelType1)
255 .setDestinationIp(ipAddress1).setDpnId(dpId1List).build();
256 removeExternalTunnelFromDpnsInput = new RemoveExternalTunnelFromDpnsInputBuilder().setTunnelType(tunnelType1)
257 .setDestinationIp(ipAddress1).setDpnId(dpId1List).build();
258 removeExternalTunnelEndpointInput = new RemoveExternalTunnelEndpointInputBuilder().setTunnelType(tunnelType1)
259 .setDestinationIp(ipAddress1).build();
260 removeTerminatingServiceActionsInput = new RemoveTerminatingServiceActionsInputBuilder().setServiceId(vlanId)
261 .setDpnId(dpId1).build();
262 getTunnelInterfaceNameInput = new GetTunnelInterfaceNameInputBuilder().setTunnelType(tunnelType1)
263 .setSourceDpid(dpId1).setDestinationDpid(dpId2).build();
264 getExternalTunnelInterfaceNameInput = new GetExternalTunnelInterfaceNameInputBuilder()
265 .setTunnelType(tunnelType1).setDestinationNode(destinationDevice).setSourceNode(sourceDevice).build();
266 iface = ItmUtils.buildTunnelInterface(dpId1,trunkInterfaceName, String.format("%s %s",
267 ItmUtils.convertTunnelTypetoString(tunnelType1), "Trunk Interface"),true,tunnelType1,
268 tunnelEndPointsVxlan.getIpAddress(),ipAddress1,gtwyIp1,tunnelEndPointsVxlan.getVLANID(), false, false,
269 monitorProtocol,null, false, null);
270 subnetsTest = new SubnetsBuilder().setGatewayIp(gtwyIp1).setVlanId(vlanId).setKey(new SubnetsKey(ipPrefixTest))
271 .setDeviceVteps(deviceVtepsList).build();
272 subnetsList.add(subnetsTest);
273 transportZone = new TransportZoneBuilder().setZoneName(transportZone1)
274 .setTunnelType(tunnelType1).setKey(new TransportZoneKey(transportZone1))
275 .setSubnets(subnetsList).build();
276 transportZoneList.add(transportZone);
277 transportZones = new TransportZonesBuilder().setTransportZone(transportZoneList).build();
278 doReturn(mockReadTx).when(dataBroker).newReadOnlyTransaction();
279 doReturn(mockWriteTx).when(dataBroker).newWriteOnlyTransaction();
280 doReturn(Futures.immediateCheckedFuture(null)).when(mockWriteTx).submit();
284 public void testGetInternalOrExternalInterfaceNameExtTunnelPresent() {
285 itmManagerRpcService.getInternalOrExternalInterfaceName(getInternalOrExternalInterfaceNameInput);
287 verify(mockReadTx).read(LogicalDatastoreType.CONFIGURATION, externalTunnelIdentifier);
292 public void testGetInternalOrExternalInterfaceNameExtTunnelAbsent() {
293 doReturn(Futures.immediateCheckedFuture(Optional.absent())).when(mockReadTx).read(LogicalDatastoreType
294 .CONFIGURATION,externalTunnelIdentifier);
296 itmManagerRpcService.getInternalOrExternalInterfaceName(getInternalOrExternalInterfaceNameInput);
298 verify(mockReadTx).read(LogicalDatastoreType.CONFIGURATION, externalTunnelIdentifier);
299 verify(mockReadTx).read(LogicalDatastoreType.CONFIGURATION, internalTunnelIdentifierNew);
304 public void testAddExternalTunnelEndpoint() {
305 externalTunnelNew = ItmUtils.buildExternalTunnel(dpId1.toString(), ipAddress1.toString(),
306 tunnelType1, trunkInterfaceName);
308 itmManagerRpcService.addExternalTunnelEndpoint(addExternalTunnelEndpointInput);
310 verify(mockWriteTx).merge(LogicalDatastoreType.CONFIGURATION, interfaceIdentifier, iface, true);
311 verify(mockWriteTx).merge(LogicalDatastoreType.CONFIGURATION, externalTunnelIdentifierNew,
312 externalTunnelNew,true);
316 public void testAddL2GwDevice() {
317 itmManagerRpcService.addL2GwDevice(addL2GwDeviceInput);
319 verify(mockWriteTx).put(LogicalDatastoreType.CONFIGURATION, deviceVtepsIdentifier, deviceVteps, true);
323 public void testAddL2GwMlagDevice() {
324 itmManagerRpcService.addL2GwMlagDevice(addL2GwMlagDeviceInput);
326 verify(mockWriteTx).put(LogicalDatastoreType.CONFIGURATION, deviceVtepsIdentifier, deviceVteps, true);
330 public void testDeleteL2GwDevice() {
331 itmManagerRpcService.deleteL2GwDevice(deleteL2GwDeviceInput);
333 verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,deviceVtepsIdentifier);
337 public void testDeleteL2GwMlagDevice() {
338 itmManagerRpcService.deleteL2GwMlagDevice(deleteL2GwMlagDeviceInput);
340 verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,deviceVtepsIdentifier);
345 public void testBuildExternalTunnelFromDpns() {
346 externalTunnelNew = ItmUtils.buildExternalTunnel(dpId1.toString(), ipAddress1.toString(),
347 tunnelType1, trunkInterfaceName);
349 itmManagerRpcService.buildExternalTunnelFromDpns(buildExternalTunnelFromDpnsInput);
351 verify(mockWriteTx).merge(LogicalDatastoreType.CONFIGURATION,interfaceIdentifier,iface,true);
352 verify(mockWriteTx).merge(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifierNew,
353 externalTunnelNew,true);
358 public void testRemoveExternalTunnelFromDpns() {
360 itmManagerRpcService.removeExternalTunnelFromDpns(removeExternalTunnelFromDpnsInput);
362 verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,interfaceIdentifier);
363 verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifierNew);
368 public void testRemoveExternalTunnelEndpoint() {
369 itmManagerRpcService.removeExternalTunnelEndpoint(removeExternalTunnelEndpointInput);
371 verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,interfaceIdentifier);
372 verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifierNew);
376 public void testGetTunnelInterfaceName() {
377 itmManagerRpcService.getTunnelInterfaceName(getTunnelInterfaceNameInput);
379 verify(mockReadTx).read(LogicalDatastoreType.CONFIGURATION,internalTunnelIdentifier);
383 public void testGetExternalTunnelInterfaceName() {
384 itmManagerRpcService.getExternalTunnelInterfaceName(getExternalTunnelInterfaceNameInput);
386 verify(mockReadTx).read(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifier1);