Package org.eclipse.jetty.server.handler

Class BufferedResponseHandler.ArrayBufferedInterceptor

java.lang.Object

org.eclipse.jetty.server.handler.BufferedResponseHandler.ArrayBufferedInterceptor

All Implemented Interfaces:

BufferedResponseHandler.BufferedInterceptor, HttpOutput.Interceptor

Enclosing class:

BufferedResponseHandler

class BufferedResponseHandler.ArrayBufferedInterceptor
extends java.lang.Object
implements BufferedResponseHandler.BufferedInterceptor

Field Summary

Fields

Modifier and Type	Field	Description
private java.nio.ByteBuffer	_aggregate
private java.lang.Boolean	_aggregating
private java.util.Queue<java.nio.ByteBuffer>	_buffers
private HttpChannel	_channel
private HttpOutput.Interceptor	_next

Constructor Summary

Constructors

Constructor	Description
ArrayBufferedInterceptor(HttpChannel httpChannel, HttpOutput.Interceptor interceptor)

Method Summary

Modifier and Type	Method	Description
private void	commit(Callback callback)
HttpOutput.Interceptor	getNextInterceptor()
boolean	isOptimizedForDirectBuffers()
void	resetBuffer()	Reset the buffers.
void	write(java.nio.ByteBuffer content, boolean last, Callback callback)	Write content.

Methods inherited from class java.lang.Object

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

Field Detail

_next

private final HttpOutput.Interceptor _next

_channel

private final HttpChannel _channel

_buffers

private final java.util.Queue<java.nio.ByteBuffer> _buffers

_aggregating

private java.lang.Boolean _aggregating

_aggregate

private java.nio.ByteBuffer _aggregate

Constructor Detail

ArrayBufferedInterceptor

public ArrayBufferedInterceptor(HttpChannel httpChannel,
                                HttpOutput.Interceptor interceptor)

Method Detail

getNextInterceptor

public HttpOutput.Interceptor getNextInterceptor()

Specified by:

getNextInterceptor in interface HttpOutput.Interceptor

Returns:

The next Interceptor in the chain or null if this is the last Interceptor in the chain.

isOptimizedForDirectBuffers

public boolean isOptimizedForDirectBuffers()

Specified by:

isOptimizedForDirectBuffers in interface HttpOutput.Interceptor

Returns:

True if the Interceptor is optimized to receive direct ByteBuffers in the HttpOutput.Interceptor.write(ByteBuffer, boolean, Callback) method. If false is returned, then passing direct buffers may cause inefficiencies.

resetBuffer

public void resetBuffer()

Description copied from interface: HttpOutput.Interceptor

Reset the buffers.

If the Interceptor contains buffers then reset them.

Specified by:

resetBuffer in interface HttpOutput.Interceptor

write

public void write(java.nio.ByteBuffer content,
                  boolean last,
                  Callback callback)

Description copied from interface: HttpOutput.Interceptor

Write content. The response is committed by the first call to write and is closed by a call with last == true. Empty content buffers may be passed to force a commit or close.

Specified by:

write in interface HttpOutput.Interceptor

Parameters:

content - The content to be written or an empty buffer.

last - True if this is the last call to write

callback - The callback to use to indicate Callback.succeeded() or Callback.failed(Throwable).

commit

private void commit(Callback callback)