2 * Copyright (c) 2015 NetIDE Consortium and others. All rights reserved.
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.openflowjava.protocol.impl.deserialization.factories;
10 import static java.util.Objects.requireNonNull;
11 import static org.opendaylight.yangtools.yang.common.netty.ByteBufUtils.readUint16;
12 import static org.opendaylight.yangtools.yang.common.netty.ByteBufUtils.readUint32;
13 import static org.opendaylight.yangtools.yang.common.netty.ByteBufUtils.readUint64;
14 import static org.opendaylight.yangtools.yang.common.netty.ByteBufUtils.readUint8;
16 import io.netty.buffer.ByteBuf;
17 import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistry;
18 import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistryInjector;
19 import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
20 import org.opendaylight.openflowjava.protocol.api.keys.MessageCodeKey;
21 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
22 import org.opendaylight.openflowjava.protocol.impl.util.CodeKeyMakerFactory;
23 import org.opendaylight.openflowjava.protocol.impl.util.ListDeserializer;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.FlowModCommand;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.FlowModFlags;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortNumber;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.TableId;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.grouping.Match;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowModInput;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowModInputBuilder;
33 * Translates FlowModInput messages.
35 public class FlowModInputMessageFactory implements OFDeserializer<FlowModInput>, DeserializerRegistryInjector {
36 private static final byte PADDING = 2;
38 private DeserializerRegistry registry = null;
41 public FlowModInput deserialize(final ByteBuf rawMessage) {
42 FlowModInputBuilder builder = new FlowModInputBuilder()
43 .setVersion(EncodeConstants.OF_VERSION_1_3)
44 .setXid(readUint32(rawMessage))
45 .setCookie(readUint64(rawMessage))
46 .setCookieMask(readUint64(rawMessage))
47 .setTableId(new TableId(readUint8(rawMessage).toUint32()))
48 .setCommand(FlowModCommand.forValue(rawMessage.readUnsignedByte()))
49 .setIdleTimeout(readUint16(rawMessage))
50 .setHardTimeout(readUint16(rawMessage))
51 .setPriority(readUint16(rawMessage))
52 .setBufferId(readUint32(rawMessage))
53 .setOutPort(new PortNumber(readUint32(rawMessage)))
54 .setOutGroup(readUint32(rawMessage))
55 .setFlags(createFlowModFlagsFromBitmap(rawMessage.readUnsignedShort()));
56 rawMessage.skipBytes(PADDING);
57 OFDeserializer<Match> matchDeserializer = registry.getDeserializer(
58 new MessageCodeKey(EncodeConstants.OF_VERSION_1_3, EncodeConstants.EMPTY_VALUE, Match.class));
60 .setMatch(matchDeserializer.deserialize(rawMessage))
61 .setInstruction(ListDeserializer.deserializeList(EncodeConstants.OF13_VERSION_ID,
62 rawMessage.readableBytes(), rawMessage,
63 CodeKeyMakerFactory.createInstructionsKeyMaker(EncodeConstants.OF_VERSION_1_3), registry))
67 @SuppressWarnings("checkstyle:AbbreviationAsWordInName")
68 private static FlowModFlags createFlowModFlagsFromBitmap(final int input) {
69 final Boolean _oFPFFSENDFLOWREM = (input & 1 << 0) != 0;
70 final Boolean _oFPFFCHECKOVERLAP = (input & 1 << 1) != 0;
71 final Boolean _oFPFFRESETCOUNTS = (input & 1 << 2) != 0;
72 final Boolean _oFPFFNOPKTCOUNTS = (input & 1 << 3) != 0;
73 final Boolean _oFPFFNOBYTCOUNTS = (input & 1 << 4) != 0;
74 return new FlowModFlags(_oFPFFCHECKOVERLAP, _oFPFFNOBYTCOUNTS, _oFPFFNOPKTCOUNTS, _oFPFFRESETCOUNTS,
79 public void injectDeserializerRegistry(final DeserializerRegistry deserializerRegistry) {
80 registry = requireNonNull(deserializerRegistry);