Modifier and Type	Class and Description
private static class	DefaultFilterChain.FilterExecution
private static class	DefaultFilterChain.FiltersState
private class	DefaultFilterChain.FiltersStateFactory
private static class	DefaultFilterChain.FilterStateElement

Modifier and Type	Field and Description
private final DefaultFilterChain.FiltersStateFactory	filtersStateFactory
private static final Logger	LOGGER

Access	Constructor and Description
public	DefaultFilterChain()
public	DefaultFilterChain(Collection<Filter> initialFilters)

Method Summary

Modifier and Type	Method and Description
private void	checkStoredMessage(final FilterChainContext `FilterChainContext` ctx, final DefaultFilterChain.FiltersState `FiltersState` associated with the Connection filtersState, final int the current filter index filterIdx) Checks if `Connection` has some stored data related to the processing `Filter`.
public ProcessorResult	execute(FilterChainContext `FilterChainContext` processing context ctx) Implements org.glassfish.grizzly.filterchain.FilterChain.execute. Execute this FilterChain.
protected DefaultFilterChain.FilterExecution	Returns: Todo Update executeChainPart(FilterChainContext `FilterChainContext` processing context ctx, final FilterExecutor `FilterExecutor`, which will call appropriate filter operation to process `IOEvent`. executor, final int start, final int end, final DefaultFilterChain.FiltersState filtersState) Sequentially lets each `Filter` in chain to process `IOEvent`.
protected NextAction	Returns: `NextAction`. executeFilter(final FilterExecutor executor, final Filter currentFilter, final FilterChainContext ctx) Execute the `Filter`, using specific `FilterExecutor` and `FilterChainContext`.
public void	fail(FilterChainContext context, Throwable failure) Implements org.glassfish.grizzly.filterchain.FilterChain.fail.
public void	fireEventDownstream(final Connection<L> connection, final FilterChainEvent event, final CompletionHandler<FilterChainContext> completionHandler) Implements org.glassfish.grizzly.filterchain.FilterChain.fireEventDownstream.
public void	fireEventUpstream(final Connection<L> connection, final FilterChainEvent event, final CompletionHandler<FilterChainContext> completionHandler) Implements org.glassfish.grizzly.filterchain.FilterChain.fireEventUpstream.
public void	flush(final Connection<L> connection, final CompletionHandler<WriteResult<K, L>> completionHandler) Implements org.glassfish.grizzly.filterchain.FilterChain.flush.
private void	notifyComplete(final FilterChainContext context)
private void	notifyFailure(final FilterChainContext context, final Throwable e)
private DefaultFilterChain.FiltersState	obtainFiltersState(final Connection<L> connection)
private static boolean	prepareRemainder(final FilterChainContext ctx, final DefaultFilterChain.FiltersState filtersState) Locates a message remainder in the `FilterChain`, associated with the `Connection` and prepares the `Context` for remainder processing.
public ProcessorResult	process(final Context context) Implements org.glassfish.grizzly.Processor.process. Method will be called by framework to process some event, which occurred on a connection
public void	read(final Connection<L> connection, final CompletionHandler<ReadResult<K, L>> completionHandler) Implements org.glassfish.grizzly.Processor.read.
public ReadResult<K, L>	read(final FilterChainContext context) Implements org.glassfish.grizzly.filterchain.FilterChain.read.
private <M> void	storeMessage(final FilterChainContext ctx, final DefaultFilterChain.FiltersState filtersState, final boolean isIncomplete, final int filterIdx, final M messageToStore, final Appender<M> appender) Stores the Filter associated remainder.
public DefaultFilterChain	subList(int fromIndex, int toIndex) Implements java.util.List.subList. Returns a view of the portion of this list between the specified `fromIndex`, inclusive, and `toIndex`, exclusive.
private void	Returns: position of the last executed `Filter` throwChain(final FilterChainContext `FilterChainContext` ctx, final FilterExecutor executor, final Throwable exception) Notify the filters about error.
public void	write(final Connection<L> connection, final Object dstAddress, final Object message, final CompletionHandler<WriteResult<K, L>> completionHandler) Implements org.glassfish.grizzly.Processor.write.
public void	write(final Connection<L> connection, final Object dstAddress, final Object message, final CompletionHandler<WriteResult<K, L>> completionHandler, final MessageCloner<E> messageCloner) Implements org.glassfish.grizzly.Processor.write.
public void	write(final Connection<L> connection, final Object dstAddress, final Object message, final CompletionHandler<E> completionHandler, final PushBackHandler pushBackHandler) Implements org.glassfish.grizzly.Processor.write. Deprecated

