X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-compability%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fcompability%2FToSalConversionsUtils.java;fp=opendaylight%2Fmd-sal%2Fsal-compability%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fcompability%2FToSalConversionsUtils.java;h=0000000000000000000000000000000000000000;hb=cfa6e9d0a2193edb2a2e36c04ca95eaf28a651f9;hp=41b425ef2d6a9526023855a876851b2d9e979f2c;hpb=18fa9cb41678400d1decd007a66fc1f7be894f66;p=controller.git diff --git a/opendaylight/md-sal/sal-compability/src/main/java/org/opendaylight/controller/sal/compability/ToSalConversionsUtils.java b/opendaylight/md-sal/sal-compability/src/main/java/org/opendaylight/controller/sal/compability/ToSalConversionsUtils.java deleted file mode 100644 index 41b425ef2d..0000000000 --- a/opendaylight/md-sal/sal-compability/src/main/java/org/opendaylight/controller/sal/compability/ToSalConversionsUtils.java +++ /dev/null @@ -1,573 +0,0 @@ -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; - } -}