commons/testutils/src/main/java/org/opendaylight/genius/testutils/itm/ItmRpcTestImpl.java

   1 /*
   2  * Copyright © 2017 Ericsson India Global Services Pvt Ltd. and others.  All rights reserved.
   3  *
   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
   7  */
   8 package org.opendaylight.genius.testutils.itm;
   9
  10 import com.google.common.collect.Lists;
  11 import java.math.BigInteger;
  12 import java.util.Map;
  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;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetExternalTunnelInterfaceNameInput;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetExternalTunnelInterfaceNameOutput;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetExternalTunnelInterfaceNameOutputBuilder;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetInternalOrExternalInterfaceNameInput;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetInternalOrExternalInterfaceNameOutput;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetTunnelInterfaceNameInput;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetTunnelInterfaceNameOutput;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.GetTunnelInterfaceNameOutputBuilder;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.IsDcgwPresentInput;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.IsDcgwPresentOutput;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.IsDcgwPresentOutputBuilder;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.IsTunnelInternalOrExternalInput;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.IsTunnelInternalOrExternalOutput;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.RemoveExternalTunnelEndpointInput;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.RemoveExternalTunnelFromDpnsInput;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.RemoveTerminatingServiceActionsInput;
  44 import org.opendaylight.yangtools.yang.common.RpcResult;
  45 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  46
  47 public final class ItmRpcTestImpl implements ItmRpcService {
  48
  49     private final Map<BigInteger, IpAddress> tepIps = new ConcurrentHashMap<>();
  50     private final Map<BigInteger, Map<String, String>> interfaceNames = new ConcurrentHashMap<>();
  51     private final Map<BigInteger, Map<String, String>> externalInterfaceNames = new ConcurrentHashMap<>();
  52
  53     public synchronized void addDpn(BigInteger dpnId, String tepIp) {
  54         tepIps.put(dpnId, new IpAddress(new Ipv4Address(tepIp)));
  55     }
  56
  57     public synchronized void addInterface(BigInteger dpnId, String dstTep, String interfaceName) {
  58         interfaceNames.putIfAbsent(dpnId, new ConcurrentHashMap<>());
  59         interfaceNames.get(dpnId).put(dstTep, interfaceName);
  60     }
  61
  62     public synchronized void addExternalInterface(BigInteger dpnId, String dstTep, String interfaceName) {
  63         dstTep = new IpAddress(new Ipv4Address(dstTep)).toString();
  64         externalInterfaceNames.putIfAbsent(dpnId, new ConcurrentHashMap<>());
  65         externalInterfaceNames.get(dpnId).put(dstTep, interfaceName);
  66     }
  67
  68     @Override
  69     public synchronized Future<RpcResult<Void>> buildExternalTunnelFromDpns(BuildExternalTunnelFromDpnsInput input) {
  70         return RpcResultBuilder.<Void>success().buildFuture();
  71     }
  72
  73     @Override
  74     public synchronized Future<RpcResult<Void>> removeExternalTunnelEndpoint(RemoveExternalTunnelEndpointInput input) {
  75         return RpcResultBuilder.<Void>success().buildFuture();
  76     }
  77
  78     @Override
  79     public synchronized Future<RpcResult<Void>> addL2GwMlagDevice(AddL2GwMlagDeviceInput input) {
  80         return RpcResultBuilder.<Void>success().buildFuture();
  81     }
  82
  83     @Override
  84     public synchronized Future<RpcResult<Void>> removeExternalTunnelFromDpns(RemoveExternalTunnelFromDpnsInput input) {
  85         return RpcResultBuilder.<Void>success().buildFuture();
  86     }
  87
  88     @Override
  89     public synchronized Future<RpcResult<Void>> deleteL2GwDevice(DeleteL2GwDeviceInput input) {
  90         return RpcResultBuilder.<Void>success().buildFuture();
  91     }
  92
  93     @Override
  94     public synchronized Future<RpcResult<Void>> addL2GwDevice(AddL2GwDeviceInput input) {
  95         return RpcResultBuilder.<Void>success().buildFuture();
  96     }
  97
  98     @Override
  99     public synchronized Future<RpcResult<IsTunnelInternalOrExternalOutput>> isTunnelInternalOrExternal(
 100             IsTunnelInternalOrExternalInput input) {
 101         IsTunnelInternalOrExternalOutput output = null;
 102         return RpcResultBuilder.success(output).buildFuture();
 103     }
 104
 105     @Override
 106     public synchronized Future<RpcResult<GetTunnelInterfaceNameOutput>> getTunnelInterfaceName(
 107             GetTunnelInterfaceNameInput input) {
 108         String interfaceName = interfaceNames.get(input.getSourceDpid())
 109                 .get(new String(tepIps.get(input.getDestinationDpid()).getValue()));
 110         GetTunnelInterfaceNameOutput output =
 111                 new GetTunnelInterfaceNameOutputBuilder().setInterfaceName(interfaceName).build();
 112         return RpcResultBuilder.success(output).buildFuture();
 113     }
 114
 115     @Override
 116     public synchronized Future<RpcResult<IsDcgwPresentOutput>> isDcgwPresent(IsDcgwPresentInput input) {
 117         IsDcgwPresentOutput output = new IsDcgwPresentOutputBuilder().setRetVal(0L).build();
 118         return RpcResultBuilder.success(output).buildFuture();
 119     }
 120
 121     @Override
 122     public synchronized Future<RpcResult<GetExternalTunnelInterfaceNameOutput>> getExternalTunnelInterfaceName(
 123             GetExternalTunnelInterfaceNameInput input) {
 124         String interfaceName = externalInterfaceNames.get(new BigInteger(input.getSourceNode(), 10))
 125                 .get(input.getDestinationNode());
 126         GetExternalTunnelInterfaceNameOutput output = new GetExternalTunnelInterfaceNameOutputBuilder()
 127                 .setInterfaceName(interfaceName)
 128                 .build();
 129         return RpcResultBuilder.success(output).buildFuture();
 130     }
 131
 132     @Override
 133     public synchronized Future<RpcResult<Void>> createTerminatingServiceActions(
 134             CreateTerminatingServiceActionsInput input) {
 135         return RpcResultBuilder.<Void>success().buildFuture();
 136     }
 137
 138     @Override
 139     public synchronized Future<RpcResult<GetDpnEndpointIpsOutput>> getDpnEndpointIps(GetDpnEndpointIpsInput input) {
 140         GetDpnEndpointIpsOutput output = new GetDpnEndpointIpsOutputBuilder()
 141                 .setNexthopipList(Lists.newArrayList(tepIps.get(input.getSourceDpid()))).build();
 142         return RpcResultBuilder.success(output).buildFuture();
 143     }
 144
 145     @Override
 146     public synchronized Future<RpcResult<Void>> deleteL2GwMlagDevice(DeleteL2GwMlagDeviceInput input) {
 147         return RpcResultBuilder.<Void>success().buildFuture();
 148     }
 149
 150     @Override
 151     public synchronized Future<RpcResult<GetInternalOrExternalInterfaceNameOutput>> getInternalOrExternalInterfaceName(
 152             GetInternalOrExternalInterfaceNameInput input) {
 153         GetInternalOrExternalInterfaceNameOutput output = null;
 154         return RpcResultBuilder.success(output).buildFuture();
 155     }
 156
 157     @Override
 158     public synchronized Future<RpcResult<Void>> removeTerminatingServiceActions(
 159             RemoveTerminatingServiceActionsInput input) {
 160         return RpcResultBuilder.<Void>success().buildFuture();
 161     }
 162
 163     @Override
 164     public synchronized Future<RpcResult<Void>> addExternalTunnelEndpoint(AddExternalTunnelEndpointInput input) {
 165         return RpcResultBuilder.<Void>success().buildFuture();
 166     }
 167 }