Don't release messages before throw UnsupportedOperationException, as the caller method will take care
This commit is contained in:
parent
a5871dfd86
commit
4bf5003f76
@ -15,7 +15,6 @@
|
|||||||
*/
|
*/
|
||||||
package io.netty.channel.socket.oio;
|
package io.netty.channel.socket.oio;
|
||||||
|
|
||||||
import io.netty.buffer.ByteBufUtil;
|
|
||||||
import io.netty.channel.ChannelException;
|
import io.netty.channel.ChannelException;
|
||||||
import io.netty.channel.ChannelMetadata;
|
import io.netty.channel.ChannelMetadata;
|
||||||
import io.netty.channel.MessageList;
|
import io.netty.channel.MessageList;
|
||||||
@ -185,10 +184,6 @@ public class OioServerSocketChannel extends AbstractOioMessageChannel
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected int doWrite(MessageList<Object> msgs, int index) throws Exception {
|
protected int doWrite(MessageList<Object> msgs, int index) throws Exception {
|
||||||
int size = msgs.size();
|
|
||||||
for (int i = index; i < size; i ++) {
|
|
||||||
ByteBufUtil.release(msgs.get(i));
|
|
||||||
}
|
|
||||||
throw new UnsupportedOperationException();
|
throw new UnsupportedOperationException();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user