Modifier and Type	Class and Description
private class	IdleTimeoutFilter.ContextCompletionListener
private static class	IdleTimeoutFilter.DefaultWorker
private static class	IdleTimeoutFilter.IdleRecord
private static class	IdleTimeoutFilter.IdleTimeoutResolver
private static class	IdleTimeoutFilter.Resolver
public static interface	IdleTimeoutFilter.TimeoutHandler
public static interface	IdleTimeoutFilter.TimeoutResolver

Modifier and Type	Field and Description
private final FilterChainContext.CompletionListener	contextCompletionListener
public static final Long	FOREVER
public static final Long	FOREVER_SPECIAL
private static final Attribute<IdleTimeoutFilter.IdleRecord>	IDLE_ATTR
public static final String	IDLE_ATTRIBUTE_NAME
private final DelayedExecutor.DelayQueue<Connection<L>>	queue
private final DelayedExecutor.Resolver<Connection<L>>	resolver
private final IdleTimeoutFilter.TimeoutResolver	timeoutResolver

Access	Constructor and Description
public	IdleTimeoutFilter(final DelayedExecutor executor, final long timeout, final TimeUnit timeoutUnit)
public	IdleTimeoutFilter(final DelayedExecutor executor, final IdleTimeoutFilter.TimeoutResolver timeoutResolver)
public	IdleTimeoutFilter(final DelayedExecutor executor, final long timeout, final TimeUnit timeUnit, final IdleTimeoutFilter.TimeoutHandler handler)
public	IdleTimeoutFilter(final DelayedExecutor executor, final IdleTimeoutFilter.TimeoutResolver timeoutResolver, final IdleTimeoutFilter.TimeoutHandler handler)
protected	IdleTimeoutFilter(final DelayedExecutor executor, final DelayedExecutor.Worker<Connection<L>> worker, final IdleTimeoutFilter.TimeoutResolver timeoutResolver)

Method Summary

Modifier and Type	Method and Description
private static long	convertToMillis(final long time, final TimeUnit timeUnit)
public static DelayedExecutor	createDefaultIdleDelayedExecutor()
public static DelayedExecutor	createDefaultIdleDelayedExecutor(final long checkInterval, final TimeUnit checkIntervalUnit)
public DelayedExecutor.Resolver<Connection<L>>	getResolver()
public NextAction	handleAccept(final FilterChainContext ctx) Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleAccept. Implements org.glassfish.grizzly.filterchain.Filter.handleAccept. Execute a unit of processing work to be performed, when server channel has accepted the client connection.
public NextAction	handleClose(final FilterChainContext ctx) Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleClose. Implements org.glassfish.grizzly.filterchain.Filter.handleClose. Execute a unit of processing work to be performed, when connection has been closed.
public NextAction	handleConnect(final FilterChainContext ctx) Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleConnect. Implements org.glassfish.grizzly.filterchain.Filter.handleConnect. Execute a unit of processing work to be performed, when channel gets connected.
public NextAction	handleRead(final FilterChainContext ctx) Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleRead. Implements org.glassfish.grizzly.filterchain.Filter.handleRead. Execute a unit of processing work to be performed, when channel will become available for reading.
public NextAction	handleWrite(final FilterChainContext ctx) Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleWrite. Implements org.glassfish.grizzly.filterchain.Filter.handleWrite. Execute a unit of processing work to be performed, when some data should be written on channel.
protected void	queueAction(final FilterChainContext ctx)
public static void	setCustomTimeout(final Connection<L> The `Connection` which is having the idle detection adjusted. connection, final long the new idle timeout. timeout, final TimeUnit `TimeUnit`. timeunit) Provides an override mechanism for the default timeout.

Inherited from org.glassfish.grizzly.filterchain.BaseFilter:: createContext exceptionOccurred handleEvent onAdded onFilterChainChanged onRemoved toString

Field Detail

contextCompletionListener	back to summary
private final FilterChainContext.CompletionListener contextCompletionListener

FOREVER	back to summary
public static final Long FOREVER

FOREVER_SPECIAL	back to summary
public static final Long FOREVER_SPECIAL

IDLE_ATTR	back to summary
private static final Attribute<IdleTimeoutFilter.IdleRecord> IDLE_ATTR

