mdsalutil/mdsalutil-api/src/main/java/org/opendaylight/genius/mdsalutil/actions/ActionNxConntrack.java

   1 /*
   2  * Copyright © 2016 Red Hat, Inc. and others.
   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 package org.opendaylight.genius.mdsalutil.actions;
   9
  10 import java.util.ArrayList;
  11 import java.util.Collections;
  12 import java.util.List;
  13 import java.util.stream.Collectors;
  14
  15 import org.opendaylight.genius.mdsalutil.ActionInfo;
  16 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.Action;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.ActionBuilder;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.ActionKey;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.action.rev140714.nodes.node.table.flow.instructions.instruction.instruction.apply.actions._case.apply.actions.action.action.NxActionConntrackNodesNodeTableFlowApplyActionsCaseBuilder;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.action.rev140714.nx.action.conntrack.grouping.NxConntrackBuilder;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.action.rev140714.nx.action.conntrack.grouping.nx.conntrack.CtActions;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.action.rev140714.nx.action.conntrack.grouping.nx.conntrack.CtActionsBuilder;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.action.rev140714.ofpact.actions.ofpact.actions.NxActionNatCaseBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.nicira.action.rev140714.ofpact.actions.ofpact.actions.nx.action.nat._case.NxActionNatBuilder;
  26
  27 /**
  28  * NX conntrack action.
  29  */
  30 public class ActionNxConntrack extends ActionInfo {
  31     private static final long serialVersionUID = 1L;
  32
  33     private final int flags;
  34     private final long zoneSrc;
  35     private final int conntrackZone;
  36     private final short recircTable;
  37     private final List<NxCtAction> ctActions = new ArrayList<>();
  38
  39     public ActionNxConntrack(int flags, long zoneSrc, int conntrackZone, short recircTable) {
  40         this(0, flags, zoneSrc, conntrackZone, recircTable, Collections.emptyList());
  41     }
  42
  43     public ActionNxConntrack(int flags, long zoneSrc, int conntrackZone, short recircTable,
  44             List<NxCtAction> ctActions) {
  45         this(0, flags, zoneSrc, conntrackZone, recircTable, ctActions);
  46     }
  47
  48     public ActionNxConntrack(int actionKey, int flags, long zoneSrc, int conntrackZone, short recircTable) {
  49         this(actionKey, flags, zoneSrc, conntrackZone, recircTable, Collections.emptyList());
  50     }
  51
  52     public ActionNxConntrack(int actionKey, int flags, long zoneSrc, int conntrackZone, short recircTable,
  53             List<NxCtAction> ctActions) {
  54         super(actionKey);
  55         this.flags = flags;
  56         this.zoneSrc = zoneSrc;
  57         this.conntrackZone = conntrackZone;
  58         this.recircTable = recircTable;
  59         this.ctActions.addAll(ctActions);
  60     }
  61
  62     @Override
  63     public Action buildAction() {
  64         return buildAction(getActionKey());
  65     }
  66
  67     @Override
  68     public Action buildAction(int newActionKey) {
  69         NxConntrackBuilder ctb = new NxConntrackBuilder()
  70                 .setFlags(flags)
  71                 .setZoneSrc(zoneSrc)
  72                 .setConntrackZone(conntrackZone)
  73                 .setRecircTable(recircTable);
  74         ctb.setCtActions(this.ctActions.stream().map(NxCtAction::buildCtActions).collect(Collectors.toList()));
  75         ActionBuilder ab = new ActionBuilder();
  76         ab.setAction(new NxActionConntrackNodesNodeTableFlowApplyActionsCaseBuilder()
  77                 .setNxConntrack(ctb.build()).build());
  78         ab.setKey(new ActionKey(newActionKey));
  79         return ab.build();
  80     }
  81
  82     public int getFlags() {
  83         return flags;
  84     }
  85
  86     public long getZoneSrc() {
  87         return zoneSrc;
  88     }
  89
  90     public int getConntrackZone() {
  91         return conntrackZone;
  92     }
  93
  94     public short getRecircTable() {
  95         return recircTable;
  96     }
  97
  98     public List<NxCtAction> getCtActions() {
  99         return ctActions;
 100     }
 101
 102     @Override
 103     public boolean equals(Object other) {
 104         if (this == other) {
 105             return true;
 106         }
 107         if (other == null || getClass() != other.getClass()) {
 108             return false;
 109         }
 110         if (!super.equals(other)) {
 111             return false;
 112         }
 113
 114         ActionNxConntrack that = (ActionNxConntrack) other;
 115
 116         if (flags != that.flags) {
 117             return false;
 118         }
 119         if (zoneSrc != that.zoneSrc) {
 120             return false;
 121         }
 122         if (conntrackZone != that.conntrackZone) {
 123             return false;
 124         }
 125         if (recircTable != that.recircTable) {
 126             return false;
 127         }
 128         return ctActions.equals(that.ctActions);
 129     }
 130
 131     @Override
 132     public int hashCode() {
 133         int result = super.hashCode();
 134         result = 31 * result + flags;
 135         result = 31 * result + (int) (zoneSrc ^ zoneSrc >>> 32);
 136         result = 31 * result + conntrackZone;
 137         result = 31 * result + recircTable;
 138         result = 31 * result + ctActions.hashCode();
 139         return result;
 140     }
 141
 142     @Override
 143     public String toString() {
 144         return "ActionNxConntrack [flags=" + flags + ", zoneSrc=" + zoneSrc + ", conntrackZone=" + conntrackZone
 145                 + ", recircTable=" + recircTable + ", ctActions=" + ctActions + ", getActionKey()=" + getActionKey()
 146                 + "]";
 147     }
 148
 149     public interface NxCtAction {
 150         CtActions buildCtActions();
 151     }
 152
 153     public static class NxNat implements NxCtAction {
 154         private final int flags;
 155         private final int rangePresent;
 156         private final IpAddress ipAddressMin;
 157         private final IpAddress ipAddressMax;
 158         private final int portMin;
 159         private final int portMax;
 160
 161         public NxNat(int actionKey, int flags, int natType, IpAddress ipAddressMin,
 162                 IpAddress ipAddressMax,int portMin, int portMax) {
 163             this.flags = flags;
 164             this.rangePresent = natType;
 165             this.ipAddressMin = ipAddressMin;
 166             this.ipAddressMax = ipAddressMax;
 167             this.portMin = portMin;
 168             this.portMax = portMax;
 169         }
 170
 171         public int getFlags() {
 172             return flags;
 173         }
 174
 175         public int getRangePresent() {
 176             return rangePresent;
 177         }
 178
 179         public IpAddress getIpAddressMin() {
 180             return ipAddressMin;
 181         }
 182
 183         public IpAddress getIpAddressMax() {
 184             return ipAddressMax;
 185         }
 186
 187         public int getPortMin() {
 188             return portMin;
 189         }
 190
 191         public int getPortMax() {
 192             return portMax;
 193         }
 194
 195         @Override
 196         public CtActions buildCtActions() {
 197             NxActionNatBuilder nxActionNatBuilder = new NxActionNatBuilder()
 198                     .setFlags(flags)
 199                     .setRangePresent(rangePresent)
 200                     .setIpAddressMin(ipAddressMin)
 201                     .setIpAddressMax(ipAddressMax)
 202                     .setPortMin(portMin)
 203                     .setPortMax(portMax);
 204
 205             CtActionsBuilder ctActionsBuilder = new CtActionsBuilder();
 206             NxActionNatCaseBuilder caseBuilder = new NxActionNatCaseBuilder();
 207             caseBuilder.setNxActionNat(nxActionNatBuilder.build());
 208             ctActionsBuilder.setOfpactActions(caseBuilder.build());
 209             return ctActionsBuilder.build();
 210         }
 211
 212         @Override
 213         public boolean equals(Object other) {
 214             if (this == other) {
 215                 return true;
 216             }
 217             if (other == null || getClass() != other.getClass()) {
 218                 return false;
 219             }
 220
 221             NxNat that = (NxNat) other;
 222
 223             if (flags != that.flags) {
 224                 return false;
 225             }
 226             if (rangePresent != that.rangePresent) {
 227                 return false;
 228             }
 229             if (ipAddressMin != null ? !ipAddressMin.equals(that.ipAddressMin) : that.ipAddressMin != null) {
 230                 return false;
 231             }
 232             if (ipAddressMax != null ? !ipAddressMax.equals(that.ipAddressMax) : that.ipAddressMax != null) {
 233                 return false;
 234             }
 235             if (portMin != that.portMin) {
 236                 return false;
 237             }
 238             return portMax == that.portMax;
 239         }
 240
 241         @Override
 242         public int hashCode() {
 243             int result = flags;
 244             result = 31 * result + rangePresent;
 245             result = 31 * result + ipAddressMin.hashCode();
 246             result = 31 * result + ipAddressMax.hashCode();
 247             result = 31 * result + portMin;
 248             result = 31 * result + portMax;
 249             return result;
 250         }
 251
 252         @Override
 253         public String toString() {
 254             return "NxNat [flags=" + flags + ", rangePresent=" + rangePresent + ", ipAddressMin=" + ipAddressMin
 255                     + ", ipAddressMax=" + ipAddressMax + ", portMin=" + portMin + ", portMax=" + portMax + "]";
 256         }
 257     }
 258 }