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 Object
implements BufferedResponseHandler.BufferedInterceptor

Field Summary

Fields

Modifier and Type	Field	Description
private ByteBuffer	_aggregate
private Boolean	_aggregating
private final Queue<ByteBuffer>	_buffers
private final HttpChannel	_channel
private final 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(ByteBuffer content, boolean last, Callback callback)	Write content.

Methods inherited from class Object

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

Field Details

_next

private final HttpOutput.Interceptor _next

_channel

private final HttpChannel _channel

_buffers

private final Queue<ByteBuffer> _buffers

_aggregating

private Boolean _aggregating

_aggregate

private ByteBuffer _aggregate

Constructor Details

ArrayBufferedInterceptor

public ArrayBufferedInterceptor(HttpChannel httpChannel,
 HttpOutput.Interceptor interceptor)

Method Details

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(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)