org.mobicents.protocols.sctp.netty

Class NettySctpManagementImpl

java.lang.Object

org.mobicents.protocols.sctp.netty.NettySctpManagementImpl

All Implemented Interfaces:

Management

public class NettySctpManagementImpl
extends java.lang.Object
implements Management

Author:

Amit Bhayani

Field Summary

Fields

Modifier and Type	Field and Description
protected AssociationMap<java.lang.String,Association>	associations
protected static NettySctpXMLBinding	binding
static java.lang.String	CONG_CONTROL_BACK_TO_NORMAL_DELAY_THRESHOLD_1
static java.lang.String	CONG_CONTROL_BACK_TO_NORMAL_DELAY_THRESHOLD_2
static java.lang.String	CONG_CONTROL_BACK_TO_NORMAL_DELAY_THRESHOLD_3
static java.lang.String	CONG_CONTROL_DELAY_THRESHOLD_1
static java.lang.String	CONG_CONTROL_DELAY_THRESHOLD_2
static java.lang.String	CONG_CONTROL_DELAY_THRESHOLD_3
protected double[]	congControl_BackToNormalDelayThreshold
protected double[]	congControl_DelayThreshold
protected java.lang.String	persistDir
protected javolution.util.FastList<Server>	servers
protected static java.lang.String	TAB_INDENT

Constructor Summary

Constructors

Constructor and Description
NettySctpManagementImpl(java.lang.String name)

Method Summary

Methods

Modifier and Type	Method and Description
Association	addAssociation(java.lang.String hostAddress, int hostPort, java.lang.String peerAddress, int peerPort, java.lang.String assocName)
Association	addAssociation(java.lang.String hostAddress, int hostPort, java.lang.String peerAddress, int peerPort, java.lang.String assocName, IpChannelType ipChannelType, java.lang.String[] extraHostAddresses)
void	addCongestionListener(CongestionListener listener)
void	addManagementEventListener(ManagementEventListener listener)
Server	addServer(java.lang.String serverName, java.lang.String hostAddress, int port)
Server	addServer(java.lang.String serverName, java.lang.String hostAddress, int port, IpChannelType ipChannelType, boolean acceptAnonymousConnections, int maxConcurrentConnectionsCount, java.lang.String[] extraHostAddresses)
Server	addServer(java.lang.String serverName, java.lang.String hostAddress, int port, IpChannelType ipChannelType, java.lang.String[] extraHostAddresses)
Association	addServerAssociation(java.lang.String peerAddress, int peerPort, java.lang.String serverName, java.lang.String assocName)
Association	addServerAssociation(java.lang.String peerAddress, int peerPort, java.lang.String serverName, java.lang.String assocName, IpChannelType ipChannelType)
Association	getAssociation(java.lang.String assocName)
java.util.Map<java.lang.String,Association>	getAssociations()
protected io.netty.channel.EventLoopGroup	getBossGroup()
int	getBufferSize()
protected java.util.concurrent.ScheduledExecutorService	getClientExecutor()
double	getCongControl_BackToNormalDelayThreshold_1()
double	getCongControl_BackToNormalDelayThreshold_2()
double	getCongControl_BackToNormalDelayThreshold_3()
double	getCongControl_DelayThreshold_1()
double	getCongControl_DelayThreshold_2()
double	getCongControl_DelayThreshold_3()
protected javolution.util.FastList<CongestionListener>	getCongestionListeners()
int	getConnectDelay()
protected javolution.util.FastList<ManagementEventListener>	getManagementEventListeners()
java.lang.String	getName()
java.lang.Boolean	getOptionSctpDisableFragments()
java.lang.Integer	getOptionSctpFragmentInterleave()
java.lang.Integer	getOptionSctpInitMaxstreams_MaxInStreams()
java.lang.Integer	getOptionSctpInitMaxstreams_MaxOutStreams()
com.sun.nio.sctp.SctpStandardSocketOptions.InitMaxStreams	getOptionSctpInitMaxstreams()
java.lang.Boolean	getOptionSctpNodelay()
java.lang.Integer	getOptionSoLinger()
java.lang.Integer	getOptionSoRcvbuf()
java.lang.Integer	getOptionSoSndbuf()
java.lang.String	getPersistDir()
ServerListener	getServerListener()
java.util.List<Server>	getServers()
protected io.netty.channel.EventLoopGroup	getWorkerGroup()
int	getWorkerThreads()
boolean	isSingleThread()
boolean	isStarted()
protected void	load()
protected void	load(javolution.xml.XMLObjectReader reader)
void	removeAllResourses()
void	removeAssociation(java.lang.String assocName)
void	removeCongestionListener(CongestionListener listener)
void	removeManagementEventListener(ManagementEventListener listener)
void	removeServer(java.lang.String serverName)
void	setBufferSize(int bufferSize)
void	setCongControl_BackToNormalDelayThreshold_1(double val)
void	setCongControl_BackToNormalDelayThreshold_2(double val)
void	setCongControl_BackToNormalDelayThreshold_3(double val)
void	setCongControl_DelayThreshold_1(double val)
void	setCongControl_DelayThreshold_2(double val)
void	setCongControl_DelayThreshold_3(double val)
void	setConnectDelay(int connectDelay)
void	setOptionSctpDisableFragments(java.lang.Boolean optionSctpDisableFragments)
void	setOptionSctpFragmentInterleave(java.lang.Integer optionSctpFragmentInterleave)
void	setOptionSctpInitMaxstreams_MaxInStreams(java.lang.Integer val)
void	setOptionSctpInitMaxstreams_MaxOutStreams(java.lang.Integer val)
void	setOptionSctpNodelay(java.lang.Boolean optionSctpNodelay)
void	setOptionSoLinger(java.lang.Integer optionSoLinger)
void	setOptionSoRcvbuf(java.lang.Integer optionSoRcvbuf)
void	setOptionSoSndbuf(java.lang.Integer optionSoSndbuf)
void	setPersistDir(java.lang.String persistDir)
void	setServerListener(ServerListener serverListener)
void	setSingleThread(boolean singleThread)
void	setWorkerThreads(int workerThreads)
void	start()
void	startAssociation(java.lang.String assocName)
void	startServer(java.lang.String serverName)
void	stop()
void	stopAssociation(java.lang.String assocName)
void	stopServer(java.lang.String serverName)
void	store()

