| Modifier and Type | Field and Description |
|---|---|
| private volatile CapacityChannel | |
| private final AtomicInteger | |
| private final int |
| Access | Constructor and Description |
|---|---|
| public | |
| public |
| Modifier and Type | Method and Description |
|---|---|
| private void | |
| public int | |
| private void | |
| public void | |
| public int | read()
Implements org. |
| public int | read(final byte[]
the buffer into which the data is read. b, final int the start offset in array off, final int b
at which the data is written.the maximum number of bytes to read. len)Implements org. len bytes of data from this buffer into
an array of bytes.
|
| public void |
| capacityChannel | back to summary |
|---|---|
| private volatile CapacityChannel capacityChannel | |
| capacityIncrement | back to summary |
|---|---|
| private final AtomicInteger capacityIncrement | |
| initialBufferSize | back to summary |
|---|---|
| private final int initialBufferSize | |
| SharedInputBuffer | back to summary |
|---|---|
| public SharedInputBuffer(final ReentrantLock lock, final int initialBufferSize) | |
| SharedInputBuffer | back to summary |
|---|---|
| public SharedInputBuffer(final int bufferSize) | |
| awaitInput | back to summary |
|---|---|
| private void awaitInput() throws InterruptedIOException | |
| fill | back to summary |
|---|---|
| public int fill(final ByteBuffer src) | |
| incrementCapacity | back to summary |
|---|---|
| private void incrementCapacity() throws IOException | |
| markEndStream | back to summary |
|---|---|
| public void markEndStream() | |
| read | back to summary |
|---|---|
| public int read() throws IOException Implements org. Doc from org. 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
| |
| read | back to summary |
|---|---|
| public int read(final byte[] b, final int off, final int len) throws IOException Implements org. Doc from org. Reads up to If
| |
| updateCapacity | back to summary |
|---|---|
| public void updateCapacity(final CapacityChannel capacityChannel) throws IOException | |