org.eclipse.jetty.server

Class HttpInputOverHTTP

java.lang.Object

java.io.InputStream

javax.servlet.ServletInputStream

org.eclipse.jetty.server.HttpInput<ByteBuffer>

org.eclipse.jetty.server.HttpInputOverHTTP

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable, Callback

public class HttpInputOverHTTP
extends HttpInput<ByteBuffer>
implements Callback

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.server.HttpInput

HttpInput.State

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.Callback

Callback.Adapter

Field Summary

Fields inherited from class org.eclipse.jetty.server.HttpInput

ASYNC, EARLY_EOF, EOF, STREAM

Constructor Summary

Constructors

Constructor and Description
HttpInputOverHTTP(HttpConnection httpConnection)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	blockForContent() Blocks until some content or some end-of-file event arrives.
protected void	consume(ByteBuffer item, int length) Consumes the given content.
void	content(ByteBuffer item) Adds some content to this input stream.
void	failed(Throwable x) Callback invoked when the operation fails.
protected int	get(ByteBuffer item, byte[] buffer, int offset, int length) Copies the given content into the given byte buffer.
protected ByteBuffer	nextContent() Access the next content to be consumed from.
void	recycle()
protected int	remaining(ByteBuffer item)
void	succeeded() Callback invoked when the operation completes.
String	toString()
protected void	unready()

Methods inherited from class org.eclipse.jetty.server.HttpInput

available, consumeAll, earlyEOF, getContentRead, getNextContent, init, isAsync, isEarlyEOF, isEOF, isFinished, isReady, lock, messageComplete, onAsyncRead, read, read, run, setReadListener

Methods inherited from class javax.servlet.ServletInputStream

readLine

Methods inherited from class java.io.InputStream

close, mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpInputOverHTTP

public HttpInputOverHTTP(HttpConnection httpConnection)

Parameters:

httpConnection -

Method Detail

recycle

public void recycle()

Overrides:

recycle in class HttpInput<ByteBuffer>

blockForContent

protected void blockForContent()
                        throws IOException

Description copied from class: HttpInput

Blocks until some content or some end-of-file event arrives.

Specified by:

blockForContent in class HttpInput<ByteBuffer>

Throws:

IOException - if the wait is interrupted

toString

public String toString()

Overrides:

toString in class Object

nextContent

protected ByteBuffer nextContent()
                          throws IOException

Description copied from class: HttpInput

Access the next content to be consumed from. Returning the next item does not consume it and it may be returned multiple times until it is consumed.

Calls to HttpInput.get(Object, byte[], int, int) or HttpInput.consume(Object, int) are required to consume data from the content.

Specified by:

nextContent in class HttpInput<ByteBuffer>

Returns:

the content or null if none available.

Throws:

IOException - if retrieving the content fails

remaining

protected int remaining(ByteBuffer item)

Specified by:

remaining in class HttpInput<ByteBuffer>

Parameters:

item - the content

Returns:

how many bytes remain in the given content

get

protected int get(ByteBuffer item,
      byte[] buffer,
      int offset,
      int length)

Description copied from class: HttpInput

Copies the given content into the given byte buffer.

Specified by:

get in class HttpInput<ByteBuffer>

Parameters:

item - the content to copy from

buffer - the buffer to copy into

offset - the buffer offset to start copying from

length - the space available in the buffer

Returns:

the number of bytes actually copied

consume

protected void consume(ByteBuffer item,
           int length)

Description copied from class: HttpInput

Consumes the given content.

Specified by:

consume in class HttpInput<ByteBuffer>

Parameters:

item - the content to consume

length - the number of bytes to consume

content

public void content(ByteBuffer item)

Description copied from class: HttpInput

Adds some content to this input stream.

Specified by:

content in class HttpInput<ByteBuffer>

Parameters:

item - the content to add

unready

protected void unready()

Overrides:

unready in class HttpInput<ByteBuffer>

succeeded

public void succeeded()

Description copied from interface: Callback

Callback invoked when the operation completes.

Specified by:

succeeded in interface Callback

See Also:

Callback.failed(Throwable)

failed

public void failed(Throwable x)

Description copied from interface: Callback

Callback invoked when the operation fails.

Specified by:

failed in interface Callback

Overrides:

failed in class HttpInput<ByteBuffer>

Parameters:

x - the reason for the operation failure