package org.opendaylight.controller.sal.compability; import com.google.common.net.InetAddresses; import org.opendaylight.controller.sal.action.Controller; import org.opendaylight.controller.sal.action.Drop; import org.opendaylight.controller.sal.action.Flood; import org.opendaylight.controller.sal.action.FloodAll; import org.opendaylight.controller.sal.action.HwPath; import org.opendaylight.controller.sal.action.Loopback; import org.opendaylight.controller.sal.action.Output; import org.opendaylight.controller.sal.action.PopVlan; import org.opendaylight.controller.sal.action.PushVlan; import org.opendaylight.controller.sal.action.SetDlDst; import org.opendaylight.controller.sal.action.SetDlSrc; import org.opendaylight.controller.sal.action.SetDlType; import org.opendaylight.controller.sal.action.SetNextHop; import org.opendaylight.controller.sal.action.SetNwDst; import org.opendaylight.controller.sal.action.SetNwSrc; import org.opendaylight.controller.sal.action.SetNwTos; import org.opendaylight.controller.sal.action.SetTpDst; import org.opendaylight.controller.sal.action.SetTpSrc; import org.opendaylight.controller.sal.action.SetVlanCfi; import org.opendaylight.controller.sal.action.SetVlanId; import org.opendaylight.controller.sal.action.SetVlanPcp; import org.opendaylight.controller.sal.action.SwPath; import org.opendaylight.controller.sal.core.NodeConnector; import org.opendaylight.controller.sal.flowprogrammer.Flow; import org.opendaylight.controller.sal.match.Match; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Dscp; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Prefix; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv6Prefix; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.PortNumber; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Uri; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.MacAddress; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.ActionList; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.VlanCfi; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.ControllerAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.DropAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.FloodAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.FloodAllAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.HwPathAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.LoopbackAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.OutputAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.PopMplsAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.PopVlanAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.PushMplsAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.PushPbbAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.PushVlanAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetDlDstAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetDlSrcAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetDlTypeAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetMplsTtlAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetNextHopAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetNwDstAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetNwSrcAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetNwTosAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetNwTtlAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetQueueAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetTpDstAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetTpSrcAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetVlanCfiAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetVlanIdAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SetVlanPcpAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.action.SwPathAction; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.list.Action; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.address.Address; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.address.address.Ipv4; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.address.address.Ipv6; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction; import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.EtherType; import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanPcp; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.MacAddressFilter; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.arp.match.fields.ArpSourceHardwareAddress; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.arp.match.fields.ArpTargetHardwareAddress; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.ethernet.match.fields.EthernetType; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.EthernetMatch; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.IpMatch; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.Layer3Match; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.Layer4Match; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.VlanMatch; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._3.match.ArpMatch; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._3.match.Ipv4Match; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._3.match.Ipv6Match; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._4.match.SctpMatch; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._4.match.TcpMatch; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._4.match.UdpMatch; import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.vlan.match.fields.VlanId; import java.net.InetAddress; import java.util.ArrayList; import java.util.Collections; import java.util.List; import static org.opendaylight.controller.sal.compability.ProtocolConstants.ETHERNET_ARP; import static org.opendaylight.controller.sal.compability.ProtocolConstants.SCTP; import static org.opendaylight.controller.sal.compability.ProtocolConstants.TCP; import static org.opendaylight.controller.sal.compability.ProtocolConstants.UDP; import static org.opendaylight.controller.sal.match.MatchType.DL_DST; import static org.opendaylight.controller.sal.match.MatchType.DL_SRC; import static org.opendaylight.controller.sal.match.MatchType.DL_TYPE; import static org.opendaylight.controller.sal.match.MatchType.DL_VLAN; import static org.opendaylight.controller.sal.match.MatchType.DL_VLAN_PR; import static org.opendaylight.controller.sal.match.MatchType.NW_DST; import static org.opendaylight.controller.sal.match.MatchType.NW_PROTO; import static org.opendaylight.controller.sal.match.MatchType.NW_SRC; import static org.opendaylight.controller.sal.match.MatchType.NW_TOS; import static org.opendaylight.controller.sal.match.MatchType.TP_DST; import static org.opendaylight.controller.sal.match.MatchType.TP_SRC; public class ToSalConversionsUtils { private ToSalConversionsUtils() { } public static Flow toFlow(org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.Flow source) { final Flow target = new Flow(); Integer hardTimeout = source.getHardTimeout(); if (hardTimeout != null) { target.setHardTimeout(hardTimeout.shortValue()); } Integer idleTimeout = source.getIdleTimeout(); if (idleTimeout != null) { target.setIdleTimeout(idleTimeout.shortValue()); } Integer priority = source.getPriority(); if (priority != null) { target.setPriority(priority.shortValue()); } target.setMatch(toMatch(source.getMatch())); List actions = getAction(source); if (actions != null) { target.setActions(actionFrom(actions)); } target.setId(source.getCookie().longValue()); return target; } public static List getAction( org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.Flow source) { if (source.getInstructions() != null) { for (Instruction instruction : source.getInstructions().getInstruction()) { if (instruction.getInstruction() instanceof ActionList) { return (((ActionList) instruction.getInstruction()).getAction()); } } } // TODO Auto-generated method stub return Collections.emptyList(); } public static List actionFrom(List actions) { List targetAction = new ArrayList<>(); for (Action action : actions) { org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.action.Action sourceAction = action .getAction(); if (sourceAction instanceof ControllerAction) { targetAction.add(new Controller()); } else if (sourceAction instanceof OutputAction) { List nodeConnectors = ((OutputAction) sourceAction).getOutputNodeConnector(); if (nodeConnectors != null) { for (Uri uri : nodeConnectors) { targetAction.add(new Output(fromNodeConnectorRef(uri))); } } } else if (sourceAction instanceof PopMplsAction) { // TODO: define maping } else if (sourceAction instanceof PushMplsAction) { // TODO: define maping } else if (sourceAction instanceof PushPbbAction) { // TODO: define maping } else if (sourceAction instanceof SetMplsTtlAction) { // TODO: define maping // targetAction = //no action to map } else if (sourceAction instanceof SetNwTtlAction) { // TODO: define maping } else if (sourceAction instanceof SetQueueAction) { // TODO: define maping // targetAction = //no action to map } else if (sourceAction instanceof DropAction) { targetAction.add(new Drop()); } else if (sourceAction instanceof FloodAction) { targetAction.add(new Flood()); } else if (sourceAction instanceof FloodAllAction) { targetAction.add(new FloodAll()); } else if (sourceAction instanceof HwPathAction) { targetAction.add(new HwPath()); } else if (sourceAction instanceof LoopbackAction) { targetAction.add(new Loopback()); } else if (sourceAction instanceof PopVlanAction) { targetAction.add(new PopVlan()); } else if (sourceAction instanceof PushVlanAction) { PushVlanAction pushVlanAction = (PushVlanAction) sourceAction; PushVlan pushVlan = pushVlanFrom(pushVlanAction); if (pushVlan != null) { targetAction.add(pushVlan); } } else if (sourceAction instanceof SetDlDstAction) { MacAddress addressL2Dest = ((SetDlDstAction) sourceAction).getAddress(); if (addressL2Dest != null) { targetAction.add(new SetDlDst(bytesFrom(addressL2Dest))); } } else if (sourceAction instanceof SetDlSrcAction) { MacAddress addressL2Src = ((SetDlSrcAction) sourceAction).getAddress(); if (addressL2Src != null) { targetAction.add(new SetDlSrc(bytesFrom(addressL2Src))); } } else if (sourceAction instanceof SetDlTypeAction) { EtherType dlType = ((SetDlTypeAction) sourceAction).getDlType(); if (dlType != null) { Long dlTypeValue = dlType.getValue(); if (dlTypeValue != null) { targetAction.add(new SetDlType(dlTypeValue.intValue())); } } } else if (sourceAction instanceof SetNextHopAction) { Address addressL3 = ((SetNextHopAction) sourceAction).getAddress(); InetAddress inetAddress = inetAddressFrom(addressL3); if (inetAddress != null) { targetAction.add(new SetNextHop(inetAddress)); } } else if (sourceAction instanceof SetNwDstAction) { Address addressL3 = ((SetNwDstAction) sourceAction).getAddress(); InetAddress inetAddress = inetAddressFrom(addressL3); if (inetAddress != null) { targetAction.add(new SetNwDst(inetAddress)); } } else if (sourceAction instanceof SetNwSrcAction) { Address addressL3 = ((SetNwSrcAction) sourceAction).getAddress(); InetAddress inetAddress = inetAddressFrom(addressL3); if (inetAddress != null) { targetAction.add(new SetNwSrc(inetAddress)); } } else if (sourceAction instanceof SetNwTosAction) { Integer tos = ((SetNwTosAction) sourceAction).getTos(); if (tos != null) { targetAction.add(new SetNwTos(tos)); } } else if (sourceAction instanceof SetTpDstAction) { PortNumber port = ((SetTpDstAction) sourceAction).getPort(); if (port != null) { Integer portValue = port.getValue(); if (port.getValue() != null) { targetAction.add(new SetTpDst(portValue)); } } } else if (sourceAction instanceof SetTpSrcAction) { PortNumber port = ((SetTpSrcAction) sourceAction).getPort(); if (port != null) { Integer portValue = port.getValue(); if (port.getValue() != null) { targetAction.add(new SetTpSrc(portValue)); } } } else if (sourceAction instanceof SetVlanCfiAction) { VlanCfi vlanCfi = ((SetVlanCfiAction) sourceAction).getVlanCfi(); if (vlanCfi != null) { Integer vlanCfiValue = vlanCfi.getValue(); if (vlanCfiValue != null) { targetAction.add(new SetVlanCfi(vlanCfiValue)); } } } else if (sourceAction instanceof SetVlanIdAction) { org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanId vlanID = ((SetVlanIdAction) sourceAction) .getVlanId(); if (vlanID != null) { Integer vlanIdValue = vlanID.getValue(); if (vlanIdValue != null) { targetAction.add(new SetVlanId(vlanIdValue)); } } } else if (sourceAction instanceof SetVlanPcpAction) { VlanPcp vlanPcp = ((SetVlanPcpAction) sourceAction).getVlanPcp(); if (vlanPcp != null) { Short vlanPcpValue = vlanPcp.getValue(); if (vlanPcpValue != null) { targetAction.add(new SetVlanPcp(vlanPcpValue)); } } } else if (sourceAction instanceof SwPathAction) { targetAction.add(new SwPath()); } } return targetAction; } private static InetAddress inetAddressFrom(Address addressL3) { if (addressL3 != null) { if (addressL3 instanceof Ipv4) { Ipv4Prefix addressL3Ipv4 = ((Ipv4) addressL3).getIpv4Address(); if (addressL3Ipv4 != null) { return inetAddressFrom(addressL3Ipv4); } } else if (addressL3 instanceof Ipv6) { Ipv6Prefix addressL3Ipv6 = ((Ipv6) addressL3).getIpv6Address(); if (addressL3Ipv6 != null) { return inetAddressFrom(addressL3Ipv6); } } } return null; } private static PushVlan pushVlanFrom(PushVlanAction pushVlanAction) { final int tag; final int pcp; final int cfi; final int vlanId; if (pushVlanAction.getTag() != null) { tag = pushVlanAction.getTag(); if (pushVlanAction.getPcp() != null) { pcp = pushVlanAction.getPcp(); if (pushVlanAction.getCfi() != null && pushVlanAction.getCfi().getValue() != null) { cfi = pushVlanAction.getCfi().getValue(); if (pushVlanAction.getVlanId() != null && pushVlanAction.getVlanId().getValue() != null) { vlanId = pushVlanAction.getVlanId().getValue(); return new PushVlan(tag, pcp, cfi, vlanId); } } } } return null; } private static NodeConnector fromNodeConnectorRef(Uri uri) { // TODO: Define mapping return null; } public static Match toMatch(org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.Match source) { Match target = new Match(); if (source != null) { fillFrom(target, source.getVlanMatch()); fillFrom(target, source.getEthernetMatch()); fillFrom(target, source.getLayer3Match()); fillFrom(target, source.getLayer4Match()); fillFrom(target, source.getIpMatch()); } return target; } private static void fillFrom(Match target, VlanMatch vlanMatch) { if (vlanMatch != null) { VlanId vlanId = vlanMatch.getVlanId(); if (vlanId != null) { org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanId vlanIdInner = vlanId .getVlanId(); if (vlanIdInner != null) { Integer vlanValue = vlanIdInner.getValue(); if (vlanValue != null) { target.setField(DL_VLAN, vlanValue.shortValue()); } } } VlanPcp vlanPcp = vlanMatch.getVlanPcp(); if (vlanPcp != null) { Short vlanPcpValue = vlanPcp.getValue(); if (vlanPcpValue != null) { target.setField(DL_VLAN_PR, vlanPcpValue.byteValue()); } } } } private static void fillFrom(Match target, IpMatch ipMatch) { if (ipMatch != null) { Short ipProtocol = ipMatch.getIpProtocol(); if (ipProtocol != null && target.getField(NW_PROTO) == null) { target.setField(NW_PROTO, ipProtocol.byteValue()); } Dscp dscp = ipMatch.getIpDscp(); if (dscp != null) { Short dscpValue = dscp.getValue(); if (dscpValue != null) { target.setField(NW_TOS, dscpValue.byteValue()); } } } } private static void fillFrom(Match target, Layer4Match layer4Match) { if (layer4Match == null) { return; } if (layer4Match instanceof SctpMatch) { fillTransportLayer(target, (SctpMatch) layer4Match); } else if (layer4Match instanceof TcpMatch) { fillTransportLayer(target, (TcpMatch) layer4Match); } else if (layer4Match instanceof UdpMatch) { fillTransportLayer(target, (UdpMatch) layer4Match); } } private static void fillTransportLayer(Match target, UdpMatch source) { PortNumber udpSourcePort = source.getUdpSourcePort(); if (udpSourcePort != null) { Integer udpSourcePortValue = udpSourcePort.getValue(); if (udpSourcePortValue != null) { target.setField(TP_SRC, udpSourcePortValue.shortValue()); } } PortNumber udpDestPort = source.getUdpDestinationPort(); if (udpDestPort != null) { Integer udpDestPortValue = udpDestPort.getValue(); if (udpDestPortValue != null) { target.setField(TP_DST, udpDestPortValue.shortValue()); } } target.setField(NW_PROTO, UDP); } private static void fillTransportLayer(Match target, TcpMatch source) { PortNumber tcpSourcePort = source.getTcpSourcePort(); if (tcpSourcePort != null) { Integer tcpSourcePortValue = tcpSourcePort.getValue(); if (tcpSourcePortValue != null) { target.setField(TP_SRC, tcpSourcePortValue.shortValue()); } } PortNumber tcpDestPort = source.getTcpDestinationPort(); if (tcpDestPort != null) { Integer tcpDestPortValue = tcpDestPort.getValue(); if (tcpDestPortValue != null) { target.setField(TP_DST, tcpDestPortValue.shortValue()); } } target.setField(NW_PROTO, TCP); } private static void fillTransportLayer(Match target, SctpMatch source) { PortNumber sctpSourcePort = source.getSctpSourcePort(); if (sctpSourcePort != null) { Integer sctpSourcePortValue = sctpSourcePort.getValue(); if (sctpSourcePortValue != null) { target.setField(TP_SRC, sctpSourcePortValue.shortValue()); } } PortNumber sctpDestPort = source.getSctpDestinationPort(); if (sctpDestPort != null) { Integer sctpDestPortValue = sctpDestPort.getValue(); if (sctpDestPortValue != null) { target.setField(TP_DST, sctpDestPortValue.shortValue()); } } target.setField(NW_PROTO, SCTP); } private static void fillFrom(Match target, Layer3Match source) { if (source == null) return; if (source instanceof Ipv4Match) { fillFromIpv4(target, (Ipv4Match) source); } else if (source instanceof Ipv6Match) { fillFromIpv6(target, (Ipv6Match) source); } else if (source instanceof ArpMatch) { fillFromArp(target, (ArpMatch) source); } } private static void fillFromArp(Match target, ArpMatch source) { Ipv4Prefix sourceAddress = source.getArpSourceTransportAddress(); if (sourceAddress != null) { target.setField(NW_SRC, (InetAddress) inetAddressFrom(sourceAddress), null); } Ipv4Prefix destAddress = source.getArpTargetTransportAddress(); if (destAddress != null) { target.setField(NW_DST, (InetAddress) inetAddressFrom(destAddress), null); } ArpSourceHardwareAddress sourceHwAddress = source.getArpSourceHardwareAddress(); if (sourceHwAddress != null) { target.setField(DL_SRC, bytesFrom(sourceHwAddress.getAddress())); } ArpTargetHardwareAddress targetHwAddress = source.getArpTargetHardwareAddress(); if (targetHwAddress != null) { target.setField(DL_DST, bytesFrom(targetHwAddress.getAddress())); } target.setField(DL_TYPE, new Short(ETHERNET_ARP)); } private static void fillFromIpv6(Match target, Ipv6Match source) { Ipv6Prefix sourceAddress = source.getIpv6Source(); if (sourceAddress != null) { target.setField(NW_SRC, (InetAddress) inetAddressFrom(sourceAddress), null); } Ipv6Prefix destAddress = source.getIpv6Destination(); if (destAddress != null) { target.setField(NW_DST, (InetAddress) inetAddressFrom(destAddress), null); } } private static void fillFromIpv4(Match target, Ipv4Match source) { Ipv4Prefix sourceAddress = source.getIpv4Source(); if (sourceAddress != null) { target.setField(NW_SRC, (InetAddress) inetAddressFrom(sourceAddress), null); } Ipv4Prefix destAddress = source.getIpv4Destination(); if (destAddress != null) { target.setField(NW_DST, (InetAddress) inetAddressFrom(destAddress), null); } } private static InetAddress inetAddressFrom(Ipv4Prefix source) { if (source != null) { String[] parts = source.getValue().split("/"); return InetAddresses.forString(parts[0]); } return null; } private static InetAddress inetAddressFrom(Ipv6Prefix source) { if (source != null) { String[] parts = source.getValue().split("/"); return InetAddresses.forString(parts[0]); } return null; } private static void fillFrom(Match target, EthernetMatch source) { if (source == null) return; EthernetType ethType = source.getEthernetType(); if (ethType != null) { EtherType ethInnerType = ethType.getType(); if (ethInnerType != null && target.getField(DL_TYPE) == null) { Long value = ethInnerType.getValue(); target.setField(DL_TYPE, value.shortValue()); } } MacAddressFilter ethSource = source.getEthernetSource(); if (ethSource != null) { target.setField(DL_SRC, bytesFrom(ethSource.getAddress())); } MacAddressFilter ethDest = source.getEthernetDestination(); if (ethDest != null) { target.setField(DL_DST, bytesFrom(ethDest.getAddress())); } } private static byte[] bytesFrom(MacAddress address) { String[] mac = address.getValue().split(":"); byte[] macAddress = new byte[6]; // mac.length == 6 bytes for (int i = 0; i < mac.length; i++) { macAddress[i] = Integer.decode("0x" + mac[i]).byteValue(); } return macAddress; } }