Extend openflow-protocol-impl serialization
[openflowjava.git] / openflow-protocol-impl / src / main / java / org / opendaylight / openflowjava / protocol / impl / deserialization / factories / GroupModInputMessageFactory.java
1 /*
2  * Copyright (c) 2015 NetIDE Consortium and others.  All rights reserved.
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.openflowjava.protocol.impl.deserialization.factories;
9
10 import io.netty.buffer.ByteBuf;
11 import java.util.ArrayList;
12 import java.util.List;
13 import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistry;
14 import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistryInjector;
15 import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
16 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
17 import org.opendaylight.openflowjava.protocol.impl.util.CodeKeyMaker;
18 import org.opendaylight.openflowjava.protocol.impl.util.CodeKeyMakerFactory;
19 import org.opendaylight.openflowjava.protocol.impl.util.ListDeserializer;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.Action;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupId;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupModCommand;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupType;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortNumber;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GroupModInput;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GroupModInputBuilder;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.buckets.grouping.BucketsList;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.buckets.grouping.BucketsListBuilder;
29
30 /**
31  * @author giuseppex.petralia@intel.com
32  *
33  */
34 public class GroupModInputMessageFactory implements OFDeserializer<GroupModInput>, DeserializerRegistryInjector {
35
36     private DeserializerRegistry registry;
37     private static final byte PADDING = 1;
38     private static final byte PADDING_IN_BUCKETS_HEADER = 4;
39     private static final byte BUCKETS_HEADER_LENGTH = 16;
40
41     @Override
42     public void injectDeserializerRegistry(DeserializerRegistry deserializerRegistry) {
43         registry = deserializerRegistry;
44     }
45
46     @Override
47     public GroupModInput deserialize(ByteBuf rawMessage) {
48         GroupModInputBuilder builder = new GroupModInputBuilder();
49         builder.setVersion((short) EncodeConstants.OF13_VERSION_ID);
50         builder.setXid(rawMessage.readUnsignedInt());
51         builder.setCommand(GroupModCommand.forValue(rawMessage.readUnsignedShort()));
52         builder.setType(GroupType.forValue(rawMessage.readUnsignedByte()));
53         rawMessage.skipBytes(PADDING);
54         builder.setGroupId(new GroupId(rawMessage.readUnsignedInt()));
55         List<BucketsList> bucketsList = new ArrayList<>();
56         while (rawMessage.readableBytes() > 0) {
57             BucketsListBuilder bucketsBuilder = new BucketsListBuilder();
58             int bucketsLength = rawMessage.readUnsignedShort();
59             bucketsBuilder.setWeight(rawMessage.readUnsignedShort());
60             bucketsBuilder.setWatchPort(new PortNumber(rawMessage.readUnsignedInt()));
61             bucketsBuilder.setWatchGroup(rawMessage.readUnsignedInt());
62             rawMessage.skipBytes(PADDING_IN_BUCKETS_HEADER);
63             CodeKeyMaker keyMaker = CodeKeyMakerFactory.createActionsKeyMaker(EncodeConstants.OF13_VERSION_ID);
64             List<Action> actions = ListDeserializer.deserializeList(EncodeConstants.OF13_VERSION_ID,
65                     bucketsLength - BUCKETS_HEADER_LENGTH, rawMessage, keyMaker, registry);
66             bucketsBuilder.setAction(actions);
67             bucketsList.add(bucketsBuilder.build());
68         }
69         builder.setBucketsList(bucketsList);
70         return builder.build();
71     }
72
73 }