org.waarp.ftp.core.config

Class FtpInternalConfiguration

java.lang.Object

org.waarp.ftp.core.config.FtpInternalConfiguration

public class FtpInternalConfiguration
extends Object

Internal configuration of the FTP server, related to Netty

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FtpInternalConfiguration.BindAddress org.waarp.ftp.core.config BindAddress

Field Summary

Fields

Modifier and Type	Field and Description
static long	RETRYINMS Time elapse for retry in ms
static int	RETRYNB Number of retry before error

Constructor Summary

Constructors

Constructor and Description
FtpInternalConfiguration(FtpConfiguration configuration) Constructor

Method Summary

Modifier and Type	Method and Description
void	bindPassive(InetSocketAddress address, boolean ssl) Try to add a Passive Channel listening to the specified local address
void	delFtpSession(InetAddress ipOnly, InetSocketAddress fullIp) Remove the FtpSession
FtpSession	findPassiveFtpSession(io.netty.channel.Channel channel)
io.netty.bootstrap.Bootstrap	getActiveBootstrap(boolean ssl)
io.netty.channel.group.ChannelGroup	getCommandChannelGroup()
io.netty.channel.group.ChannelGroup	getDataChannelGroup()
io.netty.util.concurrent.EventExecutorGroup	getDataExecutor() Return the associated Executor for Data Event
io.netty.util.concurrent.EventExecutorGroup	getExecutor() Return the associated Executor for Command Event
FtpSession	getFtpSession(io.netty.channel.Channel channel) Return and remove the FtpSession
FtpGlobalTrafficShapingHandler	getGlobalTrafficShapingHandler()
int	getNbBindedPassive()
int	getNumberSessions()
ExecutorService	getWorker()
boolean	isAcceptAuthProt()
boolean	isUsingNativeSsl()
io.netty.handler.traffic.ChannelTrafficShapingHandler	newChannelTrafficShapingHandler()
void	releaseResources()
void	serverStartup() Startup the server
void	setAcceptAuthProt(boolean acceptAuthProt)
void	setNewFtpSession(InetAddress ipOnly, InetSocketAddress fullIp, FtpSession session) Add a session from a couple of addresses
void	setUsingNativeSsl(boolean usingNativeSsl)
void	unbindPassive(InetSocketAddress address) Try to unbind (closing the parent channel) the Passive Channel listening to the specified local address if the last one.

Methods inherited from class java.lang.Object

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

Field Detail

RETRYINMS

public static final long RETRYINMS

Time elapse for retry in ms

See Also:

Constant Field Values

RETRYNB

public static final int RETRYNB

Number of retry before error

See Also:

Constant Field Values

Constructor Detail

FtpInternalConfiguration

public FtpInternalConfiguration(FtpConfiguration configuration)

Constructor

Parameters:

configuration -

Method Detail

serverStartup

public final void serverStartup()
                         throws FtpNoConnectionException

Startup the server

Throws:

FtpNoConnectionException

getWorker

public final ExecutorService getWorker()

Returns:

an ExecutorService

setNewFtpSession

public final void setNewFtpSession(InetAddress ipOnly,
                                   InetSocketAddress fullIp,
                                   FtpSession session)

Add a session from a couple of addresses

Parameters:

ipOnly -

fullIp -

session -

getFtpSession

public final FtpSession getFtpSession(io.netty.channel.Channel channel)

Return and remove the FtpSession

Parameters:

channel -

Returns:

the FtpSession if it exists associated to this channel

delFtpSession

public final void delFtpSession(InetAddress ipOnly,
                                InetSocketAddress fullIp)

Remove the FtpSession

Parameters:

ipOnly -

fullIp -

getNumberSessions

public final int getNumberSessions()

Returns:

the number of Active Sessions

findPassiveFtpSession

public final FtpSession findPassiveFtpSession(io.netty.channel.Channel channel)

Parameters:

channel -

Returns:

the FtpSession if found

bindPassive

public final void bindPassive(InetSocketAddress address,
                              boolean ssl)
                       throws Reply425Exception

Try to add a Passive Channel listening to the specified local address

Parameters:

address -

ssl -

Throws:

Reply425Exception - in case the channel cannot be opened

unbindPassive

public final void unbindPassive(InetSocketAddress address)

Try to unbind (closing the parent channel) the Passive Channel listening to the specified local address if the last one. It returns only when the underlying parent channel is closed if this was the last session that wants to open on this local address.

Parameters:

address -

getNbBindedPassive

public final int getNbBindedPassive()

Returns:

the number of Binded Passive Connections

getExecutor

public final io.netty.util.concurrent.EventExecutorGroup getExecutor()

Return the associated Executor for Command Event

Returns:

the Command Event Executor

getDataExecutor

public final io.netty.util.concurrent.EventExecutorGroup getDataExecutor()

Return the associated Executor for Data Event

Returns:

the Data Event Executor

getActiveBootstrap

public final io.netty.bootstrap.Bootstrap getActiveBootstrap(boolean ssl)

Parameters:

ssl -

Returns:

the ActiveBootstrap

getCommandChannelGroup

public final io.netty.channel.group.ChannelGroup getCommandChannelGroup()

Returns:

the commandChannelGroup

getDataChannelGroup

public final io.netty.channel.group.ChannelGroup getDataChannelGroup()

Returns:

the dataChannelGroup

getGlobalTrafficShapingHandler

public final FtpGlobalTrafficShapingHandler getGlobalTrafficShapingHandler()

Returns:

The TrafficCounterFactory

newChannelTrafficShapingHandler

public final io.netty.handler.traffic.ChannelTrafficShapingHandler newChannelTrafficShapingHandler()

Returns:

a new ChannelTrafficShapingHandler

releaseResources

public final void releaseResources()

isAcceptAuthProt

public final boolean isAcceptAuthProt()

isUsingNativeSsl

public final boolean isUsingNativeSsl()

Returns:

the usingNativeSsl

setUsingNativeSsl

public final void setUsingNativeSsl(boolean usingNativeSsl)

Parameters:

usingNativeSsl - the usingNativeSsl to set

setAcceptAuthProt

public final void setAcceptAuthProt(boolean acceptAuthProt)

Parameters:

acceptAuthProt - the acceptAuthProt to set