Updated experimenter model
[openflowjava.git] / openflow-protocol-impl / src / main / java / org / opendaylight / openflowjava / protocol / impl / serialization / action / OF13SetFieldActionSerializer.java
1 /*\r
2  * Copyright (c) 2013 Pantheon Technologies s.r.o. and others. All rights reserved.\r
3  *\r
4  * This program and the accompanying materials are made available under the\r
5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,\r
6  * and is available at http://www.eclipse.org/legal/epl-v10.html\r
7  */\r
8 \r
9 package org.opendaylight.openflowjava.protocol.impl.serialization.action;\r
10 \r
11 import io.netty.buffer.ByteBuf;\r
12 \r
13 import org.opendaylight.openflowjava.protocol.api.extensibility.HeaderSerializer;\r
14 import org.opendaylight.openflowjava.protocol.api.extensibility.OFSerializer;\r
15 import org.opendaylight.openflowjava.protocol.api.extensibility.SerializerRegistry;\r
16 import org.opendaylight.openflowjava.protocol.api.extensibility.SerializerRegistryInjector;\r
17 import org.opendaylight.openflowjava.protocol.api.keys.MatchEntrySerializerKey;\r
18 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;\r
19 import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;\r
20 import org.opendaylight.openflowjava.util.ByteBufUtils;\r
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.ExperimenterIdMatchEntry;\r
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.OxmFieldsAction;\r
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.actions.grouping.Action;\r
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.ExperimenterClass;\r
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.oxm.fields.grouping.MatchEntries;\r
26 \r
27 /**\r
28  * @author michal.polkorab\r
29  *\r
30  */\r
31 public class OF13SetFieldActionSerializer implements OFSerializer<Action>,\r
32         HeaderSerializer<Action>, SerializerRegistryInjector {\r
33 \r
34     private SerializerRegistry registry;\r
35 \r
36     @Override\r
37     public void serialize(Action action, ByteBuf outBuffer) {\r
38         int startIndex = outBuffer.writerIndex();\r
39         outBuffer.writeShort(ActionConstants.SET_FIELD_CODE);\r
40         int lengthIndex = outBuffer.writerIndex();\r
41         outBuffer.writeShort(EncodeConstants.EMPTY_LENGTH);\r
42         OxmFieldsAction oxmField = action.getAugmentation(OxmFieldsAction.class);\r
43         MatchEntries entry = oxmField.getMatchEntries().get(0);\r
44         MatchEntrySerializerKey<?, ?> key = new MatchEntrySerializerKey<>(\r
45                 EncodeConstants.OF13_VERSION_ID, entry.getOxmClass(), entry.getOxmMatchField());\r
46         if (entry.getOxmClass().equals(ExperimenterClass.class)) {\r
47             key.setExperimenterId(entry.getAugmentation(ExperimenterIdMatchEntry.class)\r
48                     .getExperimenter().getValue());\r
49         } else {\r
50             key.setExperimenterId(null);\r
51         }\r
52         OFSerializer<MatchEntries> serializer = registry.getSerializer(key);\r
53         serializer.serialize(entry, outBuffer);\r
54         int paddingRemainder = (outBuffer.writerIndex() - startIndex) % EncodeConstants.PADDING;\r
55         if (paddingRemainder != 0) {\r
56             ByteBufUtils.padBuffer(EncodeConstants.PADDING - paddingRemainder, outBuffer);\r
57         }\r
58         outBuffer.setShort(lengthIndex, outBuffer.writerIndex() - startIndex);\r
59     }\r
60 \r
61     @Override\r
62     public void serializeHeader(Action input, ByteBuf outBuffer) {\r
63         outBuffer.writeShort(ActionConstants.SET_FIELD_CODE);\r
64         outBuffer.writeShort(ActionConstants.ACTION_IDS_LENGTH);\r
65     }\r
66 \r
67     @Override\r
68     public void injectSerializerRegistry(SerializerRegistry serializerRegistry) {\r
69         registry = serializerRegistry;\r
70     }\r
71 \r
72 }\r