Skip to content

Commit

Permalink
AbstractKQueueChannel#writeFilter is invoked with the correct boolean…
Browse files Browse the repository at this point in the history
… depending on the ChannelOutboundBuffer state (netty#11128)

Motivation:

This is a regression caused by netty#11086

Modifications:

AbstractKQueueChannel#writeFilter should be invoked with `!in.isEmpty()`
- false - all messages are written
- true - there are still messages to be written

Result:

AbstractKQueueChannel#writeFilter is invoked with the correct boolean depending on the ChannelOutboundBuffer state
  • Loading branch information
violetagg authored Mar 30, 2021
1 parent ff0c014 commit 41ef4e4
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -279,7 +279,7 @@ protected void doWrite(ChannelOutboundBuffer in) throws Exception {
}

// Whether all messages were written or not.
writeFilter(in.isEmpty());
writeFilter(!in.isEmpty());
}

private boolean doWriteMessage(Object msg) throws Exception {
Expand Down

0 comments on commit 41ef4e4

Please sign in to comment.