public class ManagementImpl extends java.lang.Object implements Management
| Modifier and Type | Field and Description |
|---|---|
protected AssociationMap<java.lang.String,Association> |
associations |
protected static SctpXMLBinding |
binding |
protected java.lang.String |
persistDir |
protected javolution.util.FastList<Server> |
servers |
protected static java.lang.String |
TAB_INDENT |
| Constructor and Description |
|---|
ManagementImpl(java.lang.String name) |
| Modifier and Type | Method and Description |
|---|---|
AssociationImpl |
addAssociation(java.lang.String hostAddress,
int hostPort,
java.lang.String peerAddress,
int peerPort,
java.lang.String assocName) |
AssociationImpl |
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) |
ServerImpl |
addServer(java.lang.String serverName,
java.lang.String hostAddress,
int port) |
ServerImpl |
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) |
AssociationImpl |
addServerAssociation(java.lang.String peerAddress,
int peerPort,
java.lang.String serverName,
java.lang.String assocName) |
AssociationImpl |
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() |
int |
getBufferSize() |
double |
getCongControl_BackToNormalDelayThreshold_1() |
double |
getCongControl_BackToNormalDelayThreshold_2() |
double |
getCongControl_BackToNormalDelayThreshold_3() |
double |
getCongControl_DelayThreshold_1() |
double |
getCongControl_DelayThreshold_2() |
double |
getCongControl_DelayThreshold_3() |
int |
getConnectDelay() |
protected java.util.concurrent.ExecutorService |
getExecutorService(int index) |
protected javolution.util.FastList<ManagementEventListener> |
getManagementEventListeners() |
int |
getMaxIOErrors() |
java.lang.String |
getName() |
java.lang.Boolean |
getOptionSctpDisableFragments() |
java.lang.Integer |
getOptionSctpFragmentInterleave() |
java.lang.Integer |
getOptionSctpInitMaxstreams_MaxInStreams() |
java.lang.Integer |
getOptionSctpInitMaxstreams_MaxOutStreams() |
java.lang.Boolean |
getOptionSctpNodelay() |
java.lang.Integer |
getOptionSoLinger() |
java.lang.Integer |
getOptionSoRcvbuf() |
java.lang.Integer |
getOptionSoSndbuf() |
protected javolution.util.FastList<ChangeRequest> |
getPendingChanges() |
java.lang.String |
getPersistDir() |
ServerListener |
getServerListener() |
java.util.List<Server> |
getServers() |
protected java.nio.channels.Selector |
getSocketSelector() |
int |
getWorkerThreads() |
boolean |
isSingleThread() |
boolean |
isStarted() |
void |
load() |
protected void |
populateWorkerThread(int[] workerThreadTable) |
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 |
setMaxIOErrors(int maxIOErrors) |
void |
setOptionSctpDisableFragments(java.lang.Boolean optionSctpDisableFragments) |
void |
setOptionSctpFragmentInterleave(java.lang.Integer optionSctpFragmentInterleave) |
void |
setOptionSctpInitMaxstreams_MaxInStreams(java.lang.Integer maxInStreams) |
void |
setOptionSctpInitMaxstreams_MaxOutStreams(java.lang.Integer maxOutStreams) |
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() |
protected static final SctpXMLBinding binding
protected static final java.lang.String TAB_INDENT
protected java.lang.String persistDir
protected javolution.util.FastList<Server> servers
protected AssociationMap<java.lang.String,Association> associations
public ManagementImpl(java.lang.String name)
throws java.io.IOException
java.io.IOExceptionpublic java.lang.String getName()
getName in interface Managementpublic java.lang.String getPersistDir()
getPersistDir in interface Managementpublic void setPersistDir(java.lang.String persistDir)
setPersistDir in interface Managementpublic int getConnectDelay()
getConnectDelay in interface Managementpublic void setConnectDelay(int connectDelay)
throws java.lang.Exception
setConnectDelay in interface ManagementconnectDelay - the connectDelay to setjava.lang.Exceptionpublic int getWorkerThreads()
getWorkerThreads in interface Managementpublic void setWorkerThreads(int workerThreads)
throws java.lang.Exception
setWorkerThreads in interface ManagementworkerThreads - the workerThreads to setjava.lang.Exceptionpublic int getMaxIOErrors()
public void setMaxIOErrors(int maxIOErrors)
maxIOErrors - the maxIOErrors to setpublic boolean isSingleThread()
isSingleThread in interface Managementpublic void setSingleThread(boolean singleThread)
throws java.lang.Exception
setSingleThread in interface ManagementsingleThread - the singleThread to setjava.lang.Exceptionpublic int getBufferSize()
getBufferSize in interface Managementpublic void setBufferSize(int bufferSize)
throws java.lang.Exception
setBufferSize in interface Managementjava.lang.Exceptionpublic ServerListener getServerListener()
getServerListener in interface Managementprotected javolution.util.FastList<ManagementEventListener> getManagementEventListeners()
public void setServerListener(ServerListener serverListener)
setServerListener in interface Managementpublic void addManagementEventListener(ManagementEventListener listener)
addManagementEventListener in interface Managementpublic void removeManagementEventListener(ManagementEventListener listener)
removeManagementEventListener in interface Managementpublic void start()
throws java.lang.Exception
start in interface Managementjava.lang.Exceptionpublic void stop()
throws java.lang.Exception
stop in interface Managementjava.lang.Exceptionpublic boolean isStarted()
isStarted in interface Managementpublic void load()
throws java.io.FileNotFoundException
java.io.FileNotFoundExceptionpublic void store()
public void removeAllResourses()
throws java.lang.Exception
removeAllResourses in interface Managementjava.lang.Exceptionpublic ServerImpl addServer(java.lang.String serverName, java.lang.String hostAddress, int port) throws java.lang.Exception
addServer in interface Managementjava.lang.Exceptionpublic Server addServer(java.lang.String serverName, java.lang.String hostAddress, int port, IpChannelType ipChannelType, java.lang.String[] extraHostAddresses) throws java.lang.Exception
addServer in interface Managementjava.lang.Exceptionpublic ServerImpl 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
addServer in interface Managementjava.lang.Exceptionpublic void removeServer(java.lang.String serverName)
throws java.lang.Exception
removeServer in interface Managementjava.lang.Exceptionpublic void startServer(java.lang.String serverName)
throws java.lang.Exception
startServer in interface Managementjava.lang.Exceptionpublic void stopServer(java.lang.String serverName)
throws java.lang.Exception
stopServer in interface Managementjava.lang.Exceptionpublic AssociationImpl addServerAssociation(java.lang.String peerAddress, int peerPort, java.lang.String serverName, java.lang.String assocName) throws java.lang.Exception
addServerAssociation in interface Managementjava.lang.Exceptionpublic AssociationImpl addServerAssociation(java.lang.String peerAddress, int peerPort, java.lang.String serverName, java.lang.String assocName, IpChannelType ipChannelType) throws java.lang.Exception
addServerAssociation in interface Managementjava.lang.Exceptionpublic AssociationImpl addAssociation(java.lang.String hostAddress, int hostPort, java.lang.String peerAddress, int peerPort, java.lang.String assocName) throws java.lang.Exception
addAssociation in interface Managementjava.lang.Exceptionpublic AssociationImpl 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
addAssociation in interface Managementjava.lang.Exceptionpublic Association getAssociation(java.lang.String assocName) throws java.lang.Exception
getAssociation in interface Managementjava.lang.Exceptionpublic java.util.Map<java.lang.String,Association> getAssociations()
getAssociations in interface Managementpublic void startAssociation(java.lang.String assocName)
throws java.lang.Exception
startAssociation in interface Managementjava.lang.Exceptionpublic void stopAssociation(java.lang.String assocName)
throws java.lang.Exception
stopAssociation in interface Managementjava.lang.Exceptionpublic void removeAssociation(java.lang.String assocName)
throws java.lang.Exception
removeAssociation in interface Managementjava.lang.Exceptionpublic java.util.List<Server> getServers()
getServers in interface Managementprotected javolution.util.FastList<ChangeRequest> getPendingChanges()
protected java.nio.channels.Selector getSocketSelector()
protected void populateWorkerThread(int[] workerThreadTable)
protected java.util.concurrent.ExecutorService getExecutorService(int index)
public double getCongControl_DelayThreshold_1()
getCongControl_DelayThreshold_1 in interface Managementpublic double getCongControl_DelayThreshold_2()
getCongControl_DelayThreshold_2 in interface Managementpublic double getCongControl_DelayThreshold_3()
getCongControl_DelayThreshold_3 in interface Managementpublic void setCongControl_DelayThreshold_1(double val)
throws java.lang.Exception
setCongControl_DelayThreshold_1 in interface Managementjava.lang.Exceptionpublic void setCongControl_DelayThreshold_2(double val)
throws java.lang.Exception
setCongControl_DelayThreshold_2 in interface Managementjava.lang.Exceptionpublic void setCongControl_DelayThreshold_3(double val)
throws java.lang.Exception
setCongControl_DelayThreshold_3 in interface Managementjava.lang.Exceptionpublic double getCongControl_BackToNormalDelayThreshold_1()
getCongControl_BackToNormalDelayThreshold_1 in interface Managementpublic double getCongControl_BackToNormalDelayThreshold_2()
getCongControl_BackToNormalDelayThreshold_2 in interface Managementpublic double getCongControl_BackToNormalDelayThreshold_3()
getCongControl_BackToNormalDelayThreshold_3 in interface Managementpublic void setCongControl_BackToNormalDelayThreshold_1(double val)
throws java.lang.Exception
setCongControl_BackToNormalDelayThreshold_1 in interface Managementjava.lang.Exceptionpublic void setCongControl_BackToNormalDelayThreshold_2(double val)
throws java.lang.Exception
setCongControl_BackToNormalDelayThreshold_2 in interface Managementjava.lang.Exceptionpublic void setCongControl_BackToNormalDelayThreshold_3(double val)
throws java.lang.Exception
setCongControl_BackToNormalDelayThreshold_3 in interface Managementjava.lang.Exceptionpublic java.lang.Boolean getOptionSctpDisableFragments()
getOptionSctpDisableFragments in interface Managementpublic void setOptionSctpDisableFragments(java.lang.Boolean optionSctpDisableFragments)
setOptionSctpDisableFragments in interface Managementpublic java.lang.Integer getOptionSctpFragmentInterleave()
getOptionSctpFragmentInterleave in interface Managementpublic void setOptionSctpFragmentInterleave(java.lang.Integer optionSctpFragmentInterleave)
setOptionSctpFragmentInterleave in interface Managementpublic java.lang.Boolean getOptionSctpNodelay()
getOptionSctpNodelay in interface Managementpublic void setOptionSctpNodelay(java.lang.Boolean optionSctpNodelay)
setOptionSctpNodelay in interface Managementpublic java.lang.Integer getOptionSoSndbuf()
getOptionSoSndbuf in interface Managementpublic void setOptionSoSndbuf(java.lang.Integer optionSoSndbuf)
setOptionSoSndbuf in interface Managementpublic java.lang.Integer getOptionSoRcvbuf()
getOptionSoRcvbuf in interface Managementpublic void setOptionSoRcvbuf(java.lang.Integer optionSoRcvbuf)
setOptionSoRcvbuf in interface Managementpublic java.lang.Integer getOptionSoLinger()
getOptionSoLinger in interface Managementpublic void setOptionSoLinger(java.lang.Integer optionSoLinger)
setOptionSoLinger in interface Managementpublic java.lang.Integer getOptionSctpInitMaxstreams_MaxOutStreams()
getOptionSctpInitMaxstreams_MaxOutStreams in interface Managementpublic java.lang.Integer getOptionSctpInitMaxstreams_MaxInStreams()
getOptionSctpInitMaxstreams_MaxInStreams in interface Managementpublic void setOptionSctpInitMaxstreams_MaxOutStreams(java.lang.Integer maxOutStreams)
setOptionSctpInitMaxstreams_MaxOutStreams in interface Managementpublic void setOptionSctpInitMaxstreams_MaxInStreams(java.lang.Integer maxInStreams)
setOptionSctpInitMaxstreams_MaxInStreams in interface Managementpublic void addCongestionListener(CongestionListener listener)
addCongestionListener in interface Managementpublic void removeCongestionListener(CongestionListener listener)
removeCongestionListener in interface ManagementCopyright © 2017. All Rights Reserved.