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 org.eclipse.jdt.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,
53 ConvertorExecutor convertorExecutor) {
54 List<MatchEntry> result = new ArrayList<>();
56 if (source.getArpOp() != null) {
57 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
58 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
59 matchEntryBuilder.setHasMask(false);
60 matchEntryBuilder.setOxmMatchField(ArpOp.class);
61 ArpOpCaseBuilder arpOpCaseBuilder = new ArpOpCaseBuilder();
62 ArpOpBuilder arpOpBuilder = new ArpOpBuilder();
63 arpOpBuilder.setOpCode(source.getArpOp());
64 arpOpCaseBuilder.setArpOp(arpOpBuilder.build());
65 matchEntryBuilder.setMatchEntryValue(arpOpCaseBuilder.build());
66 result.add(matchEntryBuilder.build());
69 if (source.getArpSourceTransportAddress() != null) {
70 Ipv4Prefix ipv4Prefix = source.getArpSourceTransportAddress();
71 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
72 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
73 matchEntryBuilder.setOxmMatchField(ArpSpa.class);
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);
88 ArpSpaCaseBuilder arpSpaCaseBuilder = new ArpSpaCaseBuilder();
89 arpSpaCaseBuilder.setArpSpa(arpSpaBuilder.build());
90 matchEntryBuilder.setMatchEntryValue(arpSpaCaseBuilder.build());
91 result.add(matchEntryBuilder.build());
94 if (source.getArpTargetTransportAddress() != null) {
95 Ipv4Prefix ipv4Prefix = source.getArpTargetTransportAddress();
96 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
97 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
98 matchEntryBuilder.setOxmMatchField(ArpTpa.class);
100 ArpTpaBuilder arpTpaBuilder = new ArpTpaBuilder();
102 Iterator<String> addressParts = IpConversionUtil.splitToParts(ipv4Prefix);
103 Ipv4Address ipv4Address = new Ipv4Address(addressParts.next());
104 arpTpaBuilder.setIpv4Address(ipv4Address);
105 boolean hasMask = false;
106 byte[] mask = MatchConvertorUtil.extractIpv4Mask(addressParts);
108 arpTpaBuilder.setMask(mask);
111 matchEntryBuilder.setHasMask(hasMask);
113 ArpTpaCaseBuilder arpTpaCaseBuilder = new ArpTpaCaseBuilder();
114 arpTpaCaseBuilder.setArpTpa(arpTpaBuilder.build());
115 matchEntryBuilder.setMatchEntryValue(arpTpaCaseBuilder.build());
116 result.add(matchEntryBuilder.build());
119 ArpSourceHardwareAddress arpSourceHardwareAddress = source.getArpSourceHardwareAddress();
120 if (arpSourceHardwareAddress != null) {
121 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
122 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
123 matchEntryBuilder.setOxmMatchField(ArpSha.class);
125 ArpShaCaseBuilder arpShaCaseBuilder = new ArpShaCaseBuilder();
126 ArpShaBuilder arpShaBuilder = new ArpShaBuilder();
127 arpShaBuilder.setMacAddress(arpSourceHardwareAddress.getAddress());
128 boolean hasMask = false;
129 if (null != arpSourceHardwareAddress.getMask()) {
130 arpShaBuilder.setMask(ByteBufUtils.macAddressToBytes(arpSourceHardwareAddress.getMask().getValue()));
133 arpShaCaseBuilder.setArpSha(arpShaBuilder.build());
134 matchEntryBuilder.setMatchEntryValue(arpShaCaseBuilder.build());
135 matchEntryBuilder.setHasMask(hasMask);
136 result.add(matchEntryBuilder.build());
139 ArpTargetHardwareAddress arpTargetHardwareAddress = source.getArpTargetHardwareAddress();
140 if (arpTargetHardwareAddress != null) {
141 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
142 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
143 matchEntryBuilder.setOxmMatchField(ArpTha.class);
145 ArpThaCaseBuilder arpThaCaseBuilder = new ArpThaCaseBuilder();
146 ArpThaBuilder arpThaBuilder = new ArpThaBuilder();
147 arpThaBuilder.setMacAddress(arpTargetHardwareAddress.getAddress());
148 boolean hasMask = false;
149 if (null != arpTargetHardwareAddress.getMask()) {
150 arpThaBuilder.setMask(ByteBufUtils.macAddressToBytes(arpTargetHardwareAddress.getMask().getValue()));
153 arpThaCaseBuilder.setArpTha(arpThaBuilder.build());
154 matchEntryBuilder.setMatchEntryValue(arpThaCaseBuilder.build());
155 matchEntryBuilder.setHasMask(hasMask);
156 result.add(matchEntryBuilder.build());
159 return Optional.of(result);