org.waarp.ftp.core.config

Class FtpGlobalTrafficShapingHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelDuplexHandler

io.netty.handler.traffic.AbstractTrafficShapingHandler

io.netty.handler.traffic.GlobalChannelTrafficShapingHandler

org.waarp.ftp.core.config.FtpGlobalTrafficShapingHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, io.netty.channel.ChannelOutboundHandler

public class FtpGlobalTrafficShapingHandler
extends io.netty.handler.traffic.GlobalChannelTrafficShapingHandler

Global Traffic Shaping Handler for FTP

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields inherited from class io.netty.handler.traffic.AbstractTrafficShapingHandler

checkInterval, DEFAULT_CHECK_INTERVAL, DEFAULT_MAX_TIME, maxTime, trafficCounter

Constructor Summary

Constructors

Constructor and Description
FtpGlobalTrafficShapingHandler(ScheduledExecutorService executor)
FtpGlobalTrafficShapingHandler(ScheduledExecutorService executor, long checkInterval)
FtpGlobalTrafficShapingHandler(ScheduledExecutorService executor, long writeGlobalLimit, long readGlobalLimit, long writeChannelLimit, long readChannelLimit)
FtpGlobalTrafficShapingHandler(ScheduledExecutorService executor, long writeGlobalLimit, long readGlobalLimit, long writeChannelLimit, long readChannelLimit, long checkInterval)
FtpGlobalTrafficShapingHandler(ScheduledExecutorService executor, long writeGlobalLimit, long readGlobalLimit, long writeChannelLimit, long readChannelLimit, long checkInterval, long maxTime)

Method Summary

Modifier and Type	Method and Description
protected long	calculateSize(Object msg)

Methods inherited from class io.netty.handler.traffic.GlobalChannelTrafficShapingHandler

accelerationFactor, channelRead, channelTrafficCounters, checkWaitReadTime, configureChannel, doAccounting, getMaxGlobalWriteSize, getReadChannelLimit, getWriteChannelLimit, handlerAdded, handlerRemoved, informReadOperation, maxDeviation, maximumCumulativeReadBytes, maximumCumulativeWrittenBytes, queuesSize, release, setMaxDeviation, setMaxGlobalWriteSize, setReadChannelLimit, setWriteChannelLimit, slowDownFactor, submitWrite, toString, userDefinedWritabilityIndex, write

Methods inherited from class io.netty.handler.traffic.AbstractTrafficShapingHandler

channelRegistered, configure, configure, configure, getCheckInterval, getMaxTimeWait, getMaxWriteDelay, getMaxWriteSize, getReadLimit, getWriteLimit, isHandlerActive, read, setCheckInterval, setMaxTimeWait, setMaxWriteDelay, setMaxWriteSize, setReadLimit, setWriteLimit, submitWrite, trafficCounter

Methods inherited from class io.netty.channel.ChannelDuplexHandler

bind, close, connect, deregister, disconnect, flush

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

exceptionCaught

Constructor Detail

FtpGlobalTrafficShapingHandler

public FtpGlobalTrafficShapingHandler(ScheduledExecutorService executor,
                                      long writeGlobalLimit,
                                      long readGlobalLimit,
                                      long writeChannelLimit,
                                      long readChannelLimit,
                                      long checkInterval,
                                      long maxTime)

FtpGlobalTrafficShapingHandler

public FtpGlobalTrafficShapingHandler(ScheduledExecutorService executor,
                                      long writeGlobalLimit,
                                      long readGlobalLimit,
                                      long writeChannelLimit,
                                      long readChannelLimit,
                                      long checkInterval)

FtpGlobalTrafficShapingHandler

public FtpGlobalTrafficShapingHandler(ScheduledExecutorService executor,
                                      long writeGlobalLimit,
                                      long readGlobalLimit,
                                      long writeChannelLimit,
                                      long readChannelLimit)

FtpGlobalTrafficShapingHandler

public FtpGlobalTrafficShapingHandler(ScheduledExecutorService executor,
                                      long checkInterval)

FtpGlobalTrafficShapingHandler

public FtpGlobalTrafficShapingHandler(ScheduledExecutorService executor)

Method Detail

calculateSize

protected long calculateSize(Object msg)

Overrides:

calculateSize in class io.netty.handler.traffic.AbstractTrafficShapingHandler