Methods inherited from class java.lang.Object

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

Field Detail

CONG_CONTROL_DELAY_THRESHOLD_1

public static final java.lang.String CONG_CONTROL_DELAY_THRESHOLD_1

See Also:

Constant Field Values

CONG_CONTROL_DELAY_THRESHOLD_2

public static final java.lang.String CONG_CONTROL_DELAY_THRESHOLD_2

See Also:

Constant Field Values

CONG_CONTROL_DELAY_THRESHOLD_3

public static final java.lang.String CONG_CONTROL_DELAY_THRESHOLD_3

See Also:

Constant Field Values

CONG_CONTROL_BACK_TO_NORMAL_DELAY_THRESHOLD_1

public static final java.lang.String CONG_CONTROL_BACK_TO_NORMAL_DELAY_THRESHOLD_1

See Also:

Constant Field Values

CONG_CONTROL_BACK_TO_NORMAL_DELAY_THRESHOLD_2

public static final java.lang.String CONG_CONTROL_BACK_TO_NORMAL_DELAY_THRESHOLD_2

See Also:

Constant Field Values

CONG_CONTROL_BACK_TO_NORMAL_DELAY_THRESHOLD_3

public static final java.lang.String CONG_CONTROL_BACK_TO_NORMAL_DELAY_THRESHOLD_3

See Also:

Constant Field Values

binding

protected static final NettySctpXMLBinding binding

TAB_INDENT

protected static final java.lang.String TAB_INDENT

See Also:

Constant Field Values

persistDir

protected java.lang.String persistDir

congControl_DelayThreshold

protected double[] congControl_DelayThreshold

congControl_BackToNormalDelayThreshold

protected double[] congControl_BackToNormalDelayThreshold

servers

protected javolution.util.FastList<Server> servers

associations

protected AssociationMap<java.lang.String,Association> associations

Constructor Detail

NettySctpManagementImpl

public NettySctpManagementImpl(java.lang.String name)
                        throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getName

public java.lang.String getName()

Specified by:

