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