Class CompressExtension

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.websocket.common.extensions.AbstractExtension

org.eclipse.jetty.websocket.common.extensions.compress.CompressExtension

All Implemented Interfaces:

org.eclipse.jetty.util.component.LifeCycle, Extension, IncomingFrames, OutgoingFrames

Direct Known Subclasses:

DeflateFrameExtension, PerMessageDeflateExtension

public abstract class CompressExtension
extends AbstractExtension

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.AbstractLifeCycle.AbstractLifeCycleListener

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

org.eclipse.jetty.util.component.LifeCycle.Listener

Field Summary

Fields

Modifier and Type	Field	Description
protected AtomicInteger	decompressCount
protected static final int	INFLATE_BUFFER_SIZE	Inflater / Decompressed Buffer Size
protected static final int	INPUT_MAX_BUFFER_SIZE	Deflater / Inflater: Maximum Input Buffer Size
protected static final int	RSV_USE_ALWAYS	Always set RSV flag, on all frame types
protected static final int	RSV_USE_ONLY_FIRST	Only set RSV flag on first frame in multi-frame messages.
protected static final byte[]	TAIL_BYTES
protected static final ByteBuffer	TAIL_BYTES_BUF
protected static final int	TAIL_DROP_ALWAYS	Always drop tail bytes 0000FFFF, from all frame types
protected static final int	TAIL_DROP_FIN_ONLY	Only drop tail bytes 0000FFFF, from fin==true frames
protected static final int	TAIL_DROP_NEVER	Never drop tail bytes 0000FFFF, from any frame type

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CompressExtension()

Method Summary

Modifier and Type	Method	Description
protected void	decompress(ByteAccumulator accumulator, ByteBuffer buf)
protected void	doStop()
static boolean	endsWithTail(ByteBuffer buf)
protected void	forwardIncoming(Frame frame, ByteAccumulator accumulator)
Deflater	getDeflater()
Inflater	getInflater()
boolean	isRsv1User()	Indicates use of RSV1 flag for indicating deflation is in use.
protected ByteAccumulator	newByteAccumulator()
protected void	notifyCallbackFailure(WriteCallback callback, Throwable failure)
protected void	notifyCallbackSuccess(WriteCallback callback)
void	outgoingFrame(Frame frame, WriteCallback callback, BatchMode batchMode)	A frame, and optional callback, intended for the network layer.
void	setDeflaterPool(org.eclipse.jetty.util.compression.DeflaterPool deflaterPool)
void	setInflaterPool(org.eclipse.jetty.util.compression.InflaterPool inflaterPool)
String	toString()

Methods inherited from class AbstractExtension

getBufferPool, getConfig, getConnection, getName, getNextIncoming, getNextOutgoing, getPolicy, init, init, isRsv2User, isRsv3User, nextIncomingFrame, nextOutgoingFrame, setBufferPool, setConfig, setConnection, setNextIncomingFrames, setNextOutgoingFrames, setPolicy

Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

addLifeCycleListener, doStart, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, setStopTimeout, start, stop

Methods inherited from class Object

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

Methods inherited from interface IncomingFrames

incomingFrame

Field Details

TAIL_BYTES

protected static final byte[] TAIL_BYTES

TAIL_BYTES_BUF

protected static final ByteBuffer TAIL_BYTES_BUF

TAIL_DROP_NEVER

protected static final int TAIL_DROP_NEVER

Never drop tail bytes 0000FFFF, from any frame type

See Also:

• Constant Field Values

TAIL_DROP_ALWAYS

protected static final int TAIL_DROP_ALWAYS

Always drop tail bytes 0000FFFF, from all frame types

See Also:

• Constant Field Values

TAIL_DROP_FIN_ONLY

protected static final int TAIL_DROP_FIN_ONLY

Only drop tail bytes 0000FFFF, from fin==true frames

See Also:

• Constant Field Values

RSV_USE_ALWAYS

protected static final int RSV_USE_ALWAYS

Always set RSV flag, on all frame types

See Also:

• Constant Field Values

RSV_USE_ONLY_FIRST

protected static final int RSV_USE_ONLY_FIRST

Only set RSV flag on first frame in multi-frame messages.

Note: this automatically means no-continuation frames have the RSV bit set

See Also:

• Constant Field Values

INFLATE_BUFFER_SIZE

protected static final int INFLATE_BUFFER_SIZE

Inflater / Decompressed Buffer Size

See Also:

• Constant Field Values

INPUT_MAX_BUFFER_SIZE

protected static final int INPUT_MAX_BUFFER_SIZE

Deflater / Inflater: Maximum Input Buffer Size

See Also:

• Constant Field Values

decompressCount

protected AtomicInteger decompressCount

Constructor Details

CompressExtension

protected CompressExtension()

Method Details

setInflaterPool

public void setInflaterPool(org.eclipse.jetty.util.compression.InflaterPool inflaterPool)

setDeflaterPool

public void setDeflaterPool(org.eclipse.jetty.util.compression.DeflaterPool deflaterPool)

getDeflater

public Deflater getDeflater()

getInflater

public Inflater getInflater()

isRsv1User

public boolean isRsv1User()

Indicates use of RSV1 flag for indicating deflation is in use.

Specified by:

isRsv1User in interface Extension

Overrides:

isRsv1User in class AbstractExtension

Returns:

true if extension uses RSV1 for its own purposes.

forwardIncoming

protected void forwardIncoming(Frame frame,
 ByteAccumulator accumulator)

newByteAccumulator

protected ByteAccumulator newByteAccumulator()

decompress

protected void decompress(ByteAccumulator accumulator,
 ByteBuffer buf)
                   throws DataFormatException

Throws:

DataFormatException

outgoingFrame

public void outgoingFrame(Frame frame,
 WriteCallback callback,
 BatchMode batchMode)

Description copied from interface: OutgoingFrames

A frame, and optional callback, intended for the network layer.

Note: the frame can undergo many transformations in the various layers and extensions present in the implementation.

If you are implementing a mutation, you are obliged to handle the incoming WriteCallback appropriately.

Parameters:

frame - the frame to eventually write to the network layer.

callback - the callback to notify when the frame is written.

batchMode - the batch mode requested by the sender.

notifyCallbackSuccess

protected void notifyCallbackSuccess(WriteCallback callback)

notifyCallbackFailure

protected void notifyCallbackFailure(WriteCallback callback,
 Throwable failure)

endsWithTail

public static boolean endsWithTail(ByteBuffer buf)

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class org.eclipse.jetty.util.component.AbstractLifeCycle

Throws:

Exception

toString

public String toString()

Overrides:

toString in class AbstractExtension