openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/translator/FlowRemovedTranslator.java

   1 /**
   2  * Copyright (c) 2014 Ericsson India Global Services Pvt Ltd. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8
   9 package org.opendaylight.openflowplugin.openflow.md.core.translator;
  10
  11 import java.math.BigInteger;
  12 import java.util.Collections;
  13 import java.util.HashMap;
  14 import java.util.List;
  15 import java.util.Map;
  16 import java.util.Optional;
  17 import java.util.concurrent.CopyOnWriteArrayList;
  18 import org.opendaylight.openflowjava.util.ByteBufUtils;
  19 import org.opendaylight.openflowplugin.api.OFConstants;
  20 import org.opendaylight.openflowplugin.api.openflow.md.core.IMDMessageTranslator;
  21 import org.opendaylight.openflowplugin.api.openflow.md.core.SwitchConnectionDistinguisher;
  22 import org.opendaylight.openflowplugin.api.openflow.md.core.session.SessionContext;
  23 import org.opendaylight.openflowplugin.api.openflow.md.util.OpenflowVersion;
  24 import org.opendaylight.openflowplugin.extension.api.AugmentTuple;
  25 import org.opendaylight.openflowplugin.extension.api.path.MatchPath;
  26 import org.opendaylight.openflowplugin.openflow.md.core.extension.MatchExtensionHelper;
  27 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.ConvertorManager;
  28 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.common.IpConversionUtil;
  29 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.data.VersionDatapathIdConvertorData;
  30 import org.opendaylight.openflowplugin.openflow.md.util.ByteUtil;
  31 import org.opendaylight.openflowplugin.openflow.md.util.InventoryDataServiceUtil;
  32 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6FlowLabel;
  33 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.PortNumber;
  34 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.MacAddress;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.SwitchFlowRemovedBuilder;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.FlowCookie;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.RemovedReasonFlags;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.mod.removed.Match;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.mod.removed.MatchBuilder;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.EtherType;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanId;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.arp.match.fields.ArpSourceHardwareAddressBuilder;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.arp.match.fields.ArpTargetHardwareAddressBuilder;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.ethernet.match.fields.EthernetDestinationBuilder;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.ethernet.match.fields.EthernetSourceBuilder;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.ethernet.match.fields.EthernetTypeBuilder;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.ipv6.match.fields.Ipv6ExtHeaderBuilder;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.ipv6.match.fields.Ipv6LabelBuilder;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.EthernetMatchBuilder;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.Icmpv4MatchBuilder;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.Icmpv6MatchBuilder;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.IpMatchBuilder;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.MetadataBuilder;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.ProtocolMatchFieldsBuilder;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.TunnelBuilder;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.VlanMatchBuilder;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._3.match.ArpMatchBuilder;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._3.match.Ipv4MatchBuilder;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._3.match.Ipv6MatchBuilder;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._4.match.SctpMatchBuilder;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._4.match.TcpMatchBuilder;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._4.match.UdpMatchBuilder;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.protocol.match.fields.PbbBuilder;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.vlan.match.fields.VlanIdBuilder;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.FlowRemovedReason;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.Ipv6ExthdrFlags;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpOp;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpSha;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpSpa;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpTha;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ArpTpa;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.EthDst;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.EthSrc;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.EthType;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Icmpv4Code;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Icmpv4Type;
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Icmpv6Code;
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Icmpv6Type;
  80 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.InPhyPort;
  81 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.InPort;
  82 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.IpDscp;
  83 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.IpEcn;
  84 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.IpProto;
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Ipv4Dst;
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Ipv4Src;
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Ipv6Dst;
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Ipv6Exthdr;
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Ipv6Flabel;
  90 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Ipv6NdSll;
  91 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Ipv6NdTarget;
  92 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Ipv6NdTll;
  93 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Ipv6Src;
  94 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.MatchField;
  95 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Metadata;
  96 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.MplsBos;
  97 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.MplsLabel;
  98 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.MplsTc;
  99 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.PbbIsid;
 100 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.SctpDst;
 101 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.SctpSrc;
 102 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.TcpDst;
 103 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.TcpSrc;
 104 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.TunnelId;
 105 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.UdpDst;
 106 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.UdpSrc;
 107 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.VlanPcp;
 108 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.VlanVid;
 109 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entries.grouping.MatchEntry;
 110 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ArpOpCase;
 111 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ArpShaCase;
 112 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ArpSpaCase;
 113 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ArpThaCase;
 114 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.ArpTpaCase;
 115 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.EthDstCase;
 116 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.EthSrcCase;
 117 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.EthTypeCase;
 118 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Icmpv4CodeCase;
 119 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Icmpv4TypeCase;
 120 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Icmpv6CodeCase;
 121 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Icmpv6TypeCase;
 122 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.InPhyPortCase;
 123 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.InPortCase;
 124 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.IpDscpCase;
 125 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.IpEcnCase;
 126 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.IpProtoCase;
 127 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Ipv4DstCase;
 128 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Ipv4SrcCase;
 129 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Ipv6DstCase;
 130 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Ipv6ExthdrCase;
 131 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Ipv6FlabelCase;
 132 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Ipv6NdSllCase;
 133 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Ipv6NdTargetCase;
 134 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Ipv6NdTllCase;
 135 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Ipv6SrcCase;
 136 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.MetadataCase;
 137 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.MplsBosCase;
 138 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.MplsLabelCase;
 139 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.MplsTcCase;
 140 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.PbbIsidCase;
 141 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.SctpDstCase;
 142 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.SctpSrcCase;
 143 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.TcpDstCase;
 144 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.TcpSrcCase;
 145 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.TunnelIdCase;
 146 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.UdpDstCase;
 147 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.UdpSrcCase;
 148 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.VlanPcpCase;
 149 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.VlanVidCase;
 150 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowRemovedMessage;
 151 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
 152 import org.opendaylight.yang.gen.v1.urn.opendaylight.table.types.rev131026.TunnelIpv4Dst;
 153 import org.opendaylight.yang.gen.v1.urn.opendaylight.table.types.rev131026.TunnelIpv4Src;
 154 import org.opendaylight.yangtools.yang.binding.DataObject;
 155 import org.slf4j.Logger;
 156 import org.slf4j.LoggerFactory;
 157
 158 public class FlowRemovedTranslator implements IMDMessageTranslator<OfHeader, List<DataObject>> {
 159
 160     private static final Logger LOG = LoggerFactory.getLogger(FlowRemovedTranslator.class);
 161     private static final String PREFIX_SEPARATOR = "/";
 162
 163     @Override
 164     public List<DataObject> translate(final SwitchConnectionDistinguisher cookie, final SessionContext sc, final OfHeader msg) {
 165         if (msg instanceof FlowRemovedMessage) {
 166             FlowRemovedMessage ofFlow = (FlowRemovedMessage) msg;
 167             List<DataObject> list = new CopyOnWriteArrayList<DataObject>();
 168             LOG.debug("Flow Removed Message received: Table Id={}, Flow removed reason={} ", ofFlow.getTableId(),
 169                     ofFlow.getReason());
 170
 171             SwitchFlowRemovedBuilder salFlowRemoved = new SwitchFlowRemovedBuilder();
 172
 173             if (ofFlow.getCookie() != null) {
 174                 salFlowRemoved.setCookie(new FlowCookie(ofFlow.getCookie()));
 175             }
 176             salFlowRemoved.setPriority(ofFlow.getPriority());
 177
 178             if (ofFlow.getTableId() != null) {
 179                 salFlowRemoved.setTableId(ofFlow.getTableId().getValue().shortValue());
 180             }
 181
 182             salFlowRemoved.setDurationSec(ofFlow.getDurationSec());
 183             salFlowRemoved.setDurationNsec(ofFlow.getDurationNsec());
 184             salFlowRemoved.setIdleTimeout(ofFlow.getIdleTimeout());
 185             salFlowRemoved.setHardTimeout(ofFlow.getHardTimeout());
 186             salFlowRemoved.setPacketCount(ofFlow.getPacketCount());
 187             salFlowRemoved.setByteCount(ofFlow.getByteCount());
 188             RemovedReasonFlags removeReasonFlag = new RemovedReasonFlags(
 189                     FlowRemovedReason.OFPRRDELETE.equals(ofFlow.getReason()),
 190                     FlowRemovedReason.OFPRRGROUPDELETE.equals(ofFlow.getReason()),
 191                     FlowRemovedReason.OFPRRHARDTIMEOUT.equals(ofFlow.getReason()),
 192                     FlowRemovedReason.OFPRRIDLETIMEOUT.equals(ofFlow.getReason())
 193             );
 194
 195             salFlowRemoved.setRemovedReason(removeReasonFlag);
 196
 197             OpenflowVersion ofVersion = OpenflowVersion.get(sc.getPrimaryConductor().getVersion());
 198             org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.grouping.Match ofMatch = ofFlow
 199                     .getMatch();
 200             if (ofMatch != null) {
 201                 salFlowRemoved.setMatch(fromMatch(ofMatch, sc.getFeatures().getDatapathId(), ofVersion));
 202             } else if (ofFlow.getMatchV10() != null) {
 203                 final VersionDatapathIdConvertorData data = new VersionDatapathIdConvertorData(sc.getPrimaryConductor().getVersion());
 204                 data.setDatapathId(sc.getFeatures().getDatapathId());
 205
 206                 final Optional<MatchBuilder> matchBuilderOptional = ConvertorManager.getInstance().convert(ofFlow.getMatchV10(), data);
 207                 salFlowRemoved.setMatch(matchBuilderOptional.orElse(new MatchBuilder()).build());
 208             }
 209             salFlowRemoved.setNode(new NodeRef(InventoryDataServiceUtil.identifierFromDatapathId(sc.getFeatures()
 210                     .getDatapathId())));
 211             list.add(salFlowRemoved.build());
 212             return list;
 213         } else {
 214             LOG.error("Message is not a flow removed message ");
 215             return Collections.emptyList();
 216         }
 217     }
 218
 219
 220     public Match fromMatch(final org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.grouping.Match ofMatch,
 221                            final BigInteger datapathid, final OpenflowVersion ofVersion) {
 222         MatchBuilder matchBuilder = new MatchBuilder();
 223         EthernetMatchBuilder ethernetMatch = null;
 224         VlanMatchBuilder vlanMatch = null;
 225         IpMatchBuilder ipMatch = null;
 226         TcpMatchBuilder tcpMatch = null;
 227         UdpMatchBuilder udpMatch = null;
 228         SctpMatchBuilder sctpMatch = null;
 229         Icmpv4MatchBuilder icmpv4Match = null;
 230         Icmpv6MatchBuilder icmpv6Match = null;
 231         Ipv4MatchBuilder ipv4Match = null;
 232         ArpMatchBuilder arpMatch = null;
 233         Ipv6MatchBuilder ipv6Match = null;
 234         ProtocolMatchFieldsBuilder protocolMatchFields = null;
 235
 236         for (MatchEntry entry : ofMatch.getMatchEntry()) {
 237             Class<? extends MatchField> field = entry.getOxmMatchField();
 238             if (field.equals(InPort.class)) {
 239                 matchBuilder.setInPort(InventoryDataServiceUtil.nodeConnectorIdfromDatapathPortNo(datapathid,
 240                         ((InPortCase) entry.getMatchEntryValue()).getInPort().getPortNumber().getValue(), ofVersion));
 241             } else if (field.equals(InPhyPort.class)) {
 242                 matchBuilder.setInPhyPort(InventoryDataServiceUtil.nodeConnectorIdfromDatapathPortNo(datapathid,
 243                         ((InPhyPortCase) entry.getMatchEntryValue()).getInPhyPort().getPortNumber().getValue(), ofVersion));
 244             } else if (field.equals(Metadata.class)) {
 245                 MetadataBuilder metadata = new MetadataBuilder();
 246                 MetadataCase metadataCase = ((MetadataCase) entry.getMatchEntryValue());
 247                 metadata.setMetadata(new BigInteger(OFConstants.SIGNUM_UNSIGNED, metadataCase.getMetadata().getMetadata()));
 248                 if (entry.isHasMask()) {
 249                     metadata.setMetadataMask(new BigInteger(OFConstants.SIGNUM_UNSIGNED, metadataCase.getMetadata().getMask()));
 250                 }
 251                 matchBuilder.setMetadata(metadata.build());
 252             } else if (field.equals(EthDst.class) || field.equals(EthSrc.class) || field.equals(EthType.class)) {
 253                 if (ethernetMatch == null) {
 254                     ethernetMatch = new EthernetMatchBuilder();
 255                 }
 256                 if (field.equals(EthDst.class)) {
 257                     EthernetDestinationBuilder ethDst = new EthernetDestinationBuilder();
 258                     EthDstCase ethDstCase = (EthDstCase) entry.getMatchEntryValue();
 259                     ethDst.setAddress(ethDstCase.getEthDst().getMacAddress());
 260                     if (entry.isHasMask()) {
 261                         ethDst.setMask(new MacAddress(ByteUtil.bytesToHexstring(ethDstCase.getEthDst().getMask(), ":")));
 262                     }
 263                     ethernetMatch.setEthernetDestination(ethDst.build());
 264                 } else if (field.equals(EthSrc.class)) {
 265                     EthernetSourceBuilder ethSrc = new EthernetSourceBuilder();
 266                     EthSrcCase ethSrcCase = ((EthSrcCase) entry.getMatchEntryValue());
 267                     ethSrc.setAddress(ethSrcCase.getEthSrc().getMacAddress());
 268                     if (entry.isHasMask()) {
 269                         ethSrc.setMask(new MacAddress(ByteUtil.bytesToHexstring(ethSrcCase.getEthSrc().getMask(), ":")));
 270                     }
 271                     ethernetMatch.setEthernetSource(ethSrc.build());
 272                 } else if (field.equals(EthType.class)) {
 273                     EthernetTypeBuilder ethType = new EthernetTypeBuilder();
 274                     EthTypeCase ethTypeCase = ((EthTypeCase) entry.getMatchEntryValue());
 275                     ethType.setType(new EtherType(ethTypeCase.getEthType().getEthType().getValue().longValue()));
 276                     ethernetMatch.setEthernetType(ethType.build());
 277                 }
 278             } else if (field.equals(VlanVid.class) || field.equals(VlanPcp.class)) {
 279                 if (vlanMatch == null) {
 280                     vlanMatch = new VlanMatchBuilder();
 281                 }
 282                 if (field.equals(VlanVid.class)) {
 283                     boolean vlanIdPresent = false;
 284                     VlanIdBuilder vlanId = new VlanIdBuilder();
 285                     VlanVidCase vlanVidCase = ((VlanVidCase) entry.getMatchEntryValue());
 286                     Integer vlanVidValue = vlanVidCase.getVlanVid().getVlanVid();
 287                     if (vlanVidCase.getVlanVid().isCfiBit()) {
 288                         vlanIdPresent = true;
 289                     }
 290                     vlanId.setVlanIdPresent(vlanIdPresent);
 291                     if (vlanVidValue != null) {
 292                         vlanId.setVlanId(new VlanId(vlanVidValue));
 293                     }
 294                     vlanMatch.setVlanId(vlanId.build());
 295                 } else if (field.equals(VlanPcp.class)) {
 296                     VlanPcpCase vlanPcpCase = ((VlanPcpCase) entry.getMatchEntryValue());
 297                     vlanMatch.setVlanPcp(new org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanPcp(vlanPcpCase.getVlanPcp().getVlanPcp()));
 298                 }
 299             } else if (field.equals(IpDscp.class) || field.equals(IpEcn.class) || field.equals(IpProto.class)) {
 300                 if (ipMatch == null) {
 301                     ipMatch = new IpMatchBuilder();
 302                 }
 303                 if (field.equals(IpDscp.class)) {
 304                     IpDscpCase ipDscpCase = ((IpDscpCase) entry.getMatchEntryValue());
 305                     ipMatch.setIpDscp(new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Dscp(
 306                             ipDscpCase.getIpDscp().getDscp()));
 307                 } else if (field.equals(IpEcn.class)) {
 308                     IpEcnCase ipEcnCase = ((IpEcnCase) entry.getMatchEntryValue());
 309                     ipMatch.setIpEcn(ipEcnCase.getIpEcn().getEcn());
 310                 } else if (field.equals(IpProto.class)) {
 311                     IpProtoCase ipProtoCase = ((IpProtoCase) entry.getMatchEntryValue());
 312                     ipMatch.setIpProtocol(ipProtoCase.getIpProto().getProtocolNumber());
 313                 }
 314             } else if (field.equals(TcpSrc.class) || field.equals(TcpDst.class)) {
 315                 if (tcpMatch == null) {
 316                     tcpMatch = new TcpMatchBuilder();
 317                 }
 318                 if (field.equals(TcpSrc.class)) {
 319                     TcpSrcCase tcpSrcCase = ((TcpSrcCase) entry.getMatchEntryValue());
 320                     tcpMatch.setTcpSourcePort(new PortNumber(tcpSrcCase.getTcpSrc().getPort().getValue()));
 321                 } else if (field.equals(TcpDst.class)) {
 322                     TcpDstCase tcpDstCase = ((TcpDstCase) entry.getMatchEntryValue());
 323                     tcpMatch.setTcpDestinationPort(new PortNumber(tcpDstCase.getTcpDst().getPort().getValue()));
 324                 }
 325             } else if (field.equals(UdpSrc.class) || field.equals(UdpDst.class)) {
 326                 if (udpMatch == null) {
 327                     udpMatch = new UdpMatchBuilder();
 328                 }
 329                 if (field.equals(UdpSrc.class)) {
 330                     UdpSrcCase udpSrcCase = ((UdpSrcCase) entry.getMatchEntryValue());
 331                     udpMatch.setUdpSourcePort(new PortNumber(udpSrcCase.getUdpSrc().getPort().getValue()));
 332                 } else if (field.equals(UdpDst.class)) {
 333                     UdpDstCase udpDstCase = ((UdpDstCase) entry.getMatchEntryValue());
 334                     udpMatch.setUdpDestinationPort(new PortNumber(udpDstCase.getUdpDst().getPort()));
 335                 }
 336             } else if (field.equals(SctpSrc.class) || field.equals(SctpDst.class)) {
 337                 if (sctpMatch == null) {
 338                     sctpMatch = new SctpMatchBuilder();
 339                 }
 340                 if (field.equals(SctpSrc.class)) {
 341                     SctpSrcCase sctpSrcCase = ((SctpSrcCase) entry.getMatchEntryValue());
 342                     sctpMatch.setSctpSourcePort(new PortNumber(sctpSrcCase.getSctpSrc().getPort()));
 343                 } else if (field.equals(SctpDst.class)) {
 344                     SctpDstCase sctpDstCase = ((SctpDstCase) entry.getMatchEntryValue());
 345                     sctpMatch.setSctpDestinationPort(new PortNumber(sctpDstCase.getSctpDst().getPort()));
 346                 }
 347             } else if (field.equals(Icmpv4Type.class) || field.equals(Icmpv4Code.class)) {
 348                 if (icmpv4Match == null) {
 349                     icmpv4Match = new Icmpv4MatchBuilder();
 350                 }
 351                 if (field.equals(Icmpv4Type.class)) {
 352                     Icmpv4TypeCase icmpv4TypeCase = ((Icmpv4TypeCase) entry.getMatchEntryValue());
 353                     icmpv4Match.setIcmpv4Type(icmpv4TypeCase.getIcmpv4Type().getIcmpv4Type());
 354                 } else if (field.equals(Icmpv4Code.class)) {
 355                     Icmpv4CodeCase icmpv4CodeCase = ((Icmpv4CodeCase) entry.getMatchEntryValue());
 356                     icmpv4Match.setIcmpv4Code(icmpv4CodeCase.getIcmpv4Code().getIcmpv4Code());
 357                 }
 358             } else if (field.equals(Icmpv6Type.class) || field.equals(Icmpv6Code.class)) {
 359                 if (icmpv6Match == null) {
 360                     icmpv6Match = new Icmpv6MatchBuilder();
 361                 }
 362                 if (field.equals(Icmpv6Type.class)) {
 363                     Icmpv6TypeCase icmpv6TypeCase = ((Icmpv6TypeCase) entry.getMatchEntryValue());
 364                     icmpv6Match.setIcmpv6Type(icmpv6TypeCase.getIcmpv6Type().getIcmpv6Type());
 365                 } else if (field.equals(Icmpv6Code.class)) {
 366                     Icmpv6CodeCase icmpv6CodeCase = ((Icmpv6CodeCase) entry.getMatchEntryValue());
 367                     icmpv6Match.setIcmpv6Code(icmpv6CodeCase.getIcmpv6Code().getIcmpv6Code());
 368                 }
 369             } else if (field.equals(Ipv4Src.class) || field.equals(Ipv4Dst.class)) {
 370                 if (ipv4Match == null) {
 371                     ipv4Match = new Ipv4MatchBuilder();
 372                 }
 373                 if (field.equals(Ipv4Src.class)) {
 374                     Ipv4SrcCase ipv4SrcCase = ((Ipv4SrcCase) entry.getMatchEntryValue());
 375                     int prefix;
 376                     if (entry.isHasMask()) {
 377                         prefix = IpConversionUtil.countBits(ipv4SrcCase.getIpv4Src().getMask());
 378                     } else {
 379                         prefix = 32;
 380                     }
 381                     ipv4Match.setIpv4Source(
 382                         IpConversionUtil.createPrefix(ipv4SrcCase.getIpv4Src().getIpv4Address(), prefix)
 383                     );
 384
 385                 } else if (field.equals(Ipv4Dst.class)) {
 386                     Ipv4DstCase ipv4DstCase = ((Ipv4DstCase) entry.getMatchEntryValue());
 387                     int prefix;
 388                     if (entry.isHasMask()) {
 389                         prefix = IpConversionUtil.countBits(ipv4DstCase.getIpv4Dst().getMask());
 390                     } else {
 391                         prefix = 32;
 392                     }
 393                     ipv4Match.setIpv4Destination(
 394                         IpConversionUtil.createPrefix(ipv4DstCase.getIpv4Dst().getIpv4Address(), prefix)
 395                     );
 396                 }
 397             } else if (field.equals(ArpOp.class) || field.equals(ArpSpa.class) || field.equals(ArpTpa.class)
 398                     || field.equals(ArpSha.class) || field.equals(ArpTha.class)) {
 399                 if (arpMatch == null) {
 400                     arpMatch = new ArpMatchBuilder();
 401                 }
 402                 if (field.equals(ArpOp.class)) {
 403                     ArpOpCase arpOpCase = ((ArpOpCase) entry.getMatchEntryValue());
 404                     arpMatch.setArpOp(arpOpCase.getArpOp().getOpCode());
 405                 } else if (field.equals(ArpSpa.class)) {
 406
 407                     ArpSpaCase arpSpaCase = ((ArpSpaCase) entry.getMatchEntryValue());
 408                     int prefix;
 409                     if (entry.isHasMask()) {
 410                         prefix = IpConversionUtil.countBits(arpSpaCase.getArpSpa().getMask());
 411                     } else {
 412                         prefix = 32;
 413                     }
 414                     arpMatch.setArpSourceTransportAddress(
 415                         IpConversionUtil.createPrefix(arpSpaCase.getArpSpa().getIpv4Address(), prefix)
 416                     );
 417                 } else if (field.equals(ArpTpa.class)) {
 418                     ArpTpaCase arpTpaCase = ((ArpTpaCase) entry.getMatchEntryValue());
 419                     int prefix;
 420                     if (entry.isHasMask()) {
 421                         prefix = IpConversionUtil.countBits(arpTpaCase.getArpTpa().getMask());
 422                     } else {
 423                         prefix = 32;
 424                     }
 425
 426                     arpMatch.setArpTargetTransportAddress(
 427                         IpConversionUtil.createPrefix(arpTpaCase.getArpTpa().getIpv4Address(), prefix)
 428                     );
 429                 } else if (field.equals(ArpSha.class)) {
 430                     ArpSourceHardwareAddressBuilder arpSha = new ArpSourceHardwareAddressBuilder();
 431                     ArpShaCase arpShaCase = ((ArpShaCase) entry.getMatchEntryValue());
 432                     arpSha.setAddress(arpShaCase.getArpSha().getMacAddress());
 433                     if (entry.isHasMask()) {
 434                         arpSha.setMask(new MacAddress(ByteUtil.bytesToHexstring(arpShaCase.getArpSha().getMask(), ":")));
 435                     }
 436                     arpMatch.setArpSourceHardwareAddress(arpSha.build());
 437                 } else if (field.equals(ArpTha.class)) {
 438                     ArpThaCase arpThaCase = ((ArpThaCase) entry.getMatchEntryValue());
 439                     ArpTargetHardwareAddressBuilder arpTha = new ArpTargetHardwareAddressBuilder();
 440                     arpTha.setAddress(arpThaCase.getArpTha().getMacAddress());
 441                     if (entry.isHasMask()) {
 442                         arpTha.setMask(new MacAddress(ByteUtil.bytesToHexstring(arpThaCase.getArpTha().getMask(), ":")));
 443                     }
 444                     arpMatch.setArpTargetHardwareAddress(arpTha.build());
 445                 }
 446             } else if (field.equals(TunnelIpv4Src.class) || field.equals(TunnelIpv4Dst.class)) {
 447                 if (ipv4Match == null) {
 448                     ipv4Match = new Ipv4MatchBuilder();
 449                 }
 450                 if (field.equals(TunnelIpv4Src.class)) {
 451                     Ipv4SrcCase ipv4SrcCase = ((Ipv4SrcCase) entry.getMatchEntryValue());
 452                     int prefix;
 453                     if (entry.isHasMask()) {
 454                         prefix = IpConversionUtil.countBits(ipv4SrcCase.getIpv4Src().getMask());
 455                     } else {
 456                         prefix = 32;
 457                     }
 458
 459                     ipv4Match.setIpv4Source(
 460                         IpConversionUtil.createPrefix(ipv4SrcCase.getIpv4Src().getIpv4Address(), prefix)
 461                     );
 462                 } else if (field.equals(TunnelIpv4Dst.class)) {
 463                     Ipv4DstCase ipv4DstCase = ((Ipv4DstCase) entry.getMatchEntryValue());
 464                     int prefix;
 465                     if (entry.isHasMask()) {
 466                         prefix = IpConversionUtil.countBits(ipv4DstCase.getIpv4Dst().getMask());
 467                     } else {
 468                         prefix = 32;
 469                     }
 470
 471                     ipv4Match.setIpv4Destination(
 472                         IpConversionUtil.createPrefix(ipv4DstCase.getIpv4Dst().getIpv4Address(), prefix)
 473                     );               }
 474             } else if (field.equals(Ipv6Src.class) || field.equals(Ipv6Dst.class) || field.equals(Ipv6Flabel.class)
 475                     || field.equals(Ipv6NdTarget.class) || field.equals(Ipv6NdSll.class)
 476                     || field.equals(Ipv6NdTll.class) || field.equals(Ipv6Exthdr.class)) {
 477                 if (ipv6Match == null) {
 478                     ipv6Match = new Ipv6MatchBuilder();
 479                 }
 480                 if (field.equals(Ipv6Src.class)) {
 481                     Ipv6SrcCase ipv6SrcCase = ((Ipv6SrcCase) entry.getMatchEntryValue());
 482                     int prefix ;
 483                     if (entry.isHasMask()) {
 484                         prefix = IpConversionUtil.countBits(ipv6SrcCase.getIpv6Src().getMask());
 485                     } else {
 486                         prefix = 128;
 487                     }
 488                     ipv6Match.setIpv6Source(
 489                         IpConversionUtil.createPrefix(ipv6SrcCase.getIpv6Src().getIpv6Address(), prefix)
 490                     );
 491                 } else if (field.equals(Ipv6Dst.class)) {
 492                     Ipv6DstCase ipv6DstCase = ((Ipv6DstCase) entry.getMatchEntryValue());
 493                     int prefix;
 494                     if (entry.isHasMask()) {
 495                         prefix = IpConversionUtil.countBits(ipv6DstCase.getIpv6Dst().getMask());
 496                     } else {
 497                         prefix = 128;
 498                     }
 499                     ipv6Match.setIpv6Destination(
 500                         IpConversionUtil.createPrefix(ipv6DstCase.getIpv6Dst().getIpv6Address(), prefix)
 501                     );
 502                 } else if (field.equals(Ipv6Flabel.class)) {
 503                     Ipv6LabelBuilder ipv6Label = new Ipv6LabelBuilder();
 504                     Ipv6FlabelCase ipv6FlabelCase = ((Ipv6FlabelCase) entry.getMatchEntryValue());
 505                     ipv6Label.setIpv6Flabel(ipv6FlabelCase.getIpv6Flabel().getIpv6Flabel());
 506                     if (entry.isHasMask()) {
 507                         ipv6Label.setFlabelMask(new Ipv6FlowLabel(ByteUtil.bytesToUnsignedInt(ipv6FlabelCase.getIpv6Flabel().getMask())));
 508                     }
 509                     ipv6Match.setIpv6Label(ipv6Label.build());
 510                 } else if (field.equals(Ipv6NdTarget.class)) {
 511                     Ipv6NdTargetCase ipv6NdTargetCase = ((Ipv6NdTargetCase) entry.getMatchEntryValue());
 512                     ipv6Match.setIpv6NdTarget(ipv6NdTargetCase.getIpv6NdTarget().getIpv6Address());
 513                 } else if (field.equals(Ipv6NdSll.class)) {
 514                     Ipv6NdSllCase ipv6NdSllCase = ((Ipv6NdSllCase) entry.getMatchEntryValue());
 515                     ipv6Match.setIpv6NdSll(ipv6NdSllCase.getIpv6NdSll().getMacAddress());
 516                 } else if (field.equals(Ipv6NdTll.class)) {
 517                     Ipv6NdTllCase ipv6NdTllCase = ((Ipv6NdTllCase) entry.getMatchEntryValue());
 518                     ipv6Match.setIpv6NdTll(ipv6NdTllCase.getIpv6NdTll().getMacAddress());
 519                 } else if (field.equals(Ipv6Exthdr.class)) {
 520                     Ipv6ExthdrCase ipv6ExthdrCase = ((Ipv6ExthdrCase) entry.getMatchEntryValue());
 521                     // verify
 522                     Ipv6ExtHeaderBuilder ipv6ExtHeaderBuilder = new Ipv6ExtHeaderBuilder();
 523                     Ipv6ExthdrFlags pseudoField = ipv6ExthdrCase.getIpv6Exthdr().getPseudoField();
 524                     Map<Integer, Boolean> map = new HashMap<>();
 525                     map.put(0, pseudoField.isNonext());
 526                     map.put(1, pseudoField.isEsp());
 527                     map.put(2, pseudoField.isAuth());
 528                     map.put(3, pseudoField.isDest());
 529                     map.put(4, pseudoField.isFrag());
 530                     map.put(5, pseudoField.isRouter());
 531                     map.put(6, pseudoField.isHop());
 532                     map.put(7, pseudoField.isUnrep());
 533                     map.put(8, pseudoField.isUnseq());
 534                     int bitmap = ByteBufUtils.fillBitMaskFromMap(map);
 535                     ipv6ExtHeaderBuilder.setIpv6Exthdr(bitmap);
 536                     if (entry.isHasMask()) {
 537                         ipv6ExtHeaderBuilder.setIpv6ExthdrMask(
 538                                 ByteUtil.bytesToUnsignedShort(ipv6ExthdrCase.getIpv6Exthdr().getMask()));
 539                     }
 540                     ipv6Match.setIpv6ExtHeader(ipv6ExtHeaderBuilder.build());
 541                 }
 542             } else if (field.equals(MplsLabel.class) || field.equals(MplsTc.class) || field.equals(MplsBos.class)
 543                     || field.equals(PbbIsid.class)) {
 544                 if (protocolMatchFields == null) {
 545                     protocolMatchFields = new ProtocolMatchFieldsBuilder();
 546                 }
 547                 if (field.equals(MplsLabel.class)) {
 548                     MplsLabelCase mplsLabelCase = ((MplsLabelCase) entry.getMatchEntryValue());
 549                     protocolMatchFields.setMplsLabel(mplsLabelCase.getMplsLabel().getMplsLabel());
 550                 } else if (field.equals(MplsTc.class)) {
 551                     MplsTcCase mplsTcCase = ((MplsTcCase) entry.getMatchEntryValue());
 552                     protocolMatchFields.setMplsTc(mplsTcCase.getMplsTc().getTc());
 553                 } else if (field.equals(MplsBos.class)) {
 554                     MplsBosCase mplsBosCase = ((MplsBosCase) entry.getMatchEntryValue());
 555                     protocolMatchFields
 556                             .setMplsBos((short) (mplsBosCase.getMplsBos().isBos() ? 1 : 0));
 557                 } else if (field.equals(PbbIsid.class)) {
 558                     PbbIsidCase pbbIsidCase = ((PbbIsidCase) entry.getMatchEntryValue());
 559                     PbbBuilder pbb = new PbbBuilder();
 560                     pbb.setPbbIsid(pbbIsidCase.getPbbIsid().getIsid());
 561                     if (entry.isHasMask()) {
 562                         pbb.setPbbMask(ByteUtil.bytesToUnsignedInt(pbbIsidCase.getPbbIsid().getMask()));
 563                     }
 564                     protocolMatchFields.setPbb(pbb.build());
 565                 }
 566             } else if (field.equals(TunnelId.class)) {
 567                 TunnelIdCase tunnelIdCase = ((TunnelIdCase) entry.getMatchEntryValue());
 568                 TunnelBuilder tunnel = new TunnelBuilder();
 569                 tunnel.setTunnelId(new BigInteger(OFConstants.SIGNUM_UNSIGNED, tunnelIdCase.getTunnelId().getTunnelId()));
 570                 if (entry.isHasMask()) {
 571                     tunnel.setTunnelMask(new BigInteger(OFConstants.SIGNUM_UNSIGNED, tunnelIdCase.getTunnelId().getMask()));
 572                 }
 573                 matchBuilder.setTunnel(tunnel.build());
 574             }
 575         }
 576
 577         AugmentTuple<Match> matchExtensionWrap =
 578                 MatchExtensionHelper.processAllExtensions(
 579                         ofMatch.getMatchEntry(), ofVersion, MatchPath.SWITCHFLOWREMOVED_MATCH);
 580         if (matchExtensionWrap != null) {
 581             matchBuilder.addAugmentation(matchExtensionWrap.getAugmentationClass(), matchExtensionWrap.getAugmentationObject());
 582         }
 583
 584
 585         if (ethernetMatch != null) {
 586             matchBuilder.setEthernetMatch(ethernetMatch.build());
 587         }
 588         if (vlanMatch != null) {
 589             matchBuilder.setVlanMatch(vlanMatch.build());
 590         }
 591         if (ipMatch != null) {
 592             matchBuilder.setIpMatch(ipMatch.build());
 593         }
 594
 595         if (tcpMatch != null) {
 596             matchBuilder.setLayer4Match(tcpMatch.build());
 597         } else if (udpMatch != null) {
 598             matchBuilder.setLayer4Match(udpMatch.build());
 599         } else if (sctpMatch != null) {
 600             matchBuilder.setLayer4Match(sctpMatch.build());
 601         }
 602
 603         if (icmpv4Match != null) {
 604             matchBuilder.setIcmpv4Match(icmpv4Match.build());
 605         } else if (icmpv6Match != null) {
 606             matchBuilder.setIcmpv6Match(icmpv6Match.build());
 607         }
 608
 609         if (ipv4Match != null) {
 610             matchBuilder.setLayer3Match(ipv4Match.build());
 611         } else if (arpMatch != null) {
 612             matchBuilder.setLayer3Match(arpMatch.build());
 613         } else if (ipv6Match != null) {
 614             matchBuilder.setLayer3Match(ipv6Match.build());
 615         }
 616         if (protocolMatchFields != null) {
 617             matchBuilder.setProtocolMatchFields(protocolMatchFields.build());
 618         }
 619         return matchBuilder.build();
 620     }
 621
 622 }