getName in interface Management

getPersistDir

public java.lang.String getPersistDir()

Specified by:

getPersistDir in interface Management

setPersistDir

public void setPersistDir(java.lang.String persistDir)

Specified by:

setPersistDir in interface Management

getServerListener

public ServerListener getServerListener()

Specified by:

getServerListener in interface Management

setServerListener

public void setServerListener(ServerListener serverListener)

Specified by:

setServerListener in interface Management

getBossGroup

protected io.netty.channel.EventLoopGroup getBossGroup()

getWorkerGroup

protected io.netty.channel.EventLoopGroup getWorkerGroup()

getClientExecutor

protected java.util.concurrent.ScheduledExecutorService getClientExecutor()

addManagementEventListener

public void addManagementEventListener(ManagementEventListener listener)

Specified by:

addManagementEventListener in interface Management

removeManagementEventListener

public void removeManagementEventListener(ManagementEventListener listener)

Specified by:

removeManagementEventListener in interface Management

addCongestionListener

public void addCongestionListener(CongestionListener listener)

Specified by:

addCongestionListener in interface Management

removeCongestionListener

public void removeCongestionListener(CongestionListener listener)

Specified by:

removeCongestionListener in interface Management

start

public void start()
           throws java.lang.Exception

Specified by:

start in interface Management

Throws:

java.lang.Exception

stop

public void stop()
          throws java.lang.Exception

Specified by:

stop in interface Management

Throws:

java.lang.Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface Management

removeAllResourses

public void removeAllResourses()
                        throws java.lang.Exception

Specified by:

removeAllResourses in interface Management

Throws:

java.lang.Exception

addServer

public Server addServer(java.lang.String serverName,
               java.lang.String hostAddress,
               int port,
               IpChannelType ipChannelType,
               boolean acceptAnonymousConnections,
               int maxConcurrentConnectionsCount,
               java.lang.String[] extraHostAddresses)
                 throws java.lang.Exception

Specified by:

addServer in interface Management

Throws:

java.lang.Exception

addServer

public Server addServer(java.lang.String serverName,
               java.lang.String hostAddress,
               int port,
               IpChannelType ipChannelType,
               java.lang.String[] extraHostAddresses)
                 throws java.lang.Exception

Specified by:

addServer in interface Management

Throws:

java.lang.Exception

addServer

public Server addServer(java.lang.String serverName,
               java.lang.String hostAddress,
               int port)
                 throws java.lang.Exception

Specified by:

addServer in interface Management

Throws:

java.lang.Exception

removeServer

public void removeServer(java.lang.String serverName)
                  throws java.lang.Exception

Specified by:

removeServer in interface Management

Throws:

java.lang.Exception

startServer

public void startServer(java.lang.String serverName)
                 throws java.lang.Exception

Specified by:

startServer in interface Management

Throws:

java.lang.Exception

stopServer

public void stopServer(java.lang.String serverName)
                throws java.lang.Exception

Specified by:

stopServer in interface Management

Throws:

java.lang.Exception

getServers

public java.util.List<Server> getServers()

Specified by:

getServers in interface Management

addServerAssociation

public Association addServerAssociation(java.lang.String peerAddress,
                               int peerPort,
                               java.lang.String serverName,
                               java.lang.String assocName)
                                 throws java.lang.Exception

Specified by:

addServerAssociation in interface Management

Throws:

java.lang.Exception

addServerAssociation

public Association addServerAssociation(java.lang.String peerAddress,
                               int peerPort,
                               java.lang.String serverName,
                               java.lang.String assocName,
                               IpChannelType ipChannelType)
                                 throws java.lang.Exception

Specified by:

addServerAssociation in interface Management

Throws:

java.lang.Exception

addAssociation

public Association addAssociation(java.lang.String hostAddress,
                         int hostPort,
                         java.lang.String peerAddress,
                         int peerPort,
                         java.lang.String assocName)
                           throws java.lang.Exception

Specified by:

addAssociation in interface Management

Throws:

java.lang.Exception

addAssociation

public Association addAssociation(java.lang.String hostAddress,
                         int hostPort,
                         java.lang.String peerAddress,
                         int peerPort,
                         java.lang.String assocName,
                         IpChannelType ipChannelType,
                         java.lang.String[] extraHostAddresses)
                           throws java.lang.Exception

