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 throw new UnsupportedOperationException("TODO");
123 public synchronized Future<RpcResult<GetTunnelInterfaceNameOutput>> getTunnelInterfaceName(
124 GetTunnelInterfaceNameInput input) {
125 String interfaceName = interfaceNames.get(input.getSourceDpid())
126 .get(new String(tepIps.get(input.getDestinationDpid()).getValue()));
127 GetTunnelInterfaceNameOutput output =
128 new GetTunnelInterfaceNameOutputBuilder().setInterfaceName(interfaceName).build();
129 return RpcResultBuilder.success(output).buildFuture();
133 public synchronized Future<RpcResult<IsDcgwPresentOutput>> isDcgwPresent(IsDcgwPresentInput input) {
134 IsDcgwPresentOutput output = new IsDcgwPresentOutputBuilder().setRetVal(0L).build();
135 return RpcResultBuilder.success(output).buildFuture();
139 public synchronized Future<RpcResult<GetExternalTunnelInterfaceNameOutput>> getExternalTunnelInterfaceName(
140 GetExternalTunnelInterfaceNameInput input) {
141 String interfaceName = externalInterfaceNames.get(new BigInteger(input.getSourceNode(), 10))
142 .get(input.getDestinationNode());
143 GetExternalTunnelInterfaceNameOutput output = new GetExternalTunnelInterfaceNameOutputBuilder()
144 .setInterfaceName(interfaceName)
146 return RpcResultBuilder.success(output).buildFuture();
150 public synchronized Future<RpcResult<Void>> createTerminatingServiceActions(
151 CreateTerminatingServiceActionsInput input) {
152 return RpcResultBuilder.<Void>success().buildFuture();
156 public synchronized Future<RpcResult<GetDpnEndpointIpsOutput>> getDpnEndpointIps(GetDpnEndpointIpsInput input) {
157 GetDpnEndpointIpsOutput output = new GetDpnEndpointIpsOutputBuilder()
158 .setNexthopipList(Lists.newArrayList(tepIps.get(input.getSourceDpid()))).build();
159 return RpcResultBuilder.success(output).buildFuture();
163 public synchronized Future<RpcResult<Void>> deleteL2GwMlagDevice(DeleteL2GwMlagDeviceInput input) {
164 return RpcResultBuilder.<Void>success().buildFuture();
168 public synchronized Future<RpcResult<GetInternalOrExternalInterfaceNameOutput>> getInternalOrExternalInterfaceName(
169 GetInternalOrExternalInterfaceNameInput input) {
170 throw new UnsupportedOperationException("TODO");
174 public synchronized Future<RpcResult<Void>> removeTerminatingServiceActions(
175 RemoveTerminatingServiceActionsInput input) {
176 return RpcResultBuilder.<Void>success().buildFuture();
180 public synchronized Future<RpcResult<Void>> addExternalTunnelEndpoint(AddExternalTunnelEndpointInput input) {
181 return RpcResultBuilder.<Void>success().buildFuture();
185 public synchronized Future<RpcResult<Void>> setBfdEnableOnTunnel(SetBfdEnableOnTunnelInput input) {
186 throw new UnsupportedOperationException("TODO");
190 public synchronized Future<RpcResult<GetEgressActionsForTunnelOutput>>
191 getEgressActionsForTunnel(GetEgressActionsForTunnelInput input) {
192 throw new UnsupportedOperationException("TODO");
196 public synchronized Future<RpcResult<GetTunnelTypeOutput>> getTunnelType(GetTunnelTypeInput input) {
197 throw new UnsupportedOperationException("TODO");