1 package org.opendaylight.controller.sal.compability;
3 import com.google.common.net.InetAddresses;
5 import org.opendaylight.controller.sal.action.Flood;
6 import org.opendaylight.controller.sal.action.FloodAll;
7 import org.opendaylight.controller.sal.action.HwPath;
8 import org.opendaylight.controller.sal.action.Loopback;
9 import org.opendaylight.controller.sal.action.Output;
10 import org.opendaylight.controller.sal.action.PopVlan;
11 import org.opendaylight.controller.sal.action.PushVlan;
12 import org.opendaylight.controller.sal.action.SetDlDst;
13 import org.opendaylight.controller.sal.action.SetDlSrc;
14 import org.opendaylight.controller.sal.action.SetDlType;
15 import org.opendaylight.controller.sal.action.SetNextHop;
16 import org.opendaylight.controller.sal.action.SetNwDst;
17 import org.opendaylight.controller.sal.action.SetNwSrc;
18 import org.opendaylight.controller.sal.action.SetNwTos;
19 import org.opendaylight.controller.sal.action.SetTpDst;
20 import org.opendaylight.controller.sal.action.SetTpSrc;
21 import org.opendaylight.controller.sal.action.SetVlanCfi;
22 import org.opendaylight.controller.sal.action.SetVlanId;
23 import org.opendaylight.controller.sal.action.SetVlanPcp;
24 import org.opendaylight.controller.sal.action.SwPath;
25 import org.opendaylight.controller.sal.flowprogrammer.Flow;
26 import org.opendaylight.controller.sal.match.MatchType;
27 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Dscp;
28 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Prefix;
29 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv6Prefix;
30 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.PortNumber;
31 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Uri;
32 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.MacAddress;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.FlowAddedBuilder;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.NodeFlow;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.VlanCfi;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.ControllerActionBuilder;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.DropActionBuilder;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.FloodActionBuilder;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.FloodAllActionBuilder;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.HwPathActionBuilder;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.LoopbackActionBuilder;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.OutputActionBuilder;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.PopMplsActionBuilder;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.PopVlanActionBuilder;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.PushMplsActionBuilder;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.PushPbbActionBuilder;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.PushVlanActionBuilder;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetDlDstActionBuilder;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetDlSrcActionBuilder;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetDlTypeActionBuilder;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetMplsTtlActionBuilder;
52 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetNextHopActionBuilder;
53 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetNwDstActionBuilder;
54 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetNwSrcActionBuilder;
55 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetNwTosActionBuilder;
56 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetNwTtlActionBuilder;
57 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetQueueActionBuilder;
58 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetTpDstActionBuilder;
59 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetTpSrcActionBuilder;
60 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetVlanCfiActionBuilder;
61 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetVlanIdActionBuilder;
62 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetVlanPcpActionBuilder;
63 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SwPathActionBuilder;
64 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.list.Action;
65 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.list.ActionBuilder;
66 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.address.Address;
67 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.address.address.Ipv4Builder;
68 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.address.address.Ipv6Builder;
69 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.Instructions;
70 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.InstructionsBuilder;
71 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.Match;
72 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.MatchBuilder;
73 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.ApplyActions;
74 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.ApplyActionsBuilder;
75 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction;
76 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.InstructionBuilder;
77 import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.EtherType;
78 import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanId;
79 import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanPcp;
80 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.arp.match.fields.ArpSourceHardwareAddressBuilder;
81 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.arp.match.fields.ArpTargetHardwareAddressBuilder;
82 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.ethernet.match.fields.EthernetDestination;
83 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.ethernet.match.fields.EthernetDestinationBuilder;
84 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.ethernet.match.fields.EthernetSource;
85 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.ethernet.match.fields.EthernetSourceBuilder;
86 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.ethernet.match.fields.EthernetType;
87 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.ethernet.match.fields.EthernetTypeBuilder;
88 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.EthernetMatch;
89 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.EthernetMatchBuilder;
90 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.IpMatch;
91 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.IpMatchBuilder;
92 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.Layer3Match;
93 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.Layer4Match;
94 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.VlanMatch;
95 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.VlanMatchBuilder;
96 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._3.match.ArpMatchBuilder;
97 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._3.match.Ipv4MatchBuilder;
98 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._3.match.Ipv6MatchBuilder;
99 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._4.match.SctpMatchBuilder;
100 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._4.match.TcpMatchBuilder;
101 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._4.match.UdpMatchBuilder;
102 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.vlan.match.fields.VlanIdBuilder;
104 import java.math.BigInteger;
105 import java.net.Inet4Address;
106 import java.net.Inet6Address;
107 import java.net.InetAddress;
108 import java.util.ArrayList;
109 import java.util.Collections;
110 import java.util.List;
112 import static org.junit.Assert.assertEquals;
113 import static org.junit.Assert.assertTrue;
114 import static org.opendaylight.controller.sal.compability.ProtocolConstants.ETHERNET_ARP;
115 import static org.opendaylight.controller.sal.compability.ProtocolConstants.SCTP;
116 import static org.opendaylight.controller.sal.compability.ProtocolConstants.TCP;
117 import static org.opendaylight.controller.sal.compability.ProtocolConstants.UDP;
119 public class TestToSalConversionsUtils {
121 // od|Od = Open Daylight
122 private enum MtchType {
123 other, ipv4, ipv6, arp, sctp, tcp, udp
127 public void testToSalConversion() {
128 FlowAddedBuilder odNodeFlowBuilder = new FlowAddedBuilder();
129 odNodeFlowBuilder = prepareOdFlowCommon();
131 Flow salFlow = ToSalConversionsUtils.toFlow(prepareOdFlow(odNodeFlowBuilder, MtchType.other));
132 checkSalMatch(salFlow.getMatch(), MtchType.other);
134 salFlow = ToSalConversionsUtils.toFlow(prepareOdFlow(odNodeFlowBuilder, MtchType.ipv4));
135 checkSalMatch(salFlow.getMatch(), MtchType.ipv4);
137 salFlow = ToSalConversionsUtils.toFlow(prepareOdFlow(odNodeFlowBuilder, MtchType.ipv6));
138 checkSalMatch(salFlow.getMatch(), MtchType.ipv6);
140 salFlow = ToSalConversionsUtils.toFlow(prepareOdFlow(odNodeFlowBuilder, MtchType.arp));
141 checkSalMatch(salFlow.getMatch(), MtchType.arp);
143 salFlow = ToSalConversionsUtils.toFlow(prepareOdFlow(odNodeFlowBuilder, MtchType.sctp));
144 checkSalMatch(salFlow.getMatch(), MtchType.sctp);
146 salFlow = ToSalConversionsUtils.toFlow(prepareOdFlow(odNodeFlowBuilder, MtchType.tcp));
147 checkSalMatch(salFlow.getMatch(), MtchType.tcp);
149 salFlow = ToSalConversionsUtils.toFlow(prepareOdFlow(odNodeFlowBuilder, MtchType.udp));
150 checkSalMatch(salFlow.getMatch(), MtchType.udp);
152 checkSalFlow(salFlow);
155 private void checkSalMatch(org.opendaylight.controller.sal.match.Match match, MtchType mt) {
158 /*assertNotNull("DL_DST isn't equal.", "3C:A9:F4:00:E0:C8",
159 new String((byte[]) match.getField(MatchType.DL_DST).getValue()));
160 assertEquals("DL_SRC isn't equal.", "24:77:03:7C:C5:F1",
161 new String((byte[]) match.getField(MatchType.DL_SRC).getValue()));
163 assertEquals("DL_TYPE isn't equal.", (short) 0xffff, (short) match.getField(MatchType.DL_TYPE).getValue());
164 assertEquals("NW_TOS isn't equal.", (byte) 0x33, (byte) match.getField(MatchType.NW_TOS).getValue());
165 assertEquals("NW_PROTO isn't equal.", (byte) 0x3f, (byte) match.getField(MatchType.NW_PROTO).getValue());
166 assertEquals("DL_VLAN isn't equal.", (short) 0xfff, (short) match.getField(MatchType.DL_VLAN).getValue());
167 assertEquals("DL_VLAN_PR isn't equal.", (byte) 0x7, (byte) match.getField(MatchType.DL_VLAN_PR).getValue());
171 assertEquals("DL_SRC isn't equal.", "22:44:66:88:AA:CC",
172 new String((byte[]) match.getField(MatchType.DL_SRC).getValue()));
173 assertEquals("DL_DST isn't equal.", "11:33:55:77:BB:DD",
174 new String((byte[]) match.getField(MatchType.DL_DST).getValue()));
176 assertEquals("NW_SRC isn't equal.", "192.168.1.101",
177 InetAddresses.toAddrString((InetAddress) match.getField(MatchType.NW_SRC).getValue()));
178 assertEquals("NW_DST isn't equal.", "192.168.1.102",
179 InetAddresses.toAddrString((InetAddress) match.getField(MatchType.NW_DST).getValue()));
180 assertEquals("DL_TYPE isn't equal.", ETHERNET_ARP, match.getField(MatchType.DL_TYPE).getValue());
183 assertEquals("NW_SRC isn't equal.", "192.168.1.104",
184 InetAddresses.toAddrString((InetAddress) match.getField(MatchType.NW_SRC).getValue()));
185 assertEquals("NW_DST isn't equal.", "192.168.1.105",
186 InetAddresses.toAddrString((InetAddress) match.getField(MatchType.NW_DST).getValue()));
189 assertEquals("NW_SRC isn't equal.", "3001:db8:85a3::8a2e:370:7334",
190 InetAddresses.toAddrString((InetAddress) match.getField(MatchType.NW_SRC).getValue()));
191 assertEquals("NW_DST isn't equal.", "3001:db8:85a3::8a2e:370:7335",
192 InetAddresses.toAddrString((InetAddress) match.getField(MatchType.NW_DST).getValue()));
195 assertEquals("TP_SRC isn't equal.", 31, (short) match.getField(MatchType.TP_SRC).getValue());
196 assertEquals("TP_DST isn't equal.", 32, (short) match.getField(MatchType.TP_DST).getValue());
197 assertEquals("NW_PROTO isn't equal.", SCTP, (byte) match.getField(MatchType.NW_PROTO).getValue());
200 assertEquals("TP_SRC isn't equal.", 21, (short) match.getField(MatchType.TP_SRC).getValue());
201 assertEquals("TP_DST isn't equal.", 22, (short) match.getField(MatchType.TP_DST).getValue());
202 assertEquals("NW_PROTO isn't equal.", TCP, (byte) match.getField(MatchType.NW_PROTO).getValue());
205 assertEquals("TP_SRC isn't equal.", 11, (short) match.getField(MatchType.TP_SRC).getValue());
206 assertEquals("TP_DST isn't equal.", 12, (short) match.getField(MatchType.TP_DST).getValue());
207 assertEquals("NW_PROTO isn't equal.", UDP, (byte) match.getField(MatchType.NW_PROTO).getValue());
216 private void checkSalFlow(Flow salFlow) {
217 assertTrue("Id value is incorrect.", salFlow.getId() == 9223372036854775807L);
218 assertTrue("Hard timeout is incorrect.", salFlow.getHardTimeout() == 32767);
219 assertTrue("Iddle timeout is incorrect.", salFlow.getIdleTimeout() == 32767);
220 assertTrue("Priority value is incorrect.", salFlow.getPriority() == 32767);
222 checkSalActions(salFlow.getActions());
225 private void checkSalActions(List<org.opendaylight.controller.sal.action.Action> actions) {
226 checkSalAction(actions, Flood.class, 1);
227 checkSalAction(actions, FloodAll.class, 1);
228 checkSalAction(actions, HwPath.class, 1);
229 checkSalAction(actions, Loopback.class, 1);
230 checkSalAction(actions, Output.class, 2, true);
231 checkSalAction(actions, PopVlan.class, 1);
232 checkSalAction(actions, PushVlan.class, 1, true);
233 checkSalAction(actions, SetDlDst.class, 1, true);
234 checkSalAction(actions, SetDlSrc.class, 1, true);
235 checkSalAction(actions, SetDlType.class, 1, true);
236 checkSalAction(actions, SetNextHop.class, 2, true);
237 checkSalAction(actions, SetNwDst.class, 2, true);
238 checkSalAction(actions, SetNwSrc.class, 2, true);
239 checkSalAction(actions, SetNwTos.class, 1, true);
240 checkSalAction(actions, SetTpDst.class, 1, true);
241 checkSalAction(actions, SetTpSrc.class, 1, true);
242 checkSalAction(actions, SetVlanCfi.class, 1, true);
243 checkSalAction(actions, SetVlanId.class, 1, true);
244 checkSalAction(actions, SetVlanPcp.class, 1, true);
245 checkSalAction(actions, SwPath.class, 1);
248 private void checkSalAction(List<org.opendaylight.controller.sal.action.Action> actions, Class<?> cls,
250 checkSalAction(actions, cls, numOfActions, false);
253 private void checkSalAction(List<org.opendaylight.controller.sal.action.Action> actions, Class<?> cls,
254 int numOfActions, boolean additionalCheck) {
255 int numOfEqualClass = 0;
256 for (org.opendaylight.controller.sal.action.Action action : actions) {
257 if (action.getClass().equals(cls)) {
258 if (additionalCheck) {
259 additionalActionCheck(action);
264 assertEquals("Incorrect number of actions of type " + cls.getName() + " was found.", numOfActions,
268 // implement special checks
269 private void additionalActionCheck(org.opendaylight.controller.sal.action.Action action) {
270 if (action instanceof Output) {
271 // ((Output)action).getPort() //TODO finish check when mapping will
273 } else if (action instanceof PushVlan) {
274 assertEquals("Wrong value for action PushVlan for tag.", 0x8100, ((PushVlan) action).getTag());
275 assertEquals("Wrong value for action PushVlan for pcp.", 7, ((PushVlan) action).getPcp());
276 assertEquals("Wrong value for action PushVlan for cfi.", 1, ((PushVlan) action).getCfi());
277 assertEquals("Wrong value for action PushVlan for vlanID.", 4095, ((PushVlan) action).getVlanId());
278 } else if (action instanceof SetDlDst) {
279 //assertEquals("Wrong value for action SetDlDst for MAC address.", "3C:A9:F4:00:E0:C8", new String(
280 // ((SetDlDst) action).getDlAddress()));
281 } else if (action instanceof SetDlSrc) {
282 //assertEquals("Wrong value for action SetDlSrc for MAC address.", "24:77:03:7C:C5:F1", new String(
283 // ((SetDlSrc) action).getDlAddress()));
284 } else if (action instanceof SetDlType) {
285 assertEquals("Wrong value for action SetDlType for.", 513l, ((SetDlType) action).getDlType());
286 } else if (action instanceof SetNextHop) {
287 InetAddress inetAddress = ((SetNextHop) action).getAddress();
288 checkIpAddresses(inetAddress, "192.168.100.100", "2001:db8:85a3::8a2e:370:7334");
289 } else if (action instanceof SetNwDst) {
290 InetAddress inetAddress = ((SetNwDst) action).getAddress();
291 checkIpAddresses(inetAddress, "192.168.100.101", "2001:db8:85a3::8a2e:370:7335");
292 } else if (action instanceof SetNwSrc) {
293 InetAddress inetAddress = ((SetNwSrc) action).getAddress();
294 checkIpAddresses(inetAddress, "192.168.100.102", "2001:db8:85a3::8a2e:370:7336");
295 } else if (action instanceof SetNwTos) {
296 assertEquals("Wrong value for action SetNwTos for tos.", 63, ((SetNwTos) action).getNwTos());
297 } else if (action instanceof SetTpDst) {
298 assertEquals("Wrong value for action SetTpDst for port.", 65535, ((SetTpDst) action).getPort());
299 } else if (action instanceof SetTpSrc) {
300 assertEquals("Wrong value for action SetTpSrc for port.", 65535, ((SetTpSrc) action).getPort());
301 } else if (action instanceof SetVlanCfi) {
302 assertEquals("Wrong value for action SetVlanCfi for port.", 1, ((SetVlanCfi) action).getCfi());
303 } else if (action instanceof SetVlanId) {
304 assertEquals("Wrong value for action SetVlanId for vlan ID.", 4095, ((SetVlanId) action).getVlanId());
305 } else if (action instanceof SetVlanPcp) {
306 assertEquals("Wrong value for action SetVlanPcp for vlan ID.", 7, ((SetVlanPcp) action).getPcp());
310 private void checkIpAddresses(InetAddress inetAddress, String ipv4, String ipv6) {
311 if (inetAddress instanceof Inet4Address) {
312 assertEquals("Wrong value for IP address.", ipv4, InetAddresses.toAddrString(inetAddress));
313 } else if (inetAddress instanceof Inet6Address) {
314 assertEquals("Wrong value for IP address.", ipv6, InetAddresses.toAddrString(inetAddress));
318 private FlowAddedBuilder prepareOdFlowCommon() {
319 FlowAddedBuilder odNodeFlowBuilder = new FlowAddedBuilder();
321 odNodeFlowBuilder.setCookie(new BigInteger("9223372036854775807"));
322 odNodeFlowBuilder.setHardTimeout(32767);
323 odNodeFlowBuilder.setIdleTimeout(32767);
324 odNodeFlowBuilder.setPriority(32767);
325 odNodeFlowBuilder.setInstructions(prepareOdActions());
326 return odNodeFlowBuilder;
329 private NodeFlow prepareOdFlow(FlowAddedBuilder odNodeFlowBuilder, MtchType mt) {
330 odNodeFlowBuilder.setMatch(prepOdMatch(mt));
331 return odNodeFlowBuilder.build();
334 private Instructions prepareOdActions() {
335 List<Action> odActions = new ArrayList<>();
337 ControllerActionBuilder controllerActionBuilder = new ControllerActionBuilder();
338 DropActionBuilder dropActionBuilder = new DropActionBuilder();
339 FloodActionBuilder floodActionBuilder = new FloodActionBuilder();
340 FloodAllActionBuilder floodAllActionBuilder = new FloodAllActionBuilder();
341 HwPathActionBuilder hwPathActionBuilder = new HwPathActionBuilder();
342 LoopbackActionBuilder loopbackActionBuilder = new LoopbackActionBuilder();
343 OutputActionBuilder outputActionBuilder = new OutputActionBuilder();
344 PopMplsActionBuilder popMplsActionBuilder = new PopMplsActionBuilder();
345 PopVlanActionBuilder popVlanActionBuilder = new PopVlanActionBuilder();
346 PushMplsActionBuilder pushMplsActionBuilder = new PushMplsActionBuilder();
347 PushPbbActionBuilder pushPbbActionBuilder = new PushPbbActionBuilder();
348 PushVlanActionBuilder pushVlanActionBuilder = new PushVlanActionBuilder();
349 SetDlDstActionBuilder setDlDstActionBuilder = new SetDlDstActionBuilder();
350 SetDlSrcActionBuilder setDlSrcActionBuilder = new SetDlSrcActionBuilder();
351 SetDlTypeActionBuilder setDlTypeActionBuilder = new SetDlTypeActionBuilder();
352 SetMplsTtlActionBuilder setMplsTtlActionBuilder = new SetMplsTtlActionBuilder();
353 SetNwTosActionBuilder setNwTosActionBuilder = new SetNwTosActionBuilder();
354 SetNwTtlActionBuilder setNwTtlActionBuilder = new SetNwTtlActionBuilder();
355 SetQueueActionBuilder setQueueActionBuilder = new SetQueueActionBuilder();
356 SetTpDstActionBuilder setTpDstActionBuilder = new SetTpDstActionBuilder();
357 SetTpSrcActionBuilder setTpSrcActionBuilder = new SetTpSrcActionBuilder();
358 SetVlanCfiActionBuilder setVlanCfiActionBuilder = new SetVlanCfiActionBuilder();
359 SetVlanIdActionBuilder setVlanIdActionBuilder = new SetVlanIdActionBuilder();
360 SetVlanPcpActionBuilder setVlanPcpActionBuilder = new SetVlanPcpActionBuilder();
361 SwPathActionBuilder swPathActionBuilder = new SwPathActionBuilder();
363 prepareActionOutput(outputActionBuilder);
364 prepareActionPushVlan(pushVlanActionBuilder);
365 prepareActionSetDlDst(setDlDstActionBuilder);
366 prepareActionSetDlSrc(setDlSrcActionBuilder);
367 prepareActionSetDlType(setDlTypeActionBuilder);
368 prepareActionNextHop(odActions);
369 prepareActionSetNwDst(odActions);
370 prepareActionSetNwSrc(odActions);
371 prepareActionSetNwTos(setNwTosActionBuilder);
372 prepareActionSetTpDst(setTpDstActionBuilder);
373 prepareActionSetTpSrc(setTpSrcActionBuilder);
374 prepareActionSetVlanCfi(setVlanCfiActionBuilder);
375 prepareActionSetVladId(setVlanIdActionBuilder);
376 prepareActionSetVlanPcp(setVlanPcpActionBuilder);
378 odActions.add(new ActionBuilder().setAction(controllerActionBuilder.build()).build());
379 odActions.add(new ActionBuilder().setAction(dropActionBuilder.build()).build());
380 odActions.add(new ActionBuilder().setAction(floodActionBuilder.build()).build());
381 odActions.add(new ActionBuilder().setAction(floodAllActionBuilder.build()).build());
382 odActions.add(new ActionBuilder().setAction(hwPathActionBuilder.build()).build());
383 odActions.add(new ActionBuilder().setAction(loopbackActionBuilder.build()).build());
384 odActions.add(new ActionBuilder().setAction(outputActionBuilder.build()).build());
385 odActions.add(new ActionBuilder().setAction(popMplsActionBuilder.build()).build());
386 odActions.add(new ActionBuilder().setAction(popVlanActionBuilder.build()).build());
387 odActions.add(new ActionBuilder().setAction(pushMplsActionBuilder.build()).build());
388 odActions.add(new ActionBuilder().setAction(pushPbbActionBuilder.build()).build());
389 odActions.add(new ActionBuilder().setAction(pushVlanActionBuilder.build()).build());
390 odActions.add(new ActionBuilder().setAction(setDlDstActionBuilder.build()).build());
391 odActions.add(new ActionBuilder().setAction(setDlSrcActionBuilder.build()).build());
392 odActions.add(new ActionBuilder().setAction(setDlTypeActionBuilder.build()).build());
393 odActions.add(new ActionBuilder().setAction(setMplsTtlActionBuilder.build()).build());
394 odActions.add(new ActionBuilder().setAction(setNwTosActionBuilder.build()).build());
395 odActions.add(new ActionBuilder().setAction(setNwTtlActionBuilder.build()).build());
396 odActions.add(new ActionBuilder().setAction(setQueueActionBuilder.build()).build());
397 odActions.add(new ActionBuilder().setAction(setTpDstActionBuilder.build()).build());
398 odActions.add(new ActionBuilder().setAction(setTpSrcActionBuilder.build()).build());
399 odActions.add(new ActionBuilder().setAction(setVlanCfiActionBuilder.build()).build());
400 odActions.add(new ActionBuilder().setAction(setVlanIdActionBuilder.build()).build());
401 odActions.add(new ActionBuilder().setAction(setVlanPcpActionBuilder.build()).build());
402 odActions.add(new ActionBuilder().setAction(swPathActionBuilder.build()).build());
405 ApplyActions innerInst = new ApplyActionsBuilder().setAction(odActions).build();
406 Instruction applyActions = new InstructionBuilder().setInstruction(innerInst).build();
407 List<Instruction> instructions = Collections.singletonList(applyActions );
408 InstructionsBuilder instBuilder = new InstructionsBuilder();
410 instBuilder.setInstruction(instructions);
412 return instBuilder.build();
415 private void prepareActionSetVlanPcp(SetVlanPcpActionBuilder setVlanPcpActionBuilder) {
416 setVlanPcpActionBuilder.setVlanPcp(new VlanPcp((short) 7));
419 private void prepareActionSetVladId(SetVlanIdActionBuilder setVlanIdActionBuilder) {
420 setVlanIdActionBuilder.setVlanId(new VlanId(4095));
423 private void prepareActionSetVlanCfi(SetVlanCfiActionBuilder setVlanCfiActionBuilder) {
424 setVlanCfiActionBuilder.setVlanCfi(new VlanCfi(1));
427 private void prepareActionSetTpDst(SetTpDstActionBuilder setTpDstActionBuilder) {
428 setTpDstActionBuilder.setPort(new PortNumber(65535));
431 private void prepareActionSetTpSrc(SetTpSrcActionBuilder setTpSrcActionBuilder) {
432 setTpSrcActionBuilder.setPort(new PortNumber(65535));
435 private void prepareActionSetNwTos(SetNwTosActionBuilder setNwTosActionBuilder) {
436 setNwTosActionBuilder.setTos(63);
439 private void prepareActionSetNwSrc(List<Action> odActions) {
440 // test case for IPv4
441 SetNwSrcActionBuilder setNwSrcActionBuilderIpv4 = new SetNwSrcActionBuilder();
442 setNwSrcActionBuilderIpv4.setAddress(prapareIpv4Address("192.168.100.102"));
443 odActions.add(new ActionBuilder().setAction(setNwSrcActionBuilderIpv4.build()).build());
445 // test case for IPv6
446 SetNwSrcActionBuilder setNwSrcActionBuilderIpv6 = new SetNwSrcActionBuilder();
447 setNwSrcActionBuilderIpv6.setAddress(prapareIpv6Address("2001:0db8:85a3:0000:0000:8a2e:0370:7336"));
448 odActions.add(new ActionBuilder().setAction(setNwSrcActionBuilderIpv6.build()).build());
451 private void prepareActionSetNwDst(List<Action> odActions) {
452 // test case for IPv4
453 SetNwDstActionBuilder setNwDstActionBuilderIpv4 = new SetNwDstActionBuilder();
454 setNwDstActionBuilderIpv4.setAddress(prapareIpv4Address("192.168.100.101"));
455 odActions.add(new ActionBuilder().setAction(setNwDstActionBuilderIpv4.build()).build());
457 // test case for IPv6
458 SetNwDstActionBuilder setNwDstActionBuilderIpv6 = new SetNwDstActionBuilder();
459 setNwDstActionBuilderIpv6.setAddress(prapareIpv6Address("2001:0db8:85a3:0000:0000:8a2e:0370:7335"));
460 odActions.add(new ActionBuilder().setAction(setNwDstActionBuilderIpv6.build()).build());
463 private void prepareActionNextHop(List<Action> odActions) {
464 // test case for IPv4
465 SetNextHopActionBuilder setNextHopActionBuilderIpv4 = new SetNextHopActionBuilder();
466 setNextHopActionBuilderIpv4.setAddress(prapareIpv4Address("192.168.100.100"));
467 odActions.add(new ActionBuilder().setAction(setNextHopActionBuilderIpv4.build()).build());
469 // test case for IPv6
470 SetNextHopActionBuilder setNextHopActionBuilderIpv6 = new SetNextHopActionBuilder();
471 setNextHopActionBuilderIpv6.setAddress(prapareIpv6Address("2001:0db8:85a3:0000:0000:8a2e:0370:7334"));
472 odActions.add(new ActionBuilder().setAction(setNextHopActionBuilderIpv6.build()).build());
475 private Address prapareIpv4Address(String ipv4Address) {
476 Ipv4Builder ipv4Builder = new Ipv4Builder();
477 ipv4Builder.setIpv4Address(new Ipv4Prefix(ipv4Address));
478 return ipv4Builder.build();
481 private Address prapareIpv6Address(String ipv6Address) {
482 Ipv6Builder ipv6Builder = new Ipv6Builder();
483 ipv6Builder.setIpv6Address(new Ipv6Prefix(ipv6Address));
484 return ipv6Builder.build();
487 private void prepareActionSetDlType(SetDlTypeActionBuilder setDlTypeActionBuilder) {
488 setDlTypeActionBuilder.setDlType(new EtherType(513l));
491 private void prepareActionSetDlSrc(SetDlSrcActionBuilder setDlSrcActionBuilder) {
492 setDlSrcActionBuilder.setAddress(new MacAddress("24:77:03:7C:C5:F1"));
495 private void prepareActionSetDlDst(SetDlDstActionBuilder setDlDstActionBuilder) {
496 setDlDstActionBuilder.setAddress(new MacAddress("3C:A9:F4:00:E0:C8"));
499 private void prepareActionPushVlan(PushVlanActionBuilder pushVlanActionBuilder) {
500 pushVlanActionBuilder.setPcp(7); // 3 bits
501 pushVlanActionBuilder.setCfi(new VlanCfi(1)); // 1 bit
502 pushVlanActionBuilder.setVlanId(new VlanId(4095));
503 pushVlanActionBuilder.setTag(0x8100); // 12 bit
506 private void prepareActionOutput(OutputActionBuilder outputActionBuilder) {
507 List<Uri> uris = new ArrayList<>();
508 uris.add(new Uri("uri1"));
509 uris.add(new Uri("uri2"));
510 outputActionBuilder.setOutputNodeConnector(uris);
513 private Match prepOdMatch(MtchType mt) {
514 MatchBuilder odMatchBuilder = new MatchBuilder();
517 odMatchBuilder.setEthernetMatch(prepEthernetMatch());
518 odMatchBuilder.setIpMatch(prepIpMatch());
519 odMatchBuilder.setVlanMatch(prepVlanMatch());
522 odMatchBuilder.setLayer3Match(prepLayer3MatchIpv4());
525 odMatchBuilder.setLayer3Match(prepLayer3MatchIpv6());
528 odMatchBuilder.setLayer3Match(prepLayer3MatchArp());
531 odMatchBuilder.setLayer4Match(prepLayer4MatchSctp());
534 odMatchBuilder.setLayer4Match(prepLayer4MatchTcp());
537 odMatchBuilder.setLayer4Match(prepLayer4MatchUdp());
540 return odMatchBuilder.build();
543 private Layer4Match prepLayer4MatchUdp() {
544 UdpMatchBuilder udpMatchBuilder = new UdpMatchBuilder();
546 udpMatchBuilder.setUdpSourcePort(new PortNumber(11));
547 udpMatchBuilder.setUdpDestinationPort(new PortNumber(12));
549 return udpMatchBuilder.build();
552 private Layer4Match prepLayer4MatchTcp() {
553 TcpMatchBuilder tcpMatchBuilder = new TcpMatchBuilder();
555 tcpMatchBuilder.setTcpSourcePort(new PortNumber(21));
556 tcpMatchBuilder.setTcpDestinationPort(new PortNumber(22));
558 return tcpMatchBuilder.build();
561 private Layer4Match prepLayer4MatchSctp() {
562 SctpMatchBuilder sctpMatchBuilder = new SctpMatchBuilder();
564 sctpMatchBuilder.setSctpSourcePort(new PortNumber(31));
565 sctpMatchBuilder.setSctpDestinationPort(new PortNumber(32));
567 return sctpMatchBuilder.build();
570 private Layer3Match prepLayer3MatchIpv4() {
571 Ipv4MatchBuilder ipv4MatchBuilder = new Ipv4MatchBuilder();
572 ipv4MatchBuilder.setIpv4Source(new Ipv4Prefix("192.168.1.104"));
573 ipv4MatchBuilder.setIpv4Destination(new Ipv4Prefix("192.168.1.105"));
574 return ipv4MatchBuilder.build();
577 private Layer3Match prepLayer3MatchIpv6() {
578 Ipv6MatchBuilder ipv6MatchBuilder = new Ipv6MatchBuilder();
579 ipv6MatchBuilder.setIpv6Source(new Ipv6Prefix("3001:0db8:85a3:0000:0000:8a2e:0370:7334"));
580 ipv6MatchBuilder.setIpv6Destination(new Ipv6Prefix("3001:0db8:85a3:0000:0000:8a2e:0370:7335"));
581 return ipv6MatchBuilder.build();
584 private Layer3Match prepLayer3MatchArp() {
585 ArpMatchBuilder arpMatchBuilder = new ArpMatchBuilder();
586 arpMatchBuilder.setArpSourceTransportAddress(new Ipv4Prefix("192.168.1.101"));
587 arpMatchBuilder.setArpTargetTransportAddress(new Ipv4Prefix("192.168.1.102"));
589 ArpSourceHardwareAddressBuilder arpSourAddressBuild = new ArpSourceHardwareAddressBuilder();
590 arpSourAddressBuild.setAddress(new MacAddress("22:44:66:88:AA:CC"));
591 arpMatchBuilder.setArpSourceHardwareAddress(arpSourAddressBuild.build());
593 ArpTargetHardwareAddressBuilder arpTarAddressBuild = new ArpTargetHardwareAddressBuilder();
594 arpTarAddressBuild.setAddress(new MacAddress("11:33:55:77:BB:DD"));
595 arpMatchBuilder.setArpTargetHardwareAddress(arpTarAddressBuild.build());
596 return arpMatchBuilder.build();
599 private VlanMatch prepVlanMatch() {
600 VlanMatchBuilder vlanMatchBuilder = new VlanMatchBuilder();
602 VlanIdBuilder vlanIdBuilder = new VlanIdBuilder().setVlanId(new VlanId(0xfff));
603 vlanMatchBuilder.setVlanId(vlanIdBuilder.build());
604 vlanMatchBuilder.setVlanPcp(new VlanPcp((short) 0x7));
606 return vlanMatchBuilder.build();
610 private IpMatch prepIpMatch() {
611 IpMatchBuilder ipMatchBuilder = new IpMatchBuilder();
612 ipMatchBuilder.setIpDscp(new Dscp((short) 0x33));
613 ipMatchBuilder.setIpProtocol((short) 0x3f);
614 return ipMatchBuilder.build();
617 private EthernetMatch prepEthernetMatch() {
618 EthernetMatchBuilder odEthernetMatchBuilder = new EthernetMatchBuilder();
619 odEthernetMatchBuilder.setEthernetDestination(prepEthDest());
620 odEthernetMatchBuilder.setEthernetSource(prepEthSour());
621 odEthernetMatchBuilder.setEthernetType(prepEthType());
622 return odEthernetMatchBuilder.build();
625 private EthernetType prepEthType() {
626 EthernetTypeBuilder ethTypeBuild = new EthernetTypeBuilder();
627 ethTypeBuild.setType(new EtherType(0xffffl));
628 return ethTypeBuild.build();
631 private EthernetSource prepEthSour() {
632 EthernetSourceBuilder ethSourBuild = new EthernetSourceBuilder();
633 ethSourBuild.setAddress(new MacAddress("24:77:03:7C:C5:F1"));
634 return ethSourBuild.build();
637 private EthernetDestination prepEthDest() {
638 EthernetDestinationBuilder ethDestBuild = new EthernetDestinationBuilder();
639 ethDestBuild.setAddress(new MacAddress("3C:A9:F4:00:E0:C8"));
640 return ethDestBuild.build();