2 * Copyright (c) 2013 Pantheon Technologies s.r.o. 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
9 package org.opendaylight.openflowjava.protocol.impl.core;
11 import io.netty.buffer.ByteBuf;
12 import io.netty.channel.ChannelHandlerContext;
13 import io.netty.handler.codec.ByteToMessageDecoder;
14 import java.util.List;
15 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
16 import org.slf4j.Logger;
17 import org.slf4j.LoggerFactory;
20 * Detects version of used OpenFlow Protocol and discards unsupported version messages
21 * @author michal.polkorab
23 public class OFVersionDetector extends ByteToMessageDecoder {
25 /** Version number of OpenFlow 1.0 protocol */
26 private static final byte OF10_VERSION_ID = EncodeConstants.OF10_VERSION_ID;
27 /** Version number of OpenFlow 1.3 protocol */
28 private static final byte OF13_VERSION_ID = EncodeConstants.OF13_VERSION_ID;
29 private static final short OF_PACKETIN = 10;
30 private static final Logger LOGGER = LoggerFactory.getLogger(OFVersionDetector.class);
31 private volatile boolean filterPacketIns;
34 * Constructor of class.
36 public OFVersionDetector() {
37 LOGGER.trace("Creating OFVersionDetector");
40 public void setFilterPacketIns(final boolean enabled) {
41 filterPacketIns = enabled;
45 protected void decode(final ChannelHandlerContext ctx, final ByteBuf in, final List<Object> out) {
46 if (!in.isReadable()) {
47 LOGGER.debug("not enough data");
52 final byte version = in.readByte();
53 if (version == OF13_VERSION_ID || version == OF10_VERSION_ID) {
54 LOGGER.debug("detected version: {}", version);
55 if (!filterPacketIns || OF_PACKETIN != in.getUnsignedByte(in.readerIndex())) {
56 ByteBuf messageBuffer = in.slice();
57 out.add(new VersionMessageWrapper(version, messageBuffer));
58 messageBuffer.retain();
60 LOGGER.debug("dropped packetin");
63 LOGGER.warn("detected version: {} - currently not supported", version);
65 in.skipBytes(in.readableBytes());