/** Version number of OpenFlow 1.3 protocol */
private static final byte OF13_VERSION_ID = EncodeConstants.OF13_VERSION_ID;
private static final short OF_PACKETIN = 10;
- private static final Logger LOGGER = LoggerFactory.getLogger(OFVersionDetector.class);
+ private static final Logger LOG = LoggerFactory.getLogger(OFVersionDetector.class);
private final StatisticsCounters statisticsCounters;
private volatile boolean filterPacketIns;
* Constructor of class.
*/
public OFVersionDetector() {
- LOGGER.trace("Creating OFVersionDetector");
+ LOG.trace("Creating OFVersionDetector");
statisticsCounters = StatisticsCounters.getInstance();
}
@Override
protected void decode(final ChannelHandlerContext ctx, final ByteBuf in, final List<Object> out) {
if (!in.isReadable()) {
- LOGGER.debug("not enough data");
+ LOG.debug("not enough data");
in.release();
return;
}
final byte version = in.readByte();
if (version == OF13_VERSION_ID || version == OF10_VERSION_ID) {
- LOGGER.debug("detected version: {}", version);
+ LOG.debug("detected version: {}", version);
if (!filterPacketIns || OF_PACKETIN != in.getUnsignedByte(in.readerIndex())) {
ByteBuf messageBuffer = in.slice();
out.add(new VersionMessageWrapper(version, messageBuffer));
messageBuffer.retain();
} else {
- LOGGER.debug("dropped packetin");
+ LOG.debug("dropped packetin");
statisticsCounters.incrementCounter(CounterEventTypes.US_DROPPED_PACKET_IN);
}
} else {
- LOGGER.warn("detected version: {} - currently not supported", version);
+ LOG.warn("detected version: {} - currently not supported", version);
}
in.skipBytes(in.readableBytes());
}