Field Detail

filtersStateFactory	back to summary
private final DefaultFilterChain.FiltersStateFactory filtersStateFactory

LOGGER	back to summary
private static final Logger LOGGER

Constructor Detail

DefaultFilterChain	back to summary
public DefaultFilterChain()

DefaultFilterChain	back to summary
public DefaultFilterChain(Collection<Filter> initialFilters)

Method Detail

checkStoredMessage back to summary

checkStoredMessage	back to summary
private void checkStoredMessage(final FilterChainContext ctx, final DefaultFilterChain.FiltersState filtersState, final int filterIdx) Checks if `Connection` has some stored data related to the processing `Filter`. If yes - appends new context data to the stored one and set the result as context message. Parameters ctx:FilterChainContext `FilterChainContext` filtersState:DefaultFilterChain.FiltersState `FiltersState` associated with the Connection filterIdx:int the current filter index Annotations @SuppressWarnings:unchecked

private void checkStoredMessage(final FilterChainContext ctx, final DefaultFilterChain.FiltersState filtersState, final int filterIdx)

Checks if Connection has some stored data related to the processing Filter. If yes - appends new context data to the stored one and set the result as context message.

Parameters

ctx:FilterChainContext: FilterChainContext
filtersState:DefaultFilterChain.FiltersState: FiltersState associated with the Connection
filterIdx:int: the current filter index

Annotations

@SuppressWarnings:unchecked

execute back to summary

execute	back to summary
public ProcessorResult execute(FilterChainContext ctx) Implements org.glassfish.grizzly.filterchain.FilterChain.execute. Execute this FilterChain. Parameters ctx:FilterChainContext `FilterChainContext` processing context Annotations @Override

public ProcessorResult execute(FilterChainContext ctx)

Implements org.glassfish.grizzly.filterchain.FilterChain.execute.

Execute this FilterChain.

Parameters

ctx:FilterChainContext: FilterChainContext processing context

Annotations

@Override

executeChainPart back to summary

executeChainPart	back to summary
protected DefaultFilterChain.FilterExecution executeChainPart(FilterChainContext ctx, final FilterExecutor executor, final int start, final int end, final DefaultFilterChain.FiltersState filtersState) throws IOException Sequentially lets each `Filter` in chain to process `IOEvent`. Parameters ctx:FilterChainContext `FilterChainContext` processing context executor:FilterExecutor `FilterExecutor`, which will call appropriate filter operation to process `IOEvent`. Returns:DefaultFilterChain.FilterExecution Todo Update Annotations @SuppressWarnings:unchecked

protected DefaultFilterChain.FilterExecution executeChainPart(FilterChainContext ctx, final FilterExecutor executor, final int start, final int end, final DefaultFilterChain.FiltersState filtersState) throws IOException

Sequentially lets each Filter in chain to process IOEvent.

Parameters

ctx:FilterChainContext: FilterChainContext processing context
executor:FilterExecutor: FilterExecutor, which will call appropriate filter operation to process IOEvent.

Returns:DefaultFilterChain.FilterExecution

Todo

Update

Annotations

@SuppressWarnings:unchecked

executeFilter back to summary

executeFilter	back to summary
protected NextAction executeFilter(final FilterExecutor executor, final Filter currentFilter, final FilterChainContext ctx) throws IOException Execute the `Filter`, using specific `FilterExecutor` and `FilterChainContext`. Returns:NextAction `NextAction`.

