2 * Copyright © 2016 Red Hat, Inc. and others.
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
8 package org.opendaylight.genius.mdsalutil.actions;
10 import java.util.ArrayList;
11 import java.util.Collections;
12 import java.util.List;
13 import java.util.stream.Collectors;
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;
28 * NX conntrack action.
30 public class ActionNxConntrack extends ActionInfo {
31 private static final long serialVersionUID = 1L;
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<>();
39 public ActionNxConntrack(int flags, long zoneSrc, int conntrackZone, short recircTable) {
40 this(0, flags, zoneSrc, conntrackZone, recircTable, Collections.emptyList());
43 public ActionNxConntrack(int flags, long zoneSrc, int conntrackZone, short recircTable,
44 List<NxCtAction> ctActions) {
45 this(0, flags, zoneSrc, conntrackZone, recircTable, ctActions);
48 public ActionNxConntrack(int actionKey, int flags, long zoneSrc, int conntrackZone, short recircTable) {
49 this(actionKey, flags, zoneSrc, conntrackZone, recircTable, Collections.emptyList());
52 public ActionNxConntrack(int actionKey, int flags, long zoneSrc, int conntrackZone, short recircTable,
53 List<NxCtAction> ctActions) {
56 this.zoneSrc = zoneSrc;
57 this.conntrackZone = conntrackZone;
58 this.recircTable = recircTable;
59 this.ctActions.addAll(ctActions);
63 public Action buildAction() {
64 return buildAction(getActionKey());
68 public Action buildAction(int newActionKey) {
69 NxConntrackBuilder ctb = new NxConntrackBuilder()
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));
82 public int getFlags() {
86 public long getZoneSrc() {
90 public int getConntrackZone() {
94 public short getRecircTable() {
98 public List<NxCtAction> getCtActions() {
103 public boolean equals(Object other) {
107 if (other == null || getClass() != other.getClass()) {
110 if (!super.equals(other)) {
114 ActionNxConntrack that = (ActionNxConntrack) other;
116 if (flags != that.flags) {
119 if (zoneSrc != that.zoneSrc) {
122 if (conntrackZone != that.conntrackZone) {
125 if (recircTable != that.recircTable) {
128 return ctActions.equals(that.ctActions);
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();
143 public String toString() {
144 return "ActionNxConntrack [flags=" + flags + ", zoneSrc=" + zoneSrc + ", conntrackZone=" + conntrackZone
145 + ", recircTable=" + recircTable + ", ctActions=" + ctActions + ", getActionKey()=" + getActionKey()
149 public interface NxCtAction {
150 CtActions buildCtActions();
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;
161 public NxNat(int actionKey, int flags, int natType, IpAddress ipAddressMin,
162 IpAddress ipAddressMax,int portMin, int portMax) {
164 this.rangePresent = natType;
165 this.ipAddressMin = ipAddressMin;
166 this.ipAddressMax = ipAddressMax;
167 this.portMin = portMin;
168 this.portMax = portMax;
171 public int getFlags() {
175 public int getRangePresent() {
179 public IpAddress getIpAddressMin() {
183 public IpAddress getIpAddressMax() {
187 public int getPortMin() {
191 public int getPortMax() {
196 public CtActions buildCtActions() {
197 NxActionNatBuilder nxActionNatBuilder = new NxActionNatBuilder()
199 .setRangePresent(rangePresent)
200 .setIpAddressMin(ipAddressMin)
201 .setIpAddressMax(ipAddressMax)
203 .setPortMax(portMax);
205 CtActionsBuilder ctActionsBuilder = new CtActionsBuilder();
206 NxActionNatCaseBuilder caseBuilder = new NxActionNatCaseBuilder();
207 caseBuilder.setNxActionNat(nxActionNatBuilder.build());
208 ctActionsBuilder.setOfpactActions(caseBuilder.build());
209 return ctActionsBuilder.build();
213 public boolean equals(Object other) {
217 if (other == null || getClass() != other.getClass()) {
221 NxNat that = (NxNat) other;
223 if (flags != that.flags) {
226 if (rangePresent != that.rangePresent) {
229 if (ipAddressMin != null ? !ipAddressMin.equals(that.ipAddressMin) : that.ipAddressMin != null) {
232 if (ipAddressMax != null ? !ipAddressMax.equals(that.ipAddressMax) : that.ipAddressMax != null) {
235 if (portMin != that.portMin) {
238 return portMax == that.portMax;
242 public int hashCode() {
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;
253 public String toString() {
254 return "NxNat [flags=" + flags + ", rangePresent=" + rangePresent + ", ipAddressMin=" + ipAddressMin
255 + ", ipAddressMax=" + ipAddressMax + ", portMin=" + portMin + ", portMax=" + portMax + "]";