Package org.eclipse.jetty.server.handler.gzip

Class GzipHttpOutputInterceptor

java.lang.Object

org.eclipse.jetty.server.handler.gzip.GzipHttpOutputInterceptor

All Implemented Interfaces:

HttpOutput.Interceptor

public class GzipHttpOutputInterceptor
extends Object
implements HttpOutput.Interceptor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	GzipHttpOutputInterceptor.GzipBufferCB
private static enum	GzipHttpOutputInterceptor.GZState

Field Summary

Fields

Modifier and Type	Field	Description
private ByteBuffer	_buffer
private final int	_bufferSize
private final HttpChannel	_channel
private final CRC32	_crc
private Deflater	_deflater
private final GzipFactory	_factory
private final HttpOutput.Interceptor	_interceptor
private final AtomicReference<GzipHttpOutputInterceptor.GZState>	_state
private final boolean	_syncFlush
private final HttpField	_vary
private static final byte[]	GZIP_HEADER
static Logger	LOG
static final HttpField	VARY_ACCEPT_ENCODING
static final HttpField	VARY_ACCEPT_ENCODING_USER_AGENT

Constructor Summary

Constructors

Constructor	Description
GzipHttpOutputInterceptor(GzipFactory factory, HttpField vary, int bufferSize, HttpChannel channel, HttpOutput.Interceptor next, boolean syncFlush)
GzipHttpOutputInterceptor(GzipFactory factory, HttpField vary, HttpChannel channel, HttpOutput.Interceptor next, boolean syncFlush)
GzipHttpOutputInterceptor(GzipFactory factory, HttpChannel channel, HttpOutput.Interceptor next, boolean syncFlush)

Method Summary

Modifier and Type	Method	Description
private void	addTrailer()
protected void	commit(ByteBuffer content, boolean complete, Callback callback)
private String	etagGzip(String etag)
HttpOutput.Interceptor	getNextInterceptor()
private void	gzip(ByteBuffer content, boolean complete, Callback callback)
boolean	isOptimizedForDirectBuffers()
boolean	mightCompress()
void	noCompression()
void	noCompressionIfPossible()
void	write(ByteBuffer content, boolean complete, Callback callback)	Write content.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.server.HttpOutput.Interceptor

resetBuffer

Field Details

LOG

public static Logger LOG

GZIP_HEADER

private static final byte[] GZIP_HEADER

VARY_ACCEPT_ENCODING_USER_AGENT

public static final HttpField VARY_ACCEPT_ENCODING_USER_AGENT

VARY_ACCEPT_ENCODING

public static final HttpField VARY_ACCEPT_ENCODING

_state

private final AtomicReference<GzipHttpOutputInterceptor.GZState> _state

_crc

private final CRC32 _crc

_factory

private final GzipFactory _factory

_interceptor

private final HttpOutput.Interceptor _interceptor

_channel

private final HttpChannel _channel

_vary

private final HttpField _vary

_bufferSize

private final int _bufferSize

_syncFlush

private final boolean _syncFlush

_deflater

private Deflater _deflater

_buffer

private ByteBuffer _buffer

Constructor Details

GzipHttpOutputInterceptor

public GzipHttpOutputInterceptor(GzipFactory factory,
 HttpChannel channel,
 HttpOutput.Interceptor next,
 boolean syncFlush)

GzipHttpOutputInterceptor

public GzipHttpOutputInterceptor(GzipFactory factory,
 HttpField vary,
 HttpChannel channel,
 HttpOutput.Interceptor next,
 boolean syncFlush)

GzipHttpOutputInterceptor

public GzipHttpOutputInterceptor(GzipFactory factory,
 HttpField vary,
 int bufferSize,
 HttpChannel channel,
 HttpOutput.Interceptor next,
 boolean syncFlush)

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.

write

public void write(ByteBuffer content,
 boolean complete,
 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.

complete - True if this is the last call to write

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

addTrailer

private void addTrailer()

gzip

private void gzip(ByteBuffer content,
 boolean complete,
 Callback callback)

commit

protected void commit(ByteBuffer content,
 boolean complete,
 Callback callback)

etagGzip

private String etagGzip(String etag)

noCompression

public void noCompression()

noCompressionIfPossible

public void noCompressionIfPossible()

mightCompress

public boolean mightCompress()