protected NextAction executeFilter(final FilterExecutor executor, final Filter currentFilter, final FilterChainContext ctx) throws IOException

Execute the Filter, using specific FilterExecutor and FilterChainContext.

Returns:NextAction: NextAction.

fail	back to summary
public void fail(FilterChainContext context, Throwable failure) Implements org.glassfish.grizzly.filterchain.FilterChain.fail. Annotations @Override

fail

back to summary

public void fail(FilterChainContext context, Throwable failure)

Implements org.glassfish.grizzly.filterchain.FilterChain.fail.

Annotations

@Override

fireEventDownstream	back to summary
public void fireEventDownstream(final Connection<L> connection, final FilterChainEvent event, final CompletionHandler<FilterChainContext> completionHandler) Implements org.glassfish.grizzly.filterchain.FilterChain.fireEventDownstream. Annotations @Override

fireEventDownstream

back to summary

public void fireEventDownstream(final Connection<L> connection, final FilterChainEvent event, final CompletionHandler<FilterChainContext> completionHandler)

Implements org.glassfish.grizzly.filterchain.FilterChain.fireEventDownstream.

Annotations

@Override

fireEventUpstream	back to summary
public void fireEventUpstream(final Connection<L> connection, final FilterChainEvent event, final CompletionHandler<FilterChainContext> completionHandler) Implements org.glassfish.grizzly.filterchain.FilterChain.fireEventUpstream. Annotations @Override

fireEventUpstream

back to summary

public void fireEventUpstream(final Connection<L> connection, final FilterChainEvent event, final CompletionHandler<FilterChainContext> completionHandler)

Implements org.glassfish.grizzly.filterchain.FilterChain.fireEventUpstream.

Annotations

@Override

flush	back to summary
public void flush(final Connection<L> connection, final CompletionHandler<WriteResult<K, L>> completionHandler) Implements org.glassfish.grizzly.filterchain.FilterChain.flush. Annotations @Override

flush

back to summary

public void flush(final Connection<L> connection, final CompletionHandler<WriteResult<K, L>> completionHandler)

Implements org.glassfish.grizzly.filterchain.FilterChain.flush.

Annotations

@Override

notifyComplete	back to summary
private void notifyComplete(final FilterChainContext context)

notifyFailure	back to summary
private void notifyFailure(final FilterChainContext context, final Throwable e)

obtainFiltersState	back to summary
private DefaultFilterChain.FiltersState obtainFiltersState(final Connection<L> connection) Annotations @SuppressWarnings:unchecked

prepareRemainder	back to summary
private static boolean prepareRemainder(final FilterChainContext ctx, final DefaultFilterChain.FiltersState filtersState) Locates a message remainder in the `FilterChain`, associated with the `Connection` and prepares the `Context` for remainder processing.

process	back to summary
public ProcessorResult process(final Context context) Implements org.glassfish.grizzly.Processor.process. Doc from org.glassfish.grizzly.Processor.process. Method will be called by framework to process some event, which occurred on a connection Annotations @Override

process

back to summary

public ProcessorResult process(final Context context)

Implements org.glassfish.grizzly.Processor.process.

Doc from org.glassfish.grizzly.Processor.process.

Method will be called by framework to process some event, which occurred on a connection

Annotations

@Override

read	back to summary
public void read(final Connection<L> connection, final CompletionHandler<ReadResult<K, L>> completionHandler) Implements org.glassfish.grizzly.Processor.read. Annotations @Override

read

back to summary

public void read(final Connection<L> connection, final CompletionHandler<ReadResult<K, L>> completionHandler)

Implements org.glassfish.grizzly.Processor.read.

Annotations

@Override

read	back to summary
public ReadResult<K, L> read(final FilterChainContext context) throws IOException Implements org.glassfish.grizzly.filterchain.FilterChain.read. Annotations @Override @SuppressWarnings:unchecked

read

back to summary

public ReadResult<K, L> read(final FilterChainContext context) throws IOException

