Mailing-List: contact dev-help@hc.apache.org; run by ezmlm
Precedence: bulk
Reply-To: "HttpComponents Project" <dev@hc.apache.org>
Received-SPF: neutral (athena.apache.org: local policy)
Subject: Re: [HttpCore] HttpCore 4.1-beta1 release preview
From: James Leigh <james-nospam@leighnet.ca>
To: HttpComponents Project <dev@hc.apache.org>
In-Reply-To: <4BA620F3.6070104@apache.org>
References: <4BA620F3.6070104@apache.org>
Content-Type: text/plain; charset="UTF-8"
Date: Mon, 22 Mar 2010 17:50:39 -0400
Message-ID: <1269294639.2369.37.camel@isaac>
Mime-Version: 1.0
Content-Transfer-Encoding: 7bit

On Sun, 2010-03-21 at 14:36 +0100, Oleg Kalnichevski wrote:
> Folks
> 
> Please DO try to find a few minutes to review the release notes and 
> release packages for the coming HttpCore 4.1-beta1
> 
> Release notes:
> http://people.apache.org/~olegk/httpcore-4.1-beta1-preview/RELEASE_NOTES.txt
> 
> Release packages:
> http://people.apache.org/~olegk/httpcore-4.1-beta1-preview/
> 
> If I hear no complaints I will proceed with building the official 
> release packages in a few days.
> 
> Oleg
> 

Oleg, can you check on LengthDelimitedDecoder logic for Content-Length:
0? Looking at the code below (from the preview release) I don't think it
will ever change the status to complete.

On the line 95 dst.limit(newLimit), the limit is set to zero, so the
next read operation returns zero. This causes a perpetual read of zero
bytes and never completes. Perhaps it should have another condition to
complete immediately if the content length is zero?

Normally, I would create a bug for this, but because of the timing I
wanted to bring this up for discussion right away.

--
Thanks,
James

public class LengthDelimitedDecoder extends AbstractContentDecoder 
        implements FileContentDecoder {
    
    private final long contentLength;
    
    private long len;

    public LengthDelimitedDecoder(
            final ReadableByteChannel channel, 
            final SessionInputBuffer buffer,
            final HttpTransportMetricsImpl metrics,
            long contentLength) {
        super(channel, buffer, metrics);
        if (contentLength < 0) {
            throw new IllegalArgumentException("Content length may not be negative");
        }
        this.contentLength = contentLength;
    }

    public int read(final ByteBuffer dst) throws IOException {
        if (dst == null) {
            throw new IllegalArgumentException("Byte buffer may not be null");
        }
        if (this.completed) {
            return -1;
        }
        int lenRemaining = (int) (this.contentLength - this.len);
        
        int bytesRead;
        if (this.buffer.hasData()) {
            int maxLen = Math.min(lenRemaining, this.buffer.length());
            bytesRead = this.buffer.read(dst, maxLen);
        } else {
            if (dst.remaining() > lenRemaining) {
                int oldLimit = dst.limit();
                int newLimit = oldLimit - (dst.remaining() - lenRemaining);
                dst.limit(newLimit);
                bytesRead = this.channel.read(dst);
                dst.limit(oldLimit);
            } else {
                bytesRead = this.channel.read(dst);
            }
            if (bytesRead > 0) {
                this.metrics.incrementBytesTransferred(bytesRead);
            }
        }
        if (bytesRead == -1) {
            this.completed = true;
            return -1;
        }
        this.len += bytesRead;
        if (this.len >= this.contentLength) {
            this.completed = true;
        }
        return bytesRead;
    }


---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@hc.apache.org
For additional commands, e-mail: dev-help@hc.apache.org