IDLE_ATTRIBUTE_NAME	back to summary
public static final String IDLE_ATTRIBUTE_NAME

queue	back to summary
private final DelayedExecutor.DelayQueue<Connection<L>> queue

resolver	back to summary
private final DelayedExecutor.Resolver<Connection<L>> resolver

timeoutResolver	back to summary
private final IdleTimeoutFilter.TimeoutResolver timeoutResolver

Constructor Detail

IdleTimeoutFilter	back to summary
public IdleTimeoutFilter(final DelayedExecutor executor, final long timeout, final TimeUnit timeoutUnit)

IdleTimeoutFilter	back to summary
public IdleTimeoutFilter(final DelayedExecutor executor, final IdleTimeoutFilter.TimeoutResolver timeoutResolver) Annotations @SuppressWarnings:UnusedDeclaration

IdleTimeoutFilter	back to summary
public IdleTimeoutFilter(final DelayedExecutor executor, final long timeout, final TimeUnit timeUnit, final IdleTimeoutFilter.TimeoutHandler handler)

IdleTimeoutFilter	back to summary
public IdleTimeoutFilter(final DelayedExecutor executor, final IdleTimeoutFilter.TimeoutResolver timeoutResolver, final IdleTimeoutFilter.TimeoutHandler handler)

IdleTimeoutFilter	back to summary
protected IdleTimeoutFilter(final DelayedExecutor executor, final DelayedExecutor.Worker<Connection<L>> worker, final IdleTimeoutFilter.TimeoutResolver timeoutResolver)

Method Detail

convertToMillis	back to summary
private static long convertToMillis(final long time, final TimeUnit timeUnit)

createDefaultIdleDelayedExecutor	back to summary
public static DelayedExecutor createDefaultIdleDelayedExecutor() Annotations @SuppressWarnings:UnusedDeclaration

createDefaultIdleDelayedExecutor	back to summary
public static DelayedExecutor createDefaultIdleDelayedExecutor(final long checkInterval, final TimeUnit checkIntervalUnit) Annotations @SuppressWarnings:UnusedDeclaration

getResolver	back to summary
public DelayedExecutor.Resolver<Connection<L>> getResolver() Annotations @SuppressWarnings:UnusedDeclaration

handleAccept back to summary

handleAccept	back to summary
public NextAction handleAccept(final FilterChainContext ctx) throws IOException Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleAccept. Implements org.glassfish.grizzly.filterchain.Filter.handleAccept. Doc from org.glassfish.grizzly.filterchain.BaseFilter.handleAccept. Execute a unit of processing work to be performed, when server channel has accepted the client connection. This `Filter` may either complete the required processing and return false, or delegate remaining processing to the next `Filter` in a `FilterChain` containing this `Filter` by returning true. Annotations @Override

public NextAction handleAccept(final FilterChainContext ctx) throws IOException

Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleAccept.

Implements org.glassfish.grizzly.filterchain.Filter.handleAccept.

Doc from org.glassfish.grizzly.filterchain.BaseFilter.handleAccept.

Execute a unit of processing work to be performed, when server channel has accepted the client connection. This Filter may either complete the required processing and return false, or delegate remaining processing to the next Filter in a FilterChain containing this Filter by returning true.

Annotations

@Override

handleClose back to summary

handleClose	back to summary
public NextAction handleClose(final FilterChainContext ctx) throws IOException Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleClose. Implements org.glassfish.grizzly.filterchain.Filter.handleClose. Doc from org.glassfish.grizzly.filterchain.BaseFilter.handleClose. Execute a unit of processing work to be performed, when connection has been closed. This `Filter` may either complete the required processing and return false, or delegate remaining processing to the next `Filter` in a `FilterChain` containing this `Filter` by returning true. Annotations @Override

public NextAction handleClose(final FilterChainContext ctx) throws IOException

Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleClose.

Implements org.glassfish.grizzly.filterchain.Filter.handleClose.

Doc from org.glassfish.grizzly.filterchain.BaseFilter.handleClose.

Execute a unit of processing work to be performed, when connection has been closed. This Filter may either complete the required processing and return false, or delegate remaining processing to the next Filter in a FilterChain containing this Filter by returning true.

Annotations

@Override

handleConnect back to summary