Specified by:

addAssociation in interface Management

Throws:

java.lang.Exception

removeAssociation

public void removeAssociation(java.lang.String assocName)
                       throws java.lang.Exception

Specified by:

removeAssociation in interface Management

Throws:

java.lang.Exception

getAssociation

public Association getAssociation(java.lang.String assocName)
                           throws java.lang.Exception

Specified by:

getAssociation in interface Management

Throws:

java.lang.Exception

getAssociations

public java.util.Map<java.lang.String,Association> getAssociations()

Specified by:

getAssociations in interface Management

startAssociation

public void startAssociation(java.lang.String assocName)
                      throws java.lang.Exception

Specified by:

startAssociation in interface Management

Throws:

java.lang.Exception

stopAssociation

public void stopAssociation(java.lang.String assocName)
                     throws java.lang.Exception

Specified by:

stopAssociation in interface Management

Throws:

java.lang.Exception

getConnectDelay

public int getConnectDelay()

Specified by:

getConnectDelay in interface Management

setConnectDelay

public void setConnectDelay(int connectDelay)
                     throws java.lang.Exception

Specified by:

setConnectDelay in interface Management

Throws:

java.lang.Exception

getCongControl_DelayThreshold_1

public double getCongControl_DelayThreshold_1()

Specified by:

getCongControl_DelayThreshold_1 in interface Management

getCongControl_DelayThreshold_2

public double getCongControl_DelayThreshold_2()

Specified by:

getCongControl_DelayThreshold_2 in interface Management

getCongControl_DelayThreshold_3

public double getCongControl_DelayThreshold_3()

Specified by:

getCongControl_DelayThreshold_3 in interface Management

setCongControl_DelayThreshold_1

public void setCongControl_DelayThreshold_1(double val)
                                     throws java.lang.Exception

Specified by:

setCongControl_DelayThreshold_1 in interface Management

Throws:

java.lang.Exception

setCongControl_DelayThreshold_2

public void setCongControl_DelayThreshold_2(double val)
                                     throws java.lang.Exception

Specified by:

setCongControl_DelayThreshold_2 in interface Management

Throws:

java.lang.Exception

setCongControl_DelayThreshold_3

public void setCongControl_DelayThreshold_3(double val)
                                     throws java.lang.Exception

Specified by:

setCongControl_DelayThreshold_3 in interface Management

Throws:

java.lang.Exception

getCongControl_BackToNormalDelayThreshold_1

public double getCongControl_BackToNormalDelayThreshold_1()

Specified by:

getCongControl_BackToNormalDelayThreshold_1 in interface Management

getCongControl_BackToNormalDelayThreshold_2

public double getCongControl_BackToNormalDelayThreshold_2()

Specified by:

getCongControl_BackToNormalDelayThreshold_2 in interface Management

getCongControl_BackToNormalDelayThreshold_3

public double getCongControl_BackToNormalDelayThreshold_3()

Specified by:

getCongControl_BackToNormalDelayThreshold_3 in interface Management

setCongControl_BackToNormalDelayThreshold_1

public void setCongControl_BackToNormalDelayThreshold_1(double val)
                                                 throws java.lang.Exception

Specified by:

setCongControl_BackToNormalDelayThreshold_1 in interface Management

Throws:

java.lang.Exception

setCongControl_BackToNormalDelayThreshold_2

public void setCongControl_BackToNormalDelayThreshold_2(double val)
                                                 throws java.lang.Exception

Specified by:

setCongControl_BackToNormalDelayThreshold_2 in interface Management

Throws:

java.lang.Exception

setCongControl_BackToNormalDelayThreshold_3

public void setCongControl_BackToNormalDelayThreshold_3(double val)
                                                 throws java.lang.Exception

Specified by:

setCongControl_BackToNormalDelayThreshold_3 in interface Management

Throws:

java.lang.Exception

getWorkerThreads

public int getWorkerThreads()

Specified by:

getWorkerThreads in interface Management

setWorkerThreads

public void setWorkerThreads(int workerThreads)
                      throws java.lang.Exception

Specified by:

setWorkerThreads in interface Management

