org.red5.server.net.filter

Class TrafficShapingFilter

java.lang.Object

org.apache.mina.core.filterchain.IoFilterAdapter

org.red5.server.net.filter.TrafficShapingFilter

All Implemented Interfaces:

org.apache.mina.core.filterchain.IoFilter

public class TrafficShapingFilter
extends org.apache.mina.core.filterchain.IoFilterAdapter

An IoFilter that limits bandwidth (bytes per second) related with read and write operations on a per-session basis.

It is always recommended to add this filter in the first place of the IoFilterChain.
This originated from the Mina sandbox.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.mina.core.filterchain.IoFilter

org.apache.mina.core.filterchain.IoFilter.NextFilter

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
TrafficShapingFilter(int maxReadThroughput, int maxWriteThroughput)
TrafficShapingFilter(ScheduledExecutorService scheduledExecutor, int maxReadThroughput, int maxWriteThroughput)
TrafficShapingFilter(ScheduledExecutorService scheduledExecutor, MessageSizeEstimator messageSizeEstimator, int maxReadThroughput, int maxWriteThroughput)

Method Summary

Methods

Modifier and Type	Method and Description
int	getMaxReadThroughput()
int	getMaxWriteThroughput()
MessageSizeEstimator	getMessageSizeEstimator()
int	getPoolSize()
ScheduledExecutorService	getScheduledExecutor()
void	messageReceived(org.apache.mina.core.filterchain.IoFilter.NextFilter nextFilter, org.apache.mina.core.session.IoSession session, Object message)
void	messageSent(org.apache.mina.core.filterchain.IoFilter.NextFilter nextFilter, org.apache.mina.core.session.IoSession session, org.apache.mina.core.write.WriteRequest writeRequest)
void	onPostRemove(org.apache.mina.core.filterchain.IoFilterChain parent, String name, org.apache.mina.core.filterchain.IoFilter.NextFilter nextFilter)
void	onPreAdd(org.apache.mina.core.filterchain.IoFilterChain parent, String name, org.apache.mina.core.filterchain.IoFilter.NextFilter nextFilter)
void	setMaxReadThroughput(int maxReadThroughput)
void	setMaxWriteThroughput(int maxWriteThroughput)
void	setPoolSize(int poolSize)

Methods inherited from class org.apache.mina.core.filterchain.IoFilterAdapter

destroy, exceptionCaught, filterClose, filterWrite, init, onPostAdd, onPreRemove, sessionClosed, sessionCreated, sessionIdle, sessionOpened, toString

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static org.slf4j.Logger log

Constructor Detail

TrafficShapingFilter

public TrafficShapingFilter(int maxReadThroughput,
                    int maxWriteThroughput)

TrafficShapingFilter

public TrafficShapingFilter(ScheduledExecutorService scheduledExecutor,
                    int maxReadThroughput,
                    int maxWriteThroughput)

TrafficShapingFilter

public TrafficShapingFilter(ScheduledExecutorService scheduledExecutor,
                    MessageSizeEstimator messageSizeEstimator,
                    int maxReadThroughput,
                    int maxWriteThroughput)

Method Detail

getScheduledExecutor

public ScheduledExecutorService getScheduledExecutor()

getMessageSizeEstimator

public MessageSizeEstimator getMessageSizeEstimator()

getMaxReadThroughput

public int getMaxReadThroughput()

setMaxReadThroughput

public void setMaxReadThroughput(int maxReadThroughput)

getMaxWriteThroughput

public int getMaxWriteThroughput()

setMaxWriteThroughput

public void setMaxWriteThroughput(int maxWriteThroughput)

getPoolSize

public int getPoolSize()

setPoolSize

public void setPoolSize(int poolSize)

onPreAdd

public void onPreAdd(org.apache.mina.core.filterchain.IoFilterChain parent,
            String name,
            org.apache.mina.core.filterchain.IoFilter.NextFilter nextFilter)
              throws Exception

Specified by:

onPreAdd in interface org.apache.mina.core.filterchain.IoFilter

Overrides:

onPreAdd in class org.apache.mina.core.filterchain.IoFilterAdapter

Throws:

Exception

onPostRemove

public void onPostRemove(org.apache.mina.core.filterchain.IoFilterChain parent,
                String name,
                org.apache.mina.core.filterchain.IoFilter.NextFilter nextFilter)
                  throws Exception

Specified by:

onPostRemove in interface org.apache.mina.core.filterchain.IoFilter

Overrides:

onPostRemove in class org.apache.mina.core.filterchain.IoFilterAdapter

Throws:

Exception

messageReceived

public void messageReceived(org.apache.mina.core.filterchain.IoFilter.NextFilter nextFilter,
                   org.apache.mina.core.session.IoSession session,
                   Object message)
                     throws Exception

Specified by:

messageReceived in interface org.apache.mina.core.filterchain.IoFilter

Overrides:

messageReceived in class org.apache.mina.core.filterchain.IoFilterAdapter

Throws:

Exception

messageSent

public void messageSent(org.apache.mina.core.filterchain.IoFilter.NextFilter nextFilter,
               org.apache.mina.core.session.IoSession session,
               org.apache.mina.core.write.WriteRequest writeRequest)
                 throws Exception

Specified by:

messageSent in interface org.apache.mina.core.filterchain.IoFilter

Overrides:

messageSent in class org.apache.mina.core.filterchain.IoFilterAdapter

Throws:

Exception