vpnmanager/vpnmanager-impl/src/main/java/org/opendaylight/vpnservice/VpnUtil.java

   1 /*
   2  * Copyright (c) 2015 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
   9 package org.opendaylight.vpnservice;
  10
  11 import java.util.List;
  12 import java.util.concurrent.ExecutionException;
  13 import java.util.concurrent.Future;
  14
  15 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.VpnInterfaces;
  16 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances.VpnInstance;
  17 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.VpnInstances;
  18 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances.VpnInstanceKey;
  19 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.interfaces.VpnInterface;
  20 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.interfaces.VpnInterfaceKey;
  21 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.interfaces.VpnInterfaceBuilder;
  22 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.Interfaces;
  23 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
  24 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceKey;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.l3vpn.rev130911.adjacency.list.Adjacency;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.l3vpn.rev130911.Adjacencies;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.l3vpn.rev130911.AdjacenciesBuilder;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.IdPools;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.id.pools.IdPool;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.id.pools.IdPoolKey;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.AllocateIdInput;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.AllocateIdInputBuilder;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.AllocateIdOutput;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.ReleaseIdInput;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.ReleaseIdInputBuilder;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.IdManagerService;
  37 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  38 import org.opendaylight.yangtools.yang.common.RpcResult;
  39 import org.slf4j.Logger;
  40 import org.slf4j.LoggerFactory;
  41
  42 public class VpnUtil {
  43
  44     private static final Logger LOG = LoggerFactory.getLogger(VpnUtil.class);
  45     private static final int DEFAULT_PREFIX_LENGTH = 32;
  46     private static final String PREFIX_SEPARATOR = "/";
  47
  48     static InstanceIdentifier<VpnInterface> getVpnInterfaceIdentifier(String vpnInterfaceName) {
  49         return InstanceIdentifier.builder(VpnInterfaces.class)
  50                 .child(VpnInterface.class, new VpnInterfaceKey(vpnInterfaceName)).build();
  51     }
  52
  53     static InstanceIdentifier<VpnInstance> getVpnInstanceIdentifier(String vpnName) {
  54         return InstanceIdentifier.builder(VpnInstances.class)
  55                 .child(VpnInstance.class, new VpnInstanceKey(vpnName)).build();
  56     }
  57
  58     static VpnInterface getVpnInterface(String intfName, String vpnName, Adjacencies aug) {
  59         return new VpnInterfaceBuilder().setKey(new VpnInterfaceKey(intfName)).setVpnInstanceName(vpnName)
  60                 .addAugmentation(Adjacencies.class, aug).build();
  61     }
  62
  63     static Adjacencies getVpnInterfaceAugmentation(List<Adjacency> nextHops) {
  64         return new AdjacenciesBuilder().setAdjacency(nextHops).build();
  65     }
  66
  67     public static InstanceIdentifier<IdPool> getPoolId(String poolName){
  68         InstanceIdentifier.InstanceIdentifierBuilder<IdPool> idBuilder =
  69                         InstanceIdentifier.builder(IdPools.class).child(IdPool.class, new IdPoolKey(poolName));
  70         InstanceIdentifier<IdPool> id = idBuilder.build();
  71         return id;
  72     }
  73
  74     static InstanceIdentifier<VpnInterfaces> getVpnInterfacesIdentifier() {
  75         return InstanceIdentifier.builder(VpnInterfaces.class).build();
  76     }
  77
  78     static InstanceIdentifier<Interface> getInterfaceIdentifier(String interfaceName) {
  79         return InstanceIdentifier.builder(Interfaces.class)
  80                 .child(Interface.class, new InterfaceKey(interfaceName)).build();
  81     }
  82
  83     public static String getNextHopLabelKey(String rd, String prefix){
  84         String key = rd + VpnConstants.SEPARATOR + prefix;
  85         return key;
  86     }
  87
  88     static String getIpPrefix(String prefix) {
  89         String prefixValues[] = prefix.split("/");
  90         if (prefixValues.length == 1) {
  91             prefix = prefix + PREFIX_SEPARATOR + DEFAULT_PREFIX_LENGTH ;
  92         }
  93         return prefix;
  94     }
  95
  96     public static int getUniqueId(IdManagerService idManager, String poolName,String idKey) {
  97         AllocateIdInput getIdInput = new AllocateIdInputBuilder()
  98                 .setPoolName(poolName)
  99                 .setIdKey(idKey).build();
 100
 101         try {
 102             Future<RpcResult<AllocateIdOutput>> result = idManager.allocateId(getIdInput);
 103             RpcResult<AllocateIdOutput> rpcResult = result.get();
 104             if(rpcResult.isSuccessful()) {
 105                 return rpcResult.getResult().getIdValue().intValue();
 106             } else {
 107                 LOG.warn("RPC Call to Get Unique Id returned with Errors {}", rpcResult.getErrors());
 108             }
 109         } catch (InterruptedException | ExecutionException e) {
 110             LOG.warn("Exception when getting Unique Id",e);
 111         }
 112         return 0;
 113     }
 114 }