Java 类org.apache.http.TruncatedChunkException 实例源码

/**
 * Read some bytes from the stream.
 * @param b The byte array that will hold the contents from the stream.
 * @param off The offset into the byte array at which bytes will start to be
 * placed.
 * @param len the maximum number of bytes that can be returned.
 * @return The number of bytes returned or -1 if the end of stream has been
 * reached.
 * @throws IOException in case of an I/O error
 */
@Override
public int read (byte[] b, int off, int len) throws IOException {

    if (closed) {
        throw new IOException("Attempted read from closed stream.");
    }

    if (eof) {
        return -1;
    }
    if (state != CHUNK_DATA) {
        nextChunk();
        if (eof) {
            return -1;
        }
    }
    len = Math.min(len, chunkSize - pos);
    int bytesRead = in.read(b, off, len);
    if (bytesRead != -1) {
        pos += bytesRead;
        if (pos >= chunkSize) {
            state = CHUNK_CRLF;
        }
        return bytesRead;
    } else {
        eof = true;
        throw new TruncatedChunkException("Truncated chunk "
                + "( expected size: " + chunkSize
                + "; actual size: " + pos + ")");
    }
}

/**
 * Read some bytes from the stream.
 * @param b The byte array that will hold the contents from the stream.
 * @param off The offset into the byte array at which bytes will start to be
 * placed.
 * @param len the maximum number of bytes that can be returned.
 * @return The number of bytes returned or -1 if the end of stream has been
 * reached.
 * @throws IOException in case of an I/O error
 */
@Override
public int read (final byte[] b, final int off, final int len) throws IOException {

    if (closed) {
        throw new IOException("Attempted read from closed stream.");
    }

    if (eof) {
        return -1;
    }
    if (state != CHUNK_DATA) {
        nextChunk();
        if (eof) {
            return -1;
        }
    }
    final int bytesRead = in.read(b, off, Math.min(len, chunkSize - pos));
    if (bytesRead != -1) {
        pos += bytesRead;
        if (pos >= chunkSize) {
            state = CHUNK_CRLF;
        }
        return bytesRead;
    } else {
        eof = true;
        throw new TruncatedChunkException("Truncated chunk "
                + "( expected size: " + chunkSize
                + "; actual size: " + pos + ")");
    }
}

@Test
@SuppressWarnings("unchecked")
public void testTruncatedChunkException() throws Exception {
    InputSupplier<InputStream> input = ByteStreams.join(
            ByteStreams.newInputStreamSupplier("[5,6".getBytes(Charsets.UTF_8)),
            exceptionStreamSupplier(new TruncatedChunkException("Truncated chunk ( expected size: 3996; actual size: 1760)")));
    assertThrowsEOFException(input.getInput(), Integer.class);
}

/**
 * Read some bytes from the stream.
 * @param b The byte array that will hold the contents from the stream.
 * @param off The offset into the byte array at which bytes will start to be
 * placed.
 * @param len the maximum number of bytes that can be returned.
 * @return The number of bytes returned or -1 if the end of stream has been
 * reached.
 * @throws IOException in case of an I/O error
 */
@Override
public int read (final byte[] b, final int off, final int len) throws IOException {

    if (closed) {
        throw new IOException("Attempted read from closed stream.");
    }

    if (eof) {
        return -1;
    }
    if (state != CHUNK_DATA) {
        nextChunk();
        if (eof) {
            return -1;
        }
    }
    final int bytesRead = in.read(b, off, Math.min(len, chunkSize - pos));
    if (bytesRead != -1) {
        pos += bytesRead;
        if (pos >= chunkSize) {
            state = CHUNK_CRLF;
        }
        return bytesRead;
    } else {
        eof = true;
        throw new TruncatedChunkException("Truncated chunk "
                + "( expected size: " + chunkSize
                + "; actual size: " + pos + ")");
    }
}

/**
 * Read some bytes from the stream.
 * @param b The byte array that will hold the contents from the stream.
 * @param off The offset into the byte array at which bytes will start to be
 * placed.
 * @param len the maximum number of bytes that can be returned.
 * @return The number of bytes returned or -1 if the end of stream has been
 * reached.
 * @throws IOException in case of an I/O error
 */
@Override
public int read(final byte[] b, final int off, final int len) throws IOException {

    if (closed) {
        throw new IOException("Attempted read from closed stream.");
    }

    if (eof) {
        return -1;
    }
    if (state != CHUNK_DATA) {
        nextChunk();
        if (eof) {
            return -1;
        }
    }
    final int bytesRead = in.read(b, off, (int) Math.min(len, chunkSize - pos));
    if (bytesRead != -1) {
        pos += bytesRead;
        if (pos >= chunkSize) {
            state = CHUNK_CRLF;
        }
        return bytesRead;
    } else {
        eof = true;
        throw new TruncatedChunkException("Truncated chunk "
                + "( expected size: " + chunkSize
                + "; actual size: " + pos + ")");
    }
}

/**
 * Read some bytes from the stream.
 * @param b The byte array that will hold the contents from the stream.
 * @param off The offset into the byte array at which bytes will start to be
 * placed.
 * @param len the maximum number of bytes that can be returned.
 * @return The number of bytes returned or -1 if the end of stream has been
 * reached.
 * @throws IOException in case of an I/O error
 */
@Override
public int read (final byte[] b, final int off, final int len) throws IOException {

    if (closed) {
        throw new IOException("Attempted read from closed stream.");
    }

    if (eof) {
        return -1;
    }
    if (state != CHUNK_DATA) {
        nextChunk();
        if (eof) {
            return -1;
        }
    }
    final int bytesRead = in.read(b, off, Math.min(len, chunkSize - pos));
    if (bytesRead != -1) {
        pos += bytesRead;
        if (pos >= chunkSize) {
            state = CHUNK_CRLF;
        }
        return bytesRead;
    } else {
        eof = true;
        throw new TruncatedChunkException("Truncated chunk "
                + "( expected size: " + chunkSize
                + "; actual size: " + pos + ")");
    }
}