Package org.eclipse.jetty.server.handler

Class BufferedResponseHandler.BufferedInterceptor

java.lang.Object

org.eclipse.jetty.server.handler.BufferedResponseHandler.BufferedInterceptor

All Implemented Interfaces:

HttpOutput.Interceptor

Enclosing class:

BufferedResponseHandler

private class BufferedResponseHandler.BufferedInterceptor
extends Object
implements HttpOutput.Interceptor

Field Summary

Fields

Modifier and Type	Field	Description
(package private) ByteBuffer	_aggregate
(package private) Boolean	_aggregating
(package private) final Queue<ByteBuffer>	_buffers
(package private) final HttpChannel	_channel
(package private) final HttpOutput.Interceptor	_next

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected void	commit(Queue<ByteBuffer> buffers, 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 java.lang.Object

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

Field Details

_next

final HttpOutput.Interceptor _next

_channel

final HttpChannel _channel

_buffers

final Queue<ByteBuffer> _buffers

_aggregating

Boolean _aggregating

_aggregate

ByteBuffer _aggregate

Constructor Details

BufferedInterceptor

public BufferedInterceptor(HttpChannel httpChannel,
 HttpOutput.Interceptor interceptor)

Method Details

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

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.

commit

protected void commit(Queue<ByteBuffer> buffers,
 Callback callback)