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
9 package org.opendaylight.genius.itm.impl;
11 import com.google.common.base.Optional;
12 import com.google.common.util.concurrent.CheckedFuture;
13 import com.google.common.util.concurrent.Futures;
14 import com.google.common.util.concurrent.ListenableFuture;
15 import org.junit.After;
16 import org.junit.Before;
17 import org.junit.Test;
18 import org.junit.runner.RunWith;
19 import org.mockito.Mock;
20 import org.mockito.runners.MockitoJUnitRunner;
21 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
22 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
23 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
24 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
25 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker;
26 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
27 import org.opendaylight.genius.itm.globals.ITMConstants;
28 import org.opendaylight.genius.itm.rpc.ItmManagerRpcService;
29 import org.opendaylight.genius.mdsalutil.*;
30 import org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager;
31 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpAddress;
32 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpAddressBuilder;
33 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpPrefix;
34 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpPrefixBuilder;
35 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.Action;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.InstructionsBuilder;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.InstructionBuilder;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.InstructionKey;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.*;
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.op.rev160406.DpnEndpoints;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.DpnEndpointsBuilder;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.ExternalTunnelList;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.TunnelList;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfo;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfoBuilder;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfoKey;
52 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.dpn.teps.info
54 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.dpn.teps.info
55 .TunnelEndPointsBuilder;
56 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.dpn.teps.info.TunnelEndPointsKey;
57 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.external.tunnel.list.ExternalTunnel;
58 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.external.tunnel.list
59 .ExternalTunnelBuilder;
60 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.external.tunnel.list.ExternalTunnelKey;
61 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnel.list.InternalTunnel;
62 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnel.list.InternalTunnelBuilder;
63 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnel.list.InternalTunnelKey;
64 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.TransportZones;
65 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.TransportZonesBuilder;
66 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZone;
67 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZoneBuilder;
68 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZoneKey;
69 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.Subnets;
70 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone
72 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.SubnetsKey;
73 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.subnets
75 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.subnets
77 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.subnets
79 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.*;
80 import org.opendaylight.yangtools.concepts.ListenerRegistration;
81 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
82 import org.opendaylight.yangtools.yang.common.RpcResult;
83 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
85 import java.math.BigInteger;
86 import java.util.ArrayList;
87 import java.util.List;
88 import java.util.concurrent.Future;
90 import static org.mockito.Matchers.any;
91 import static org.mockito.Mockito.doReturn;
92 import static org.mockito.Mockito.verify;
93 import static org.mockito.Mockito.when;
95 @RunWith(MockitoJUnitRunner.class)
96 public class ItmManagerRpcServiceTest {
99 String portName1 = "phy0";
100 String sourceDevice = "abc";
101 String destinationDevice = "xyz";
102 String tepIp1 = "192.168.56.101";
103 String gwyIp1 = "0.0.0.0";
104 String subnetIp = "10.1.1.24";
105 String tunnelInterfaceName = "1:phy0:100" ;
106 String transportZone1 = "TZA" ;
107 String trunkInterfaceName = null;
108 IpAddress ipAddress1 = IpAddressBuilder.getDefaultInstance(tepIp1);
109 IpAddress gtwyIp1 = IpAddressBuilder.getDefaultInstance(gwyIp1);
110 IpPrefix ipPrefixTest = IpPrefixBuilder.getDefaultInstance(subnetIp + "/24");
111 BigInteger dpId1 = BigInteger.valueOf(1);
112 BigInteger dpId2 = BigInteger.valueOf(2);
113 ExternalTunnel externalTunnel = null;
114 ExternalTunnel externalTunnelNew = null;
115 InternalTunnel internalTunnel = null;
116 DpnEndpoints dpnEndpoints= null;
117 DPNTEPsInfo dpntePsInfoVxlan = null;
118 TunnelEndPoints tunnelEndPointsVxlan = null;
119 AllocateIdInput getIdInput1 = null;
120 Interface iface = null;
121 Subnets subnetsTest = null;
122 TransportZones transportZones = null;
123 TransportZone transportZone = null;
124 DeviceVteps deviceVteps = null;
125 List<DPNTEPsInfo> cfgdDpnListVxlan = new ArrayList<DPNTEPsInfo>() ;
126 List<TunnelEndPoints> tunnelEndPointsListVxlan = new ArrayList<>();
127 List<TransportZone> transportZoneList = new ArrayList<>() ;
128 List<Subnets> subnetsList = new ArrayList<>() ;
129 List<DeviceVteps> deviceVtepsList = new ArrayList<>();
130 List<String> stringList = new ArrayList<>();
131 List<BigInteger> dpId1List = new ArrayList<>();
132 DeviceVtepsKey deviceVtepKey = new DeviceVtepsKey(ipAddress1, sourceDevice);
133 AddExternalTunnelEndpointInput addExternalTunnelEndpointInput = null;
134 GetInternalOrExternalInterfaceNameInput getInternalOrExternalInterfaceNameInput = null;
135 BuildExternalTunnelFromDpnsInput buildExternalTunnelFromDpnsInput = null;
136 RemoveExternalTunnelFromDpnsInput removeExternalTunnelFromDpnsInput = null;
137 RemoveExternalTunnelEndpointInput removeExternalTunnelEndpointInput = null;
138 RemoveTerminatingServiceActionsInput removeTerminatingServiceActionsInput = null;
139 GetExternalTunnelInterfaceNameInput getExternalTunnelInterfaceNameInput = null;
140 AddL2GwDeviceInput addL2GwDeviceInput = null;
141 DeleteL2GwDeviceInput deleteL2GwDeviceInput = null;
142 AddL2GwMlagDeviceInput addL2GwMlagDeviceInput = null;
143 DeleteL2GwMlagDeviceInput deleteL2GwMlagDeviceInput = null;
144 GetTunnelInterfaceNameInput getTunnelInterfaceNameInput = null;
145 java.lang.Class<? extends TunnelTypeBase> tunnelType1 = TunnelTypeVxlan.class;
146 AllocateIdOutput expectedId1 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("100")).build();
147 Future<RpcResult<AllocateIdOutput>> idOutputOptional1 ;
149 InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier = InstanceIdentifier.create(ExternalTunnelList.class)
150 .child(ExternalTunnel.class, new ExternalTunnelKey(String.valueOf(ipAddress1), dpId1.toString(),
151 TunnelTypeMplsOverGre.class));
152 InstanceIdentifier<ExternalTunnel> externalTunnelIdentifierNew = InstanceIdentifier.create(ExternalTunnelList.class)
153 .child(ExternalTunnel.class, new ExternalTunnelKey(String.valueOf(ipAddress1), dpId1.toString(),
155 InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier1 = InstanceIdentifier.create(ExternalTunnelList.class)
156 .child(ExternalTunnel.class, new ExternalTunnelKey(destinationDevice, sourceDevice,
158 InstanceIdentifier<InternalTunnel> internalTunnelIdentifier = InstanceIdentifier.create(TunnelList.class)
159 .child(InternalTunnel.class, new InternalTunnelKey(dpId2, dpId1, tunnelType1));
160 InstanceIdentifier<InternalTunnel> internalTunnelIdentifierNew = InstanceIdentifier.create(TunnelList.class)
161 .child(InternalTunnel.class, new InternalTunnelKey(dpId1, dpId1, tunnelType1));
162 InstanceIdentifier<DpnEndpoints> dpnEndpointsIdentifier = InstanceIdentifier.builder(DpnEndpoints.class).build();
163 InstanceIdentifier<Interface> interfaceIdentifier = null;
164 InstanceIdentifier<TransportZones> transportZonesIdentifier = InstanceIdentifier.create(TransportZones.class);
165 InstanceIdentifier<DeviceVteps> deviceVtepsIdentifier = InstanceIdentifier.builder(TransportZones.class)
166 .child(TransportZone.class, new TransportZoneKey(transportZone1))
167 .child(Subnets.class, new SubnetsKey(ipPrefixTest)).child(DeviceVteps.class, deviceVtepKey).build();
170 @Mock DataBroker dataBroker;
171 @Mock ListenerRegistration<DataChangeListener> dataChangeListenerRegistration;
172 @Mock ReadOnlyTransaction mockReadTx;
173 @Mock WriteTransaction mockWriteTx;
174 @Mock IdManagerService idManagerService;
175 @Mock IMdsalApiManager mdsalApiManager;
177 ItmManagerRpcService itmManagerRpcService ;
179 Optional<ExternalTunnel> externalTunnelOptional ;
180 Optional<InternalTunnel> internalTunnelOptional;
181 Optional<DpnEndpoints> dpnEndpointsOptional ;
182 Optional<TransportZones> transportZonesOptional ;
185 public void setUp() throws Exception {
186 when(dataBroker.registerDataChangeListener(
187 any(LogicalDatastoreType.class),
188 any(InstanceIdentifier.class),
189 any(DataChangeListener.class),
190 any(AsyncDataBroker.DataChangeScope.class)))
191 .thenReturn(dataChangeListenerRegistration);
194 externalTunnelOptional = Optional.of(externalTunnel);
195 internalTunnelOptional = Optional.of(internalTunnel);
196 dpnEndpointsOptional = Optional.of(dpnEndpoints);
197 transportZonesOptional = Optional.of(transportZones);
199 doReturn(Futures.immediateCheckedFuture(externalTunnelOptional)).when(mockReadTx).read(LogicalDatastoreType
200 .CONFIGURATION,externalTunnelIdentifier);
201 doReturn(Futures.immediateCheckedFuture(externalTunnelOptional)).when(mockReadTx).read(LogicalDatastoreType
202 .CONFIGURATION,externalTunnelIdentifier1);
203 doReturn(Futures.immediateCheckedFuture(internalTunnelOptional)).when(mockReadTx).read(LogicalDatastoreType
204 .CONFIGURATION,internalTunnelIdentifier);
205 doReturn(Futures.immediateCheckedFuture(internalTunnelOptional)).when(mockReadTx).read(LogicalDatastoreType
206 .CONFIGURATION,internalTunnelIdentifierNew);
207 doReturn(Futures.immediateCheckedFuture(dpnEndpointsOptional)).when(mockReadTx).read(LogicalDatastoreType
208 .CONFIGURATION,dpnEndpointsIdentifier);
209 doReturn(Futures.immediateCheckedFuture(transportZonesOptional)).when(mockReadTx).read(LogicalDatastoreType
210 .CONFIGURATION,transportZonesIdentifier);
212 itmManagerRpcService = new ItmManagerRpcService(dataBroker,idManagerService);
213 itmManagerRpcService.setMdsalManager(mdsalApiManager);
217 public void cleanUp() {
220 private void setupMocks(){
222 deviceVteps = new DeviceVtepsBuilder().setIpAddress(ipAddress1).setKey(new DeviceVtepsKey(ipAddress1,"abc"))
223 .setNodeId(sourceDevice).setTopologyId(destinationDevice).build();
224 deviceVtepsList.add(deviceVteps);
225 stringList.add(sourceDevice);
226 dpId1List.add(dpId1);
227 stringList.add("def");
228 idOutputOptional1 = RpcResultBuilder.success(expectedId1).buildFuture();
229 getIdInput1 = new AllocateIdInputBuilder()
230 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
231 .setIdKey("1:phy0:100:192.168.56.101:192.168.56.101:VXLAN").build();
232 doReturn(idOutputOptional1).when(idManagerService).allocateId(getIdInput1);
233 when(idManagerService.releaseId(any(ReleaseIdInput.class))).thenReturn(Futures.immediateFuture(RpcResultBuilder
234 .<Void>success().build()));
235 trunkInterfaceName = ItmUtils.getTrunkInterfaceName(idManagerService, tunnelInterfaceName, ipAddress1
236 .getIpv4Address().getValue(), ipAddress1.getIpv4Address().getValue(), tunnelType1.getName());
237 interfaceIdentifier = ItmUtils.buildId(trunkInterfaceName);
238 tunnelEndPointsVxlan = new TunnelEndPointsBuilder().setVLANID(vlanId).setPortname(portName1).setIpAddress
239 (ipAddress1).setGwIpAddress(gtwyIp1).setInterfaceName(tunnelInterfaceName).setTransportZone
240 (transportZone1).setTunnelType(tunnelType1).setSubnetMask(ipPrefixTest).setKey(new TunnelEndPointsKey
241 (ipAddress1,portName1,tunnelType1,vlanId)).build();
242 tunnelEndPointsListVxlan.add(tunnelEndPointsVxlan);
243 dpntePsInfoVxlan = new DPNTEPsInfoBuilder().setDPNID(dpId1).setKey(new DPNTEPsInfoKey(dpId1)).setUp(true)
244 .setTunnelEndPoints(tunnelEndPointsListVxlan).build();
245 cfgdDpnListVxlan.add(dpntePsInfoVxlan);
246 dpnEndpoints = new DpnEndpointsBuilder().setDPNTEPsInfo(cfgdDpnListVxlan).build();
247 externalTunnel= new ExternalTunnelBuilder().setSourceDevice(sourceDevice).setDestinationDevice
248 (destinationDevice).setTransportType(tunnelType1).setTunnelInterfaceName(tunnelInterfaceName).setKey(new
249 ExternalTunnelKey(destinationDevice,sourceDevice,tunnelType1)).build();
250 internalTunnel = new InternalTunnelBuilder().setTunnelInterfaceName(tunnelInterfaceName).setDestinationDPN
251 (dpId2).setSourceDPN(dpId1).setTransportType(tunnelType1).setKey(new InternalTunnelKey(dpId2,dpId1,
252 tunnelType1)).build();
253 getInternalOrExternalInterfaceNameInput = new GetInternalOrExternalInterfaceNameInputBuilder()
254 .setDestinationIp(ipAddress1).setSourceDpid(dpId1).setTunnelType(tunnelType1).build();
255 addExternalTunnelEndpointInput = new AddExternalTunnelEndpointInputBuilder().setTunnelType(tunnelType1)
256 .setDestinationIp(ipAddress1).build();
257 addL2GwDeviceInput = new AddL2GwDeviceInputBuilder().setIpAddress(ipAddress1).setNodeId(sourceDevice)
258 .setTopologyId(destinationDevice).build();
259 deleteL2GwDeviceInput = new DeleteL2GwDeviceInputBuilder().setIpAddress(ipAddress1).setNodeId(sourceDevice)
260 .setTopologyId(destinationDevice).build();
261 addL2GwMlagDeviceInput = new AddL2GwMlagDeviceInputBuilder().setIpAddress(ipAddress1).setNodeId(stringList)
262 .setTopologyId(destinationDevice).build();
263 deleteL2GwMlagDeviceInput = new DeleteL2GwMlagDeviceInputBuilder().setIpAddress(ipAddress1).setNodeId
264 (stringList).setTopologyId(destinationDevice).build();
265 buildExternalTunnelFromDpnsInput = new BuildExternalTunnelFromDpnsInputBuilder().setTunnelType(tunnelType1)
266 .setDestinationIp(ipAddress1).setDpnId(dpId1List).build();
267 removeExternalTunnelFromDpnsInput = new RemoveExternalTunnelFromDpnsInputBuilder().setTunnelType(tunnelType1)
268 .setDestinationIp(ipAddress1).setDpnId(dpId1List).build();
269 removeExternalTunnelEndpointInput = new RemoveExternalTunnelEndpointInputBuilder().setTunnelType(tunnelType1)
270 .setDestinationIp(ipAddress1).build();
271 removeTerminatingServiceActionsInput = new RemoveTerminatingServiceActionsInputBuilder().setServiceId(vlanId)
272 .setDpnId(dpId1).build();
273 getTunnelInterfaceNameInput = new GetTunnelInterfaceNameInputBuilder().setTunnelType(tunnelType1)
274 .setSourceDpid(dpId1).setDestinationDpid(dpId2).build();
275 getExternalTunnelInterfaceNameInput = new GetExternalTunnelInterfaceNameInputBuilder().setTunnelType
276 (tunnelType1).setDestinationNode(destinationDevice).setSourceNode(sourceDevice).build();
277 iface = ItmUtils.buildTunnelInterface(dpId1,trunkInterfaceName, String.format("%s %s",
278 ItmUtils.convertTunnelTypetoString(tunnelType1), "Trunk Interface"),true,tunnelType1,tunnelEndPointsVxlan.getIpAddress()
279 ,ipAddress1,gtwyIp1,tunnelEndPointsVxlan.getVLANID(),false,false,null);
280 subnetsTest = new SubnetsBuilder().setGatewayIp(gtwyIp1).setVlanId(vlanId).setKey(new SubnetsKey(ipPrefixTest))
281 .setDeviceVteps(deviceVtepsList).build();
282 subnetsList.add(subnetsTest);
283 transportZone = new TransportZoneBuilder().setZoneName(transportZone1).setTunnelType(tunnelType1).setKey(new
284 TransportZoneKey(transportZone1)).setSubnets(subnetsList).build();
285 transportZoneList.add(transportZone);
286 transportZones = new TransportZonesBuilder().setTransportZone(transportZoneList).build();
287 doReturn(mockReadTx).when(dataBroker).newReadOnlyTransaction();
288 doReturn(mockWriteTx).when(dataBroker).newWriteOnlyTransaction();
289 doReturn(Futures.immediateCheckedFuture(null)).when(mockWriteTx).submit();
293 public void testGetInternalOrExternalInterfaceNameExtTunnelPresent(){
295 itmManagerRpcService.getInternalOrExternalInterfaceName(getInternalOrExternalInterfaceNameInput);
297 verify(mockReadTx).read(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifier);
302 public void testGetInternalOrExternalInterfaceNameExtTunnelAbsent(){
304 doReturn(Futures.immediateCheckedFuture(Optional.absent())).when(mockReadTx).read(LogicalDatastoreType
305 .CONFIGURATION,externalTunnelIdentifier);
307 itmManagerRpcService.getInternalOrExternalInterfaceName(getInternalOrExternalInterfaceNameInput);
309 verify(mockReadTx).read(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifier);
310 verify(mockReadTx).read(LogicalDatastoreType.CONFIGURATION,internalTunnelIdentifierNew);
315 public void testAddExternalTunnelEndpoint(){
317 externalTunnelNew = ItmUtils.buildExternalTunnel( dpId1.toString(), ipAddress1.toString(),
318 tunnelType1, trunkInterfaceName);
320 itmManagerRpcService.addExternalTunnelEndpoint(addExternalTunnelEndpointInput);
322 verify(mockWriteTx).merge(LogicalDatastoreType.CONFIGURATION,interfaceIdentifier,iface,true);
323 verify(mockWriteTx).merge(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifierNew,externalTunnelNew,true);
328 public void testAddL2GwDevice(){
330 itmManagerRpcService.addL2GwDevice(addL2GwDeviceInput);
332 verify(mockWriteTx).put(LogicalDatastoreType.CONFIGURATION, deviceVtepsIdentifier, deviceVteps, true);
337 public void testAddL2GwMlagDevice(){
339 itmManagerRpcService.addL2GwMlagDevice(addL2GwMlagDeviceInput);
341 verify(mockWriteTx).put(LogicalDatastoreType.CONFIGURATION, deviceVtepsIdentifier, deviceVteps, true);
346 public void testDeleteL2GwDevice(){
348 itmManagerRpcService.deleteL2GwDevice(deleteL2GwDeviceInput);
350 verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,deviceVtepsIdentifier);
355 public void testDeleteL2GwMlagDevice(){
357 itmManagerRpcService.deleteL2GwMlagDevice(deleteL2GwMlagDeviceInput);
359 verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,deviceVtepsIdentifier);
364 public void testBuildExternalTunnelFromDpns(){
366 externalTunnelNew = ItmUtils.buildExternalTunnel( dpId1.toString(), ipAddress1.toString(),
367 tunnelType1, trunkInterfaceName);
369 itmManagerRpcService.buildExternalTunnelFromDpns(buildExternalTunnelFromDpnsInput);
371 verify(mockWriteTx).merge(LogicalDatastoreType.CONFIGURATION,interfaceIdentifier,iface,true);
372 verify(mockWriteTx).merge(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifierNew,externalTunnelNew,true);
377 public void testRemoveExternalTunnelFromDpns(){
379 itmManagerRpcService.removeExternalTunnelFromDpns(removeExternalTunnelFromDpnsInput);
381 verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,interfaceIdentifier);
382 verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifierNew);
387 public void testRemoveExternalTunnelEndpoint(){
389 itmManagerRpcService.removeExternalTunnelEndpoint(removeExternalTunnelEndpointInput);
391 verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,interfaceIdentifier);
392 verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifierNew);
397 public void testGetTunnelInterfaceName(){
399 itmManagerRpcService.getTunnelInterfaceName(getTunnelInterfaceNameInput);
401 verify(mockReadTx).read(LogicalDatastoreType.CONFIGURATION,internalTunnelIdentifier);
406 public void testGetExternalTunnelInterfaceName(){
408 itmManagerRpcService.getExternalTunnelInterfaceName(getExternalTunnelInterfaceNameInput);
410 verify(mockReadTx).read(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifier1);