Implements org.glassfish.grizzly.filterchain.FilterChain.read.

Annotations

@Override
@SuppressWarnings:unchecked

storeMessage	back to summary
private <M> void storeMessage(final FilterChainContext ctx, final DefaultFilterChain.FiltersState filtersState, final boolean isIncomplete, final int filterIdx, final M messageToStore, final Appender<M> appender) Stores the Filter associated remainder. This remainder will be reused next time the same filter will be invoked on this Connection.

subList back to summary

subList	back to summary
public DefaultFilterChain subList(int fromIndex, int toIndex) Implements java.util.List.subList. Doc from java.util.List.subList. Returns a view of the portion of this list between the specified `fromIndex`, inclusive, and `toIndex`, exclusive. (If `fromIndex` and `toIndex` are equal, the returned list is empty.) The returned list is backed by this list, so non-structural changes in the returned list are reflected in this list, and vice-versa. The returned list supports all of the optional list operations supported by this list. This method eliminates the need for explicit range operations (of the sort that commonly exist for arrays). Any operation that expects a list can be used as a range operation by passing a subList view instead of a whole list. For example, the following idiom removes a range of elements from a list: `list.subList(from, to).clear();` Similar idioms may be constructed for `indexOf` and `lastIndexOf`, and all of the algorithms in the `Collections` class can be applied to a subList. The semantics of the list returned by this method become undefined if the backing list (i.e., this list) is structurally modified in any way other than via the returned list. (Structural modifications are those that change the size of this list, or otherwise perturb it in such a fashion that iterations in progress may yield incorrect results.) Annotations @Override

public DefaultFilterChain subList(int fromIndex, int toIndex)

Implements java.util.List.subList.

Doc from java.util.List.subList.

Returns a view of the portion of this list between the specified fromIndex, inclusive, and toIndex, exclusive. (If fromIndex and toIndex are equal, the returned list is empty.) The returned list is backed by this list, so non-structural changes in the returned list are reflected in this list, and vice-versa. The returned list supports all of the optional list operations supported by this list.

This method eliminates the need for explicit range operations (of the sort that commonly exist for arrays). Any operation that expects a list can be used as a range operation by passing a subList view instead of a whole list. For example, the following idiom removes a range of elements from a list:

list.subList(from, to).clear();

Similar idioms may be constructed for indexOf and lastIndexOf, and all of the algorithms in the Collections class can be applied to a subList.

The semantics of the list returned by this method become undefined if the backing list (i.e., this list) is structurally modified in any way other than via the returned list. (Structural modifications are those that change the size of this list, or otherwise perturb it in such a fashion that iterations in progress may yield incorrect results.)

Annotations

@Override

throwChain back to summary

throwChain	back to summary
private void throwChain(final FilterChainContext ctx, final FilterExecutor executor, final Throwable exception) Notify the filters about error. Parameters ctx:FilterChainContext `FilterChainContext` Returns:void position of the last executed `Filter`

private void throwChain(final FilterChainContext ctx, final FilterExecutor executor, final Throwable exception)

Notify the filters about error.

Parameters

ctx:FilterChainContext: FilterChainContext

Returns:void

position of the last executed Filter

write	back to summary
public void write(final Connection<L> connection, final Object dstAddress, final Object message, final CompletionHandler<WriteResult<K, L>> completionHandler) Implements org.glassfish.grizzly.Processor.write. Annotations @Override

write

back to summary

public void write(final Connection<L> connection, final Object dstAddress, final Object message, final CompletionHandler<WriteResult<K, L>> completionHandler)

Implements org.glassfish.grizzly.Processor.write.

Annotations

@Override

write	back to summary
public void write(final Connection<L> connection, final Object dstAddress, final Object message, final CompletionHandler<WriteResult<K, L>> completionHandler, final MessageCloner<E> messageCloner) Implements org.glassfish.grizzly.Processor.write. Annotations @Override

write

back to summary

public void write(final Connection<L> connection, final Object dstAddress, final Object message, final CompletionHandler<WriteResult<K, L>> completionHandler, final MessageCloner<E> messageCloner)

