openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/sal/convertor/action/cases/SalToOfSetTpSrcActionCase.java

   1 /*
   2  * Copyright (c) 2016 Cisco Systems, Inc. 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.sal.convertor.action.cases;
  10
  11 import java.util.ArrayList;
  12 import java.util.List;
  13 import java.util.Optional;
  14 import javax.annotation.Nonnull;
  15 import org.opendaylight.openflowplugin.api.OFConstants;
  16 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.action.data.ActionConvertorData;
  17 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.common.ConvertorCase;
  18 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.common.IPProtocols;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.SetTpSrcActionCase;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.set.tp.src.action._case.SetTpSrcAction;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.action.choice.SetFieldCaseBuilder;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.action.choice.set.field._case.SetFieldActionBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.Action;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Icmpv4Type;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.Icmpv6Type;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.OpenflowBasicClass;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.TcpSrc;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.UdpSrc;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entries.grouping.MatchEntry;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entries.grouping.MatchEntryBuilder;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Icmpv4TypeCaseBuilder;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.Icmpv6TypeCaseBuilder;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.TcpSrcCaseBuilder;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.UdpSrcCaseBuilder;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.icmpv4.type._case.Icmpv4TypeBuilder;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.icmpv6.type._case.Icmpv6TypeBuilder;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.tcp.src._case.TcpSrcBuilder;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.udp.src._case.UdpSrcBuilder;
  40 import org.slf4j.Logger;
  41 import org.slf4j.LoggerFactory;
  42
  43 public class SalToOfSetTpSrcActionCase extends ConvertorCase<SetTpSrcActionCase, Action, ActionConvertorData> {
  44     private static final Logger LOG = LoggerFactory.getLogger(SalToOfSetTpSrcActionCase.class);
  45
  46     public SalToOfSetTpSrcActionCase() {
  47         super(SetTpSrcActionCase.class, true, OFConstants.OFP_VERSION_1_3);
  48     }
  49
  50     @Nonnull
  51     @Override
  52     public Optional<Action> process(@Nonnull final SetTpSrcActionCase source, final ActionConvertorData data) {
  53         IPProtocols protocol = null;
  54
  55         if (data.getIpProtocol() != null) {
  56             protocol = IPProtocols.fromProtocolNum(data.getIpProtocol());
  57         }
  58
  59         SetTpSrcAction settpsrcaction = source.getSetTpSrcAction();
  60         SetFieldCaseBuilder setFieldCaseBuilder = new SetFieldCaseBuilder();
  61         SetFieldActionBuilder setFieldBuilder = new SetFieldActionBuilder();
  62
  63         MatchEntryBuilder matchBuilder = new MatchEntryBuilder();
  64         matchBuilder.setOxmClass(OpenflowBasicClass.class);
  65         matchBuilder.setHasMask(false);
  66
  67         int port = settpsrcaction.getPort().getValue();
  68         int type = 0xff & port;
  69
  70         if (protocol != null) {
  71             switch (protocol) {
  72                 case ICMP:
  73                     matchBuilder.setOxmMatchField(Icmpv4Type.class);
  74                     Icmpv4TypeCaseBuilder icmpv4TypeCaseBuilder = new Icmpv4TypeCaseBuilder();
  75                     Icmpv4TypeBuilder icmpv4TypeBuilder = new Icmpv4TypeBuilder();
  76                     icmpv4TypeBuilder.setIcmpv4Type((short) type);
  77                     icmpv4TypeCaseBuilder.setIcmpv4Type(icmpv4TypeBuilder.build());
  78                     matchBuilder.setMatchEntryValue(icmpv4TypeCaseBuilder.build());
  79                     break;
  80                 case ICMPV6:
  81                     matchBuilder.setOxmMatchField(Icmpv6Type.class);
  82                     Icmpv6TypeCaseBuilder icmpv6TypeCaseBuilder = new Icmpv6TypeCaseBuilder();
  83                     Icmpv6TypeBuilder icmpv6TypeBuilder = new Icmpv6TypeBuilder();
  84                     icmpv6TypeBuilder.setIcmpv6Type((short) type);
  85                     icmpv6TypeCaseBuilder.setIcmpv6Type(icmpv6TypeBuilder.build());
  86                     matchBuilder.setMatchEntryValue(icmpv6TypeCaseBuilder.build());
  87                     break;
  88                 case TCP:
  89                     matchBuilder.setOxmMatchField(TcpSrc.class);
  90                     TcpSrcCaseBuilder tcpSrcCaseBuilder = new TcpSrcCaseBuilder();
  91                     TcpSrcBuilder tcpSrcBuilder = new TcpSrcBuilder();
  92                     tcpSrcBuilder.setPort(new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.PortNumber(port));
  93                     tcpSrcCaseBuilder.setTcpSrc(tcpSrcBuilder.build());
  94                     matchBuilder.setMatchEntryValue(tcpSrcCaseBuilder.build());
  95                     break;
  96                 case UDP:
  97                     matchBuilder.setOxmMatchField(UdpSrc.class);
  98                     UdpSrcCaseBuilder udpSrcCaseBuilder = new UdpSrcCaseBuilder();
  99                     UdpSrcBuilder udpSrcBuilder = new UdpSrcBuilder();
 100                     udpSrcBuilder.setPort(new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.PortNumber(port));
 101                     udpSrcCaseBuilder.setUdpSrc(udpSrcBuilder.build());
 102                     matchBuilder.setMatchEntryValue(udpSrcCaseBuilder.build());
 103                     break;
 104                 default:
 105                     LOG.warn("Unknown protocol with combination of SetSourcePort: {}", protocol);
 106                     break;
 107             }
 108         } else {
 109             LOG.warn("Null protocol with combination of SetSourcePort");
 110         }
 111
 112         List<MatchEntry> entries = new ArrayList<>();
 113         entries.add(matchBuilder.build());
 114         setFieldBuilder.setMatchEntry(entries);
 115         setFieldCaseBuilder.setSetFieldAction(setFieldBuilder.build());
 116
 117         return Optional.of(new ActionBuilder()
 118                 .setActionChoice(setFieldCaseBuilder.build())
 119                 .build());
 120     }
 121 }