-/* Copyright (C)2013 Pantheon Technologies, s.r.o. All rights reserved. */\r
-package org.opendaylight.openflowjava.protocol.impl.util;\r
-\r
-import io.netty.buffer.ByteBuf;\r
-\r
-import java.util.Arrays;\r
-import java.util.HashMap;\r
-import java.util.List;\r
-import java.util.Map;\r
-\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.BosMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.DscpMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.EcnMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.EthTypeMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.Icmpv4CodeMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.Icmpv4TypeMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.Icmpv6CodeMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.Icmpv6TypeMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.Ipv4AddressMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.Ipv6AddressMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.Ipv6FlabelMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.IsidMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MacAddressMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MaskMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MetadataMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MplsLabelMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.OpCodeMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.PortMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.PortNumberMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.ProtocolNumberMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.PseudoFieldMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.PseudoFieldMatchEntry.PseudoField;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.TcMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.VlanPcpMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.VlanVidMatchEntry;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.StandardMatchType;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.ArpOp;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.ArpSha;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.ArpSpa;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.ArpTha;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.ArpTpa;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Clazz;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.EthDst;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.EthSrc;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.EthType;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.ExperimenterClass;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Icmpv4Code;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Icmpv4Type;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Icmpv6Code;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Icmpv6Type;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.InPhyPort;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.InPort;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.IpDscp;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.IpEcn;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.IpProto;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv4Dst;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv4Src;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv6Dst;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv6Exthdr;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv6Flabel;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv6NdSll;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv6NdTarget;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv6NdTll;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv6Src;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.MatchField;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Metadata;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.MplsBos;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.MplsLabel;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.MplsTc;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Nxm0Class;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Nxm1Class;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.OpenflowBasicClass;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.OxmMatchType;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.PbbIsid;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.SctpDst;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.SctpSrc;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.TcpDst;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.TcpSrc;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.TunnelId;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.UdpDst;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.UdpSrc;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.VlanPcp;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.VlanVid;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.oxm.fields.MatchEntries;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.match.grouping.Match;\r
-import org.slf4j.Logger;\r
-import org.slf4j.LoggerFactory;\r
-\r
-/**\r
- * Serializes ofp_match (OpenFlow v1.3) and its oxm_fields structures\r
- * @author michal.polkorab\r
- * @author timotej.kubas\r
- */\r
-public class MatchSerializer {\r
- private static final Logger LOGGER = LoggerFactory.getLogger(MatchSerializer.class);\r
- private static final byte STANDARD_MATCH_TYPE_CODE = 0;\r
- private static final byte OXM_MATCH_TYPE_CODE = 1;\r
- private static final int NXM0_CLASS_CODE = 0x0000;\r
- private static final int NXM1_CLASS_CODE = 0x0001;\r
- private static final int OPENFLOW_BASIC_CLASS_CODE = 0x8000;\r
- private static final int EXPERIMENTER_CLASS_CODE = 0xFFFF;\r
- private static final byte MATCH_TYPE_AND_LENGTH_SIZE = 4;\r
- private static final byte MATCH_ENTRY_HEADER_LENGTH = 4;\r
-\r
- /**\r
- * Encodes match (OpenFlow v1.3)\r
- * @param match ofp_match object\r
- * @param out output ByteBuf\r
- */\r
- public static void encodeMatch(Match match, ByteBuf out) {\r
- if (match == null) {\r
- LOGGER.debug("Match is null");\r
- return;\r
- }\r
- encodeType(match, out);\r
- // Length of ofp_match (excluding padding)\r
- int length = computeMatchLengthInternal(match);\r
- out.writeShort(length);\r
- encodeMatchEntries(match.getMatchEntries(), out);\r
- int paddingRemainder = length % EncodeConstants.PADDING;\r
- if (paddingRemainder != 0) {\r
- ByteBufUtils.padBuffer(EncodeConstants.PADDING - paddingRemainder, out);\r
- }\r
- }\r
-\r
- private static void encodeType(Match match, ByteBuf out) {\r
- if (match.getType().isAssignableFrom(StandardMatchType.class)) {\r
- out.writeShort(STANDARD_MATCH_TYPE_CODE);\r
- } else if (match.getType().isAssignableFrom(OxmMatchType.class)) {\r
- out.writeShort(OXM_MATCH_TYPE_CODE);\r
- }\r
- }\r
-\r
- /**\r
- * Encodes MatchEntries\r
- * @param matchEntries list of match entries (oxm_fields)\r
- * @param out output ByteBuf\r
- */\r
- public static void encodeMatchEntries(List<MatchEntries> matchEntries, ByteBuf out) {\r
- if (matchEntries == null) {\r
- LOGGER.warn("Match entries are null");\r
- return;\r
- }\r
- for (MatchEntries entry : matchEntries) {\r
- encodeClass(entry.getOxmClass(), out);\r
- encodeRest(entry, out);\r
- }\r
- }\r
-\r
- private static void encodeClass(Class<? extends Clazz> clazz, ByteBuf out) {\r
- if (clazz.isAssignableFrom(Nxm0Class.class)) {\r
- out.writeShort(NXM0_CLASS_CODE);\r
- } else if (clazz.isAssignableFrom(Nxm1Class.class)) {\r
- out.writeShort(NXM1_CLASS_CODE);\r
- } else if (clazz.isAssignableFrom(OpenflowBasicClass.class)) {\r
- out.writeShort(OPENFLOW_BASIC_CLASS_CODE);\r
- } else if (clazz.isAssignableFrom(ExperimenterClass.class)) {\r
- out.writeShort(EXPERIMENTER_CLASS_CODE);\r
- }\r
- }\r
-\r
- private static void encodeRest(MatchEntries entry, ByteBuf out) {\r
- int fieldValue = 0;\r
- Class<? extends MatchField> field = entry.getOxmMatchField();\r
- if (field.isAssignableFrom(InPort.class)) {\r
- fieldValue = 0;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_INT_IN_BYTES);\r
- out.writeInt(entry.getAugmentation(PortNumberMatchEntry.class).getPortNumber().getValue().intValue());\r
- } else if (field.isAssignableFrom(InPhyPort.class)) {\r
- fieldValue = 1;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_INT_IN_BYTES);\r
- out.writeInt(entry.getAugmentation(PortNumberMatchEntry.class).getPortNumber().getValue().intValue());\r
- } else if (field.isAssignableFrom(Metadata.class)) {\r
- fieldValue = 2;\r
- writeMetadataRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(EthDst.class)) {\r
- fieldValue = 3;\r
- writeMacAddressRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(EthSrc.class)) {\r
- fieldValue = 4;\r
- writeMacAddressRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(EthType.class)) {\r
- fieldValue = 5;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);\r
- out.writeShort(entry.getAugmentation(EthTypeMatchEntry.class).getEthType().getValue().shortValue());\r
- } else if (field.isAssignableFrom(VlanVid.class)) {\r
- fieldValue = 6;\r
- fieldValue = fieldValue << 1;\r
- VlanVidMatchEntry vlanVid = entry.getAugmentation(VlanVidMatchEntry.class);\r
- int vlanVidValue = vlanVid.getVlanVid();\r
- if (vlanVid.isCfiBit()) {\r
- short cfi = 1 << 12; // 13-th bit\r
- vlanVidValue = vlanVidValue | cfi;\r
- }\r
- if (entry.isHasMask()) {\r
- fieldValue = fieldValue | 1;\r
- out.writeByte(fieldValue);\r
- byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();\r
- out.writeByte(EncodeConstants.SIZE_OF_SHORT_IN_BYTES + mask.length);\r
- out.writeShort(vlanVidValue);\r
- out.writeBytes(mask);\r
- } else {\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);\r
- out.writeShort(vlanVidValue);\r
- }\r
- } else if (field.isAssignableFrom(VlanPcp.class)) {\r
- fieldValue = 7;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);\r
- out.writeByte(entry.getAugmentation(VlanPcpMatchEntry.class).getVlanPcp().byteValue());\r
- } else if (field.isAssignableFrom(IpDscp.class)) {\r
- fieldValue = 8;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);\r
- out.writeByte(entry.getAugmentation(DscpMatchEntry.class).getDscp().getValue());\r
- } else if (field.isAssignableFrom(IpEcn.class)) {\r
- fieldValue = 9;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);\r
- out.writeByte(entry.getAugmentation(EcnMatchEntry.class).getEcn());\r
- } else if (field.isAssignableFrom(IpProto.class)) {\r
- fieldValue = 10;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);\r
- out.writeByte(entry.getAugmentation(ProtocolNumberMatchEntry.class).getProtocolNumber());\r
- } else if (field.isAssignableFrom(Ipv4Src.class)) {\r
- fieldValue = 11;\r
- writeIpv4AddressRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(Ipv4Dst.class)) {\r
- fieldValue = 12;\r
- writeIpv4AddressRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(TcpSrc.class)) {\r
- fieldValue = 13;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);\r
- out.writeShort(entry.getAugmentation(PortMatchEntry.class).getPort().getValue().intValue());\r
- } else if (field.isAssignableFrom(TcpDst.class)) {\r
- fieldValue = 14;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);\r
- out.writeShort(entry.getAugmentation(PortMatchEntry.class).getPort().getValue().intValue());\r
- } else if (field.isAssignableFrom(UdpSrc.class)) {\r
- fieldValue = 15;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);\r
- out.writeShort(entry.getAugmentation(PortMatchEntry.class).getPort().getValue().intValue());\r
- } else if (field.isAssignableFrom(UdpDst.class)) {\r
- fieldValue = 16;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);\r
- out.writeShort(entry.getAugmentation(PortMatchEntry.class).getPort().getValue().intValue());\r
- } else if (field.isAssignableFrom(SctpSrc.class)) {\r
- fieldValue = 17;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);\r
- out.writeShort(entry.getAugmentation(PortMatchEntry.class).getPort().getValue().intValue());\r
- } else if (field.isAssignableFrom(SctpDst.class)) {\r
- fieldValue = 18;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);\r
- out.writeShort(entry.getAugmentation(PortMatchEntry.class).getPort().getValue().intValue());\r
- } else if (field.isAssignableFrom(Icmpv4Type.class)) {\r
- fieldValue = 19;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);\r
- out.writeByte(entry.getAugmentation(Icmpv4TypeMatchEntry.class).getIcmpv4Type());\r
- } else if (field.isAssignableFrom(Icmpv4Code.class)) {\r
- fieldValue = 20;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);\r
- out.writeByte(entry.getAugmentation(Icmpv4CodeMatchEntry.class).getIcmpv4Code());\r
- } else if (field.isAssignableFrom(ArpOp.class)) {\r
- fieldValue = 21;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);\r
- out.writeShort(entry.getAugmentation(OpCodeMatchEntry.class).getOpCode());\r
- } else if (field.isAssignableFrom(ArpSpa.class)) {\r
- fieldValue = 22;\r
- writeIpv4AddressRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(ArpTpa.class)) {\r
- fieldValue = 23;\r
- writeIpv4AddressRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(ArpSha.class)) {\r
- fieldValue = 24;\r
- writeMacAddressRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(ArpTha.class)) {\r
- fieldValue = 25;\r
- writeMacAddressRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(Ipv6Src.class)) {\r
- fieldValue = 26;\r
- writeIpv6AddressRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(Ipv6Dst.class)) {\r
- fieldValue = 27;\r
- writeIpv6AddressRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(Ipv6Flabel.class)) {\r
- fieldValue = 28;\r
- fieldValue = fieldValue << 1;\r
- if (entry.isHasMask()) {\r
- fieldValue = fieldValue | 1;\r
- out.writeByte(fieldValue);\r
- byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();\r
- out.writeByte(EncodeConstants.SIZE_OF_INT_IN_BYTES + mask.length); // 20 b + mask [OF 1.3.2 spec]\r
- LOGGER.warn("Ipv6Flabel match entry: possible wrong length written (wrote 4 - maybe must be 3)");\r
- out.writeInt(entry.getAugmentation(Ipv6FlabelMatchEntry.class).getIpv6Flabel().getValue().intValue());\r
- out.writeBytes(entry.getAugmentation(MaskMatchEntry.class).getMask());\r
- } else {\r
- out.writeByte(fieldValue);\r
- out.writeByte(EncodeConstants.SIZE_OF_INT_IN_BYTES); // 20 b [OF 1.3.2 spec]\r
- LOGGER.warn("Ipv6Flabel match entry: possible wrong length written (wrote 4 - maybe must be 3)");\r
- out.writeInt(entry.getAugmentation(Ipv6FlabelMatchEntry.class).getIpv6Flabel().getValue().intValue());\r
- }\r
- } else if (field.isAssignableFrom(Icmpv6Type.class)) {\r
- fieldValue = 29;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);\r
- out.writeByte(entry.getAugmentation(Icmpv6TypeMatchEntry.class).getIcmpv6Type());\r
- } else if (field.isAssignableFrom(Icmpv6Code.class)) {\r
- fieldValue = 30;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);\r
- out.writeByte(entry.getAugmentation(Icmpv6CodeMatchEntry.class).getIcmpv6Code());\r
- } else if (field.isAssignableFrom(Ipv6NdTarget.class)) {\r
- fieldValue = 31;\r
- writeIpv6AddressRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(Ipv6NdSll.class)) {\r
- fieldValue = 32;\r
- writeMacAddressRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(Ipv6NdTll.class)) {\r
- fieldValue = 33;\r
- writeMacAddressRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(MplsLabel.class)) {\r
- fieldValue = 34;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_INT_IN_BYTES);\r
- LOGGER.warn("MplsLabel match entry: possible wrong length written (wrote 4 - maybe must be 3)");\r
- out.writeInt(entry.getAugmentation(MplsLabelMatchEntry.class).getMplsLabel().intValue());\r
- } else if (field.isAssignableFrom(MplsTc.class)) {\r
- fieldValue = 35;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);\r
- out.writeByte(entry.getAugmentation(TcMatchEntry.class).getTc());\r
- } else if (field.isAssignableFrom(MplsBos.class)) {\r
- fieldValue = 36;\r
- writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);\r
- out.writeBoolean(entry.getAugmentation(BosMatchEntry.class).isBos().booleanValue());\r
- } else if (field.isAssignableFrom(PbbIsid.class)) {\r
- fieldValue = 37;\r
- fieldValue = fieldValue << 1;\r
- if (entry.isHasMask()) {\r
- fieldValue = fieldValue | 1;\r
- out.writeByte(fieldValue);\r
- byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();\r
- out.writeByte(EncodeConstants.SIZE_OF_LONG_IN_BYTES + mask.length);\r
- LOGGER.warn("PbbIsid match entry: possible wrong length written (wrote 4 - maybe must be 3)");\r
- out.writeInt(entry.getAugmentation(IsidMatchEntry.class).getIsid().intValue());\r
- out.writeBytes(mask);\r
- } else {\r
- out.writeByte(fieldValue);\r
- out.writeByte(EncodeConstants.SIZE_OF_LONG_IN_BYTES);\r
- LOGGER.warn("PbbIsid match entry: possible wrong length written (wrote 4 - maybe must be 3)");\r
- out.writeInt(entry.getAugmentation(IsidMatchEntry.class).getIsid().intValue());\r
- }\r
- } else if (field.isAssignableFrom(TunnelId.class)) {\r
- fieldValue = 38;\r
- writeMetadataRelatedEntry(entry, out, fieldValue);\r
- } else if (field.isAssignableFrom(Ipv6Exthdr.class)) {\r
- fieldValue = 39;\r
- fieldValue = fieldValue << 1;\r
- PseudoField pseudoField = entry.getAugmentation(PseudoFieldMatchEntry.class).getPseudoField();\r
- Map<Integer, Boolean> map = new HashMap<>();\r
- map.put(0, pseudoField.isNonext());\r
- map.put(1, pseudoField.isEsp());\r
- map.put(2, pseudoField.isAuth());\r
- map.put(3, pseudoField.isDest());\r
- map.put(4, pseudoField.isFrag());\r
- map.put(5, pseudoField.isRouter());\r
- map.put(6, pseudoField.isHop());\r
- map.put(7, pseudoField.isUnrep());\r
- map.put(8, pseudoField.isUnseq());\r
- int bitmap = ByteBufUtils.fillBitMaskFromMap(map);\r
- if (entry.isHasMask()) {\r
- fieldValue = fieldValue | 1;\r
- out.writeByte(fieldValue);\r
- byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();\r
- out.writeByte(EncodeConstants.SIZE_OF_SHORT_IN_BYTES + mask.length);\r
- out.writeShort(bitmap);\r
- out.writeBytes(mask);\r
- } else {\r
- out.writeByte(fieldValue);\r
- out.writeByte(EncodeConstants.SIZE_OF_SHORT_IN_BYTES);\r
- out.writeShort(bitmap);\r
- }\r
- }\r
- }\r
-\r
- private static void writeOxmFieldAndLength(ByteBuf out, int fieldValue, int length) {\r
- int fieldAndMask = fieldValue << 1;\r
- out.writeByte(fieldAndMask);\r
- out.writeByte(length);\r
- }\r
-\r
- private static void writeMetadataRelatedEntry(MatchEntries entry, ByteBuf out, int value) {\r
- int fieldValue = value << 1;\r
- if (entry.isHasMask()) {\r
- fieldValue = fieldValue | 1;\r
- out.writeByte(fieldValue);\r
- byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();\r
- out.writeByte(EncodeConstants.SIZE_OF_LONG_IN_BYTES + mask.length);\r
- out.writeBytes(entry.getAugmentation(MetadataMatchEntry.class).getMetadata());\r
- out.writeBytes(mask);\r
- } else {\r
- out.writeByte(fieldValue);\r
- out.writeByte(EncodeConstants.SIZE_OF_LONG_IN_BYTES);\r
- out.writeBytes(entry.getAugmentation(MetadataMatchEntry.class).getMetadata());\r
- }\r
- }\r
-\r
- private static void writeMacAddressRelatedEntry(MatchEntries entry, ByteBuf out, int value) {\r
- int fieldValue = value << 1;\r
- if (entry.isHasMask()) {\r
- fieldValue = fieldValue | 1;\r
- out.writeByte(fieldValue);\r
- byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();\r
- out.writeByte(EncodeConstants.MAC_ADDRESS_LENGTH + mask.length); // 48 b + mask [OF 1.3.2 spec]\r
- String macAddress = entry.getAugmentation(MacAddressMatchEntry.class).getMacAddress().getValue();\r
- out.writeBytes(ByteBufUtils.macAddressToBytes(macAddress));\r
- out.writeBytes(mask);\r
- } else {\r
- out.writeByte(fieldValue);\r
- out.writeByte(EncodeConstants.MAC_ADDRESS_LENGTH); // 48 b [OF 1.3.2 spec]\r
- String macAddress = entry.getAugmentation(MacAddressMatchEntry.class).getMacAddress().getValue();\r
- out.writeBytes(ByteBufUtils.macAddressToBytes(macAddress));\r
- }\r
- }\r
-\r
- private static void writeIpv4AddressRelatedEntry(MatchEntries entry, ByteBuf out, int value) {\r
- int fieldValue = value << 1;\r
- if (entry.isHasMask()) {\r
- fieldValue = fieldValue | 1;\r
- out.writeByte(fieldValue);\r
- byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();\r
- out.writeByte(EncodeConstants.SIZE_OF_INT_IN_BYTES + mask.length);\r
- writeIpv4Address(entry, out);\r
- out.writeBytes(mask);\r
- } else {\r
- out.writeByte(fieldValue);\r
- out.writeByte(EncodeConstants.SIZE_OF_INT_IN_BYTES);\r
- writeIpv4Address(entry, out);\r
- }\r
- }\r
-\r
- private static void writeIpv4Address(MatchEntries entry, ByteBuf out) {\r
- String[] addressGroups = entry.getAugmentation(Ipv4AddressMatchEntry.class).getIpv4Address().getValue().split("\\.");\r
- for (int i = 0; i < addressGroups.length; i++) {\r
- out.writeByte(Integer.parseInt(addressGroups[i]));\r
- }\r
- }\r
-\r
- private static void writeIpv6AddressRelatedEntry(MatchEntries entry, ByteBuf out, int value) {\r
- int fieldValue = value << 1;\r
- String textAddress = entry.getAugmentation(Ipv6AddressMatchEntry.class).getIpv6Address().getValue();\r
- String[] address;\r
- if (textAddress.equals("::")) {\r
- address = new String[EncodeConstants.GROUPS_IN_IPV6_ADDRESS];\r
- Arrays.fill(address, "0");\r
- } else {\r
- address = parseIpv6Address(textAddress.split(":"));\r
- }\r
- if (entry.isHasMask()) {\r
- fieldValue = fieldValue | 1;\r
- out.writeByte(fieldValue);\r
- byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();\r
- out.writeByte(EncodeConstants.SIZE_OF_IPV6_ADDRESS_IN_BYTES + mask.length);\r
- for (int i = 0; i < address.length; i++) {\r
- out.writeShort(Integer.parseInt(address[i], 16));\r
- }\r
- out.writeBytes(mask);\r
- } else {\r
- out.writeByte(fieldValue);\r
- out.writeByte(EncodeConstants.SIZE_OF_IPV6_ADDRESS_IN_BYTES);\r
- for (int i = 0; i < address.length; i++) {\r
- out.writeShort(Integer.parseInt(address[i], 16));\r
- }\r
- }\r
- }\r
-\r
- private static String[] parseIpv6Address(String[] addressGroups) {\r
- int countEmpty = 0;\r
- for (int i = 0; i < addressGroups.length; i++) {\r
- if (addressGroups[i].equals("")){\r
- countEmpty++;\r
- }\r
- }\r
- String[] ready = new String[EncodeConstants.GROUPS_IN_IPV6_ADDRESS];\r
- switch (countEmpty) {\r
- case 0:\r
- ready = addressGroups;\r
- break;\r
- case 1:\r
- int zerosToBePushed = EncodeConstants.GROUPS_IN_IPV6_ADDRESS - addressGroups.length + 1;\r
- int index = 0;\r
- for (int i = 0; i < addressGroups.length; i++) {\r
- if (addressGroups[i].equals("")) {\r
- for (int j = 0; j < zerosToBePushed; j++) {\r
- ready[index] = "0";\r
- index++;\r
- }\r
- } else {\r
- ready[index] = addressGroups[i];\r
- index++;\r
- }\r
- }\r
- break;\r
- case 2:\r
- Arrays.fill(ready, "0");\r
- ready[ready.length - 1] = addressGroups[addressGroups.length - 1];\r
- break;\r
- default:\r
- throw new IllegalStateException("Incorrect ipv6 address");\r
- }\r
- return ready;\r
- }\r
-\r
- /**\r
- * Computes length of match (in bytes)\r
- * @param match\r
- * @return length of ofp_match (excluding padding)\r
- */\r
- public static int computeMatchLengthInternal(Match match) {\r
- int length = 0;\r
- if (match != null) {\r
- length += MATCH_TYPE_AND_LENGTH_SIZE + computeMatchEntriesLength(match.getMatchEntries());\r
- }\r
- return length;\r
- }\r
-\r
- /**\r
- * Computes length of match (in bytes)\r
- * @param match\r
- * @return length of ofp_match (excluding padding)\r
- */\r
- public static int computeMatchLength(Match match) {\r
- int length = computeMatchLengthInternal(match);\r
- int paddingRemainder = length % EncodeConstants.PADDING;\r
- if (paddingRemainder != 0) {\r
- length += EncodeConstants.PADDING - paddingRemainder;\r
- }\r
- return length;\r
- }\r
-\r
- /**\r
- * Computes length of MatchEntries (in bytes)\r
- * @param matchEntries list of match entries (oxm_fields)\r
- * @return length of MatchEntries\r
- */\r
- public static int computeMatchEntriesLength(List<MatchEntries> matchEntries) {\r
- int length = 0;\r
- if (matchEntries != null) {\r
- for (MatchEntries entry : matchEntries) {\r
- length += MATCH_ENTRY_HEADER_LENGTH;\r
- Class<? extends MatchField> field = entry.getOxmMatchField();\r
- if (field.isAssignableFrom(InPort.class)) {\r
- length += EncodeConstants.SIZE_OF_INT_IN_BYTES;\r
- } else if (field.isAssignableFrom(InPhyPort.class)) {\r
- length += EncodeConstants.SIZE_OF_INT_IN_BYTES;\r
- } else if (field.isAssignableFrom(Metadata.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_LONG_IN_BYTES);\r
- } else if (field.isAssignableFrom(EthDst.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.MAC_ADDRESS_LENGTH);\r
- } else if (field.isAssignableFrom(EthSrc.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.MAC_ADDRESS_LENGTH);\r
- } else if (field.isAssignableFrom(EthType.class)) {\r
- length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;\r
- } else if (field.isAssignableFrom(VlanVid.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);\r
- } else if (field.isAssignableFrom(VlanPcp.class)) {\r
- length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;\r
- } else if (field.isAssignableFrom(IpDscp.class)) {\r
- length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;\r
- } else if (field.isAssignableFrom(IpEcn.class)) {\r
- length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;\r
- } else if (field.isAssignableFrom(IpProto.class)) {\r
- length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;\r
- } else if (field.isAssignableFrom(Ipv4Src.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_INT_IN_BYTES);\r
- } else if (field.isAssignableFrom(Ipv4Dst.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_INT_IN_BYTES);\r
- } else if (field.isAssignableFrom(TcpSrc.class)) {\r
- length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;\r
- } else if (field.isAssignableFrom(TcpDst.class)) {\r
- length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;\r
- } else if (field.isAssignableFrom(UdpSrc.class)) {\r
- length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;\r
- } else if (field.isAssignableFrom(UdpDst.class)) {\r
- length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;\r
- } else if (field.isAssignableFrom(SctpSrc.class)) {\r
- length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;\r
- } else if (field.isAssignableFrom(SctpDst.class)) {\r
- length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;\r
- } else if (field.isAssignableFrom(Icmpv4Type.class)) {\r
- length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;\r
- } else if (field.isAssignableFrom(Icmpv4Code.class)) {\r
- length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;\r
- } else if (field.isAssignableFrom(ArpOp.class)) {\r
- length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;\r
- } else if (field.isAssignableFrom(ArpSpa.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_INT_IN_BYTES);\r
- } else if (field.isAssignableFrom(ArpTpa.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_INT_IN_BYTES);\r
- } else if (field.isAssignableFrom(ArpSha.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.MAC_ADDRESS_LENGTH);\r
- } else if (field.isAssignableFrom(ArpTha.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.MAC_ADDRESS_LENGTH);\r
- } else if (field.isAssignableFrom(Ipv6Src.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_IPV6_ADDRESS_IN_BYTES);\r
- } else if (field.isAssignableFrom(Ipv6Dst.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_IPV6_ADDRESS_IN_BYTES);\r
- } else if (field.isAssignableFrom(Ipv6Flabel.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_INT_IN_BYTES);\r
- } else if (field.isAssignableFrom(Icmpv6Type.class)) {\r
- length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;\r
- } else if (field.isAssignableFrom(Icmpv6Code.class)) {\r
- length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;\r
- } else if (field.isAssignableFrom(Ipv6NdTarget.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_IPV6_ADDRESS_IN_BYTES);\r
- } else if (field.isAssignableFrom(Ipv6NdSll.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.MAC_ADDRESS_LENGTH);\r
- } else if (field.isAssignableFrom(Ipv6NdTll.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.MAC_ADDRESS_LENGTH);\r
- } else if (field.isAssignableFrom(MplsLabel.class)) {\r
- length += EncodeConstants.SIZE_OF_INT_IN_BYTES;\r
- } else if (field.isAssignableFrom(MplsTc.class)) {\r
- length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;\r
- } else if (field.isAssignableFrom(MplsBos.class)) {\r
- length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;\r
- } else if (field.isAssignableFrom(PbbIsid.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_INT_IN_BYTES);\r
- } else if (field.isAssignableFrom(TunnelId.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_LONG_IN_BYTES);\r
- } else if (field.isAssignableFrom(Ipv6Exthdr.class)) {\r
- length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);\r
- }\r
- }\r
- }\r
- return length;\r
- }\r
-\r
- private static int computePossibleMaskEntryLength(MatchEntries entry, int length) {\r
- int entryLength = length;\r
- if (entry.isHasMask()) {\r
- entryLength *= 2;\r
- }\r
- return entryLength;\r
- }\r
-\r
-}\r
+/*
+ * Copyright (c) 2013 Pantheon Technologies s.r.o. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+package org.opendaylight.openflowjava.protocol.impl.util;
+
+import io.netty.buffer.ByteBuf;
+
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.BosMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.DscpMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.EcnMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.EthTypeMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.Icmpv4CodeMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.Icmpv4TypeMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.Icmpv6CodeMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.Icmpv6TypeMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.Ipv4AddressMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.Ipv6AddressMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.Ipv6FlabelMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.IsidMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MacAddressMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MaskMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MetadataMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MplsLabelMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.OpCodeMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.PortMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.PortNumberMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.ProtocolNumberMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.PseudoFieldMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.PseudoFieldMatchEntry.PseudoField;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.TcMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.VlanPcpMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.VlanVidMatchEntry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.StandardMatchType;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.ArpOp;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.ArpSha;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.ArpSpa;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.ArpTha;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.ArpTpa;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Clazz;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.EthDst;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.EthSrc;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.EthType;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.ExperimenterClass;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Icmpv4Code;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Icmpv4Type;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Icmpv6Code;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Icmpv6Type;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.InPhyPort;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.InPort;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.IpDscp;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.IpEcn;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.IpProto;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv4Dst;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv4Src;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv6Dst;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv6Exthdr;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv6Flabel;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv6NdSll;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv6NdTarget;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv6NdTll;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Ipv6Src;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.MatchField;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Metadata;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.MplsBos;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.MplsLabel;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.MplsTc;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Nxm0Class;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Nxm1Class;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.OpenflowBasicClass;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.OxmMatchType;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.PbbIsid;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.SctpDst;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.SctpSrc;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.TcpDst;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.TcpSrc;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.TunnelId;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.UdpDst;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.UdpSrc;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.VlanPcp;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.VlanVid;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.oxm.fields.MatchEntries;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.match.grouping.Match;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Serializes ofp_match (OpenFlow v1.3) and its oxm_fields structures
+ * @author michal.polkorab
+ * @author timotej.kubas
+ */
+public class MatchSerializer {
+ private static final Logger LOGGER = LoggerFactory.getLogger(MatchSerializer.class);
+ private static final byte STANDARD_MATCH_TYPE_CODE = 0;
+ private static final byte OXM_MATCH_TYPE_CODE = 1;
+ private static final int NXM0_CLASS_CODE = 0x0000;
+ private static final int NXM1_CLASS_CODE = 0x0001;
+ private static final int OPENFLOW_BASIC_CLASS_CODE = 0x8000;
+ private static final int EXPERIMENTER_CLASS_CODE = 0xFFFF;
+ private static final byte MATCH_TYPE_AND_LENGTH_SIZE = 4;
+ private static final byte MATCH_ENTRY_HEADER_LENGTH = 4;
+
+ /**
+ * Encodes match (OpenFlow v1.3)
+ * @param match ofp_match object
+ * @param out output ByteBuf
+ */
+ public static void encodeMatch(Match match, ByteBuf out) {
+ if (match == null) {
+ LOGGER.debug("Match is null");
+ return;
+ }
+ encodeType(match, out);
+ // Length of ofp_match (excluding padding)
+ int length = computeMatchLengthInternal(match);
+ out.writeShort(length);
+ encodeMatchEntries(match.getMatchEntries(), out);
+ int paddingRemainder = length % EncodeConstants.PADDING;
+ if (paddingRemainder != 0) {
+ ByteBufUtils.padBuffer(EncodeConstants.PADDING - paddingRemainder, out);
+ }
+ }
+
+ private static void encodeType(Match match, ByteBuf out) {
+ if (match.getType().isAssignableFrom(StandardMatchType.class)) {
+ out.writeShort(STANDARD_MATCH_TYPE_CODE);
+ } else if (match.getType().isAssignableFrom(OxmMatchType.class)) {
+ out.writeShort(OXM_MATCH_TYPE_CODE);
+ }
+ }
+
+ /**
+ * Encodes MatchEntries
+ * @param matchEntries list of match entries (oxm_fields)
+ * @param out output ByteBuf
+ */
+ public static void encodeMatchEntries(List<MatchEntries> matchEntries, ByteBuf out) {
+ if (matchEntries == null) {
+ LOGGER.warn("Match entries are null");
+ return;
+ }
+ for (MatchEntries entry : matchEntries) {
+ encodeClass(entry.getOxmClass(), out);
+ encodeRest(entry, out);
+ }
+ }
+
+ private static void encodeClass(Class<? extends Clazz> clazz, ByteBuf out) {
+ if (clazz.isAssignableFrom(Nxm0Class.class)) {
+ out.writeShort(NXM0_CLASS_CODE);
+ } else if (clazz.isAssignableFrom(Nxm1Class.class)) {
+ out.writeShort(NXM1_CLASS_CODE);
+ } else if (clazz.isAssignableFrom(OpenflowBasicClass.class)) {
+ out.writeShort(OPENFLOW_BASIC_CLASS_CODE);
+ } else if (clazz.isAssignableFrom(ExperimenterClass.class)) {
+ out.writeShort(EXPERIMENTER_CLASS_CODE);
+ }
+ }
+
+ private static void encodeRest(MatchEntries entry, ByteBuf out) {
+ int fieldValue = 0;
+ Class<? extends MatchField> field = entry.getOxmMatchField();
+ if (field.isAssignableFrom(InPort.class)) {
+ fieldValue = 0;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_INT_IN_BYTES);
+ out.writeInt(entry.getAugmentation(PortNumberMatchEntry.class).getPortNumber().getValue().intValue());
+ } else if (field.isAssignableFrom(InPhyPort.class)) {
+ fieldValue = 1;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_INT_IN_BYTES);
+ out.writeInt(entry.getAugmentation(PortNumberMatchEntry.class).getPortNumber().getValue().intValue());
+ } else if (field.isAssignableFrom(Metadata.class)) {
+ fieldValue = 2;
+ writeMetadataRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(EthDst.class)) {
+ fieldValue = 3;
+ writeMacAddressRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(EthSrc.class)) {
+ fieldValue = 4;
+ writeMacAddressRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(EthType.class)) {
+ fieldValue = 5;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
+ out.writeShort(entry.getAugmentation(EthTypeMatchEntry.class).getEthType().getValue().shortValue());
+ } else if (field.isAssignableFrom(VlanVid.class)) {
+ fieldValue = 6;
+ fieldValue = fieldValue << 1;
+ VlanVidMatchEntry vlanVid = entry.getAugmentation(VlanVidMatchEntry.class);
+ int vlanVidValue = vlanVid.getVlanVid();
+ if (vlanVid.isCfiBit()) {
+ short cfi = 1 << 12; // 13-th bit
+ vlanVidValue = vlanVidValue | cfi;
+ }
+ if (entry.isHasMask()) {
+ fieldValue = fieldValue | 1;
+ out.writeByte(fieldValue);
+ byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();
+ out.writeByte(EncodeConstants.SIZE_OF_SHORT_IN_BYTES + mask.length);
+ out.writeShort(vlanVidValue);
+ out.writeBytes(mask);
+ } else {
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
+ out.writeShort(vlanVidValue);
+ }
+ } else if (field.isAssignableFrom(VlanPcp.class)) {
+ fieldValue = 7;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);
+ out.writeByte(entry.getAugmentation(VlanPcpMatchEntry.class).getVlanPcp().byteValue());
+ } else if (field.isAssignableFrom(IpDscp.class)) {
+ fieldValue = 8;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);
+ out.writeByte(entry.getAugmentation(DscpMatchEntry.class).getDscp().getValue());
+ } else if (field.isAssignableFrom(IpEcn.class)) {
+ fieldValue = 9;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);
+ out.writeByte(entry.getAugmentation(EcnMatchEntry.class).getEcn());
+ } else if (field.isAssignableFrom(IpProto.class)) {
+ fieldValue = 10;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);
+ out.writeByte(entry.getAugmentation(ProtocolNumberMatchEntry.class).getProtocolNumber());
+ } else if (field.isAssignableFrom(Ipv4Src.class)) {
+ fieldValue = 11;
+ writeIpv4AddressRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(Ipv4Dst.class)) {
+ fieldValue = 12;
+ writeIpv4AddressRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(TcpSrc.class)) {
+ fieldValue = 13;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
+ out.writeShort(entry.getAugmentation(PortMatchEntry.class).getPort().getValue().intValue());
+ } else if (field.isAssignableFrom(TcpDst.class)) {
+ fieldValue = 14;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
+ out.writeShort(entry.getAugmentation(PortMatchEntry.class).getPort().getValue().intValue());
+ } else if (field.isAssignableFrom(UdpSrc.class)) {
+ fieldValue = 15;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
+ out.writeShort(entry.getAugmentation(PortMatchEntry.class).getPort().getValue().intValue());
+ } else if (field.isAssignableFrom(UdpDst.class)) {
+ fieldValue = 16;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
+ out.writeShort(entry.getAugmentation(PortMatchEntry.class).getPort().getValue().intValue());
+ } else if (field.isAssignableFrom(SctpSrc.class)) {
+ fieldValue = 17;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
+ out.writeShort(entry.getAugmentation(PortMatchEntry.class).getPort().getValue().intValue());
+ } else if (field.isAssignableFrom(SctpDst.class)) {
+ fieldValue = 18;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
+ out.writeShort(entry.getAugmentation(PortMatchEntry.class).getPort().getValue().intValue());
+ } else if (field.isAssignableFrom(Icmpv4Type.class)) {
+ fieldValue = 19;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);
+ out.writeByte(entry.getAugmentation(Icmpv4TypeMatchEntry.class).getIcmpv4Type());
+ } else if (field.isAssignableFrom(Icmpv4Code.class)) {
+ fieldValue = 20;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);
+ out.writeByte(entry.getAugmentation(Icmpv4CodeMatchEntry.class).getIcmpv4Code());
+ } else if (field.isAssignableFrom(ArpOp.class)) {
+ fieldValue = 21;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
+ out.writeShort(entry.getAugmentation(OpCodeMatchEntry.class).getOpCode());
+ } else if (field.isAssignableFrom(ArpSpa.class)) {
+ fieldValue = 22;
+ writeIpv4AddressRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(ArpTpa.class)) {
+ fieldValue = 23;
+ writeIpv4AddressRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(ArpSha.class)) {
+ fieldValue = 24;
+ writeMacAddressRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(ArpTha.class)) {
+ fieldValue = 25;
+ writeMacAddressRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(Ipv6Src.class)) {
+ fieldValue = 26;
+ writeIpv6AddressRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(Ipv6Dst.class)) {
+ fieldValue = 27;
+ writeIpv6AddressRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(Ipv6Flabel.class)) {
+ fieldValue = 28;
+ fieldValue = fieldValue << 1;
+ if (entry.isHasMask()) {
+ fieldValue = fieldValue | 1;
+ out.writeByte(fieldValue);
+ byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();
+ out.writeByte(EncodeConstants.SIZE_OF_INT_IN_BYTES + mask.length); // 20 b + mask [OF 1.3.2 spec]
+ LOGGER.warn("Ipv6Flabel match entry: possible wrong length written (wrote 4 - maybe must be 3)");
+ out.writeInt(entry.getAugmentation(Ipv6FlabelMatchEntry.class).getIpv6Flabel().getValue().intValue());
+ out.writeBytes(entry.getAugmentation(MaskMatchEntry.class).getMask());
+ } else {
+ out.writeByte(fieldValue);
+ out.writeByte(EncodeConstants.SIZE_OF_INT_IN_BYTES); // 20 b [OF 1.3.2 spec]
+ LOGGER.warn("Ipv6Flabel match entry: possible wrong length written (wrote 4 - maybe must be 3)");
+ out.writeInt(entry.getAugmentation(Ipv6FlabelMatchEntry.class).getIpv6Flabel().getValue().intValue());
+ }
+ } else if (field.isAssignableFrom(Icmpv6Type.class)) {
+ fieldValue = 29;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);
+ out.writeByte(entry.getAugmentation(Icmpv6TypeMatchEntry.class).getIcmpv6Type());
+ } else if (field.isAssignableFrom(Icmpv6Code.class)) {
+ fieldValue = 30;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);
+ out.writeByte(entry.getAugmentation(Icmpv6CodeMatchEntry.class).getIcmpv6Code());
+ } else if (field.isAssignableFrom(Ipv6NdTarget.class)) {
+ fieldValue = 31;
+ writeIpv6AddressRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(Ipv6NdSll.class)) {
+ fieldValue = 32;
+ writeMacAddressRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(Ipv6NdTll.class)) {
+ fieldValue = 33;
+ writeMacAddressRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(MplsLabel.class)) {
+ fieldValue = 34;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_INT_IN_BYTES);
+ LOGGER.warn("MplsLabel match entry: possible wrong length written (wrote 4 - maybe must be 3)");
+ out.writeInt(entry.getAugmentation(MplsLabelMatchEntry.class).getMplsLabel().intValue());
+ } else if (field.isAssignableFrom(MplsTc.class)) {
+ fieldValue = 35;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);
+ out.writeByte(entry.getAugmentation(TcMatchEntry.class).getTc());
+ } else if (field.isAssignableFrom(MplsBos.class)) {
+ fieldValue = 36;
+ writeOxmFieldAndLength(out, fieldValue, EncodeConstants.SIZE_OF_BYTE_IN_BYTES);
+ out.writeBoolean(entry.getAugmentation(BosMatchEntry.class).isBos().booleanValue());
+ } else if (field.isAssignableFrom(PbbIsid.class)) {
+ fieldValue = 37;
+ fieldValue = fieldValue << 1;
+ if (entry.isHasMask()) {
+ fieldValue = fieldValue | 1;
+ out.writeByte(fieldValue);
+ byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();
+ out.writeByte(EncodeConstants.SIZE_OF_LONG_IN_BYTES + mask.length);
+ LOGGER.warn("PbbIsid match entry: possible wrong length written (wrote 4 - maybe must be 3)");
+ out.writeInt(entry.getAugmentation(IsidMatchEntry.class).getIsid().intValue());
+ out.writeBytes(mask);
+ } else {
+ out.writeByte(fieldValue);
+ out.writeByte(EncodeConstants.SIZE_OF_LONG_IN_BYTES);
+ LOGGER.warn("PbbIsid match entry: possible wrong length written (wrote 4 - maybe must be 3)");
+ out.writeInt(entry.getAugmentation(IsidMatchEntry.class).getIsid().intValue());
+ }
+ } else if (field.isAssignableFrom(TunnelId.class)) {
+ fieldValue = 38;
+ writeMetadataRelatedEntry(entry, out, fieldValue);
+ } else if (field.isAssignableFrom(Ipv6Exthdr.class)) {
+ fieldValue = 39;
+ fieldValue = fieldValue << 1;
+ PseudoField pseudoField = entry.getAugmentation(PseudoFieldMatchEntry.class).getPseudoField();
+ Map<Integer, Boolean> map = new HashMap<>();
+ map.put(0, pseudoField.isNonext());
+ map.put(1, pseudoField.isEsp());
+ map.put(2, pseudoField.isAuth());
+ map.put(3, pseudoField.isDest());
+ map.put(4, pseudoField.isFrag());
+ map.put(5, pseudoField.isRouter());
+ map.put(6, pseudoField.isHop());
+ map.put(7, pseudoField.isUnrep());
+ map.put(8, pseudoField.isUnseq());
+ int bitmap = ByteBufUtils.fillBitMaskFromMap(map);
+ if (entry.isHasMask()) {
+ fieldValue = fieldValue | 1;
+ out.writeByte(fieldValue);
+ byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();
+ out.writeByte(EncodeConstants.SIZE_OF_SHORT_IN_BYTES + mask.length);
+ out.writeShort(bitmap);
+ out.writeBytes(mask);
+ } else {
+ out.writeByte(fieldValue);
+ out.writeByte(EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
+ out.writeShort(bitmap);
+ }
+ }
+ }
+
+ private static void writeOxmFieldAndLength(ByteBuf out, int fieldValue, int length) {
+ int fieldAndMask = fieldValue << 1;
+ out.writeByte(fieldAndMask);
+ out.writeByte(length);
+ }
+
+ private static void writeMetadataRelatedEntry(MatchEntries entry, ByteBuf out, int value) {
+ int fieldValue = value << 1;
+ if (entry.isHasMask()) {
+ fieldValue = fieldValue | 1;
+ out.writeByte(fieldValue);
+ byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();
+ out.writeByte(EncodeConstants.SIZE_OF_LONG_IN_BYTES + mask.length);
+ out.writeBytes(entry.getAugmentation(MetadataMatchEntry.class).getMetadata());
+ out.writeBytes(mask);
+ } else {
+ out.writeByte(fieldValue);
+ out.writeByte(EncodeConstants.SIZE_OF_LONG_IN_BYTES);
+ out.writeBytes(entry.getAugmentation(MetadataMatchEntry.class).getMetadata());
+ }
+ }
+
+ private static void writeMacAddressRelatedEntry(MatchEntries entry, ByteBuf out, int value) {
+ int fieldValue = value << 1;
+ if (entry.isHasMask()) {
+ fieldValue = fieldValue | 1;
+ out.writeByte(fieldValue);
+ byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();
+ out.writeByte(EncodeConstants.MAC_ADDRESS_LENGTH + mask.length); // 48 b + mask [OF 1.3.2 spec]
+ String macAddress = entry.getAugmentation(MacAddressMatchEntry.class).getMacAddress().getValue();
+ out.writeBytes(ByteBufUtils.macAddressToBytes(macAddress));
+ out.writeBytes(mask);
+ } else {
+ out.writeByte(fieldValue);
+ out.writeByte(EncodeConstants.MAC_ADDRESS_LENGTH); // 48 b [OF 1.3.2 spec]
+ String macAddress = entry.getAugmentation(MacAddressMatchEntry.class).getMacAddress().getValue();
+ out.writeBytes(ByteBufUtils.macAddressToBytes(macAddress));
+ }
+ }
+
+ private static void writeIpv4AddressRelatedEntry(MatchEntries entry, ByteBuf out, int value) {
+ int fieldValue = value << 1;
+ if (entry.isHasMask()) {
+ fieldValue = fieldValue | 1;
+ out.writeByte(fieldValue);
+ byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();
+ out.writeByte(EncodeConstants.SIZE_OF_INT_IN_BYTES + mask.length);
+ writeIpv4Address(entry, out);
+ out.writeBytes(mask);
+ } else {
+ out.writeByte(fieldValue);
+ out.writeByte(EncodeConstants.SIZE_OF_INT_IN_BYTES);
+ writeIpv4Address(entry, out);
+ }
+ }
+
+ private static void writeIpv4Address(MatchEntries entry, ByteBuf out) {
+ String[] addressGroups = entry.getAugmentation(Ipv4AddressMatchEntry.class).getIpv4Address().getValue().split("\\.");
+ for (int i = 0; i < addressGroups.length; i++) {
+ out.writeByte(Integer.parseInt(addressGroups[i]));
+ }
+ }
+
+ private static void writeIpv6AddressRelatedEntry(MatchEntries entry, ByteBuf out, int value) {
+ int fieldValue = value << 1;
+ String textAddress = entry.getAugmentation(Ipv6AddressMatchEntry.class).getIpv6Address().getValue();
+ String[] address;
+ if (textAddress.equals("::")) {
+ address = new String[EncodeConstants.GROUPS_IN_IPV6_ADDRESS];
+ Arrays.fill(address, "0");
+ } else {
+ address = parseIpv6Address(textAddress.split(":"));
+ }
+ if (entry.isHasMask()) {
+ fieldValue = fieldValue | 1;
+ out.writeByte(fieldValue);
+ byte[] mask = entry.getAugmentation(MaskMatchEntry.class).getMask();
+ out.writeByte(EncodeConstants.SIZE_OF_IPV6_ADDRESS_IN_BYTES + mask.length);
+ for (int i = 0; i < address.length; i++) {
+ out.writeShort(Integer.parseInt(address[i], 16));
+ }
+ out.writeBytes(mask);
+ } else {
+ out.writeByte(fieldValue);
+ out.writeByte(EncodeConstants.SIZE_OF_IPV6_ADDRESS_IN_BYTES);
+ for (int i = 0; i < address.length; i++) {
+ out.writeShort(Integer.parseInt(address[i], 16));
+ }
+ }
+ }
+
+ private static String[] parseIpv6Address(String[] addressGroups) {
+ int countEmpty = 0;
+ for (int i = 0; i < addressGroups.length; i++) {
+ if (addressGroups[i].equals("")){
+ countEmpty++;
+ }
+ }
+ String[] ready = new String[EncodeConstants.GROUPS_IN_IPV6_ADDRESS];
+ switch (countEmpty) {
+ case 0:
+ ready = addressGroups;
+ break;
+ case 1:
+ int zerosToBePushed = EncodeConstants.GROUPS_IN_IPV6_ADDRESS - addressGroups.length + 1;
+ int index = 0;
+ for (int i = 0; i < addressGroups.length; i++) {
+ if (addressGroups[i].equals("")) {
+ for (int j = 0; j < zerosToBePushed; j++) {
+ ready[index] = "0";
+ index++;
+ }
+ } else {
+ ready[index] = addressGroups[i];
+ index++;
+ }
+ }
+ break;
+ case 2:
+ Arrays.fill(ready, "0");
+ ready[ready.length - 1] = addressGroups[addressGroups.length - 1];
+ break;
+ default:
+ throw new IllegalStateException("Incorrect ipv6 address");
+ }
+ return ready;
+ }
+
+ /**
+ * Computes length of match (in bytes)
+ * @param match
+ * @return length of ofp_match (excluding padding)
+ */
+ public static int computeMatchLengthInternal(Match match) {
+ int length = 0;
+ if (match != null) {
+ length += MATCH_TYPE_AND_LENGTH_SIZE + computeMatchEntriesLength(match.getMatchEntries());
+ }
+ return length;
+ }
+
+ /**
+ * Computes length of match (in bytes)
+ * @param match
+ * @return length of ofp_match (excluding padding)
+ */
+ public static int computeMatchLength(Match match) {
+ int length = computeMatchLengthInternal(match);
+ int paddingRemainder = length % EncodeConstants.PADDING;
+ if (paddingRemainder != 0) {
+ length += EncodeConstants.PADDING - paddingRemainder;
+ }
+ return length;
+ }
+
+ /**
+ * Computes length of MatchEntries (in bytes)
+ * @param matchEntries list of match entries (oxm_fields)
+ * @return length of MatchEntries
+ */
+ public static int computeMatchEntriesLength(List<MatchEntries> matchEntries) {
+ int length = 0;
+ if (matchEntries != null) {
+ for (MatchEntries entry : matchEntries) {
+ length += MATCH_ENTRY_HEADER_LENGTH;
+ Class<? extends MatchField> field = entry.getOxmMatchField();
+ if (field.isAssignableFrom(InPort.class)) {
+ length += EncodeConstants.SIZE_OF_INT_IN_BYTES;
+ } else if (field.isAssignableFrom(InPhyPort.class)) {
+ length += EncodeConstants.SIZE_OF_INT_IN_BYTES;
+ } else if (field.isAssignableFrom(Metadata.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_LONG_IN_BYTES);
+ } else if (field.isAssignableFrom(EthDst.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.MAC_ADDRESS_LENGTH);
+ } else if (field.isAssignableFrom(EthSrc.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.MAC_ADDRESS_LENGTH);
+ } else if (field.isAssignableFrom(EthType.class)) {
+ length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;
+ } else if (field.isAssignableFrom(VlanVid.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
+ } else if (field.isAssignableFrom(VlanPcp.class)) {
+ length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;
+ } else if (field.isAssignableFrom(IpDscp.class)) {
+ length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;
+ } else if (field.isAssignableFrom(IpEcn.class)) {
+ length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;
+ } else if (field.isAssignableFrom(IpProto.class)) {
+ length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;
+ } else if (field.isAssignableFrom(Ipv4Src.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_INT_IN_BYTES);
+ } else if (field.isAssignableFrom(Ipv4Dst.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_INT_IN_BYTES);
+ } else if (field.isAssignableFrom(TcpSrc.class)) {
+ length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;
+ } else if (field.isAssignableFrom(TcpDst.class)) {
+ length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;
+ } else if (field.isAssignableFrom(UdpSrc.class)) {
+ length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;
+ } else if (field.isAssignableFrom(UdpDst.class)) {
+ length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;
+ } else if (field.isAssignableFrom(SctpSrc.class)) {
+ length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;
+ } else if (field.isAssignableFrom(SctpDst.class)) {
+ length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;
+ } else if (field.isAssignableFrom(Icmpv4Type.class)) {
+ length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;
+ } else if (field.isAssignableFrom(Icmpv4Code.class)) {
+ length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;
+ } else if (field.isAssignableFrom(ArpOp.class)) {
+ length += EncodeConstants.SIZE_OF_SHORT_IN_BYTES;
+ } else if (field.isAssignableFrom(ArpSpa.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_INT_IN_BYTES);
+ } else if (field.isAssignableFrom(ArpTpa.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_INT_IN_BYTES);
+ } else if (field.isAssignableFrom(ArpSha.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.MAC_ADDRESS_LENGTH);
+ } else if (field.isAssignableFrom(ArpTha.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.MAC_ADDRESS_LENGTH);
+ } else if (field.isAssignableFrom(Ipv6Src.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_IPV6_ADDRESS_IN_BYTES);
+ } else if (field.isAssignableFrom(Ipv6Dst.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_IPV6_ADDRESS_IN_BYTES);
+ } else if (field.isAssignableFrom(Ipv6Flabel.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_INT_IN_BYTES);
+ } else if (field.isAssignableFrom(Icmpv6Type.class)) {
+ length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;
+ } else if (field.isAssignableFrom(Icmpv6Code.class)) {
+ length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;
+ } else if (field.isAssignableFrom(Ipv6NdTarget.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_IPV6_ADDRESS_IN_BYTES);
+ } else if (field.isAssignableFrom(Ipv6NdSll.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.MAC_ADDRESS_LENGTH);
+ } else if (field.isAssignableFrom(Ipv6NdTll.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.MAC_ADDRESS_LENGTH);
+ } else if (field.isAssignableFrom(MplsLabel.class)) {
+ length += EncodeConstants.SIZE_OF_INT_IN_BYTES;
+ } else if (field.isAssignableFrom(MplsTc.class)) {
+ length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;
+ } else if (field.isAssignableFrom(MplsBos.class)) {
+ length += EncodeConstants.SIZE_OF_BYTE_IN_BYTES;
+ } else if (field.isAssignableFrom(PbbIsid.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_INT_IN_BYTES);
+ } else if (field.isAssignableFrom(TunnelId.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_LONG_IN_BYTES);
+ } else if (field.isAssignableFrom(Ipv6Exthdr.class)) {
+ length += computePossibleMaskEntryLength(entry, EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
+ }
+ }
+ }
+ return length;
+ }
+
+ private static int computePossibleMaskEntryLength(MatchEntries entry, int length) {
+ int entryLength = length;
+ if (entry.isHasMask()) {
+ entryLength *= 2;
+ }
+ return entryLength;
+ }
+
+}
Code Review / openflowjava.git / blobdiff