Fix regression in ChunkedWriteHandler. See #310
This commit is contained in:
parent
78ab007e1b
commit
ea5cb8ae2b
@ -192,6 +192,7 @@ public class ChunkedWriteHandler implements ChannelUpstreamHandler, ChannelDowns
|
|||||||
|
|
||||||
if (!channel.isConnected()) {
|
if (!channel.isConnected()) {
|
||||||
discard(ctx, fireNow);
|
discard(ctx, fireNow);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
while (channel.isWritable()) {
|
while (channel.isWritable()) {
|
||||||
@ -284,7 +285,7 @@ public class ChunkedWriteHandler implements ChannelUpstreamHandler, ChannelDowns
|
|||||||
|
|
||||||
if (!channel.isConnected()) {
|
if (!channel.isConnected()) {
|
||||||
discard(ctx, fireNow);
|
discard(ctx, fireNow);
|
||||||
break;
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} finally {
|
} finally {
|
||||||
@ -294,7 +295,7 @@ public class ChunkedWriteHandler implements ChannelUpstreamHandler, ChannelDowns
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if (acquired && !channel.isConnected() || (channel.isWritable() && !queue.isEmpty())) {
|
if (acquired && (!channel.isConnected() || (channel.isWritable() && !queue.isEmpty()))) {
|
||||||
flush(ctx, fireNow);
|
flush(ctx, fireNow);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user