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

Use proper buffer factory in NioDatagramWroekr

Browse Source
This commit is contained in:
Trustin Lee 2009-10-16 04:36:30 +00:00
parent abfae49a7c
commit 7a06c35238
1 changed files with 3 additions and 7 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

@ -38,7 +38,6 @@ import java.util.concurrent.locks.ReentrantReadWriteLock;
import org.jboss.netty.buffer.ChannelBuffer; import org.jboss.netty.buffer.ChannelBuffer;
import org.jboss.netty.buffer.ChannelBufferFactory; import org.jboss.netty.buffer.ChannelBufferFactory;
import org.jboss.netty.buffer.ChannelBuffers;
import org.jboss.netty.channel.Channel; import org.jboss.netty.channel.Channel;
import org.jboss.netty.channel.ChannelException; import org.jboss.netty.channel.ChannelException;
import org.jboss.netty.channel.ChannelFuture; import org.jboss.netty.channel.ChannelFuture;
@ -402,12 +401,9 @@ class NioDatagramWorker implements Runnable {
// Update the predictor. // Update the predictor.
predictor.previousReceiveBufferSize(readBytes); predictor.previousReceiveBufferSize(readBytes);
// Create a Netty ChannelByffer by wrapping the ByteBuffer. // Notify the interested parties about the newly arrived message.
final ChannelBuffer channelBuffer = ChannelBuffers fireMessageReceived(
.wrappedBuffer(byteBuffer); channel, bufferFactory.getBuffer(byteBuffer), remoteAddress);
// Notify the interested parties about the newly arrived message (channelBuffer).
fireMessageReceived(channel, channelBuffer, remoteAddress);
} }
} }