handleConnect	back to summary
public NextAction handleConnect(final FilterChainContext ctx) throws IOException Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleConnect. Implements org.glassfish.grizzly.filterchain.Filter.handleConnect. Doc from org.glassfish.grizzly.filterchain.BaseFilter.handleConnect. Execute a unit of processing work to be performed, when channel gets connected. This `Filter` may either complete the required processing and return false, or delegate remaining processing to the next `Filter` in a `FilterChain` containing this `Filter` by returning true. Annotations @Override

public NextAction handleConnect(final FilterChainContext ctx) throws IOException

Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleConnect.

Implements org.glassfish.grizzly.filterchain.Filter.handleConnect.

Doc from org.glassfish.grizzly.filterchain.BaseFilter.handleConnect.

Execute a unit of processing work to be performed, when channel gets connected. This Filter may either complete the required processing and return false, or delegate remaining processing to the next Filter in a FilterChain containing this Filter by returning true.

Annotations

@Override

handleRead back to summary

handleRead	back to summary
public NextAction handleRead(final FilterChainContext ctx) throws IOException Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleRead. Implements org.glassfish.grizzly.filterchain.Filter.handleRead. Doc from org.glassfish.grizzly.filterchain.BaseFilter.handleRead. Execute a unit of processing work to be performed, when channel will become available for reading. This `Filter` may either complete the required processing and return false, or delegate remaining processing to the next `Filter` in a `FilterChain` containing this `Filter` by returning true. Annotations @Override

public NextAction handleRead(final FilterChainContext ctx) throws IOException

Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleRead.

Implements org.glassfish.grizzly.filterchain.Filter.handleRead.

Doc from org.glassfish.grizzly.filterchain.BaseFilter.handleRead.

Execute a unit of processing work to be performed, when channel will become available for reading. This Filter may either complete the required processing and return false, or delegate remaining processing to the next Filter in a FilterChain containing this Filter by returning true.

Annotations

@Override

handleWrite back to summary

handleWrite	back to summary
public NextAction handleWrite(final FilterChainContext ctx) throws IOException Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleWrite. Implements org.glassfish.grizzly.filterchain.Filter.handleWrite. Doc from org.glassfish.grizzly.filterchain.BaseFilter.handleWrite. Execute a unit of processing work to be performed, when some data should be written on channel. This `Filter` may either complete the required processing and return false, or delegate remaining processing to the next `Filter` in a `FilterChain` containing this `Filter` by returning true. Annotations @Override

public NextAction handleWrite(final FilterChainContext ctx) throws IOException

Overrides org.glassfish.grizzly.filterchain.BaseFilter.handleWrite.

Implements org.glassfish.grizzly.filterchain.Filter.handleWrite.

Doc from org.glassfish.grizzly.filterchain.BaseFilter.handleWrite.

Execute a unit of processing work to be performed, when some data should be written on channel. This Filter may either complete the required processing and return false, or delegate remaining processing to the next Filter in a FilterChain containing this Filter by returning true.

Annotations

@Override

queueAction	back to summary
protected void queueAction(final FilterChainContext ctx)

setCustomTimeout back to summary

setCustomTimeout	back to summary
public static void setCustomTimeout(final Connection<L> connection, final long timeout, final TimeUnit timeunit) Provides an override mechanism for the default timeout. Parameters connection:Connection<L> The `Connection` which is having the idle detection adjusted. timeout:long the new idle timeout. timeunit:TimeUnit `TimeUnit`.

public static void setCustomTimeout(final Connection<L> connection, final long timeout, final TimeUnit timeunit)

Provides an override mechanism for the default timeout.

Parameters

connection:Connection<L>: The Connection which is having the idle detection adjusted.
timeout:long: the new idle timeout.
timeunit:TimeUnit: TimeUnit.

org.glassfish.grizzly.utils back to summary

private final Class IdleTimeoutFilter.ContextCompletionListener

Class Inheritance

extends Object
implements CompletionListener

java.lang.Object
org.glassfish.grizzly.utils.IdleTimeoutFilter.ContextCompletionListener

All Implemented Interfaces

org.glassfish.grizzly.filterchain.FilterChainContext.CompletionListener

Constructor Summary

Access	Constructor and Description
private	ContextCompletionListener()

Method Summary

