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;
15 import java.util.List;
17 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
18 import org.slf4j.Logger;
19 import org.slf4j.LoggerFactory;
22 * Detects version of used OpenFlow Protocol and discards unsupported version messages
23 * @author michal.polkorab
25 public class OFVersionDetector extends ByteToMessageDecoder {
27 /** Version number of OpenFlow 1.0 protocol */
28 private static final byte OF10_VERSION_ID = EncodeConstants.OF10_VERSION_ID;
29 /** Version number of OpenFlow 1.3 protocol */
30 private static final byte OF13_VERSION_ID = EncodeConstants.OF13_VERSION_ID;
31 private static final Logger LOGGER = LoggerFactory.getLogger(OFVersionDetector.class);
34 * Constructor of class.
36 public OFVersionDetector() {
37 LOGGER.trace("Creating OFVersionDetector");
41 protected void decode(ChannelHandlerContext chc, ByteBuf bb, List<Object> list) throws Exception {
42 if (bb.readableBytes() == 0) {
43 LOGGER.debug("not enough data");
47 byte version = bb.readByte();
48 if ((version == OF13_VERSION_ID) || (version == OF10_VERSION_ID)) {
49 LOGGER.debug("detected version: " + version);
50 ByteBuf messageBuffer = bb.slice();
51 list.add(new VersionMessageWrapper(version, messageBuffer));
52 messageBuffer.retain();
54 LOGGER.warn("detected version: " + version + " - currently not supported");
56 bb.skipBytes(bb.readableBytes());