-/* 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.ArrayList;\r
-import java.util.List;\r
-\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.EthertypeAction;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.EthertypeActionBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.ExperimenterAction;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.ExperimenterActionBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.GroupIdAction;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.GroupIdActionBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MaxLengthAction;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MaxLengthActionBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MplsTtlAction;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MplsTtlActionBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.NwTtlAction;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.NwTtlActionBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.OxmFieldsAction;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.OxmFieldsActionBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.PortAction;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.PortActionBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.QueueIdAction;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.QueueIdActionBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.CopyTtlIn;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.CopyTtlOut;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.DecMplsTtl;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.DecNwTtl;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.Experimenter;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.Group;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.Output;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.PopMpls;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.PopPbb;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.PopVlan;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.PushMpls;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.PushPbb;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.PushVlan;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.SetField;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.SetMplsTtl;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.SetNwTtl;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.SetQueue;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.actions.ActionsList;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.actions.ActionsListBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.actions.actions.list.ActionBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.EtherType;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortNumber;\r
-\r
-/**\r
- * Deserializes ofp_actions (OpenFlow v1.3)\r
- * @author timotej.kubas\r
- * @author michal.polkorab\r
- */\r
-public abstract class ActionsDeserializer {\r
- \r
- private static final byte ACTION_HEADER_LENGTH = 4;\r
- private static final byte PADDING_IN_ACTIONS_HEADER = 4;\r
- private static final byte PADDING_IN_OUTPUT_ACTIONS_HEADER = 6;\r
- private static final byte PADDING_IN_SET_MPLS_TTL_ACTIONS_HEADER = 3;\r
- private static final byte PADDING_IN_PUSH_VLAN_ACTIONS_HEADER = 2;\r
- private static final byte PADDING_IN_NW_TTL_ACTIONS_HEADER = 3;\r
- \r
- /**\r
- * Creates list of actions (OpenFlow v1.3)\r
- * @param input input ByteBuf\r
- * @param actionsLength length of buckets\r
- * @return ActionsList\r
- */\r
- public static List<ActionsList> createActionsList(ByteBuf input, int actionsLength) {\r
- ActionsListBuilder actionsListBuilder = new ActionsListBuilder();\r
- List<ActionsList> actionsList = new ArrayList<>();\r
- int length = 0;\r
- while (length < actionsLength) {\r
- int currentActionLength = 0;\r
- switch(input.readUnsignedShort()) {\r
- case 0: currentActionLength = input.readUnsignedShort(); //outputActionLength\r
- actionsList.add(createOutputAction(input, actionsListBuilder));\r
- break;\r
- case 11: \r
- currentActionLength = input.readUnsignedShort();//empty header length\r
- actionsList.add(createCopyTtlOutAction(input, actionsListBuilder));\r
- break;\r
-\r
- case 12: \r
- currentActionLength = input.readUnsignedShort();//empty header length\r
- actionsList.add(createCopyTtlInAction(input, actionsListBuilder));\r
- break;\r
-\r
- case 15: \r
- currentActionLength = input.readUnsignedShort();//empty header length\r
- actionsList.add(createSetMplsTtlAction(input, actionsListBuilder));\r
- break;\r
-\r
- case 16: \r
- currentActionLength = input.readUnsignedShort();//empty header length\r
- actionsList.add(createDecMplsTtlOutAction(input, actionsListBuilder));\r
- break;\r
-\r
- case 17: \r
- currentActionLength = input.readUnsignedShort();\r
- actionsList.add(createPushVlanAction(input, actionsListBuilder));\r
- break;\r
-\r
- case 18: \r
- currentActionLength = input.readUnsignedShort();//empty header length\r
- actionsList.add(createPopVlanAction(input, actionsListBuilder));\r
- break;\r
-\r
- case 19: \r
- currentActionLength = input.readUnsignedShort();//8\r
- actionsList.add(createPushMplsAction(input, actionsListBuilder));\r
- break;\r
-\r
- case 20: \r
- currentActionLength = input.readUnsignedShort();//8\r
- actionsList.add(createPopMplsAction(input, actionsListBuilder));\r
- break;\r
-\r
- case 21: \r
- currentActionLength = input.readUnsignedShort();\r
- actionsList.add(createSetQueueAction(input, actionsListBuilder));\r
- break;\r
-\r
- case 22: \r
- currentActionLength = input.readUnsignedShort();//8\r
- actionsList.add(createGroupAction(input, actionsListBuilder));\r
- break;\r
-\r
- case 23: \r
- currentActionLength = input.readUnsignedShort();//8\r
- actionsList.add(createSetNwTtlAction(input, actionsListBuilder));\r
- break;\r
-\r
- case 24: \r
- currentActionLength = input.readUnsignedShort();//empty header length\r
- actionsList.add(createDecNwTtlAction(input, actionsListBuilder));\r
- break;\r
-\r
- case 25:\r
- currentActionLength = input.readUnsignedShort();//8\r
- actionsList.add(createSetFieldAction(input, actionsListBuilder, currentActionLength));\r
- break; \r
- case 26: \r
- currentActionLength = input.readUnsignedShort();//8\r
- actionsList.add(createPushPbbAction(input, actionsListBuilder));\r
- break;\r
-\r
- case 27: \r
- currentActionLength = input.readUnsignedShort();//empty header length\r
- actionsList.add(createPopPbbAction(input, actionsListBuilder));\r
- break;\r
-\r
- case 0xFFFF: \r
- currentActionLength = input.readUnsignedShort();\r
- actionsList.add(createExperimenterAction(input, actionsListBuilder));\r
- break;\r
- default: \r
- break;\r
- }\r
- length += currentActionLength;\r
- } \r
- return actionsList;\r
- }\r
- \r
- private static ActionsList createEmptyHeader(Class<? extends org.opendaylight.yang.gen.v1.\r
- urn.opendaylight.openflow.common.types.rev130731.Action> action,\r
- ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- ActionBuilder actionBuilder = new ActionBuilder();\r
- actionBuilder.setType(action);\r
- in.skipBytes(PADDING_IN_ACTIONS_HEADER);\r
- actionsListBuilder.setAction(actionBuilder.build());\r
- return actionsListBuilder.build();\r
- }\r
- \r
- private static ActionsList createCopyTtlInAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- return createEmptyHeader(CopyTtlIn.class, in, actionsListBuilder);\r
- }\r
-\r
- private static ActionsList createCopyTtlOutAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- return createEmptyHeader(CopyTtlOut.class, in, actionsListBuilder);\r
- }\r
- \r
- private static ActionsList createDecMplsTtlOutAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- return createEmptyHeader(DecMplsTtl.class, in, actionsListBuilder);\r
- }\r
- \r
- private static ActionsList createPopVlanAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- return createEmptyHeader(PopVlan.class, in, actionsListBuilder);\r
- }\r
- \r
- private static ActionsList createDecNwTtlAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- return createEmptyHeader(DecNwTtl.class, in, actionsListBuilder);\r
- }\r
- \r
- private static ActionsList createPopPbbAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- return createEmptyHeader(PopPbb.class, in, actionsListBuilder);\r
- }\r
- \r
- private static ActionsList createOutputAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- ActionBuilder actionBuilder = new ActionBuilder();\r
- actionBuilder.setType(Output.class);\r
- PortActionBuilder port = new PortActionBuilder();\r
- port.setPort(new PortNumber(in.readUnsignedInt()));\r
- actionBuilder.addAugmentation(PortAction.class, port.build());\r
- MaxLengthActionBuilder maxLen = new MaxLengthActionBuilder();\r
- maxLen.setMaxLength(in.readUnsignedShort());\r
- actionBuilder.addAugmentation(MaxLengthAction.class, maxLen.build());\r
- actionsListBuilder.setAction(actionBuilder.build());\r
- in.skipBytes(PADDING_IN_OUTPUT_ACTIONS_HEADER);\r
- return actionsListBuilder.build();\r
- }\r
- \r
- private static ActionsList createSetMplsTtlAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- ActionBuilder actionBuilder = new ActionBuilder();\r
- actionBuilder.setType(SetMplsTtl.class);\r
- MplsTtlActionBuilder mplsTtl = new MplsTtlActionBuilder();\r
- mplsTtl.setMplsTtl(in.readUnsignedByte());\r
- actionBuilder.addAugmentation(MplsTtlAction.class, mplsTtl.build());\r
- actionsListBuilder.setAction(actionBuilder.build());\r
- in.skipBytes(PADDING_IN_SET_MPLS_TTL_ACTIONS_HEADER);\r
- return actionsListBuilder.build();\r
- }\r
- \r
- private static ActionsList createPushAction(Class<? extends org.opendaylight.yang.gen.\r
- v1.urn.opendaylight.openflow.common.types.rev130731.Action> action,\r
- ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- ActionBuilder actionBuilder = new ActionBuilder();\r
- actionBuilder.setType(action);\r
- EthertypeActionBuilder etherType = new EthertypeActionBuilder();\r
- etherType.setEthertype(new EtherType(in.readUnsignedShort()));\r
- actionBuilder.addAugmentation(EthertypeAction.class, etherType.build());\r
- actionsListBuilder.setAction(actionBuilder.build());\r
- in.skipBytes(PADDING_IN_PUSH_VLAN_ACTIONS_HEADER);\r
- return actionsListBuilder.build();\r
- }\r
- \r
- private static ActionsList createPushVlanAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- return createPushAction(PushVlan.class, in, actionsListBuilder);\r
- }\r
- \r
- private static ActionsList createPushMplsAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- return createPushAction(PushMpls.class, in, actionsListBuilder);\r
- }\r
- \r
- private static ActionsList createPopMplsAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- return createPushAction(PopMpls.class, in, actionsListBuilder);\r
- }\r
- \r
- private static ActionsList createPushPbbAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- return createPushAction(PushPbb.class, in, actionsListBuilder);\r
- }\r
- \r
- private static ActionsList createSetQueueAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- ActionBuilder actionBuilder = new ActionBuilder();\r
- actionBuilder.setType(SetQueue.class);\r
- QueueIdActionBuilder queueId = new QueueIdActionBuilder();\r
- queueId.setQueueId(in.readUnsignedInt());\r
- actionBuilder.addAugmentation(QueueIdAction.class, queueId.build());\r
- actionsListBuilder.setAction(actionBuilder.build());\r
- return actionsListBuilder.build();\r
- }\r
- \r
- private static ActionsList createGroupAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- ActionBuilder actionBuilder = new ActionBuilder();\r
- actionBuilder.setType(Group.class);\r
- GroupIdActionBuilder group = new GroupIdActionBuilder();\r
- group.setGroupId(in.readUnsignedInt());\r
- actionBuilder.addAugmentation(GroupIdAction.class, group.build());\r
- actionsListBuilder.setAction(actionBuilder.build());\r
- return actionsListBuilder.build();\r
- }\r
- \r
- private static ActionsList createExperimenterAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- ActionBuilder actionBuilder = new ActionBuilder();\r
- actionBuilder.setType(Experimenter.class);\r
- ExperimenterActionBuilder experimenter = new ExperimenterActionBuilder();\r
- experimenter.setExperimenter(in.readUnsignedInt());\r
- actionBuilder.addAugmentation(ExperimenterAction.class, experimenter.build());\r
- actionsListBuilder.setAction(actionBuilder.build());\r
- return actionsListBuilder.build();\r
- }\r
- \r
- private static ActionsList createSetNwTtlAction(ByteBuf in, ActionsListBuilder actionsListBuilder) {\r
- ActionBuilder actionBuilder = new ActionBuilder();\r
- actionBuilder.setType(SetNwTtl.class);\r
- NwTtlActionBuilder nwTtl = new NwTtlActionBuilder();\r
- nwTtl.setNwTtl(in.readUnsignedByte());\r
- actionBuilder.addAugmentation(NwTtlAction.class, nwTtl.build());\r
- actionsListBuilder.setAction(actionBuilder.build());\r
- in.skipBytes(PADDING_IN_NW_TTL_ACTIONS_HEADER);\r
- return actionsListBuilder.build();\r
- }\r
- \r
- private static ActionsList createSetFieldAction(ByteBuf in, ActionsListBuilder actionsListBuilder, int actionLength) {\r
- ActionBuilder actionBuilder = new ActionBuilder();\r
- actionBuilder.setType(SetField.class);\r
- OxmFieldsActionBuilder matchEntries = new OxmFieldsActionBuilder();\r
- matchEntries.setMatchEntries(MatchDeserializer.createMatchEntry(in, actionLength - ACTION_HEADER_LENGTH));\r
- actionBuilder.addAugmentation(OxmFieldsAction.class, matchEntries.build());\r
- actionsListBuilder.setAction(actionBuilder.build());\r
- return actionsListBuilder.build();\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.ArrayList;
+import java.util.List;
+
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.EthertypeAction;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.EthertypeActionBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.ExperimenterAction;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.ExperimenterActionBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.GroupIdAction;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.GroupIdActionBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MaxLengthAction;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MaxLengthActionBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MplsTtlAction;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MplsTtlActionBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.NwTtlAction;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.NwTtlActionBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.OxmFieldsAction;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.OxmFieldsActionBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.PortAction;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.PortActionBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.QueueIdAction;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.QueueIdActionBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.CopyTtlIn;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.CopyTtlOut;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.DecMplsTtl;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.DecNwTtl;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.Experimenter;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.Group;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.Output;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.PopMpls;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.PopPbb;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.PopVlan;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.PushMpls;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.PushPbb;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.PushVlan;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.SetField;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.SetMplsTtl;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.SetNwTtl;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.SetQueue;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.actions.grouping.Action;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.actions.grouping.ActionBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.ActionBase;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.EtherType;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortNumber;
+
+/**
+ * Deserializes ofp_actions (OpenFlow v1.3)
+ * @author timotej.kubas
+ * @author michal.polkorab
+ */
+public abstract class ActionsDeserializer {
+
+ private static final byte ACTION_HEADER_LENGTH = 4;
+ private static final byte PADDING_IN_ACTIONS_HEADER = 4;
+ private static final byte PADDING_IN_OUTPUT_ACTIONS_HEADER = 6;
+ private static final byte PADDING_IN_SET_MPLS_TTL_ACTIONS_HEADER = 3;
+ private static final byte PADDING_IN_PUSH_VLAN_ACTIONS_HEADER = 2;
+ private static final byte PADDING_IN_NW_TTL_ACTIONS_HEADER = 3;
+
+ /**
+ * Creates list of actions (OpenFlow v1.3)
+ * @param input input ByteBuf
+ * @param actionsLength length of buckets
+ * @return ActionsList
+ */
+ public static List<Action> createActions(ByteBuf input, int actionsLength) {
+ List<Action> actions = new ArrayList<>();
+ int length = 0;
+ while (length < actionsLength) {
+ int type = input.readUnsignedShort();
+ int currentActionLength = input.readUnsignedShort();
+ ActionBuilder actionBuilder = new ActionBuilder();
+ switch(type) {
+ case 0:
+ actions.add(createOutputAction(input, actionBuilder));
+ break;
+ case 11:
+ actions.add(createCopyTtlOutAction(input, actionBuilder));
+ break;
+ case 12:
+ actions.add(createCopyTtlInAction(input, actionBuilder));
+ break;
+ case 15:
+ actions.add(createSetMplsTtlAction(input, actionBuilder));
+ break;
+ case 16:
+ actions.add(createDecMplsTtlOutAction(input, actionBuilder));
+ break;
+ case 17:
+ actions.add(createPushVlanAction(input, actionBuilder));
+ break;
+ case 18:
+ actions.add(createPopVlanAction(input, actionBuilder));
+ break;
+ case 19:
+ actions.add(createPushMplsAction(input, actionBuilder));
+ break;
+ case 20:
+ actions.add(createPopMplsAction(input, actionBuilder));
+ break;
+ case 21:
+ actions.add(createSetQueueAction(input, actionBuilder));
+ break;
+ case 22:
+ actions.add(createGroupAction(input, actionBuilder));
+ break;
+ case 23:
+ actions.add(createSetNwTtlAction(input, actionBuilder));
+ break;
+ case 24:
+ actions.add(createDecNwTtlAction(input, actionBuilder));
+ break;
+ case 25:
+ actions.add(createSetFieldAction(input, actionBuilder, currentActionLength));
+ break;
+ case 26:
+ actions.add(createPushPbbAction(input, actionBuilder));
+ break;
+ case 27:
+ actions.add(createPopPbbAction(input, actionBuilder));
+ break;
+ case 0xFFFF:
+ actions.add(createExperimenterAction(input, actionBuilder));
+ break;
+ default:
+ break;
+ }
+ length += currentActionLength;
+ }
+ return actions;
+ }
+
+ /**
+ * Creates action ids - actions without values (OpenFlow v1.3)
+ * @param input input ByteBuf
+ * @param actionsLength length of actions
+ * @return ActionsList
+ */
+ public static List<Action> createActionIds(ByteBuf input, int actionsLength) {
+ List<Action> actionsList = new ArrayList<>();
+ int length = 0;
+ ActionBuilder builder;
+ while (length < actionsLength) {
+ builder = new ActionBuilder();
+ int type = input.readUnsignedShort();
+ int currentActionLength = input.readUnsignedShort();
+ switch(type) {
+ case 0:
+ builder.setType(Output.class);
+ break;
+ case 11:
+ builder.setType(CopyTtlOut.class);
+ break;
+ case 12:
+ builder.setType(CopyTtlIn.class);
+ break;
+ case 15:
+ builder.setType(SetMplsTtl.class);
+ break;
+ case 16:
+ builder.setType(DecMplsTtl.class);
+ break;
+ case 17:
+ builder.setType(PushVlan.class);
+ break;
+ case 18:
+ builder.setType(PopVlan.class);
+ break;
+ case 19:
+ builder.setType(PushMpls.class);
+ break;
+ case 20:
+ builder.setType(PopMpls.class);
+ break;
+ case 21:
+ builder.setType(SetQueue.class);
+ break;
+ case 22:
+ builder.setType(Group.class);
+ break;
+ case 23:
+ builder.setType(SetNwTtl.class);
+ break;
+ case 24:
+ builder.setType(DecNwTtl.class);
+ break;
+ case 25:
+ builder.setType(SetField.class);
+ break;
+ case 26:
+ builder.setType(PushPbb.class);
+ break;
+ case 27:
+ builder.setType(PopPbb.class);
+ break;
+ case 0xFFFF:
+ builder.setType(Experimenter.class);
+ ExperimenterActionBuilder experimenter = new ExperimenterActionBuilder();
+ experimenter.setExperimenter(input.readUnsignedInt());
+ builder.addAugmentation(ExperimenterAction.class, experimenter.build());
+ break;
+ default:
+ break;
+ }
+ actionsList.add(builder.build());
+ length += currentActionLength;
+ }
+ return actionsList;
+ }
+
+ private static Action createEmptyHeader(Class<? extends ActionBase> action,
+ ByteBuf in, ActionBuilder actionBuilder) {
+ actionBuilder.setType(action);
+ in.skipBytes(PADDING_IN_ACTIONS_HEADER);
+ return actionBuilder.build();
+ }
+
+ private static Action createCopyTtlInAction(ByteBuf in, ActionBuilder actionBuilder) {
+ return createEmptyHeader(CopyTtlIn.class, in, actionBuilder);
+ }
+
+ private static Action createCopyTtlOutAction(ByteBuf in, ActionBuilder actionBuilder) {
+ return createEmptyHeader(CopyTtlOut.class, in, actionBuilder);
+ }
+
+ private static Action createDecMplsTtlOutAction(ByteBuf in, ActionBuilder actionBuilder) {
+ return createEmptyHeader(DecMplsTtl.class, in, actionBuilder);
+ }
+
+ private static Action createPopVlanAction(ByteBuf in, ActionBuilder actionBuilder) {
+ return createEmptyHeader(PopVlan.class, in, actionBuilder);
+ }
+
+ private static Action createDecNwTtlAction(ByteBuf in, ActionBuilder actionBuilder) {
+ return createEmptyHeader(DecNwTtl.class, in, actionBuilder);
+ }
+
+ private static Action createPopPbbAction(ByteBuf in, ActionBuilder actionBuilder) {
+ return createEmptyHeader(PopPbb.class, in, actionBuilder);
+ }
+
+ private static Action createOutputAction(ByteBuf in, ActionBuilder actionBuilder) {
+ actionBuilder.setType(Output.class);
+ PortActionBuilder port = new PortActionBuilder();
+ port.setPort(new PortNumber(in.readUnsignedInt()));
+ actionBuilder.addAugmentation(PortAction.class, port.build());
+ MaxLengthActionBuilder maxLen = new MaxLengthActionBuilder();
+ maxLen.setMaxLength(in.readUnsignedShort());
+ actionBuilder.addAugmentation(MaxLengthAction.class, maxLen.build());
+ in.skipBytes(PADDING_IN_OUTPUT_ACTIONS_HEADER);
+ return actionBuilder.build();
+ }
+
+ private static Action createSetMplsTtlAction(ByteBuf in, ActionBuilder actionBuilder) {
+ actionBuilder.setType(SetMplsTtl.class);
+ MplsTtlActionBuilder mplsTtl = new MplsTtlActionBuilder();
+ mplsTtl.setMplsTtl(in.readUnsignedByte());
+ actionBuilder.addAugmentation(MplsTtlAction.class, mplsTtl.build());
+ in.skipBytes(PADDING_IN_SET_MPLS_TTL_ACTIONS_HEADER);
+ return actionBuilder.build();
+ }
+
+ private static Action createPushAction(Class<? extends ActionBase> action,
+ ByteBuf in, ActionBuilder actionBuilder) {
+ actionBuilder.setType(action);
+ EthertypeActionBuilder etherType = new EthertypeActionBuilder();
+ etherType.setEthertype(new EtherType(in.readUnsignedShort()));
+ actionBuilder.addAugmentation(EthertypeAction.class, etherType.build());
+ in.skipBytes(PADDING_IN_PUSH_VLAN_ACTIONS_HEADER);
+ return actionBuilder.build();
+ }
+
+ private static Action createPushVlanAction(ByteBuf in, ActionBuilder actionBuilder) {
+ return createPushAction(PushVlan.class, in, actionBuilder);
+ }
+
+ private static Action createPushMplsAction(ByteBuf in, ActionBuilder actionBuilder) {
+ return createPushAction(PushMpls.class, in, actionBuilder);
+ }
+
+ private static Action createPopMplsAction(ByteBuf in, ActionBuilder actionBuilder) {
+ return createPushAction(PopMpls.class, in, actionBuilder);
+ }
+
+ private static Action createPushPbbAction(ByteBuf in, ActionBuilder actionBuilder) {
+ return createPushAction(PushPbb.class, in, actionBuilder);
+ }
+
+ private static Action createSetQueueAction(ByteBuf in, ActionBuilder actionBuilder) {
+ actionBuilder.setType(SetQueue.class);
+ QueueIdActionBuilder queueId = new QueueIdActionBuilder();
+ queueId.setQueueId(in.readUnsignedInt());
+ actionBuilder.addAugmentation(QueueIdAction.class, queueId.build());
+ return actionBuilder.build();
+ }
+
+ private static Action createGroupAction(ByteBuf in, ActionBuilder actionBuilder) {
+ actionBuilder.setType(Group.class);
+ GroupIdActionBuilder group = new GroupIdActionBuilder();
+ group.setGroupId(in.readUnsignedInt());
+ actionBuilder.addAugmentation(GroupIdAction.class, group.build());
+ return actionBuilder.build();
+ }
+
+ private static Action createExperimenterAction(ByteBuf in, ActionBuilder actionBuilder) {
+ actionBuilder.setType(Experimenter.class);
+ ExperimenterActionBuilder experimenter = new ExperimenterActionBuilder();
+ experimenter.setExperimenter(in.readUnsignedInt());
+ actionBuilder.addAugmentation(ExperimenterAction.class, experimenter.build());
+ return actionBuilder.build();
+ }
+
+ private static Action createSetNwTtlAction(ByteBuf in, ActionBuilder actionBuilder) {
+ actionBuilder.setType(SetNwTtl.class);
+ NwTtlActionBuilder nwTtl = new NwTtlActionBuilder();
+ nwTtl.setNwTtl(in.readUnsignedByte());
+ actionBuilder.addAugmentation(NwTtlAction.class, nwTtl.build());
+ in.skipBytes(PADDING_IN_NW_TTL_ACTIONS_HEADER);
+ return actionBuilder.build();
+ }
+
+ private static Action createSetFieldAction(ByteBuf in, ActionBuilder actionBuilder, int actionLength) {
+ actionBuilder.setType(SetField.class);
+ OxmFieldsActionBuilder matchEntries = new OxmFieldsActionBuilder();
+ matchEntries.setMatchEntries(MatchDeserializer.createMatchEntry(in, actionLength - ACTION_HEADER_LENGTH));
+ actionBuilder.addAugmentation(OxmFieldsAction.class, matchEntries.build());
+ return actionBuilder.build();
+ }
+}
Code Review / openflowjava.git / blobdiff