Fixed issue: NETTY-373 Deadlock in ChunkedWriteHandler on channel
close. * channelInterestChanged event is not fired anymore when a socket is closing because it is unnecessary
This commit is contained in:
parent
5c75915f4c
commit
ae6a5ca82d
@ -293,7 +293,7 @@ class NioDatagramChannel extends AbstractChannel
|
||||
if (newWriteBufferSize == 0 || newWriteBufferSize < lowWaterMark) {
|
||||
if (newWriteBufferSize + messageSize >= lowWaterMark) {
|
||||
highWaterMarkCounter.decrementAndGet();
|
||||
if (!notifying.get()) {
|
||||
if (isBound() && !notifying.get()) {
|
||||
notifying.set(Boolean.TRUE);
|
||||
fireChannelInterestChanged(NioDatagramChannel.this);
|
||||
notifying.set(Boolean.FALSE);
|
||||
|
@ -237,7 +237,7 @@ class NioSocketChannel extends AbstractChannel
|
||||
if (newWriteBufferSize == 0 || newWriteBufferSize < lowWaterMark) {
|
||||
if (newWriteBufferSize + messageSize >= lowWaterMark) {
|
||||
highWaterMarkCounter.decrementAndGet();
|
||||
if (!notifying.get()) {
|
||||
if (isConnected() && !notifying.get()) {
|
||||
notifying.set(Boolean.TRUE);
|
||||
fireChannelInterestChanged(NioSocketChannel.this);
|
||||
notifying.set(Boolean.FALSE);
|
||||
|
Loading…
x
Reference in New Issue
Block a user