org.apache.mina.filter.executor

Class IoEventQueueThrottle

java.lang.Object

org.apache.mina.filter.executor.IoEventQueueThrottle

All Implemented Interfaces:

java.util.EventListener, IoEventQueueHandler

public class IoEventQueueThrottle
extends java.lang.Object
implements IoEventQueueHandler

Throttles incoming or outgoing events.

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.atomic.AtomicInteger	counter
private IoEventSizeEstimator	eventSizeEstimator The event size estimator instance
private java.lang.Object	lock
private static org.slf4j.Logger	LOGGER A logger for this class
private int	threshold
private int	waiters

Fields inherited from interface org.apache.mina.filter.executor.IoEventQueueHandler

NOOP

Constructor Summary

Constructors

Constructor and Description
IoEventQueueThrottle()
IoEventQueueThrottle(int threshold)
IoEventQueueThrottle(IoEventSizeEstimator eventSizeEstimator, int threshold)

Method Summary

Modifier and Type	Method and Description
boolean	accept(java.lang.Object source, IoEvent event) Returns true if and only if the specified event is allowed to be offered to the event queue.
protected void	block()
private int	estimateSize(IoEvent event)
int	getCounter()
IoEventSizeEstimator	getEventSizeEstimator()
int	getThreshold()
private void	logState()
void	offered(java.lang.Object source, IoEvent event) Invoked after the specified event has been offered to the event queue.
void	polled(java.lang.Object source, IoEvent event) Invoked after the specified event has been polled from the event queue.
void	setThreshold(int threshold)
protected void	unblock()

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

A logger for this class

eventSizeEstimator

private final IoEventSizeEstimator eventSizeEstimator

The event size estimator instance

threshold

private volatile int threshold

lock

private final java.lang.Object lock

counter

private final java.util.concurrent.atomic.AtomicInteger counter

waiters

private int waiters

Constructor Detail

IoEventQueueThrottle

public IoEventQueueThrottle()

IoEventQueueThrottle

public IoEventQueueThrottle(int threshold)

IoEventQueueThrottle

public IoEventQueueThrottle(IoEventSizeEstimator eventSizeEstimator,
                            int threshold)

Method Detail

getEventSizeEstimator

public IoEventSizeEstimator getEventSizeEstimator()

getThreshold

public int getThreshold()

getCounter

public int getCounter()

setThreshold

public void setThreshold(int threshold)

accept

public boolean accept(java.lang.Object source,
                      IoEvent event)

Description copied from interface: IoEventQueueHandler

Returns true if and only if the specified event is allowed to be offered to the event queue. The event is dropped if false is returned.

Specified by:

accept in interface IoEventQueueHandler

offered

public void offered(java.lang.Object source,
                    IoEvent event)

Description copied from interface: IoEventQueueHandler

Invoked after the specified event has been offered to the event queue.

Specified by:

offered in interface IoEventQueueHandler

polled

public void polled(java.lang.Object source,
                   IoEvent event)

Description copied from interface: IoEventQueueHandler

Invoked after the specified event has been polled from the event queue.

Specified by:

polled in interface IoEventQueueHandler

estimateSize

private int estimateSize(IoEvent event)

logState

private void logState()

block

protected void block()

unblock

protected void unblock()