2 * Copyright (c) 2016 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.match.cases;
11 import java.util.ArrayList;
12 import java.util.Iterator;
13 import java.util.List;
14 import java.util.Optional;
15 import javax.annotation.Nonnull;
16 import org.opendaylight.openflowjava.util.ByteBufUtils;
17 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.ConvertorExecutor;
18 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.common.ConvertorCase;
19 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.common.IpConversionUtil;
20 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.data.VersionConvertorData;
21 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.match.MatchConvertorUtil;
22 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
23 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Prefix;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.arp.match.fields.ArpSourceHardwareAddress;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.arp.match.fields.ArpTargetHardwareAddress;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._3.match.ArpMatch;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpOp;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpSha;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpSpa;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpTha;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpTpa;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.OpenflowBasicClass;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entries.grouping.MatchEntry;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entries.grouping.MatchEntryBuilder;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ArpOpCaseBuilder;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ArpShaCaseBuilder;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ArpSpaCaseBuilder;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ArpThaCaseBuilder;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ArpTpaCaseBuilder;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.arp.op._case.ArpOpBuilder;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.arp.sha._case.ArpShaBuilder;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.arp.spa._case.ArpSpaBuilder;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.arp.tha._case.ArpThaBuilder;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.arp.tpa._case.ArpTpaBuilder;
46 public class SalToOfArpMatchCase extends ConvertorCase<ArpMatch, List<MatchEntry>, VersionConvertorData> {
47 public SalToOfArpMatchCase() {
48 super(ArpMatch.class, true);
52 public Optional<List<MatchEntry>> process(@Nonnull ArpMatch source, VersionConvertorData data, ConvertorExecutor convertorExecutor) {
53 List<MatchEntry> result = new ArrayList<>();
55 if (source.getArpOp() != null) {
56 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
57 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
58 matchEntryBuilder.setHasMask(false);
59 matchEntryBuilder.setOxmMatchField(ArpOp.class);
60 ArpOpCaseBuilder arpOpCaseBuilder = new ArpOpCaseBuilder();
61 ArpOpBuilder arpOpBuilder = new ArpOpBuilder();
62 arpOpBuilder.setOpCode(source.getArpOp());
63 arpOpCaseBuilder.setArpOp(arpOpBuilder.build());
64 matchEntryBuilder.setMatchEntryValue(arpOpCaseBuilder.build());
65 result.add(matchEntryBuilder.build());
68 if (source.getArpSourceTransportAddress() != null) {
69 Ipv4Prefix ipv4Prefix = source.getArpSourceTransportAddress();
70 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
71 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
72 matchEntryBuilder.setOxmMatchField(ArpSpa.class);
74 ArpSpaCaseBuilder arpSpaCaseBuilder = new ArpSpaCaseBuilder();
75 ArpSpaBuilder arpSpaBuilder = new ArpSpaBuilder();
77 Iterator<String> addressParts = IpConversionUtil.splitToParts(ipv4Prefix);
78 Ipv4Address ipv4Address = new Ipv4Address(addressParts.next());
79 arpSpaBuilder.setIpv4Address(ipv4Address);
80 boolean hasMask = false;
81 byte[] mask = MatchConvertorUtil.extractIpv4Mask(addressParts);
83 arpSpaBuilder.setMask(mask);
86 matchEntryBuilder.setHasMask(hasMask);
87 arpSpaCaseBuilder.setArpSpa(arpSpaBuilder.build());
88 matchEntryBuilder.setMatchEntryValue(arpSpaCaseBuilder.build());
89 result.add(matchEntryBuilder.build());
92 if (source.getArpTargetTransportAddress() != null) {
93 Ipv4Prefix ipv4Prefix = source.getArpTargetTransportAddress();
94 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
95 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
96 matchEntryBuilder.setOxmMatchField(ArpTpa.class);
98 ArpTpaCaseBuilder arpTpaCaseBuilder = new ArpTpaCaseBuilder();
99 ArpTpaBuilder arpTpaBuilder = new ArpTpaBuilder();
101 Iterator<String> addressParts = IpConversionUtil.splitToParts(ipv4Prefix);
102 Ipv4Address ipv4Address = new Ipv4Address(addressParts.next());
103 arpTpaBuilder.setIpv4Address(ipv4Address);
104 boolean hasMask = false;
105 byte[] mask = MatchConvertorUtil.extractIpv4Mask(addressParts);
107 arpTpaBuilder.setMask(mask);
110 matchEntryBuilder.setHasMask(hasMask);
111 arpTpaCaseBuilder.setArpTpa(arpTpaBuilder.build());
112 matchEntryBuilder.setMatchEntryValue(arpTpaCaseBuilder.build());
113 result.add(matchEntryBuilder.build());
116 ArpSourceHardwareAddress arpSourceHardwareAddress = source.getArpSourceHardwareAddress();
117 if (arpSourceHardwareAddress != null) {
118 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
119 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
120 matchEntryBuilder.setOxmMatchField(ArpSha.class);
122 ArpShaCaseBuilder arpShaCaseBuilder = new ArpShaCaseBuilder();
123 ArpShaBuilder arpShaBuilder = new ArpShaBuilder();
124 arpShaBuilder.setMacAddress(arpSourceHardwareAddress.getAddress());
125 boolean hasMask = false;
126 if (null != arpSourceHardwareAddress.getMask()) {
127 arpShaBuilder.setMask(ByteBufUtils.macAddressToBytes(arpSourceHardwareAddress.getMask().getValue()));
130 arpShaCaseBuilder.setArpSha(arpShaBuilder.build());
131 matchEntryBuilder.setMatchEntryValue(arpShaCaseBuilder.build());
132 matchEntryBuilder.setHasMask(hasMask);
133 result.add(matchEntryBuilder.build());
136 ArpTargetHardwareAddress arpTargetHardwareAddress = source.getArpTargetHardwareAddress();
137 if (arpTargetHardwareAddress != null) {
138 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
139 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
140 matchEntryBuilder.setOxmMatchField(ArpTha.class);
142 ArpThaCaseBuilder arpThaCaseBuilder = new ArpThaCaseBuilder();
143 ArpThaBuilder arpThaBuilder = new ArpThaBuilder();
144 arpThaBuilder.setMacAddress(arpTargetHardwareAddress.getAddress());
145 boolean hasMask = false;
146 if (null != arpTargetHardwareAddress.getMask()) {
147 arpThaBuilder.setMask(ByteBufUtils.macAddressToBytes(arpTargetHardwareAddress.getMask().getValue()));
150 arpThaCaseBuilder.setArpTha(arpThaBuilder.build());
151 matchEntryBuilder.setMatchEntryValue(arpThaCaseBuilder.build());
152 matchEntryBuilder.setHasMask(hasMask);
153 result.add(matchEntryBuilder.build());
156 return Optional.of(result);