Implements org.glassfish.grizzly.Processor.write.

Annotations

@Override

write	back to summary
public void write(final Connection<L> connection, final Object dstAddress, final Object message, final CompletionHandler<E> completionHandler, final PushBackHandler pushBackHandler) Implements org.glassfish.grizzly.Processor.write. Deprecated Annotations @Override @Deprecated

write

back to summary

public void write(final Connection<L> connection, final Object dstAddress, final Object message, final CompletionHandler<E> completionHandler, final PushBackHandler pushBackHandler)

Implements org.glassfish.grizzly.Processor.write.

Deprecated

Annotations

@Override
@Deprecated

org.glassfish.grizzly.filterchain back to summary

private final Class DefaultFilterChain.FilterExecution

Class Inheritance

extends Object

java.lang.Object
org.glassfish.grizzly.filterchain.DefaultFilterChain.FilterExecution

Field Summary

Modifier and Type	Field and Description
private final FilterChainContext	context
private static final DefaultFilterChain.FilterExecution	CONTINUE
private static final int	CONTINUE_TYPE
private static final int	REEXECUTE_TYPE
private static final DefaultFilterChain.FilterExecution	TERMINATE
private static final int	TERMINATE_TYPE
private final int	type

Constructor Summary

Access	Constructor and Description
public	FilterExecution(final int type, final FilterChainContext context)

Method Summary

Modifier and Type	Method and Description
public static DefaultFilterChain.FilterExecution	createContinue()
public static DefaultFilterChain.FilterExecution	createReExecute(final FilterChainContext context)
public static DefaultFilterChain.FilterExecution	createTerminate()
public FilterChainContext	getContext()
public int	getType()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

context	back to summary
private final FilterChainContext context

CONTINUE	back to summary
private static final DefaultFilterChain.FilterExecution CONTINUE

CONTINUE_TYPE	back to summary
private static final int CONTINUE_TYPE

REEXECUTE_TYPE	back to summary
private static final int REEXECUTE_TYPE

TERMINATE	back to summary
private static final DefaultFilterChain.FilterExecution TERMINATE

TERMINATE_TYPE	back to summary
private static final int TERMINATE_TYPE

type	back to summary
private final int type

Constructor Detail

FilterExecution	back to summary
public FilterExecution(final int type, final FilterChainContext context)

Method Detail

createContinue	back to summary
public static DefaultFilterChain.FilterExecution createContinue()

createReExecute	back to summary
public static DefaultFilterChain.FilterExecution createReExecute(final FilterChainContext context)

createTerminate	back to summary
public static DefaultFilterChain.FilterExecution createTerminate()

getContext	back to summary
public FilterChainContext getContext()

getType	back to summary
public int getType()

org.glassfish.grizzly.filterchain back to summary

private final Class DefaultFilterChain.FiltersState

Class Inheritance

extends Object

java.lang.Object
org.glassfish.grizzly.filterchain.DefaultFilterChain.FiltersState

Field Summary

Modifier and Type	Field and Description
private static final int	OPERATIONS_NUM
private final DefaultFilterChain.FilterStateElement[][]	state

Constructor Summary

Access	Constructor and Description
public	FiltersState(int filtersNum)

Method Summary

Modifier and Type	Method and Description
private Object	append(final FilterChainContext.Operation operation, final int filterIdx, final Object currentMessage)
public DefaultFilterChain.FilterStateElement	get(final FilterChainContext.Operation operation, final int filterIndex)
public int	peekUnparsedIdx(final FilterChainContext.Operation operation, final int start, final int end)
public <M> void	set(final FilterChainContext.Operation operation, final int filterIndex, final boolean isIncomplete, final M messageToStore, final Appender<M> appender)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

OPERATIONS_NUM	back to summary
private static final int OPERATIONS_NUM

state	back to summary
private final DefaultFilterChain.FilterStateElement[][] state

Constructor Detail

FiltersState	back to summary
public FiltersState(int filtersNum)

