-/*\r
- * Copyright (c) 2013 Pantheon Technologies s.r.o. and others. All rights reserved.\r
- *\r
- * This program and the accompanying materials are made available under the\r
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,\r
- * and is available at http://www.eclipse.org/legal/epl-v10.html\r
- */\r
-\r
-package org.opendaylight.openflowjava.protocol.impl.deserialization.action;\r
-\r
-import java.util.ArrayList;\r
-import java.util.List;\r
-\r
-import io.netty.buffer.ByteBuf;\r
-\r
-import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistry;\r
-import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistryInjector;\r
-import org.opendaylight.openflowjava.protocol.api.extensibility.EnhancedMessageCodeKey;\r
-import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;\r
-import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;\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.common.action.rev130731.SetField;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.actions.grouping.Action;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.actions.grouping.ActionBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.ActionBase;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.oxm.fields.grouping.MatchEntries;\r
-\r
-/**\r
- * @author michal.polkorab\r
- *\r
- */\r
-public class OF13SetFieldActionDeserializer extends AbstractActionDeserializer\r
- implements DeserializerRegistryInjector {\r
-\r
- private DeserializerRegistry registry;\r
-\r
- @Override\r
- public Action deserialize(ByteBuf input) {\r
- ActionBuilder builder = new ActionBuilder();\r
- builder.setType(getType());\r
- int startIndex = input.readerIndex();\r
- input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);\r
- OxmFieldsActionBuilder matchEntries = new OxmFieldsActionBuilder();\r
- int oxmClass = input.getUnsignedShort(input.readerIndex());\r
- // get oxm_field & hasMask byte and extract the field value\r
- int oxmField = input.getUnsignedByte(input.readerIndex()\r
- + EncodeConstants.SIZE_OF_SHORT_IN_BYTES) >>> 1;\r
- OFDeserializer<MatchEntries> matchDeserializer = registry.getDeserializer(\r
- new EnhancedMessageCodeKey(EncodeConstants.OF13_VERSION_ID, oxmClass,\r
- oxmField, MatchEntries.class));\r
- List<MatchEntries> entry = new ArrayList<>();\r
- entry.add(matchDeserializer.deserialize(input));\r
- matchEntries.setMatchEntries(entry);\r
- builder.addAugmentation(OxmFieldsAction.class, matchEntries.build());\r
- int paddingRemainder = (input.readerIndex() - startIndex) % EncodeConstants.PADDING;\r
- if (paddingRemainder != 0) {\r
- input.skipBytes(EncodeConstants.PADDING - paddingRemainder);\r
- }\r
- return builder.build();\r
- }\r
-\r
- @Override\r
- protected Class<? extends ActionBase> getType() {\r
- return SetField.class;\r
- }\r
-\r
- @Override\r
- public void injectDeserializerRegistry(DeserializerRegistry deserializerRegistry) {\r
- this.registry = deserializerRegistry;\r
- }\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.deserialization.action;
+
+import io.netty.buffer.ByteBuf;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistry;
+import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistryInjector;
+import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
+import org.opendaylight.openflowjava.protocol.api.keys.MatchEntryDeserializerKey;
+import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.action.choice.SetFieldCaseBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.action.choice.set.field._case.SetFieldActionBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.Action;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entries.grouping.MatchEntry;
+
+/**
+ * @author michal.polkorab
+ *
+ */
+public class OF13SetFieldActionDeserializer extends AbstractActionDeserializer
+ implements DeserializerRegistryInjector {
+
+ private DeserializerRegistry registry;
+
+ @Override
+ public Action deserialize(ByteBuf input) {
+ org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder builder = new ActionBuilder();
+ int startIndex = input.readerIndex();
+ input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
+ SetFieldCaseBuilder caseBuilder = new SetFieldCaseBuilder();
+ SetFieldActionBuilder actionBuilder = new SetFieldActionBuilder();
+ int oxmClass = input.getUnsignedShort(input.readerIndex());
+ // get oxm_field & hasMask byte and extract the field value
+ int oxmField = input.getUnsignedByte(input.readerIndex()
+ + EncodeConstants.SIZE_OF_SHORT_IN_BYTES) >>> 1;
+ MatchEntryDeserializerKey key = new MatchEntryDeserializerKey(EncodeConstants.OF13_VERSION_ID,
+ oxmClass, oxmField);
+ if (oxmClass == EncodeConstants.EXPERIMENTER_VALUE) {
+ long expId = input.getUnsignedInt(input.readerIndex() + EncodeConstants.SIZE_OF_SHORT_IN_BYTES
+ + 2 * EncodeConstants.SIZE_OF_BYTE_IN_BYTES);
+ key.setExperimenterId(expId);
+ }
+ OFDeserializer<MatchEntry> matchDeserializer = registry.getDeserializer(key);
+ List<MatchEntry> entry = new ArrayList<>();
+ entry.add(matchDeserializer.deserialize(input));
+ actionBuilder.setMatchEntry(entry);
+ caseBuilder.setSetFieldAction(actionBuilder.build());
+ builder.setActionChoice(caseBuilder.build());
+ int paddingRemainder = (input.readerIndex() - startIndex) % EncodeConstants.PADDING;
+ if (paddingRemainder != 0) {
+ input.skipBytes(EncodeConstants.PADDING - paddingRemainder);
+ }
+ return builder.build();
+ }
+
+ @Override
+ protected ActionChoice getType() {
+ return new SetFieldCaseBuilder().build();
+ }
+
+ @Override
+ public void injectDeserializerRegistry(DeserializerRegistry deserializerRegistry) {
+ this.registry = deserializerRegistry;
+ }
+
+}
Code Review / openflowjava.git / blobdiff