Package org.apache.hc.core5.http.nio.support.classic

Class SharedInputBuffer

java.lang.Object

org.apache.hc.core5.http.impl.nio.ExpandableBuffer

org.apache.hc.core5.http.nio.support.classic.AbstractSharedBuffer

org.apache.hc.core5.http.nio.support.classic.SharedInputBuffer

All Implemented Interfaces:

ContentInputBuffer

@Contract(threading=SAFE)
public final class SharedInputBuffer
extends AbstractSharedBuffer
implements ContentInputBuffer

Since:

5.0

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hc.core5.http.impl.nio.ExpandableBuffer

ExpandableBuffer.Mode

Field Summary

Fields

Modifier and Type	Field	Description
private CapacityChannel	capacityChannel
private final AtomicInteger	capacityIncrement
private final int	initialBufferSize

Fields inherited from class org.apache.hc.core5.http.nio.support.classic.AbstractSharedBuffer

aborted, condition, endStream, lock

Constructor Summary

Constructors

Constructor	Description
SharedInputBuffer(int bufferSize)
SharedInputBuffer(ReentrantLock lock, int initialBufferSize)

Method Summary

Modifier and Type	Method	Description
private void	awaitInput()
int	fill(ByteBuffer src)
private void	incrementCapacity()
void	markEndStream()
int	read()	Reads one byte from this buffer.
int	read(byte[] b, int off, int len)	Reads up to len bytes of data from this buffer into an array of bytes.
void	updateCapacity(CapacityChannel capacityChannel)

Methods inherited from class org.apache.hc.core5.http.nio.support.classic.AbstractSharedBuffer

abort, capacity, hasData, isEndStream, length, reset

Methods inherited from class org.apache.hc.core5.http.impl.nio.ExpandableBuffer

buffer, clear, ensureAdjustedCapacity, ensureCapacity, expand, mode, setInputMode, setOutputMode, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.hc.core5.http.nio.support.classic.ContentInputBuffer

length, reset

Field Details

initialBufferSize

private final int initialBufferSize

capacityIncrement

private final AtomicInteger capacityIncrement

capacityChannel

private volatile CapacityChannel capacityChannel

Constructor Details

SharedInputBuffer

public SharedInputBuffer(ReentrantLock lock,
 int initialBufferSize)

SharedInputBuffer

public SharedInputBuffer(int bufferSize)

Method Details

fill

public int fill(ByteBuffer src)

incrementCapacity

private void incrementCapacity()
                        throws IOException

Throws:

IOException

updateCapacity

public void updateCapacity(CapacityChannel capacityChannel)
                    throws IOException

Throws:

IOException

awaitInput

private void awaitInput()
                 throws InterruptedIOException

Throws:

InterruptedIOException

read

public int read()
         throws IOException

Description copied from interface: ContentInputBuffer

Reads one byte from this buffer. If the buffer is empty this method can throw a runtime exception. The exact type of runtime exception thrown by this method depends on implementation. This method returns -1 if the end of content stream has been reached.

Specified by:

read in interface ContentInputBuffer

Returns:

one byte

Throws:

IOException

read

public int read(byte[] b,
 int off,
 int len)
         throws IOException

Description copied from interface: ContentInputBuffer

Reads up to len bytes of data from this buffer into an array of bytes. The exact number of bytes read depends how many bytes are stored in the buffer.

If off is negative, or len is negative, or off+len is greater than the length of the array b, this method can throw a runtime exception. The exact type of runtime exception thrown by this method depends on implementation. This method returns -1 if the end of content stream has been reached.

Specified by:

read in interface ContentInputBuffer

Parameters:

b - the buffer into which the data is read.

off - the start offset in array b at which the data is written.

len - the maximum number of bytes to read.

Returns:

the total number of bytes read into the buffer, or -1 if there is no more data because the end of the stream has been reached.

Throws:

IOException - if an I/O error occurs.

markEndStream

public void markEndStream()