2 * Copyright (c) 2013 Cisco Systems, Inc. and others. All rights reserved.
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
9 package org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.action;
11 import java.util.ArrayList;
12 import java.util.Iterator;
13 import java.util.List;
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;
40 * add prepared convertors and injectors into given mappings
42 * @see ActionSetNwSrcReactor
44 public class ActionSetNwSrcReactorMappingFactory {
47 * @param conversionMapping conversion mapping
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());
55 * @param injectionMapping injection mapping
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>() {
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());
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>() {
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);
85 Ipv4SrcCaseBuilder ipv4SrcCaseBuilder = new Ipv4SrcCaseBuilder();
86 Ipv4SrcBuilder ipv4SrcBuilder = new Ipv4SrcBuilder();
87 ipv4SrcBuilder.setIpv4Address(result);
88 Integer prefix = IpConversionUtil.extractPrefix(result);
90 ipv4SrcBuilder.setMask(IpConversionUtil.convertIpv6PrefixToByteArray(prefix));
92 ipv4SrcCaseBuilder.setIpv4Src(ipv4SrcBuilder.build());
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());
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>() {
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);
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));
121 ipv6SrcCaseBuilder.setIpv6Src(ipv6SrcBuilder.build());
123 matchEntryBuilder.setHasMask(false);
124 matchEntryBuilder.setMatchEntryValue(ipv6SrcCaseBuilder.build());
125 matchEntriesList.add(matchEntryBuilder.build());
127 SetFieldCaseBuilder setFieldCaseBuilder = new SetFieldCaseBuilder();
128 SetFieldActionBuilder setFieldActionBuilder = new SetFieldActionBuilder();
129 setFieldActionBuilder.setMatchEntry(matchEntriesList);
130 setFieldCaseBuilder.setSetFieldAction(setFieldActionBuilder.build());
131 target.setActionChoice(setFieldCaseBuilder.build());
137 private static byte[] extractIpv4Mask(boolean hasMask, final Iterator<String> addressParts) {
139 if (addressParts.hasNext()) {
140 int potentionalPrefix = Integer.parseInt(addressParts.next());
141 prefix = potentionalPrefix < 32 ? potentionalPrefix : 0;
147 int mask = 0xffffffff << (32 - prefix);
148 byte[] maskBytes = new byte[]{(byte) (mask >>> 24), (byte) (mask >>> 16), (byte) (mask >>> 8),