[#3740] Add missing parentheses so the fix works as expected.
This commit is contained in:
parent
e71e40057f
commit
f6c2c99efc
@ -192,8 +192,8 @@ public final class ChannelOutboundBuffer {
|
|||||||
}
|
}
|
||||||
|
|
||||||
long newWriteBufferSize = TOTAL_PENDING_SIZE_UPDATER.addAndGet(this, -size);
|
long newWriteBufferSize = TOTAL_PENDING_SIZE_UPDATER.addAndGet(this, -size);
|
||||||
if (notifyWritability && newWriteBufferSize == 0
|
if (notifyWritability && (newWriteBufferSize == 0
|
||||||
|| newWriteBufferSize <= channel.config().getWriteBufferLowWaterMark()) {
|
|| newWriteBufferSize <= channel.config().getWriteBufferLowWaterMark())) {
|
||||||
setWritable(invokeLater);
|
setWritable(invokeLater);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user