andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

OioDatagramWorker now honors buffer factory's default byte order

Browse Source
This commit is contained in:
Trustin Lee 2009-06-11 07:16:10 +00:00
parent 8f4e0b524c
commit e9d07c3c2e
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/jboss/netty/channel/socket/oio/OioDatagramWorker.java
View File

@ -28,6 +28,7 @@ import java.io.InterruptedIOException;
import java.net.DatagramPacket; import java.net.DatagramPacket;
import java.net.MulticastSocket; import java.net.MulticastSocket;
import java.net.SocketAddress; import java.net.SocketAddress;
import java.nio.ByteOrder;
import org.jboss.netty.buffer.ChannelBuffer; import org.jboss.netty.buffer.ChannelBuffer;
import org.jboss.netty.buffer.ChannelBuffers; import org.jboss.netty.buffer.ChannelBuffers;
@ -89,11 +90,12 @@ class OioDatagramWorker implements Runnable {
} }
ChannelBuffer buffer; ChannelBuffer buffer;
ByteOrder endianness = channel.getConfig().getBufferFactory().getDefaultOrder();
int readBytes = packet.getLength(); int readBytes = packet.getLength();
if (readBytes == buf.length) { if (readBytes == buf.length) {
buffer = ChannelBuffers.wrappedBuffer(buf); buffer = ChannelBuffers.wrappedBuffer(endianness, buf);
} else { } else {
buffer = ChannelBuffers.wrappedBuffer(buf, 0, readBytes); buffer = ChannelBuffers.wrappedBuffer(endianness, buf, 0, readBytes);
} }
fireMessageReceived(channel, buffer, packet.getSocketAddress()); fireMessageReceived(channel, buffer, packet.getSocketAddress());