1 package org.opendaylight.controller.protocol_plugin.openflow.core.internal;
5 import org.jboss.netty.buffer.ChannelBuffer;
6 import org.jboss.netty.buffer.ChannelBuffers;
7 import org.jboss.netty.channel.Channel;
8 import org.jboss.netty.channel.ChannelHandlerContext;
9 import org.jboss.netty.handler.codec.oneone.OneToOneEncoder;
10 import org.openflow.protocol.OFMessage;
13 * Encode an openflow message for output into a ChannelBuffer, for use in a
17 public class OFMessageEncoder extends OneToOneEncoder {
20 protected Object encode(ChannelHandlerContext ctx, Channel channel,
21 Object msg) throws Exception {
22 if (!( msg instanceof List))
25 @SuppressWarnings("unchecked")
26 List<OFMessage> msglist = (List<OFMessage>)msg;
28 for (OFMessage ofm : msglist) {
29 size += ofm.getLengthU();
32 ChannelBuffer buf = ChannelBuffers.buffer(size);;
33 for (OFMessage ofm : msglist) {