openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/sal/convertor/action/ActionSetNwSrcReactorMappingFactory.java

   1 /**
   2  * Copyright (c) 2013 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
   9 package org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.action;
  10
  11 import java.util.ArrayList;
  12 import java.util.Iterator;
  13 import java.util.List;
  14 import java.util.Map;
  15 import org.opendaylight.openflowplugin.api.OFConstants;
  16 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.common.IpConversionUtil;
  17 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.common.Convertor;
  18 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.common.InjectionKey;
  19 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.common.InjectionResultTargetKey;
  20 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.common.ResultInjector;
  21 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
  22 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Address;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.SetNwSrcActionCase;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.action.choice.SetFieldCaseBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.action.choice.SetNwSrcCaseBuilder;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.action.choice.set.field._case.SetFieldActionBuilder;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.action.choice.set.nw.src._case.SetNwSrcActionBuilder;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Ipv4Src;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Ipv6Src;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.OpenflowBasicClass;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entries.grouping.MatchEntry;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entries.grouping.MatchEntryBuilder;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Ipv4SrcCaseBuilder;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Ipv6SrcCaseBuilder;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ipv4.src._case.Ipv4SrcBuilder;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ipv6.src._case.Ipv6SrcBuilder;
  38
  39 /**
  40  * add prepared convertors and injectors into given mappings
  41  *
  42  * @see ActionSetNwSrcReactor
  43  */
  44 public class ActionSetNwSrcReactorMappingFactory {
  45
  46     /**
  47      * @param conversionMapping conversion mapping
  48      */
  49     public static void addSetNwSrcConvertors(final Map<Short, Convertor<SetNwSrcActionCase, ?>> conversionMapping) {
  50         conversionMapping.put(OFConstants.OFP_VERSION_1_0, new ActionSetNwSrcConvertorV10Impl());
  51         conversionMapping.put(OFConstants.OFP_VERSION_1_3, new ActionSetNwSrcConvertorImpl());
  52     }
  53
  54     /**
  55      * @param injectionMapping injection mapping
  56      */
  57     public static void addSetNwSrcInjectors(final Map<InjectionKey, ResultInjector<?, ?>> injectionMapping) {
  58         // OF-1.0| Ipv4Address -> ActionBuilder; SetNwSrc
  59         injectionMapping.put(new InjectionResultTargetKey(OFConstants.OFP_VERSION_1_0,
  60                         ActionBuilder.class, Ipv4Address.class),
  61                 new ResultInjector<Ipv4Address, ActionBuilder>() {
  62                     @Override
  63                     public void inject(final Ipv4Address result, final ActionBuilder target) {
  64                         SetNwSrcCaseBuilder nwSrcCaseBuilder = new SetNwSrcCaseBuilder();
  65                         SetNwSrcActionBuilder nwSrcBuilder = new SetNwSrcActionBuilder();
  66                         nwSrcBuilder.setIpAddress(new Ipv4Address(result));
  67                         nwSrcCaseBuilder.setSetNwSrcAction(nwSrcBuilder.build());
  68                         target.setActionChoice(nwSrcCaseBuilder.build());
  69                     }
  70                 });
  71
  72         // OF-1.3| Ipv4Address -> ActionBuilder; SetNwSrc
  73         injectionMapping.put(new InjectionResultTargetKey(OFConstants.OFP_VERSION_1_3,
  74                         ActionBuilder.class, Ipv4Address.class),
  75                 new ResultInjector<Ipv4Address, ActionBuilder>() {
  76                     @Override
  77                     public void inject(final Ipv4Address result, final ActionBuilder target) {
  78                         SetFieldCaseBuilder setFieldCaseBuilder = new SetFieldCaseBuilder();
  79                         SetFieldActionBuilder setFieldBuilder = new SetFieldActionBuilder();
  80                         List<MatchEntry> entries = new ArrayList<>();
  81                         MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
  82                         matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
  83                         matchEntryBuilder.setOxmMatchField(Ipv4Src.class);
  84
  85                         Ipv4SrcCaseBuilder ipv4SrcCaseBuilder = new Ipv4SrcCaseBuilder();
  86                         Ipv4SrcBuilder ipv4SrcBuilder = new Ipv4SrcBuilder();
  87                         ipv4SrcBuilder.setIpv4Address(result);
  88                         Integer prefix = IpConversionUtil.extractPrefix(result);
  89                         if (prefix != null) {
  90                             ipv4SrcBuilder.setMask(IpConversionUtil.convertIpv6PrefixToByteArray(prefix));
  91                         }
  92                         ipv4SrcCaseBuilder.setIpv4Src(ipv4SrcBuilder.build());
  93
  94                         matchEntryBuilder.setHasMask(false);
  95                         matchEntryBuilder.setMatchEntryValue(ipv4SrcCaseBuilder.build());
  96                         entries.add(matchEntryBuilder.build());
  97                         setFieldBuilder.setMatchEntry(entries);
  98                         setFieldCaseBuilder.setSetFieldAction(setFieldBuilder.build());
  99                         target.setActionChoice(setFieldCaseBuilder.build());
 100                     }
 101                 });
 102
 103         // OF-1.3| Ipv6Address -> ActionBuilder; SetNwSrc
 104         injectionMapping.put(new InjectionResultTargetKey(OFConstants.OFP_VERSION_1_3,
 105                         ActionBuilder.class, Ipv6Address.class),
 106                 new ResultInjector<Ipv6Address, ActionBuilder>() {
 107                     @Override
 108                     public void inject(final Ipv6Address result, final ActionBuilder target) {
 109                         List<MatchEntry> matchEntriesList = new ArrayList<>();
 110                         MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
 111                         matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
 112                         matchEntryBuilder.setOxmMatchField(Ipv6Src.class);
 113
 114                         Ipv6SrcCaseBuilder ipv6SrcCaseBuilder = new Ipv6SrcCaseBuilder();
 115                         Ipv6SrcBuilder ipv6SrcBuilder = new Ipv6SrcBuilder();
 116                         ipv6SrcBuilder.setIpv6Address(result);
 117                         Integer prefix = IpConversionUtil.extractPrefix(result);
 118                         if (prefix != null) {
 119                             ipv6SrcBuilder.setMask(IpConversionUtil.convertIpv6PrefixToByteArray(prefix));
 120                         }
 121                         ipv6SrcCaseBuilder.setIpv6Src(ipv6SrcBuilder.build());
 122
 123                         matchEntryBuilder.setHasMask(false);
 124                         matchEntryBuilder.setMatchEntryValue(ipv6SrcCaseBuilder.build());
 125                         matchEntriesList.add(matchEntryBuilder.build());
 126
 127                         SetFieldCaseBuilder setFieldCaseBuilder = new SetFieldCaseBuilder();
 128                         SetFieldActionBuilder setFieldActionBuilder = new SetFieldActionBuilder();
 129                         setFieldActionBuilder.setMatchEntry(matchEntriesList);
 130                         setFieldCaseBuilder.setSetFieldAction(setFieldActionBuilder.build());
 131                         target.setActionChoice(setFieldCaseBuilder.build());
 132
 133                     }
 134                 });
 135     }
 136
 137     private static byte[] extractIpv4Mask(boolean hasMask, final Iterator<String> addressParts) {
 138         final int prefix;
 139         if (addressParts.hasNext()) {
 140             int potentionalPrefix = Integer.parseInt(addressParts.next());
 141             prefix = potentionalPrefix < 32 ? potentionalPrefix : 0;
 142         } else {
 143             prefix = 0;
 144         }
 145
 146         if (prefix != 0) {
 147             int mask = 0xffffffff << (32 - prefix);
 148             byte[] maskBytes = new byte[]{(byte) (mask >>> 24), (byte) (mask >>> 16), (byte) (mask >>> 8),
 149                     (byte) mask};
 150             hasMask = true;
 151             return maskBytes;
 152         }
 153         return null;
 154     }
 155 }