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.common.ConvertorCase;
18 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.common.IpConversionUtil;
19 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.data.VersionConvertorData;
20 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.match.MatchConvertorUtil;
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.Ipv4Prefix;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.arp.match.fields.ArpSourceHardwareAddress;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.arp.match.fields.ArpTargetHardwareAddress;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._3.match.ArpMatch;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpOp;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpSha;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpSpa;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpTha;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpTpa;
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.ArpOpCaseBuilder;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ArpShaCaseBuilder;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ArpSpaCaseBuilder;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ArpThaCaseBuilder;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ArpTpaCaseBuilder;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.arp.op._case.ArpOpBuilder;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.arp.sha._case.ArpShaBuilder;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.arp.spa._case.ArpSpaBuilder;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.arp.tha._case.ArpThaBuilder;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.arp.tpa._case.ArpTpaBuilder;
45 public class SalToOfArpMatchCase extends ConvertorCase<ArpMatch, List<MatchEntry>, VersionConvertorData> {
46 public SalToOfArpMatchCase() {
47 super(ArpMatch.class, true);
51 public Optional<List<MatchEntry>> process(@Nonnull ArpMatch source, VersionConvertorData data) {
52 List<MatchEntry> result = new ArrayList<>();
54 if (source.getArpOp() != null) {
55 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
56 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
57 matchEntryBuilder.setHasMask(false);
58 matchEntryBuilder.setOxmMatchField(ArpOp.class);
59 ArpOpCaseBuilder arpOpCaseBuilder = new ArpOpCaseBuilder();
60 ArpOpBuilder arpOpBuilder = new ArpOpBuilder();
61 arpOpBuilder.setOpCode(source.getArpOp());
62 arpOpCaseBuilder.setArpOp(arpOpBuilder.build());
63 matchEntryBuilder.setMatchEntryValue(arpOpCaseBuilder.build());
64 result.add(matchEntryBuilder.build());
67 if (source.getArpSourceTransportAddress() != null) {
68 Ipv4Prefix ipv4Prefix = source.getArpSourceTransportAddress();
69 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
70 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
71 matchEntryBuilder.setOxmMatchField(ArpSpa.class);
73 ArpSpaCaseBuilder arpSpaCaseBuilder = new ArpSpaCaseBuilder();
74 ArpSpaBuilder arpSpaBuilder = new ArpSpaBuilder();
76 Iterator<String> addressParts = IpConversionUtil.splitToParts(ipv4Prefix);
77 Ipv4Address ipv4Address = new Ipv4Address(addressParts.next());
78 arpSpaBuilder.setIpv4Address(ipv4Address);
79 boolean hasMask = false;
80 byte[] mask = MatchConvertorUtil.extractIpv4Mask(addressParts);
82 arpSpaBuilder.setMask(mask);
85 matchEntryBuilder.setHasMask(hasMask);
86 arpSpaCaseBuilder.setArpSpa(arpSpaBuilder.build());
87 matchEntryBuilder.setMatchEntryValue(arpSpaCaseBuilder.build());
88 result.add(matchEntryBuilder.build());
91 if (source.getArpTargetTransportAddress() != null) {
92 Ipv4Prefix ipv4Prefix = source.getArpTargetTransportAddress();
93 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
94 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
95 matchEntryBuilder.setOxmMatchField(ArpTpa.class);
97 ArpTpaCaseBuilder arpTpaCaseBuilder = new ArpTpaCaseBuilder();
98 ArpTpaBuilder arpTpaBuilder = new ArpTpaBuilder();
100 Iterator<String> addressParts = IpConversionUtil.splitToParts(ipv4Prefix);
101 Ipv4Address ipv4Address = new Ipv4Address(addressParts.next());
102 arpTpaBuilder.setIpv4Address(ipv4Address);
103 boolean hasMask = false;
104 byte[] mask = MatchConvertorUtil.extractIpv4Mask(addressParts);
106 arpTpaBuilder.setMask(mask);
109 matchEntryBuilder.setHasMask(hasMask);
110 arpTpaCaseBuilder.setArpTpa(arpTpaBuilder.build());
111 matchEntryBuilder.setMatchEntryValue(arpTpaCaseBuilder.build());
112 result.add(matchEntryBuilder.build());
115 ArpSourceHardwareAddress arpSourceHardwareAddress = source.getArpSourceHardwareAddress();
116 if (arpSourceHardwareAddress != null) {
117 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
118 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
119 matchEntryBuilder.setOxmMatchField(ArpSha.class);
121 ArpShaCaseBuilder arpShaCaseBuilder = new ArpShaCaseBuilder();
122 ArpShaBuilder arpShaBuilder = new ArpShaBuilder();
123 arpShaBuilder.setMacAddress(arpSourceHardwareAddress.getAddress());
124 boolean hasMask = false;
125 if (null != arpSourceHardwareAddress.getMask()) {
126 arpShaBuilder.setMask(ByteBufUtils.macAddressToBytes(arpSourceHardwareAddress.getMask().getValue()));
129 arpShaCaseBuilder.setArpSha(arpShaBuilder.build());
130 matchEntryBuilder.setMatchEntryValue(arpShaCaseBuilder.build());
131 matchEntryBuilder.setHasMask(hasMask);
132 result.add(matchEntryBuilder.build());
135 ArpTargetHardwareAddress arpTargetHardwareAddress = source.getArpTargetHardwareAddress();
136 if (arpTargetHardwareAddress != null) {
137 MatchEntryBuilder matchEntryBuilder = new MatchEntryBuilder();
138 matchEntryBuilder.setOxmClass(OpenflowBasicClass.class);
139 matchEntryBuilder.setOxmMatchField(ArpTha.class);
141 ArpThaCaseBuilder arpThaCaseBuilder = new ArpThaCaseBuilder();
142 ArpThaBuilder arpThaBuilder = new ArpThaBuilder();
143 arpThaBuilder.setMacAddress(arpTargetHardwareAddress.getAddress());
144 boolean hasMask = false;
145 if (null != arpTargetHardwareAddress.getMask()) {
146 arpThaBuilder.setMask(ByteBufUtils.macAddressToBytes(arpTargetHardwareAddress.getMask().getValue()));
149 arpThaCaseBuilder.setArpTha(arpThaBuilder.build());
150 matchEntryBuilder.setMatchEntryValue(arpThaCaseBuilder.build());
151 matchEntryBuilder.setHasMask(hasMask);
152 result.add(matchEntryBuilder.build());
155 return Optional.of(result);