Modifier and Type	Method and Description
public void	onComplete(final FilterChainContext ctx) Implements org.glassfish.grizzly.filterchain.FilterChainContext.CompletionListener.onComplete. The method is called, when passed `FilterChainContext` processing is complete.

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

Constructor Detail

ContextCompletionListener	back to summary
private ContextCompletionListener()

Method Detail

onComplete back to summary

onComplete	back to summary
public void onComplete(final FilterChainContext ctx) Implements org.glassfish.grizzly.filterchain.FilterChainContext.CompletionListener.onComplete. Doc from org.glassfish.grizzly.filterchain.FilterChainContext.CompletionListener.onComplete. The method is called, when passed `FilterChainContext` processing is complete. Annotations @Override

public void onComplete(final FilterChainContext ctx)

Implements org.glassfish.grizzly.filterchain.FilterChainContext.CompletionListener.onComplete.

Doc from org.glassfish.grizzly.filterchain.FilterChainContext.CompletionListener.onComplete.

The method is called, when passed FilterChainContext processing is complete.

Annotations

@Override

org.glassfish.grizzly.utils back to summary

private final Class IdleTimeoutFilter.DefaultWorker

Class Inheritance

extends Object
implements DelayedExecutor.Worker<Connection<L>>

java.lang.Object
org.glassfish.grizzly.utils.IdleTimeoutFilter.DefaultWorker

All Implemented Interfaces

org.glassfish.grizzly.utils.DelayedExecutor.Worker

Field Summary

Modifier and Type	Field and Description
private final IdleTimeoutFilter.TimeoutHandler	handler

Constructor Summary

Access	Constructor and Description
pack-priv	DefaultWorker(final IdleTimeoutFilter.TimeoutHandler handler)

Method Summary

Modifier and Type	Method and Description
public boolean	doWork(final Connection<L> connection) Implements org.glassfish.grizzly.utils.DelayedExecutor.Worker.doWork. The method is executed by `DelayExecutor` once element's timeout expires.

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

Field Detail

handler	back to summary
private final IdleTimeoutFilter.TimeoutHandler handler

Constructor Detail

DefaultWorker	back to summary
pack-priv DefaultWorker(final IdleTimeoutFilter.TimeoutHandler handler)

Method Detail

doWork back to summary

doWork	back to summary
public boolean doWork(final Connection<L> connection) Implements org.glassfish.grizzly.utils.DelayedExecutor.Worker.doWork. Doc from org.glassfish.grizzly.utils.DelayedExecutor.Worker.doWork. The method is executed by `DelayExecutor` once element's timeout expires. Annotations @Override

public boolean doWork(final Connection<L> connection)

Implements org.glassfish.grizzly.utils.DelayedExecutor.Worker.doWork.

Doc from org.glassfish.grizzly.utils.DelayedExecutor.Worker.doWork.

The method is executed by DelayExecutor once element's timeout expires.

Annotations

@Override

org.glassfish.grizzly.utils back to summary

private final Class IdleTimeoutFilter.IdleRecord

Class Inheritance

extends Object

java.lang.Object
org.glassfish.grizzly.utils.IdleTimeoutFilter.IdleRecord

Field Summary

Modifier and Type	Field and Description
private volatile int	counter
private static final AtomicIntegerFieldUpdater<IdleTimeoutFilter.IdleRecord>	counterUpdater
private long	initialTimeoutMillis
private boolean	isClosed
private volatile boolean	isInitialSet
private volatile long	timeoutMillis
private static final AtomicLongFieldUpdater<IdleTimeoutFilter.IdleRecord>	timeoutMillisUpdater

Constructor Summary

Access	Constructor and Description
private	IdleRecord()

Method Summary

Modifier and Type	Method and Description
private void	close()
private long	getInitialTimeoutMillis(final long defaultTimeoutMillis)
private void	setInitialTimeoutMillis(final long initialTimeoutMillis)

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

Field Detail

counter	back to summary
private volatile int counter

counterUpdater	back to summary
private static final AtomicIntegerFieldUpdater<IdleTimeoutFilter.IdleRecord> counterUpdater

initialTimeoutMillis	back to summary
private long initialTimeoutMillis

isClosed	back to summary
private boolean isClosed

isInitialSet	back to summary
private volatile boolean isInitialSet

timeoutMillis	back to summary
private volatile long timeoutMillis

