extension/openflowplugin-extension-nicira/src/main/java/org/opendaylight/openflowplugin/extension/vendor/nicira/convertor/match/MatchUtil.java

   1 /**
   2  * Copyright (c) 2014 Cisco Systems, Inc. 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.openflowplugin.extension.vendor.nicira.convertor.match;
   9
  10 import com.google.common.base.Joiner;
  11 import com.google.common.base.Splitter;
  12
  13 import com.google.common.primitives.Longs;
  14 import com.google.common.primitives.UnsignedBytes;
  15 import java.util.Iterator;
  16 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Address;
  17 import java.util.HashSet;
  18 import java.util.Set;
  19 import org.opendaylight.openflowplugin.extension.api.GroupingResolver;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.MatchField;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.OxmClassBase;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entries.grouping.MatchEntryBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.MatchEntryValue;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.general.rev140714.general.extension.grouping.Extension;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxAugMatchNodesNodeTableFlow;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxAugMatchNotifPacketIn;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxAugMatchNotifSwitchFlowRemoved;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxAugMatchNotifUpdateFlowStats;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxAugMatchRpcAddFlow;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxAugMatchRpcRemoveFlow;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxAugMatchRpcUpdateFlowOriginal;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxAugMatchRpcUpdateFlowUpdated;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmNxArpShaGrouping;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmNxArpThaGrouping;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmNxCtStateGrouping;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmNxCtZoneGrouping;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmNxNshc1Grouping;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmNxNshc2Grouping;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmNxNshc3Grouping;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmNxNshc4Grouping;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmNxNsiGrouping;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmNxNspGrouping;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmNxRegGrouping;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmNxTunIdGrouping;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmNxTunIpv4DstGrouping;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmNxTunIpv4SrcGrouping;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmOfArpOpGrouping;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmOfArpSpaGrouping;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmOfArpTpaGrouping;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmOfEthDstGrouping;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmOfEthSrcGrouping;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmOfEthTypeGrouping;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmOfTcpDstGrouping;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmOfTcpSrcGrouping;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmOfUdpDstGrouping;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.match.rev140714.NxmOfUdpSrcGrouping;
  57 import org.opendaylight.yangtools.yang.binding.Augmentation;
  58
  59 /**
  60  * @author msunal
  61  *
  62  */
  63 public class MatchUtil {
  64     private static final Splitter SPLITTER = Splitter.on('.');
  65     private static final Joiner JOINER = Joiner.on('.');
  66
  67     private final static Set<Class<? extends Augmentation<Extension>>> augmentationsOfExtension = new HashSet<>();
  68     public final static GroupingResolver<NxmNxRegGrouping, Extension> regResolver = new GroupingResolver<>(
  69             NxmNxRegGrouping.class);
  70     public final static GroupingResolver<NxmNxTunIdGrouping, Extension> tunIdResolver = new GroupingResolver<>(
  71             NxmNxTunIdGrouping.class);
  72     public final static GroupingResolver<NxmNxArpShaGrouping, Extension> arpShaResolver = new GroupingResolver<>(
  73             NxmNxArpShaGrouping.class);
  74     public final static GroupingResolver<NxmNxArpThaGrouping, Extension> arpThaResolver = new GroupingResolver<>(
  75             NxmNxArpThaGrouping.class);
  76     public final static GroupingResolver<NxmOfArpOpGrouping, Extension> arpOpResolver = new GroupingResolver<>(
  77             NxmOfArpOpGrouping.class);
  78     public final static GroupingResolver<NxmOfArpSpaGrouping, Extension> arpSpaResolver = new GroupingResolver<>(
  79             NxmOfArpSpaGrouping.class);
  80     public final static GroupingResolver<NxmOfArpTpaGrouping, Extension> arpTpaResolver = new GroupingResolver<>(
  81             NxmOfArpTpaGrouping.class);
  82     public final static GroupingResolver<NxmNxTunIpv4DstGrouping, Extension> tunIpv4DstResolver = new GroupingResolver<>(
  83             NxmNxTunIpv4DstGrouping.class);
  84     public final static GroupingResolver<NxmNxTunIpv4SrcGrouping, Extension> tunIpv4SrcResolver = new GroupingResolver<>(
  85             NxmNxTunIpv4SrcGrouping.class);
  86     public final static GroupingResolver<NxmOfEthDstGrouping, Extension> ethDstResolver = new GroupingResolver<>(
  87             NxmOfEthDstGrouping.class);
  88     public final static GroupingResolver<NxmOfEthSrcGrouping, Extension> ethSrcResolver = new GroupingResolver<>(
  89             NxmOfEthSrcGrouping.class);
  90     public final static GroupingResolver<NxmOfEthTypeGrouping, Extension> ethTypeResolver = new GroupingResolver<>(
  91             NxmOfEthTypeGrouping.class);
  92     public final static GroupingResolver<NxmNxNsiGrouping, Extension> nsiResolver = new GroupingResolver<>(
  93             NxmNxNsiGrouping.class);
  94     public final static GroupingResolver<NxmNxNspGrouping, Extension> nspResolver = new GroupingResolver<>(
  95             NxmNxNspGrouping.class);
  96     public final static GroupingResolver<NxmNxNshc1Grouping, Extension> nsc1Resolver = new GroupingResolver<>(
  97             NxmNxNshc1Grouping.class);
  98     public final static GroupingResolver<NxmNxNshc2Grouping, Extension> nsc2Resolver = new GroupingResolver<>(
  99             NxmNxNshc2Grouping.class);
 100     public final static GroupingResolver<NxmNxNshc3Grouping, Extension> nsc3Resolver = new GroupingResolver<>(
 101             NxmNxNshc3Grouping.class);
 102     public final static GroupingResolver<NxmNxNshc4Grouping, Extension> nsc4Resolver = new GroupingResolver<>(
 103             NxmNxNshc4Grouping.class);
 104     public final static GroupingResolver<NxmOfTcpSrcGrouping, Extension> tcpSrcResolver = new GroupingResolver<>(
 105             NxmOfTcpSrcGrouping.class);
 106     public final static GroupingResolver<NxmOfTcpDstGrouping, Extension> tcpDstResolver = new GroupingResolver<>(
 107             NxmOfTcpDstGrouping.class);
 108     public final static GroupingResolver<NxmOfUdpSrcGrouping, Extension> udpSrcResolver = new GroupingResolver<>(
 109             NxmOfUdpSrcGrouping.class);
 110     public final static GroupingResolver<NxmOfUdpDstGrouping, Extension> udpDstResolver = new GroupingResolver<>(
 111             NxmOfUdpDstGrouping.class);
 112     public final static GroupingResolver<NxmNxCtStateGrouping, Extension> ctStateResolver = new GroupingResolver<>(
 113             NxmNxCtStateGrouping.class);
 114     public final static GroupingResolver<NxmNxCtZoneGrouping, Extension> ctZoneResolver = new GroupingResolver<>(
 115             NxmNxCtZoneGrouping.class);
 116
 117
 118     static {
 119         augmentationsOfExtension.add(NxAugMatchRpcAddFlow.class);
 120         augmentationsOfExtension.add(NxAugMatchRpcRemoveFlow.class);
 121         augmentationsOfExtension.add(NxAugMatchRpcUpdateFlowOriginal.class);
 122         augmentationsOfExtension.add(NxAugMatchRpcUpdateFlowUpdated.class);
 123         augmentationsOfExtension.add(NxAugMatchNodesNodeTableFlow.class);
 124         augmentationsOfExtension.add(NxAugMatchNotifSwitchFlowRemoved.class);
 125         augmentationsOfExtension.add(NxAugMatchNotifPacketIn.class);
 126         augmentationsOfExtension.add(NxAugMatchNotifUpdateFlowStats.class);
 127         regResolver.setAugmentations(augmentationsOfExtension);
 128         tunIdResolver.setAugmentations(augmentationsOfExtension);
 129         arpShaResolver.setAugmentations(augmentationsOfExtension);
 130         arpThaResolver.setAugmentations(augmentationsOfExtension);
 131         arpOpResolver.setAugmentations(augmentationsOfExtension);
 132         arpSpaResolver.setAugmentations(augmentationsOfExtension);
 133         arpTpaResolver.setAugmentations(augmentationsOfExtension);
 134         tunIpv4DstResolver.setAugmentations(augmentationsOfExtension);
 135         tunIpv4SrcResolver.setAugmentations(augmentationsOfExtension);
 136         ethDstResolver.setAugmentations(augmentationsOfExtension);
 137         ethSrcResolver.setAugmentations(augmentationsOfExtension);
 138         ethTypeResolver.setAugmentations(augmentationsOfExtension);
 139         nspResolver.setAugmentations(augmentationsOfExtension);
 140         nsiResolver.setAugmentations(augmentationsOfExtension);
 141         nsc1Resolver.setAugmentations(augmentationsOfExtension);
 142         nsc2Resolver.setAugmentations(augmentationsOfExtension);
 143         nsc3Resolver.setAugmentations(augmentationsOfExtension);
 144         nsc4Resolver.setAugmentations(augmentationsOfExtension);
 145         tcpSrcResolver.setAugmentations(augmentationsOfExtension);
 146         tcpDstResolver.setAugmentations(augmentationsOfExtension);
 147         udpSrcResolver.setAugmentations(augmentationsOfExtension);
 148         udpDstResolver.setAugmentations(augmentationsOfExtension);
 149         ctStateResolver.setAugmentations(augmentationsOfExtension);
 150         ctZoneResolver.setAugmentations(augmentationsOfExtension);
 151
 152     }
 153
 154     public static MatchEntryBuilder createDefaultMatchEntryBuilder(Class<? extends MatchField> matchField,
 155                                                                    Class<? extends OxmClassBase> oxmClass,
 156                                                                    MatchEntryValue matchEntryValue){
 157         MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
 158         matchEntryBuilder.setHasMask(false);
 159         matchEntryBuilder.setOxmMatchField(matchField);
 160         matchEntryBuilder.setOxmClass(oxmClass);
 161         matchEntryBuilder.setMatchEntryValue(matchEntryValue);
 162         return matchEntryBuilder;
 163     }
 164
 165     public static Long ipv4ToLong(Ipv4Address ipv4) {
 166         Iterator<String> iterator = SPLITTER.split(ipv4.getValue()).iterator();
 167         byte[] bytes = new byte[8];
 168         for(int i =0;i < bytes.length;i++) {
 169             if(i<4) {
 170                 bytes[i] = 0;
 171             } else {
 172                 bytes[i] = UnsignedBytes.parseUnsignedByte((iterator.next()));
 173             }
 174         }
 175         Long result = Longs.fromByteArray(bytes);
 176         return result;
 177     }
 178
 179     public static Ipv4Address longToIpv4Address(Long l) {
 180         byte[] bytes = Longs.toByteArray(l);
 181         String[] strArray = new String[4];
 182         for(int i = 4;i < bytes.length;i++) {
 183             strArray[i-4]=UnsignedBytes.toString(bytes[i]);
 184         }
 185         String str = JOINER.join(strArray);
 186         Ipv4Address result = new Ipv4Address(str);
 187         return result;
 188     }
 189 }