interfacemgr/interfacemgr-impl/src/main/java/org/opendaylight/vpnservice/interfacemgr/IfmUtil.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 package org.opendaylight.vpnservice.interfacemgr;
   9
  10 import java.math.BigInteger;
  11 import java.util.ArrayList;
  12 import java.util.List;
  13 import java.util.concurrent.ExecutionException;
  14 import java.util.concurrent.Future;
  15
  16 import com.google.common.base.Optional;
  17 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  18 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
  19 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  20 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.Interfaces;
  21 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.InterfacesState;
  22 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
  23 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceKey;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.WriteMetadataCase;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.write.metadata._case.WriteMetadata;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.AllocateIdInput;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.AllocateIdInputBuilder;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.AllocateIdOutput;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.IdManagerService;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.IdPools;
  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.id.pools.IdPool;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.id.pools.IdPoolKey;
  38 import org.opendaylight.yangtools.yang.binding.DataObject;
  39 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  40 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier.InstanceIdentifierBuilder;
  41
  42 public class IfmUtil {
  43
  44     public static String getDpnFromNodeConnectorId(NodeConnectorId portId) {
  45         /*
  46          * NodeConnectorId is of form 'openflow:dpnid:portnum'
  47          */
  48         String[] split = portId.getValue().split(IfmConstants.OF_URI_SEPARATOR);
  49         return split[1];
  50     }
  51
  52     public static String getPortNoFromNodeConnectorId(NodeConnectorId portId) {
  53         /*
  54          * NodeConnectorId is of form 'openflow:dpnid:portnum'
  55          */
  56         String[] split = portId.getValue().split(IfmConstants.OF_URI_SEPARATOR);
  57         return split[2];
  58     }
  59
  60     public static NodeId buildDpnNodeId(BigInteger dpnId) {
  61         return new NodeId(IfmConstants.OF_URI_PREFIX + dpnId);
  62     }
  63
  64     public static InstanceIdentifier<Interface> buildId(String interfaceName) {
  65         //TODO Make this generic and move to AbstractDataChangeListener or Utils.
  66         InstanceIdentifierBuilder<Interface> idBuilder =
  67                 InstanceIdentifier.builder(Interfaces.class).child(Interface.class, new InterfaceKey(interfaceName));
  68         InstanceIdentifier<Interface> id = idBuilder.build();
  69         return id;
  70     }
  71
  72     public static InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface> buildStateInterfaceId(String interfaceName) {
  73         InstanceIdentifierBuilder<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface> idBuilder =
  74                 InstanceIdentifier.builder(InterfacesState.class)
  75                 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface.class,
  76                         new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceKey(interfaceName));
  77         InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface> id = idBuilder.build();
  78         return id;
  79     }
  80
  81     public static org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceKey getStateInterfaceKeyFromName(
  82                     String name) {
  83         return new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceKey(name);
  84     }
  85
  86     public static InstanceIdentifier<IdPool> getPoolId(String poolName){
  87         InstanceIdentifier.InstanceIdentifierBuilder<IdPool> idBuilder =
  88                         InstanceIdentifier.builder(IdPools.class).child(IdPool.class, new IdPoolKey(poolName));
  89         InstanceIdentifier<IdPool> id = idBuilder.build();
  90         return id;
  91     }
  92
  93     public static List<String> getPortNameAndSuffixFromInterfaceName(String intfName) {
  94         List<String> strList = new ArrayList<>(2);
  95         int index = intfName.indexOf(":");
  96         if (index != -1) {
  97             strList.add(0, intfName.substring(0, index));
  98             strList.add(1, intfName.substring(index));
  99         }
 100         return strList;
 101     }
 102
 103     public static List<String> getDpIdPortNameAndSuffixFromInterfaceName(String intfName) {
 104         List<String> strList = new ArrayList<>(3);
 105         int index1 = intfName.indexOf(":");
 106         if (index1 != -1) {
 107             int index2 = intfName.indexOf(":", index1 + 1 );
 108             strList.add(0, intfName.substring(0, index1));
 109             if (index2 != -1) {
 110                 strList.add(1, intfName.substring(index1, index2));
 111                 strList.add(2, intfName.substring(index2));
 112             } else {
 113                 strList.add(1, intfName.substring(index1));
 114                 strList.add(2, "");
 115             }
 116         }
 117         return strList;
 118     }
 119
 120     public static <T extends DataObject> Optional<T> read(LogicalDatastoreType datastoreType,
 121                                                           InstanceIdentifier<T> path, DataBroker broker) {
 122
 123         ReadOnlyTransaction tx = broker.newReadOnlyTransaction();
 124
 125         Optional<T> result = Optional.absent();
 126         try {
 127             result = tx.read(datastoreType, path).get();
 128         } catch (Exception e) {
 129             throw new RuntimeException(e);
 130         }
 131
 132         return result;
 133     }
 134
 135     public static NodeId getNodeIdFromNodeConnectorId(NodeConnectorId ncId) {
 136         return new NodeId(ncId.getValue().substring(0,ncId.getValue().lastIndexOf(":")));
 137     }
 138
 139     public static BigInteger[] mergeOpenflowMetadataWriteInstructions(List<Instruction> instructions) {
 140         BigInteger metadata = new BigInteger("0", 16);
 141         BigInteger metadataMask = new BigInteger("0", 16);
 142         if (instructions != null && !instructions.isEmpty()) {
 143             // check if metadata write instruction is present
 144             for (Instruction instruction : instructions) {
 145                 org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.Instruction actualInstruction = instruction.getInstruction();
 146                 if (actualInstruction instanceof WriteMetadataCase) {
 147                     WriteMetadataCase writeMetaDataInstruction = (WriteMetadataCase) actualInstruction ;
 148                     WriteMetadata availableMetaData = writeMetaDataInstruction.getWriteMetadata();
 149                     metadata = metadata.or(availableMetaData.getMetadata());
 150                     metadataMask = metadataMask.or(availableMetaData.getMetadataMask());
 151                 }
 152             }
 153         }
 154         return new BigInteger[] { metadata, metadataMask };
 155     }
 156
 157
 158
 159 }