Top Fields Constructors Methods
org.glassfish.grizzly.streams

public abstract Class BufferedInput

extends Object
implements Input
Class Inheritance
All Implemented Interfaces
org.glassfish.grizzly.streams.Input
Known Direct Subclasses
org.glassfish.grizzly.streams.TransformerInput, org.glassfish.grizzly.nio.transport.DefaultStreamReader.Input
Imports
java.io.EOFException, .IOException, java.util.concurrent.locks.ReentrantReadWriteLock, org.glassfish.grizzly.Buffer, .CompletionHandler, .GrizzlyFuture, org.glassfish.grizzly.impl.FutureImpl, .ReadyFutureImpl, .SafeFutureImpl, org.glassfish.grizzly.memory.CompositeBuffer, org.glassfish.grizzly.utils.conditions.Condition
Author
Alexey Stashok

Field Summary

Modifier and TypeField and Description
protected CompletionHandler<Integer>
completionHandler

protected final CompositeBuffer
compositeBuffer

protected Condition
condition

protected FutureImpl<Integer>
future

private volatile boolean
isClosed

protected boolean
isCompletionHandlerRegistered

protected final ReentrantReadWriteLock
lock

protected Exception
registrationStackTrace

Constructor Summary

AccessConstructor and Description
public
BufferedInput()

Method Summary

Modifier and TypeMethod and Description
public boolean
append(final Buffer buffer)

public void
close()

Implements org.glassfish.grizzly.streams.Input.close.

public Buffer
getBuffer()

Implements org.glassfish.grizzly.streams.Input.getBuffer.

Return the Input's Buffer.

public final boolean
isBuffered()

Implements org.glassfish.grizzly.streams.Input.isBuffered.

protected void
notifyCompleted(final CompletionHandler<Integer> completionHandler)

public GrizzlyFuture<Integer>
notifyCondition(Condition condition, CompletionHandler<Integer> completionHandler)

Implements org.glassfish.grizzly.streams.Input.notifyCondition.

protected void
notifyFailure(final CompletionHandler<Integer> completionHandler, final Throwable failure)

private void
notifyUpdate()

protected abstract void
onCloseInputSource()

protected abstract void
onOpenInputSource()

public boolean
prepend(final Buffer buffer)

public byte
read()

Implements org.glassfish.grizzly.streams.Input.read.

public int
size()

Implements org.glassfish.grizzly.streams.Input.size.

public void
skip(int length)

Implements org.glassfish.grizzly.streams.Input.skip.

public Buffer
takeBuffer()

Implements org.glassfish.grizzly.streams.Input.takeBuffer.

Takes the Input's Buffer.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

completionHandlerback to summary
protected CompletionHandler<Integer> completionHandler
compositeBufferback to summary
protected final CompositeBuffer compositeBuffer
conditionback to summary
protected Condition condition
futureback to summary
protected FutureImpl<Integer> future
isClosedback to summary
private volatile boolean isClosed
isCompletionHandlerRegisteredback to summary
protected boolean isCompletionHandlerRegistered
lockback to summary
protected final ReentrantReadWriteLock lock
registrationStackTraceback to summary
protected Exception registrationStackTrace

Constructor Detail

BufferedInputback to summary
public BufferedInput()

Method Detail

appendback to summary
public boolean append(final Buffer buffer)
closeback to summary
public void close()

Implements org.glassfish.grizzly.streams.Input.close.

Annotations
@Override
getBufferback to summary
public Buffer getBuffer()

Implements org.glassfish.grizzly.streams.Input.getBuffer.

Doc from org.glassfish.grizzly.streams.Input.getBuffer.

Return the Input's Buffer.

Annotations
@Override
isBufferedback to summary
public final boolean isBuffered()

Implements org.glassfish.grizzly.streams.Input.isBuffered.

Annotations
@Override
notifyCompletedback to summary
protected void notifyCompleted(final CompletionHandler<Integer> completionHandler)
notifyConditionback to summary
public GrizzlyFuture<Integer> notifyCondition(Condition condition, CompletionHandler<Integer> completionHandler)

Implements org.glassfish.grizzly.streams.Input.notifyCondition.

Annotations
@Override
notifyFailureback to summary
protected void notifyFailure(final CompletionHandler<Integer> completionHandler, final Throwable failure)
notifyUpdateback to summary
private void notifyUpdate()
onCloseInputSourceback to summary
protected abstract void onCloseInputSource() throws IOException
onOpenInputSourceback to summary
protected abstract void onOpenInputSource() throws IOException
prependback to summary
public boolean prepend(final Buffer buffer)
readback to summary
public byte read() throws IOException

Implements org.glassfish.grizzly.streams.Input.read.

Annotations
@Override
sizeback to summary
public int size()

Implements org.glassfish.grizzly.streams.Input.size.

Annotations
@Override
skipback to summary
public void skip(int length)

Implements org.glassfish.grizzly.streams.Input.skip.

Annotations
@Override
takeBufferback to summary
public Buffer takeBuffer()

Implements org.glassfish.grizzly.streams.Input.takeBuffer.

Doc from org.glassfish.grizzly.streams.Input.takeBuffer.

Takes the Input's Buffer. This Input should never try to access this Buffer.

Annotations
@Override