Method Detail

append	back to summary
private Object append(final FilterChainContext.Operation operation, final int filterIdx, final Object currentMessage)

get	back to summary
public DefaultFilterChain.FilterStateElement get(final FilterChainContext.Operation operation, final int filterIndex)

peekUnparsedIdx	back to summary
public int peekUnparsedIdx(final FilterChainContext.Operation operation, final int start, final int end)

set	back to summary
public <M> void set(final FilterChainContext.Operation operation, final int filterIndex, final boolean isIncomplete, final M messageToStore, final Appender<M> appender)

org.glassfish.grizzly.filterchain back to summary

private final Class DefaultFilterChain.FiltersStateFactory

Class Inheritance

extends Object
implements Supplier<DefaultFilterChain.FiltersState>

java.lang.Object
org.glassfish.grizzly.filterchain.DefaultFilterChain.FiltersStateFactory

All Implemented Interfaces

java.util.function.Supplier

Constructor Summary

Access	Constructor and Description
private	FiltersStateFactory()

Method Summary

Modifier and Type	Method and Description
public DefaultFilterChain.FiltersState	get() Implements java.util.function.Supplier.get. Gets a result.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

FiltersStateFactory	back to summary
private FiltersStateFactory()

Method Detail

get

back to summary

public DefaultFilterChain.FiltersState get()

Implements java.util.function.Supplier.get.

Doc from java.util.function.Supplier.get.

Gets a result.

Annotations

@Override

org.glassfish.grizzly.filterchain back to summary

private final Class DefaultFilterChain.FilterStateElement

Class Inheritance

extends Object

java.lang.Object
org.glassfish.grizzly.filterchain.DefaultFilterChain.FilterStateElement

Field Summary

Modifier and Type	Field and Description
private Appender<E>	appender
private boolean	isIncomplete
private boolean	isValid
private Object	state

Constructor Summary

Access	Constructor and Description
private	FilterStateElement(final boolean isIncomplete, Appendable<T> state)
private <E>	FilterStateElement(final boolean isIncomplete, E state, Appender<E> appender)

Method Summary

Modifier and Type	Method and Description
private Object	append(final Object currentMessage)
pack-priv static DefaultFilterChain.FilterStateElement	create(final boolean isIncomplete, final Object remainder)
pack-priv static DefaultFilterChain.FilterStateElement	create(final boolean isIncomplete, final Appendable<T> state)
pack-priv static <E> DefaultFilterChain.FilterStateElement	create(final boolean isIncomplete, final E state, final Appender<E> appender)
private <E> void	set(final boolean isIncomplete, final E state, final Appender<E> appender)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

appender	back to summary
private Appender<E> appender

isIncomplete	back to summary
private boolean isIncomplete

isValid	back to summary
private boolean isValid

state	back to summary
private Object state

Constructor Detail

FilterStateElement	back to summary
private FilterStateElement(final boolean isIncomplete, Appendable<T> state)

FilterStateElement	back to summary
private <E> FilterStateElement(final boolean isIncomplete, E state, Appender<E> appender)

Method Detail

append	back to summary
private Object append(final Object currentMessage) Annotations @SuppressWarnings:unchecked

create	back to summary
pack-priv static DefaultFilterChain.FilterStateElement create(final boolean isIncomplete, final Object remainder)

create	back to summary
pack-priv static DefaultFilterChain.FilterStateElement create(final boolean isIncomplete, final Appendable<T> state)

create	back to summary
pack-priv static <E> DefaultFilterChain.FilterStateElement create(final boolean isIncomplete, final E state, final Appender<E> appender)

set	back to summary
private <E> void set(final boolean isIncomplete, final E state, final Appender<E> appender)

public final Class DefaultFilterChain

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class DefaultFilterChain.FilterExecution

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class DefaultFilterChain.FiltersState

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class DefaultFilterChain.FiltersStateFactory

Constructor Summary

Method Summary

Constructor Detail

Method Detail

private final Class DefaultFilterChain.FilterStateElement

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail