1 package org.opendaylight.controller.sal.compability;
3 import static org.junit.Assert.assertEquals;
4 import static org.junit.Assert.assertTrue;
6 import java.math.BigInteger;
7 import java.net.Inet4Address;
8 import java.net.Inet6Address;
9 import java.net.InetAddress;
10 import java.util.ArrayList;
11 import java.util.List;
13 import org.junit.Test;
14 import org.opendaylight.controller.sal.action.*;
15 import org.opendaylight.controller.sal.flowprogrammer.Flow;
16 import org.opendaylight.controller.sal.match.MatchType;
17 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.*;
18 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.MacAddress;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.FlowAddedBuilder;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.NodeFlow;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev130819.VlanCfi;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev130819.action.action.*;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev130819.address.Address;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev130819.address.address.Ipv4Builder;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev130819.address.address.Ipv6Builder;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev130819.flow.Action;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev130819.flow.ActionBuilder;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev130819.flow.Match;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev130819.flow.MatchBuilder;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.EtherType;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanId;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanPcp;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev130819.arp.match.fields.ArpSourceHardwareAddressBuilder;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev130819.arp.match.fields.ArpTargetHardwareAddressBuilder;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev130819.ethernet.match.fields.*;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev130819.match.*;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev130819.match.layer._3.match.ArpMatchBuilder;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev130819.match.layer._3.match.Ipv4MatchBuilder;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev130819.match.layer._3.match.Ipv6MatchBuilder;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev130819.match.layer._4.match.SctpMatchBuilder;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev130819.match.layer._4.match.TcpMatchBuilder;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev130819.match.layer._4.match.UdpMatchBuilder;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev130819.vlan.match.fields.VlanIdBuilder;
45 import com.google.common.net.InetAddresses;
46 import static org.opendaylight.controller.sal.compability.ProtocolConstants.ETHERNET_ARP;
47 import static org.opendaylight.controller.sal.compability.ProtocolConstants.SCTP;
48 import static org.opendaylight.controller.sal.compability.ProtocolConstants.TCP;
49 import static org.opendaylight.controller.sal.compability.ProtocolConstants.UDP;
51 public class TestToSalConversionsUtils {
53 // od|Od = Open Daylight
54 private enum MtchType {
55 other, ipv4, ipv6, arp, sctp, tcp, udp
59 public void testToSalConversion() {
60 FlowAddedBuilder odNodeFlowBuilder = new FlowAddedBuilder();
61 odNodeFlowBuilder = prepareOdFlowCommon();
63 Flow salFlow = ToSalConversionsUtils.flowFrom(prepareOdFlow(odNodeFlowBuilder, MtchType.other));
64 checkSalMatch(salFlow.getMatch(), MtchType.other);
66 salFlow = ToSalConversionsUtils.flowFrom(prepareOdFlow(odNodeFlowBuilder, MtchType.ipv4));
67 checkSalMatch(salFlow.getMatch(), MtchType.ipv4);
69 salFlow = ToSalConversionsUtils.flowFrom(prepareOdFlow(odNodeFlowBuilder, MtchType.ipv6));
70 checkSalMatch(salFlow.getMatch(), MtchType.ipv6);
72 salFlow = ToSalConversionsUtils.flowFrom(prepareOdFlow(odNodeFlowBuilder, MtchType.arp));
73 checkSalMatch(salFlow.getMatch(), MtchType.arp);
75 salFlow = ToSalConversionsUtils.flowFrom(prepareOdFlow(odNodeFlowBuilder, MtchType.sctp));
76 checkSalMatch(salFlow.getMatch(), MtchType.sctp);
78 salFlow = ToSalConversionsUtils.flowFrom(prepareOdFlow(odNodeFlowBuilder, MtchType.tcp));
79 checkSalMatch(salFlow.getMatch(), MtchType.tcp);
81 salFlow = ToSalConversionsUtils.flowFrom(prepareOdFlow(odNodeFlowBuilder, MtchType.udp));
82 checkSalMatch(salFlow.getMatch(), MtchType.udp);
84 checkSalFlow(salFlow);
87 private void checkSalMatch(org.opendaylight.controller.sal.match.Match match, MtchType mt) {
90 assertEquals("DL_DST isn't equal.", "3C:A9:F4:00:E0:C8",
91 new String((byte[]) match.getField(MatchType.DL_DST).getValue()));
92 assertEquals("DL_SRC isn't equal.", "24:77:03:7C:C5:F1",
93 new String((byte[]) match.getField(MatchType.DL_SRC).getValue()));
94 assertEquals("DL_TYPE isn't equal.", (short) 0xffff, (short) match.getField(MatchType.DL_TYPE).getValue());
95 assertEquals("NW_TOS isn't equal.", (byte) 0x33, (byte) match.getField(MatchType.NW_TOS).getValue());
96 assertEquals("NW_PROTO isn't equal.", (byte) 0x3f, (byte) match.getField(MatchType.NW_PROTO).getValue());
97 assertEquals("DL_VLAN isn't equal.", (short) 0xfff, (short) match.getField(MatchType.DL_VLAN).getValue());
98 assertEquals("DL_VLAN_PR isn't equal.", (byte) 0x7, (byte) match.getField(MatchType.DL_VLAN_PR).getValue());
101 assertEquals("DL_SRC isn't equal.", "22:44:66:88:AA:CC",
102 new String((byte[]) match.getField(MatchType.DL_SRC).getValue()));
103 assertEquals("DL_DST isn't equal.", "11:33:55:77:BB:DD",
104 new String((byte[]) match.getField(MatchType.DL_DST).getValue()));
105 assertEquals("NW_SRC isn't equal.", "192.168.1.101",
106 InetAddresses.toAddrString((InetAddress) match.getField(MatchType.NW_SRC).getValue()));
107 assertEquals("NW_DST isn't equal.", "192.168.1.102",
108 InetAddresses.toAddrString((InetAddress) match.getField(MatchType.NW_DST).getValue()));
109 assertEquals("DL_TYPE isn't equal.", ETHERNET_ARP, match.getField(MatchType.DL_TYPE).getValue());
112 assertEquals("NW_SRC isn't equal.", "192.168.1.104",
113 InetAddresses.toAddrString((InetAddress) match.getField(MatchType.NW_SRC).getValue()));
114 assertEquals("NW_DST isn't equal.", "192.168.1.105",
115 InetAddresses.toAddrString((InetAddress) match.getField(MatchType.NW_DST).getValue()));
118 assertEquals("NW_SRC isn't equal.", "3001:db8:85a3::8a2e:370:7334",
119 InetAddresses.toAddrString((InetAddress) match.getField(MatchType.NW_SRC).getValue()));
120 assertEquals("NW_DST isn't equal.", "3001:db8:85a3::8a2e:370:7335",
121 InetAddresses.toAddrString((InetAddress) match.getField(MatchType.NW_DST).getValue()));
124 assertEquals("TP_SRC isn't equal.", 31, (short) match.getField(MatchType.TP_SRC).getValue());
125 assertEquals("TP_DST isn't equal.", 32, (short) match.getField(MatchType.TP_DST).getValue());
126 assertEquals("NW_PROTO isn't equal.", SCTP, (byte) match.getField(MatchType.NW_PROTO).getValue());
129 assertEquals("TP_SRC isn't equal.", 21, (short) match.getField(MatchType.TP_SRC).getValue());
130 assertEquals("TP_DST isn't equal.", 22, (short) match.getField(MatchType.TP_DST).getValue());
131 assertEquals("NW_PROTO isn't equal.", TCP, (byte) match.getField(MatchType.NW_PROTO).getValue());
134 assertEquals("TP_SRC isn't equal.", 11, (short) match.getField(MatchType.TP_SRC).getValue());
135 assertEquals("TP_DST isn't equal.", 12, (short) match.getField(MatchType.TP_DST).getValue());
136 assertEquals("NW_PROTO isn't equal.", UDP, (byte) match.getField(MatchType.NW_PROTO).getValue());
145 private void checkSalFlow(Flow salFlow) {
146 assertTrue("Id value is incorrect.", salFlow.getId() == 9223372036854775807L);
147 assertTrue("Hard timeout is incorrect.", salFlow.getHardTimeout() == 32767);
148 assertTrue("Iddle timeout is incorrect.", salFlow.getIdleTimeout() == 32767);
149 assertTrue("Priority value is incorrect.", salFlow.getPriority() == 32767);
151 checkSalActions(salFlow.getActions());
154 private void checkSalActions(List<org.opendaylight.controller.sal.action.Action> actions) {
155 checkSalAction(actions, Flood.class, 1);
156 checkSalAction(actions, FloodAll.class, 1);
157 checkSalAction(actions, HwPath.class, 1);
158 checkSalAction(actions, Loopback.class, 1);
159 checkSalAction(actions, Output.class, 2, true);
160 checkSalAction(actions, PopVlan.class, 1);
161 checkSalAction(actions, PushVlan.class, 1, true);
162 checkSalAction(actions, SetDlDst.class, 1, true);
163 checkSalAction(actions, SetDlSrc.class, 1, true);
164 checkSalAction(actions, SetDlType.class, 1, true);
165 checkSalAction(actions, SetNextHop.class, 2, true);
166 checkSalAction(actions, SetNwDst.class, 2, true);
167 checkSalAction(actions, SetNwSrc.class, 2, true);
168 checkSalAction(actions, SetNwTos.class, 1, true);
169 checkSalAction(actions, SetTpDst.class, 1, true);
170 checkSalAction(actions, SetTpSrc.class, 1, true);
171 checkSalAction(actions, SetVlanCfi.class, 1, true);
172 checkSalAction(actions, SetVlanId.class, 1, true);
173 checkSalAction(actions, SetVlanPcp.class, 1, true);
174 checkSalAction(actions, SwPath.class, 1);
177 private void checkSalAction(List<org.opendaylight.controller.sal.action.Action> actions, Class<?> cls,
179 checkSalAction(actions, cls, numOfActions, false);
182 private void checkSalAction(List<org.opendaylight.controller.sal.action.Action> actions, Class<?> cls,
183 int numOfActions, boolean additionalCheck) {
184 int numOfEqualClass = 0;
185 for (org.opendaylight.controller.sal.action.Action action : actions) {
186 if (action.getClass().equals(cls)) {
187 if (additionalCheck) {
188 additionalActionCheck(action);
193 assertEquals("Incorrect number of actions of type " + cls.getName() + " was found.", numOfActions,
197 // implement special checks
198 private void additionalActionCheck(org.opendaylight.controller.sal.action.Action action) {
199 if (action instanceof Output) {
200 // ((Output)action).getPort() //TODO finish check when mapping will
202 } else if (action instanceof PushVlan) {
203 assertEquals("Wrong value for action PushVlan for tag.", 0x8100, ((PushVlan) action).getTag());
204 assertEquals("Wrong value for action PushVlan for pcp.", 7, ((PushVlan) action).getPcp());
205 assertEquals("Wrong value for action PushVlan for cfi.", 1, ((PushVlan) action).getCfi());
206 assertEquals("Wrong value for action PushVlan for vlanID.", 4095, ((PushVlan) action).getVlanId());
207 } else if (action instanceof SetDlDst) {
208 assertEquals("Wrong value for action SetDlDst for MAC address.", "3C:A9:F4:00:E0:C8", new String(
209 ((SetDlDst) action).getDlAddress()));
210 } else if (action instanceof SetDlSrc) {
211 assertEquals("Wrong value for action SetDlSrc for MAC address.", "24:77:03:7C:C5:F1", new String(
212 ((SetDlSrc) action).getDlAddress()));
213 } else if (action instanceof SetDlType) {
214 assertEquals("Wrong value for action SetDlType for.", 513l, ((SetDlType) action).getDlType());
215 } else if (action instanceof SetNextHop) {
216 InetAddress inetAddress = ((SetNextHop) action).getAddress();
217 checkIpAddresses(inetAddress, "192.168.100.100", "2001:db8:85a3::8a2e:370:7334");
218 } else if (action instanceof SetNwDst) {
219 InetAddress inetAddress = ((SetNwDst) action).getAddress();
220 checkIpAddresses(inetAddress, "192.168.100.101", "2001:db8:85a3::8a2e:370:7335");
221 } else if (action instanceof SetNwSrc) {
222 InetAddress inetAddress = ((SetNwSrc) action).getAddress();
223 checkIpAddresses(inetAddress, "192.168.100.102", "2001:db8:85a3::8a2e:370:7336");
224 } else if (action instanceof SetNwTos) {
225 assertEquals("Wrong value for action SetNwTos for tos.", 63, ((SetNwTos) action).getNwTos());
226 } else if (action instanceof SetTpDst) {
227 assertEquals("Wrong value for action SetTpDst for port.", 65535, ((SetTpDst) action).getPort());
228 } else if (action instanceof SetTpSrc) {
229 assertEquals("Wrong value for action SetTpSrc for port.", 65535, ((SetTpSrc) action).getPort());
230 } else if (action instanceof SetVlanCfi) {
231 assertEquals("Wrong value for action SetVlanCfi for port.", 1, ((SetVlanCfi) action).getCfi());
232 } else if (action instanceof SetVlanId) {
233 assertEquals("Wrong value for action SetVlanId for vlan ID.", 4095, ((SetVlanId) action).getVlanId());
234 } else if (action instanceof SetVlanPcp) {
235 assertEquals("Wrong value for action SetVlanPcp for vlan ID.", 7, ((SetVlanPcp) action).getPcp());
239 private void checkIpAddresses(InetAddress inetAddress, String ipv4, String ipv6) {
240 if (inetAddress instanceof Inet4Address) {
241 assertEquals("Wrong value for IP address.", ipv4, InetAddresses.toAddrString(inetAddress));
242 } else if (inetAddress instanceof Inet6Address) {
243 assertEquals("Wrong value for IP address.", ipv6, InetAddresses.toAddrString(inetAddress));
247 private FlowAddedBuilder prepareOdFlowCommon() {
248 FlowAddedBuilder odNodeFlowBuilder = new FlowAddedBuilder();
250 odNodeFlowBuilder.setCookie(new BigInteger("9223372036854775807"));
251 odNodeFlowBuilder.setHardTimeout(32767);
252 odNodeFlowBuilder.setIdleTimeout(32767);
253 odNodeFlowBuilder.setPriority(32767);
254 odNodeFlowBuilder.setAction(prepareOdActions());
255 return odNodeFlowBuilder;
258 private NodeFlow prepareOdFlow(FlowAddedBuilder odNodeFlowBuilder, MtchType mt) {
259 odNodeFlowBuilder.setMatch(prepOdMatch(mt));
260 return odNodeFlowBuilder.build();
263 private List<Action> prepareOdActions() {
264 List<Action> odActions = new ArrayList<>();
266 ControllerActionBuilder controllerActionBuilder = new ControllerActionBuilder();
267 DropActionBuilder dropActionBuilder = new DropActionBuilder();
268 FloodActionBuilder floodActionBuilder = new FloodActionBuilder();
269 FloodAllActionBuilder floodAllActionBuilder = new FloodAllActionBuilder();
270 HwPathActionBuilder hwPathActionBuilder = new HwPathActionBuilder();
271 LoopbackActionBuilder loopbackActionBuilder = new LoopbackActionBuilder();
272 OutputActionBuilder outputActionBuilder = new OutputActionBuilder();
273 PopMplsActionBuilder popMplsActionBuilder = new PopMplsActionBuilder();
274 PopVlanActionBuilder popVlanActionBuilder = new PopVlanActionBuilder();
275 PushMplsActionBuilder pushMplsActionBuilder = new PushMplsActionBuilder();
276 PushPbbActionBuilder pushPbbActionBuilder = new PushPbbActionBuilder();
277 PushVlanActionBuilder pushVlanActionBuilder = new PushVlanActionBuilder();
278 SetDlDstActionBuilder setDlDstActionBuilder = new SetDlDstActionBuilder();
279 SetDlSrcActionBuilder setDlSrcActionBuilder = new SetDlSrcActionBuilder();
280 SetDlTypeActionBuilder setDlTypeActionBuilder = new SetDlTypeActionBuilder();
281 SetMplsTtlActionBuilder setMplsTtlActionBuilder = new SetMplsTtlActionBuilder();
282 SetNwTosActionBuilder setNwTosActionBuilder = new SetNwTosActionBuilder();
283 SetNwTtlActionBuilder setNwTtlActionBuilder = new SetNwTtlActionBuilder();
284 SetQueueActionBuilder setQueueActionBuilder = new SetQueueActionBuilder();
285 SetTpDstActionBuilder setTpDstActionBuilder = new SetTpDstActionBuilder();
286 SetTpSrcActionBuilder setTpSrcActionBuilder = new SetTpSrcActionBuilder();
287 SetVlanCfiActionBuilder setVlanCfiActionBuilder = new SetVlanCfiActionBuilder();
288 SetVlanIdActionBuilder setVlanIdActionBuilder = new SetVlanIdActionBuilder();
289 SetVlanPcpActionBuilder setVlanPcpActionBuilder = new SetVlanPcpActionBuilder();
290 SwPathActionBuilder swPathActionBuilder = new SwPathActionBuilder();
292 prepareActionOutput(outputActionBuilder);
293 prepareActionPushVlan(pushVlanActionBuilder);
294 prepareActionSetDlDst(setDlDstActionBuilder);
295 prepareActionSetDlSrc(setDlSrcActionBuilder);
296 prepareActionSetDlType(setDlTypeActionBuilder);
297 prepareActionNextHop(odActions);
298 prepareActionSetNwDst(odActions);
299 prepareActionSetNwSrc(odActions);
300 prepareActionSetNwTos(setNwTosActionBuilder);
301 prepareActionSetTpDst(setTpDstActionBuilder);
302 prepareActionSetTpSrc(setTpSrcActionBuilder);
303 prepareActionSetVlanCfi(setVlanCfiActionBuilder);
304 prepareActionSetVladId(setVlanIdActionBuilder);
305 prepareActionSetVlanPcp(setVlanPcpActionBuilder);
307 odActions.add(new ActionBuilder().setAction(controllerActionBuilder.build()).build());
308 odActions.add(new ActionBuilder().setAction(dropActionBuilder.build()).build());
309 odActions.add(new ActionBuilder().setAction(floodActionBuilder.build()).build());
310 odActions.add(new ActionBuilder().setAction(floodAllActionBuilder.build()).build());
311 odActions.add(new ActionBuilder().setAction(hwPathActionBuilder.build()).build());
312 odActions.add(new ActionBuilder().setAction(loopbackActionBuilder.build()).build());
313 odActions.add(new ActionBuilder().setAction(outputActionBuilder.build()).build());
314 odActions.add(new ActionBuilder().setAction(popMplsActionBuilder.build()).build());
315 odActions.add(new ActionBuilder().setAction(popVlanActionBuilder.build()).build());
316 odActions.add(new ActionBuilder().setAction(pushMplsActionBuilder.build()).build());
317 odActions.add(new ActionBuilder().setAction(pushPbbActionBuilder.build()).build());
318 odActions.add(new ActionBuilder().setAction(pushVlanActionBuilder.build()).build());
319 odActions.add(new ActionBuilder().setAction(setDlDstActionBuilder.build()).build());
320 odActions.add(new ActionBuilder().setAction(setDlSrcActionBuilder.build()).build());
321 odActions.add(new ActionBuilder().setAction(setDlTypeActionBuilder.build()).build());
322 odActions.add(new ActionBuilder().setAction(setMplsTtlActionBuilder.build()).build());
323 odActions.add(new ActionBuilder().setAction(setNwTosActionBuilder.build()).build());
324 odActions.add(new ActionBuilder().setAction(setNwTtlActionBuilder.build()).build());
325 odActions.add(new ActionBuilder().setAction(setQueueActionBuilder.build()).build());
326 odActions.add(new ActionBuilder().setAction(setTpDstActionBuilder.build()).build());
327 odActions.add(new ActionBuilder().setAction(setTpSrcActionBuilder.build()).build());
328 odActions.add(new ActionBuilder().setAction(setVlanCfiActionBuilder.build()).build());
329 odActions.add(new ActionBuilder().setAction(setVlanIdActionBuilder.build()).build());
330 odActions.add(new ActionBuilder().setAction(setVlanPcpActionBuilder.build()).build());
331 odActions.add(new ActionBuilder().setAction(swPathActionBuilder.build()).build());
336 private void prepareActionSetVlanPcp(SetVlanPcpActionBuilder setVlanPcpActionBuilder) {
337 setVlanPcpActionBuilder.setVlanPcp(new VlanPcp((short) 7));
340 private void prepareActionSetVladId(SetVlanIdActionBuilder setVlanIdActionBuilder) {
341 setVlanIdActionBuilder.setVlanId(new VlanId(4095));
344 private void prepareActionSetVlanCfi(SetVlanCfiActionBuilder setVlanCfiActionBuilder) {
345 setVlanCfiActionBuilder.setVlanCfi(new VlanCfi(1));
348 private void prepareActionSetTpDst(SetTpDstActionBuilder setTpDstActionBuilder) {
349 setTpDstActionBuilder.setPort(new PortNumber(65535));
352 private void prepareActionSetTpSrc(SetTpSrcActionBuilder setTpSrcActionBuilder) {
353 setTpSrcActionBuilder.setPort(new PortNumber(65535));
356 private void prepareActionSetNwTos(SetNwTosActionBuilder setNwTosActionBuilder) {
357 setNwTosActionBuilder.setTos(63);
360 private void prepareActionSetNwSrc(List<Action> odActions) {
361 // test case for IPv4
362 SetNwSrcActionBuilder setNwSrcActionBuilderIpv4 = new SetNwSrcActionBuilder();
363 setNwSrcActionBuilderIpv4.setAddress(prapareIpv4Address("192.168.100.102"));
364 odActions.add(new ActionBuilder().setAction(setNwSrcActionBuilderIpv4.build()).build());
366 // test case for IPv6
367 SetNwSrcActionBuilder setNwSrcActionBuilderIpv6 = new SetNwSrcActionBuilder();
368 setNwSrcActionBuilderIpv6.setAddress(prapareIpv6Address("2001:0db8:85a3:0000:0000:8a2e:0370:7336"));
369 odActions.add(new ActionBuilder().setAction(setNwSrcActionBuilderIpv6.build()).build());
372 private void prepareActionSetNwDst(List<Action> odActions) {
373 // test case for IPv4
374 SetNwDstActionBuilder setNwDstActionBuilderIpv4 = new SetNwDstActionBuilder();
375 setNwDstActionBuilderIpv4.setAddress(prapareIpv4Address("192.168.100.101"));
376 odActions.add(new ActionBuilder().setAction(setNwDstActionBuilderIpv4.build()).build());
378 // test case for IPv6
379 SetNwDstActionBuilder setNwDstActionBuilderIpv6 = new SetNwDstActionBuilder();
380 setNwDstActionBuilderIpv6.setAddress(prapareIpv6Address("2001:0db8:85a3:0000:0000:8a2e:0370:7335"));
381 odActions.add(new ActionBuilder().setAction(setNwDstActionBuilderIpv6.build()).build());
384 private void prepareActionNextHop(List<Action> odActions) {
385 // test case for IPv4
386 SetNextHopActionBuilder setNextHopActionBuilderIpv4 = new SetNextHopActionBuilder();
387 setNextHopActionBuilderIpv4.setAddress(prapareIpv4Address("192.168.100.100"));
388 odActions.add(new ActionBuilder().setAction(setNextHopActionBuilderIpv4.build()).build());
390 // test case for IPv6
391 SetNextHopActionBuilder setNextHopActionBuilderIpv6 = new SetNextHopActionBuilder();
392 setNextHopActionBuilderIpv6.setAddress(prapareIpv6Address("2001:0db8:85a3:0000:0000:8a2e:0370:7334"));
393 odActions.add(new ActionBuilder().setAction(setNextHopActionBuilderIpv6.build()).build());
396 private Address prapareIpv4Address(String ipv4Address) {
397 Ipv4Builder ipv4Builder = new Ipv4Builder();
398 ipv4Builder.setIpv4Address(new Ipv4Prefix(ipv4Address));
399 return ipv4Builder.build();
402 private Address prapareIpv6Address(String ipv6Address) {
403 Ipv6Builder ipv6Builder = new Ipv6Builder();
404 ipv6Builder.setIpv6Address(new Ipv6Prefix(ipv6Address));
405 return ipv6Builder.build();
408 private void prepareActionSetDlType(SetDlTypeActionBuilder setDlTypeActionBuilder) {
409 setDlTypeActionBuilder.setDlType(new EtherType(513l));
412 private void prepareActionSetDlSrc(SetDlSrcActionBuilder setDlSrcActionBuilder) {
413 setDlSrcActionBuilder.setAddress(new MacAddress("24:77:03:7C:C5:F1"));
416 private void prepareActionSetDlDst(SetDlDstActionBuilder setDlDstActionBuilder) {
417 setDlDstActionBuilder.setAddress(new MacAddress("3C:A9:F4:00:E0:C8"));
420 private void prepareActionPushVlan(PushVlanActionBuilder pushVlanActionBuilder) {
421 pushVlanActionBuilder.setPcp(7); // 3 bits
422 pushVlanActionBuilder.setCfi(new VlanCfi(1)); // 1 bit
423 pushVlanActionBuilder.setVlanId(new VlanId(4095));
424 pushVlanActionBuilder.setTag(0x8100); // 12 bit
427 private void prepareActionOutput(OutputActionBuilder outputActionBuilder) {
428 List<Uri> uris = new ArrayList<>();
429 uris.add(new Uri("uri1"));
430 uris.add(new Uri("uri2"));
431 outputActionBuilder.setOutputNodeConnector(uris);
434 private Match prepOdMatch(MtchType mt) {
435 MatchBuilder odMatchBuilder = new MatchBuilder();
438 odMatchBuilder.setEthernetMatch(prepEthernetMatch());
439 odMatchBuilder.setIpMatch(prepIpMatch());
440 odMatchBuilder.setVlanMatch(prepVlanMatch());
443 odMatchBuilder.setLayer3Match(prepLayer3MatchIpv4());
446 odMatchBuilder.setLayer3Match(prepLayer3MatchIpv6());
449 odMatchBuilder.setLayer3Match(prepLayer3MatchArp());
452 odMatchBuilder.setLayer4Match(prepLayer4MatchSctp());
455 odMatchBuilder.setLayer4Match(prepLayer4MatchTcp());
458 odMatchBuilder.setLayer4Match(prepLayer4MatchUdp());
461 return odMatchBuilder.build();
464 private Layer4Match prepLayer4MatchUdp() {
465 UdpMatchBuilder udpMatchBuilder = new UdpMatchBuilder();
467 udpMatchBuilder.setUdpSourcePort(new PortNumber(11));
468 udpMatchBuilder.setUdpDestinationPort(new PortNumber(12));
470 return udpMatchBuilder.build();
473 private Layer4Match prepLayer4MatchTcp() {
474 TcpMatchBuilder tcpMatchBuilder = new TcpMatchBuilder();
476 tcpMatchBuilder.setTcpSourcePort(new PortNumber(21));
477 tcpMatchBuilder.setTcpDestinationPort(new PortNumber(22));
479 return tcpMatchBuilder.build();
482 private Layer4Match prepLayer4MatchSctp() {
483 SctpMatchBuilder sctpMatchBuilder = new SctpMatchBuilder();
485 sctpMatchBuilder.setSctpSourcePort(new PortNumber(31));
486 sctpMatchBuilder.setSctpDestinationPort(new PortNumber(32));
488 return sctpMatchBuilder.build();
491 private Layer3Match prepLayer3MatchIpv4() {
492 Ipv4MatchBuilder ipv4MatchBuilder = new Ipv4MatchBuilder();
493 ipv4MatchBuilder.setIpv4Source(new Ipv4Prefix("192.168.1.104"));
494 ipv4MatchBuilder.setIpv4Destination(new Ipv4Prefix("192.168.1.105"));
495 return ipv4MatchBuilder.build();
498 private Layer3Match prepLayer3MatchIpv6() {
499 Ipv6MatchBuilder ipv6MatchBuilder = new Ipv6MatchBuilder();
500 ipv6MatchBuilder.setIpv6Source(new Ipv6Prefix("3001:0db8:85a3:0000:0000:8a2e:0370:7334"));
501 ipv6MatchBuilder.setIpv6Destination(new Ipv6Prefix("3001:0db8:85a3:0000:0000:8a2e:0370:7335"));
502 return ipv6MatchBuilder.build();
505 private Layer3Match prepLayer3MatchArp() {
506 ArpMatchBuilder arpMatchBuilder = new ArpMatchBuilder();
507 arpMatchBuilder.setArpSourceTransportAddress(new Ipv4Prefix("192.168.1.101"));
508 arpMatchBuilder.setArpTargetTransportAddress(new Ipv4Prefix("192.168.1.102"));
510 ArpSourceHardwareAddressBuilder arpSourAddressBuild = new ArpSourceHardwareAddressBuilder();
511 arpSourAddressBuild.setAddress(new MacAddress("22:44:66:88:AA:CC"));
512 arpMatchBuilder.setArpSourceHardwareAddress(arpSourAddressBuild.build());
514 ArpTargetHardwareAddressBuilder arpTarAddressBuild = new ArpTargetHardwareAddressBuilder();
515 arpTarAddressBuild.setAddress(new MacAddress("11:33:55:77:BB:DD"));
516 arpMatchBuilder.setArpTargetHardwareAddress(arpTarAddressBuild.build());
517 return arpMatchBuilder.build();
520 private VlanMatch prepVlanMatch() {
521 VlanMatchBuilder vlanMatchBuilder = new VlanMatchBuilder();
523 VlanIdBuilder vlanIdBuilder = new VlanIdBuilder().setVlanId(new VlanId(0xfff));
524 vlanMatchBuilder.setVlanId(vlanIdBuilder.build());
525 vlanMatchBuilder.setVlanPcp(new VlanPcp((short) 0x7));
527 return vlanMatchBuilder.build();
531 private IpMatch prepIpMatch() {
532 IpMatchBuilder ipMatchBuilder = new IpMatchBuilder();
533 ipMatchBuilder.setIpDscp(new Dscp((short) 0x33));
534 ipMatchBuilder.setIpProtocol((short) 0x3f);
535 return ipMatchBuilder.build();
538 private EthernetMatch prepEthernetMatch() {
539 EthernetMatchBuilder odEthernetMatchBuilder = new EthernetMatchBuilder();
540 odEthernetMatchBuilder.setEthernetDestination(prepEthDest());
541 odEthernetMatchBuilder.setEthernetSource(prepEthSour());
542 odEthernetMatchBuilder.setEthernetType(prepEthType());
543 return odEthernetMatchBuilder.build();
546 private EthernetType prepEthType() {
547 EthernetTypeBuilder ethTypeBuild = new EthernetTypeBuilder();
548 ethTypeBuild.setType(new EtherType(0xffffl));
549 return ethTypeBuild.build();
552 private EthernetSource prepEthSour() {
553 EthernetSourceBuilder ethSourBuild = new EthernetSourceBuilder();
554 ethSourBuild.setAddress(new MacAddress("24:77:03:7C:C5:F1"));
555 return ethSourBuild.build();
558 private EthernetDestination prepEthDest() {
559 EthernetDestinationBuilder ethDestBuild = new EthernetDestinationBuilder();
560 ethDestBuild.setAddress(new MacAddress("3C:A9:F4:00:E0:C8"));
561 return ethDestBuild.build();