2 * Copyright © 2017 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.testutils.itm;
10 import com.google.common.collect.Lists;
11 import java.math.BigInteger;
13 import java.util.concurrent.ConcurrentHashMap;
14 import java.util.concurrent.Future;
15 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
16 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.AddExternalTunnelEndpointInput;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.AddL2GwDeviceInput;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.AddL2GwMlagDeviceInput;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.BuildExternalTunnelFromDpnsInput;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.CreateTerminatingServiceActionsInput;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.DeleteL2GwDeviceInput;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.DeleteL2GwMlagDeviceInput;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetDpnEndpointIpsInput;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetDpnEndpointIpsOutput;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetDpnEndpointIpsOutputBuilder;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetDpnInfoInput;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetDpnInfoOutput;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetEgressActionsForTunnelInput;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetEgressActionsForTunnelOutput;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetExternalTunnelInterfaceNameInput;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetExternalTunnelInterfaceNameOutput;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetExternalTunnelInterfaceNameOutputBuilder;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetInternalOrExternalInterfaceNameInput;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetInternalOrExternalInterfaceNameOutput;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetTunnelInterfaceNameInput;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetTunnelInterfaceNameOutput;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetTunnelInterfaceNameOutputBuilder;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetTunnelTypeInput;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetTunnelTypeOutput;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.IsDcgwPresentInput;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.IsDcgwPresentOutput;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.IsDcgwPresentOutputBuilder;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.IsTunnelInternalOrExternalInput;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.IsTunnelInternalOrExternalOutput;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.RemoveExternalTunnelEndpointInput;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.RemoveExternalTunnelFromDpnsInput;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.RemoveTerminatingServiceActionsInput;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.SetBfdEnableOnTunnelInput;
52 import org.opendaylight.yangtools.yang.common.RpcResult;
53 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
55 public final class ItmRpcTestImpl implements ItmRpcService {
57 private final Map<BigInteger, IpAddress> tepIps = new ConcurrentHashMap<>();
58 private final Map<BigInteger, Map<String, String>> interfaceNames = new ConcurrentHashMap<>();
59 private final Map<BigInteger, Map<String, String>> externalInterfaceNames = new ConcurrentHashMap<>();
61 public synchronized void addDpn(BigInteger dpnId, String tepIp) {
62 tepIps.put(dpnId, new IpAddress(new Ipv4Address(tepIp)));
65 public synchronized void addInterface(BigInteger dpnId, String dstTep, String interfaceName) {
66 interfaceNames.putIfAbsent(dpnId, new ConcurrentHashMap<>());
67 interfaceNames.get(dpnId).put(dstTep, interfaceName);
70 public synchronized void addL2GwInterface(BigInteger dpnId, String nodeId, String interfaceName) {
71 externalInterfaceNames.putIfAbsent(dpnId, new ConcurrentHashMap<>());
72 externalInterfaceNames.get(dpnId).put(nodeId, interfaceName);
75 public synchronized void addExternalInterface(BigInteger dpnId, String dstTep, String interfaceName) {
76 dstTep = new IpAddress(new Ipv4Address(dstTep)).toString();
77 externalInterfaceNames.putIfAbsent(dpnId, new ConcurrentHashMap<>());
78 externalInterfaceNames.get(dpnId).put(dstTep, interfaceName);
82 public synchronized Future<RpcResult<Void>> buildExternalTunnelFromDpns(BuildExternalTunnelFromDpnsInput input) {
83 return RpcResultBuilder.<Void>success().buildFuture();
87 public synchronized Future<RpcResult<Void>> removeExternalTunnelEndpoint(RemoveExternalTunnelEndpointInput input) {
88 return RpcResultBuilder.<Void>success().buildFuture();
92 public Future<RpcResult<GetDpnInfoOutput>> getDpnInfo(GetDpnInfoInput input) {
93 throw new UnsupportedOperationException("getDpnInfo");
97 public synchronized Future<RpcResult<Void>> addL2GwMlagDevice(AddL2GwMlagDeviceInput input) {
98 return RpcResultBuilder.<Void>success().buildFuture();
102 public synchronized Future<RpcResult<Void>> removeExternalTunnelFromDpns(RemoveExternalTunnelFromDpnsInput input) {
103 return RpcResultBuilder.<Void>success().buildFuture();
107 public synchronized Future<RpcResult<Void>> deleteL2GwDevice(DeleteL2GwDeviceInput input) {
108 return RpcResultBuilder.<Void>success().buildFuture();
112 public synchronized Future<RpcResult<Void>> addL2GwDevice(AddL2GwDeviceInput input) {
113 return RpcResultBuilder.<Void>success().buildFuture();
117 public synchronized Future<RpcResult<IsTunnelInternalOrExternalOutput>> isTunnelInternalOrExternal(
118 IsTunnelInternalOrExternalInput input) {
119 IsTunnelInternalOrExternalOutput output = null;
120 return RpcResultBuilder.success(output).buildFuture();
124 public synchronized Future<RpcResult<GetTunnelInterfaceNameOutput>> getTunnelInterfaceName(
125 GetTunnelInterfaceNameInput input) {
126 String interfaceName = interfaceNames.get(input.getSourceDpid())
127 .get(new String(tepIps.get(input.getDestinationDpid()).getValue()));
128 GetTunnelInterfaceNameOutput output =
129 new GetTunnelInterfaceNameOutputBuilder().setInterfaceName(interfaceName).build();
130 return RpcResultBuilder.success(output).buildFuture();
134 public synchronized Future<RpcResult<IsDcgwPresentOutput>> isDcgwPresent(IsDcgwPresentInput input) {
135 IsDcgwPresentOutput output = new IsDcgwPresentOutputBuilder().setRetVal(0L).build();
136 return RpcResultBuilder.success(output).buildFuture();
140 public synchronized Future<RpcResult<GetExternalTunnelInterfaceNameOutput>> getExternalTunnelInterfaceName(
141 GetExternalTunnelInterfaceNameInput input) {
142 String interfaceName = externalInterfaceNames.get(new BigInteger(input.getSourceNode(), 10))
143 .get(input.getDestinationNode());
144 GetExternalTunnelInterfaceNameOutput output = new GetExternalTunnelInterfaceNameOutputBuilder()
145 .setInterfaceName(interfaceName)
147 return RpcResultBuilder.success(output).buildFuture();
151 public synchronized Future<RpcResult<Void>> createTerminatingServiceActions(
152 CreateTerminatingServiceActionsInput input) {
153 return RpcResultBuilder.<Void>success().buildFuture();
157 public synchronized Future<RpcResult<GetDpnEndpointIpsOutput>> getDpnEndpointIps(GetDpnEndpointIpsInput input) {
158 GetDpnEndpointIpsOutput output = new GetDpnEndpointIpsOutputBuilder()
159 .setNexthopipList(Lists.newArrayList(tepIps.get(input.getSourceDpid()))).build();
160 return RpcResultBuilder.success(output).buildFuture();
164 public synchronized Future<RpcResult<Void>> deleteL2GwMlagDevice(DeleteL2GwMlagDeviceInput input) {
165 return RpcResultBuilder.<Void>success().buildFuture();
169 public synchronized Future<RpcResult<GetInternalOrExternalInterfaceNameOutput>> getInternalOrExternalInterfaceName(
170 GetInternalOrExternalInterfaceNameInput input) {
171 GetInternalOrExternalInterfaceNameOutput output = null;
172 return RpcResultBuilder.success(output).buildFuture();
176 public synchronized Future<RpcResult<Void>> removeTerminatingServiceActions(
177 RemoveTerminatingServiceActionsInput input) {
178 return RpcResultBuilder.<Void>success().buildFuture();
182 public synchronized Future<RpcResult<Void>> addExternalTunnelEndpoint(AddExternalTunnelEndpointInput input) {
183 return RpcResultBuilder.<Void>success().buildFuture();
187 public synchronized Future<RpcResult<Void>> setBfdEnableOnTunnel(SetBfdEnableOnTunnelInput input) {
192 public synchronized Future<RpcResult<GetEgressActionsForTunnelOutput>>
193 getEgressActionsForTunnel(GetEgressActionsForTunnelInput input) {
198 public synchronized Future<RpcResult<GetTunnelTypeOutput>> getTunnelType(GetTunnelTypeInput input) {