Fix misleading comment
This commit is contained in:
parent
d8880efe61
commit
b0742950b9
@ -319,7 +319,7 @@ public abstract class FrameDecoder extends SimpleChannelUpstreamHandler implemen
|
|||||||
ChannelBuffer cumulation = this.cumulation;
|
ChannelBuffer cumulation = this.cumulation;
|
||||||
assert cumulation.readable();
|
assert cumulation.readable();
|
||||||
if (cumulation instanceof CompositeChannelBuffer) {
|
if (cumulation instanceof CompositeChannelBuffer) {
|
||||||
// Make sure the resulting cumulation buffer has no more than 4 components.
|
// Make sure the resulting cumulation buffer has no more than the configured components.
|
||||||
CompositeChannelBuffer composite = (CompositeChannelBuffer) cumulation;
|
CompositeChannelBuffer composite = (CompositeChannelBuffer) cumulation;
|
||||||
if (composite.numComponents() >= maxCumulationBufferComponents) {
|
if (composite.numComponents() >= maxCumulationBufferComponents) {
|
||||||
cumulation = composite.copy();
|
cumulation = composite.copy();
|
||||||
|
@ -201,7 +201,7 @@ public class HttpChunkAggregator extends SimpleChannelUpstreamHandler implements
|
|||||||
protected void appendToCumulation(ChannelBuffer input) {
|
protected void appendToCumulation(ChannelBuffer input) {
|
||||||
ChannelBuffer cumulation = this.currentMessage.getContent();
|
ChannelBuffer cumulation = this.currentMessage.getContent();
|
||||||
if (cumulation instanceof CompositeChannelBuffer) {
|
if (cumulation instanceof CompositeChannelBuffer) {
|
||||||
// Make sure the resulting cumulation buffer has no more than 4 components.
|
// Make sure the resulting cumulation buffer has no more than the configured components.
|
||||||
CompositeChannelBuffer composite = (CompositeChannelBuffer) cumulation;
|
CompositeChannelBuffer composite = (CompositeChannelBuffer) cumulation;
|
||||||
if (composite.numComponents() >= maxCumulationBufferComponents) {
|
if (composite.numComponents() >= maxCumulationBufferComponents) {
|
||||||
currentMessage.setContent(ChannelBuffers.wrappedBuffer(composite.copy(), input));
|
currentMessage.setContent(ChannelBuffers.wrappedBuffer(composite.copy(), input));
|
||||||
|
Loading…
x
Reference in New Issue
Block a user