Throws:

java.lang.Exception

isSingleThread

public boolean isSingleThread()

Specified by:

isSingleThread in interface Management

setSingleThread

public void setSingleThread(boolean singleThread)
                     throws java.lang.Exception

Specified by:

setSingleThread in interface Management

Throws:

java.lang.Exception

getOptionSctpDisableFragments

public java.lang.Boolean getOptionSctpDisableFragments()

Specified by:

getOptionSctpDisableFragments in interface Management

setOptionSctpDisableFragments

public void setOptionSctpDisableFragments(java.lang.Boolean optionSctpDisableFragments)

Specified by:

setOptionSctpDisableFragments in interface Management

getOptionSctpFragmentInterleave

public java.lang.Integer getOptionSctpFragmentInterleave()

Specified by:

getOptionSctpFragmentInterleave in interface Management

setOptionSctpFragmentInterleave

public void setOptionSctpFragmentInterleave(java.lang.Integer optionSctpFragmentInterleave)

Specified by:

setOptionSctpFragmentInterleave in interface Management

getOptionSctpInitMaxstreams

public com.sun.nio.sctp.SctpStandardSocketOptions.InitMaxStreams getOptionSctpInitMaxstreams()

getOptionSctpInitMaxstreams_MaxOutStreams

public java.lang.Integer getOptionSctpInitMaxstreams_MaxOutStreams()

Specified by:

getOptionSctpInitMaxstreams_MaxOutStreams in interface Management

getOptionSctpInitMaxstreams_MaxInStreams

public java.lang.Integer getOptionSctpInitMaxstreams_MaxInStreams()

Specified by:

getOptionSctpInitMaxstreams_MaxInStreams in interface Management

setOptionSctpInitMaxstreams_MaxOutStreams

public void setOptionSctpInitMaxstreams_MaxOutStreams(java.lang.Integer val)

Specified by:

setOptionSctpInitMaxstreams_MaxOutStreams in interface Management

setOptionSctpInitMaxstreams_MaxInStreams

public void setOptionSctpInitMaxstreams_MaxInStreams(java.lang.Integer val)

Specified by:

setOptionSctpInitMaxstreams_MaxInStreams in interface Management

getOptionSctpNodelay

public java.lang.Boolean getOptionSctpNodelay()

Specified by:

getOptionSctpNodelay in interface Management

setOptionSctpNodelay

public void setOptionSctpNodelay(java.lang.Boolean optionSctpNodelay)

Specified by:

setOptionSctpNodelay in interface Management

getOptionSoSndbuf

public java.lang.Integer getOptionSoSndbuf()

Specified by:

getOptionSoSndbuf in interface Management

setOptionSoSndbuf

public void setOptionSoSndbuf(java.lang.Integer optionSoSndbuf)

Specified by:

setOptionSoSndbuf in interface Management

getOptionSoRcvbuf

public java.lang.Integer getOptionSoRcvbuf()

Specified by:

getOptionSoRcvbuf in interface Management

setOptionSoRcvbuf

public void setOptionSoRcvbuf(java.lang.Integer optionSoRcvbuf)

Specified by:

setOptionSoRcvbuf in interface Management

getOptionSoLinger

public java.lang.Integer getOptionSoLinger()

Specified by:

getOptionSoLinger in interface Management

setOptionSoLinger

public void setOptionSoLinger(java.lang.Integer optionSoLinger)

Specified by:

setOptionSoLinger in interface Management

getManagementEventListeners

protected javolution.util.FastList<ManagementEventListener> getManagementEventListeners()

getCongestionListeners

protected javolution.util.FastList<CongestionListener> getCongestionListeners()

load

protected void load()
             throws java.io.FileNotFoundException

Throws:

java.io.FileNotFoundException

load

protected void load(javolution.xml.XMLObjectReader reader)
             throws javolution.xml.stream.XMLStreamException

Throws:

javolution.xml.stream.XMLStreamException

store

public void store()

getBufferSize

public int getBufferSize()

Specified by:

getBufferSize in interface Management

setBufferSize

public void setBufferSize(int bufferSize)
                   throws java.lang.Exception

Specified by:

setBufferSize in interface Management

Throws:

java.lang.Exception