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

Make sure the ByteBuffer is copied on NioDatagramWorker.read(..). See #485

Browse Source
This commit is contained in:
norman 2012-08-01 08:43:41 +02:00
parent 40685a030d
commit 9f285d1819
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/org/jboss/netty/channel/socket/nio/NioDatagramWorker.java
View File

@ -28,6 +28,7 @@ import java.nio.channels.Selector;
import java.util.Queue; import java.util.Queue;
import java.util.concurrent.Executor; import java.util.concurrent.Executor;
import org.jboss.netty.buffer.ChannelBuffer;
import org.jboss.netty.buffer.ChannelBufferFactory; import org.jboss.netty.buffer.ChannelBufferFactory;
import org.jboss.netty.channel.ChannelException; import org.jboss.netty.channel.ChannelException;
import org.jboss.netty.channel.ChannelFuture; import org.jboss.netty.channel.ChannelFuture;
@ -95,9 +96,16 @@ public class NioDatagramWorker extends AbstractNioWorker {
// Update the predictor. // Update the predictor.
predictor.previousReceiveBufferSize(readBytes); predictor.previousReceiveBufferSize(readBytes);
final ChannelBuffer buffer = bufferFactory.getBuffer(readBytes);
buffer.setBytes(0, byteBuffer);
buffer.writerIndex(readBytes);
// Update the predictor.
predictor.previousReceiveBufferSize(readBytes);
// Notify the interested parties about the newly arrived message. // Notify the interested parties about the newly arrived message.
fireMessageReceived( fireMessageReceived(
channel, bufferFactory.getBuffer(byteBuffer), remoteAddress); channel, buffer, remoteAddress);
} }
} }