Cleanup
This commit is contained in:
parent
341f7757aa
commit
5b978497f8
|
@ -205,11 +205,7 @@ public abstract class AbstractNioByteChannel extends AbstractNioChannel {
|
||||||
*/
|
*/
|
||||||
protected abstract int doWriteBytes(ByteBuf buf, boolean lastSpin) throws Exception;
|
protected abstract int doWriteBytes(ByteBuf buf, boolean lastSpin) throws Exception;
|
||||||
|
|
||||||
protected long doWriteBytes(MessageList<ByteBuf> bufs, int index, boolean lastSpin) throws Exception {
|
protected final void updateOpWrite(long expectedWrittenBytes, long writtenBytes, boolean lastSpin) {
|
||||||
return doWriteBytes(bufs.get(index), lastSpin);
|
|
||||||
}
|
|
||||||
|
|
||||||
protected void updateOpWrite(long expectedWrittenBytes, long writtenBytes, boolean lastSpin) {
|
|
||||||
if (writtenBytes >= expectedWrittenBytes) {
|
if (writtenBytes >= expectedWrittenBytes) {
|
||||||
final SelectionKey key = selectionKey();
|
final SelectionKey key = selectionKey();
|
||||||
final int interestOps = key.interestOps();
|
final int interestOps = key.interestOps();
|
||||||
|
|
Loading…
Reference in New Issue
Block a user