timeoutMillisUpdater	back to summary
private static final AtomicLongFieldUpdater<IdleTimeoutFilter.IdleRecord> timeoutMillisUpdater

Constructor Detail

IdleRecord	back to summary
private IdleRecord()

Method Detail

close	back to summary
private void close()

getInitialTimeoutMillis	back to summary
private long getInitialTimeoutMillis(final long defaultTimeoutMillis)

setInitialTimeoutMillis	back to summary
private void setInitialTimeoutMillis(final long initialTimeoutMillis)

org.glassfish.grizzly.utils back to summary

private final Class IdleTimeoutFilter.IdleTimeoutResolver

Class Inheritance

extends Object
implements TimeoutResolver

java.lang.Object
org.glassfish.grizzly.utils.IdleTimeoutFilter.IdleTimeoutResolver

All Implemented Interfaces

org.glassfish.grizzly.utils.IdleTimeoutFilter.TimeoutResolver

Field Summary

Modifier and Type	Field and Description
private final long	defaultTimeoutMillis

Constructor Summary

Access	Constructor and Description
pack-priv	IdleTimeoutResolver(final long defaultTimeoutMillis)

Method Summary

Modifier and Type	Method and Description
public long	getTimeout(final FilterChainContext ctx) Implements org.glassfish.grizzly.utils.IdleTimeoutFilter.TimeoutResolver.getTimeout.

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

Field Detail

defaultTimeoutMillis	back to summary
private final long defaultTimeoutMillis

Constructor Detail

IdleTimeoutResolver	back to summary
pack-priv IdleTimeoutResolver(final long defaultTimeoutMillis)

Method Detail

getTimeout

back to summary

public long getTimeout(final FilterChainContext ctx)

Implements org.glassfish.grizzly.utils.IdleTimeoutFilter.TimeoutResolver.getTimeout.

Annotations

@Override

org.glassfish.grizzly.utils back to summary

private final Class IdleTimeoutFilter.Resolver

Class Inheritance

extends Object
implements DelayedExecutor.Resolver<Connection<L>>

java.lang.Object
org.glassfish.grizzly.utils.IdleTimeoutFilter.Resolver

All Implemented Interfaces

org.glassfish.grizzly.utils.DelayedExecutor.Resolver

Constructor Summary

Access	Constructor and Description
private	Resolver()

Method Summary

Modifier and Type	Method and Description
public long	getTimeoutMillis(final Connection<L> connection) Implements org.glassfish.grizzly.utils.DelayedExecutor.Resolver.getTimeoutMillis.
public boolean	removeTimeout(final Connection<L> connection) Implements org.glassfish.grizzly.utils.DelayedExecutor.Resolver.removeTimeout.
public void	setTimeoutMillis(final Connection<L> connection, final long timeoutMillis) Implements org.glassfish.grizzly.utils.DelayedExecutor.Resolver.setTimeoutMillis.

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

Constructor Detail

Resolver	back to summary
private Resolver()

Method Detail

getTimeoutMillis

back to summary

public long getTimeoutMillis(final Connection<L> connection)

Implements org.glassfish.grizzly.utils.DelayedExecutor.Resolver.getTimeoutMillis.

Annotations

@Override

removeTimeout

back to summary

public boolean removeTimeout(final Connection<L> connection)

Implements org.glassfish.grizzly.utils.DelayedExecutor.Resolver.removeTimeout.

Annotations

@Override

setTimeoutMillis

back to summary

public void setTimeoutMillis(final Connection<L> connection, final long timeoutMillis)

Implements org.glassfish.grizzly.utils.DelayedExecutor.Resolver.setTimeoutMillis.

Annotations

@Override

public Class IdleTimeoutFilter

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class IdleTimeoutFilter.ContextCompletionListener

Constructor Summary

Method Summary

Constructor Detail

Method Detail

private final Class IdleTimeoutFilter.DefaultWorker

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class IdleTimeoutFilter.IdleRecord

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class IdleTimeoutFilter.IdleTimeoutResolver

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class IdleTimeoutFilter.Resolver

Constructor Summary

Method Summary

Constructor Detail

Method Detail

public Interface IdleTimeoutFilter.TimeoutHandler

Method Summary

Method Detail

public Interface IdleTimeoutFilter.TimeoutResolver

Method Summary

Method Detail