Modifier and Type | Method and Description |
---|---|
static void |
addEventListener(EventListener listener) |
static void |
addEventListener(String threadPrefix,
EventListener listener) |
ListeningInterface |
addListeningInterface(InetAddress addressToBind,
int portToBind,
int backlog,
ProtocolContext context)
Add an interface and port to the listening socket list and provide the
protocol context.
|
ListeningInterface |
addListeningInterface(InetAddress addressToBind,
int portToBind,
ProtocolContext context)
Add an interface and port to the listening socket list and provide the
protocol context.
|
ListeningInterface |
addListeningInterface(String addressToBind,
int portToBind,
int backlog,
ProtocolContext context)
Add an interface and port to the listening socket list and provide the
protocol context.
|
ListeningInterface |
addListeningInterface(String addressToBind,
int portToBind,
ProtocolContext context)
Add an interface and port to the listening socket list and provide the
protocol context.
|
int |
getAcceptThreadPriorty() |
<K> K |
getAttribute(String name,
K defaultValue) |
ByteBufferPool |
getBufferPool()
Returns a direct buffer pool.
|
int |
getConnectThreadPriority() |
int |
getIdleServiceRunPeriod()
Get the time in seconds for each idle period service run.
|
int |
getInactiveServiceRunsPerIdleEvent()
To determine whether any channels are idle a service run is performed to
evaluate the state of each channel.
|
String |
getIpv6WorkaroundBindAddress() |
int |
getIpv6WorkaroundPort() |
ListeningInterface[] |
getListeningInterfaces()
Get the listening socket list.
|
int |
getMaximumChannelsPerThread()
Get the maximum number of channels that can be serviced by a single
selector thread.
|
int |
getPermanentAcceptThreads()
Get the number of permanent accept threads.
|
int |
getPermanentConnectThreads()
Get the number of permanent connect threads.
|
int |
getPermanentTransferThreads()
Get the number of permanent transfer threads.
|
String |
getProduct()
Get the product name used to prefix thread names
|
SelectorProvider |
getSelectorProvider()
Get the SelectorProvider used to create Selector instances.
|
Daemon |
getServer()
Get the instance of the SSHD for this context.
|
int |
getTransferThreadPriority() |
boolean |
isUsingDirectBuffers()
Determine whether the daemon is using direct byte buffers.
|
static void |
removeEventListener(EventListener listener) |
static void |
removeEventListener(String threadPrefix) |
void |
removeListeningInterface(InetAddress addressBound,
int portBound)
Remove a listening interface from the daemon at runtime.
|
void |
removeListeningInterface(String addressBound,
int portBound)
Remove a listening interface from the daemon at runtime.
|
void |
setAcceptThreadPriorty(int acceptThreadPriorty) |
void |
setAttribute(String name,
Object value) |
void |
setBufferPoolArraySize(int bufferPoolArraySize)
Set the size of the byte buffers in the pool.
|
void |
setConnectThreadPriority(int connectThreadPriority) |
void |
setIdleServiceRunPeriod(int idleServicePeriod) |
void |
setInactiveServiceRunsPerIdleEvent(int inactivePeriodsPerIdleEvent)
To determine whether any channels are idle a service run is performed to
evaluate the state of each channel.
|
void |
setIpv6WorkaroundBindAddress(String ipv6WorkaroundBindAddress) |
void |
setIpv6WorkaroundPort(int ipv6WorkaroundPort) |
void |
setMaximumChannelsPerThread(int maximumChannelsPerThread)
Set the maximum number of channels that can be serviced by a single
selector thread.
|
void |
setPermanentAcceptThreads(int permanentAcceptThreads)
Set the number of permanent accept threads.
|
void |
setPermanentConnectThreads(int permanentConnectThreads)
Set the number of permanent connect threads.
|
void |
setPermanentTransferThreads(int permanentTransferThreads)
Set the number of permanent transfer threads.
|
void |
setProduct(String product)
Set the product name used to prefix thread names
|
void |
setSelectorProvider(SelectorProvider selectorProvider)
Set the SelectorProvider used by the Selector threads.
|
void |
setTransferThreadPriority(int transferThreadPriority) |
void |
setUsingDirectBuffers(boolean useDirectByteBuffers)
Configure the byte buffer pool to use direct byte buffers.
|
public void setProduct(String product)
String
- productpublic String getProduct()
public ByteBufferPool getBufferPool()
public void setSelectorProvider(SelectorProvider selectorProvider)
selectorProvider
- SelectorProviderpublic SelectorProvider getSelectorProvider()
public Daemon getServer()
public boolean isUsingDirectBuffers()
public void setUsingDirectBuffers(boolean useDirectByteBuffers)
useDirectByteBuffers
- booleanpublic void setBufferPoolArraySize(int bufferPoolArraySize)
bufferPoolArraySize
- intpublic ListeningInterface addListeningInterface(String addressToBind, int portToBind, ProtocolContext context) throws IOException
addressToBind
- StringportToBind
- intprotocolContext
- IOException
IOException
public ListeningInterface addListeningInterface(String addressToBind, int portToBind, int backlog, ProtocolContext context) throws IOException
addressToBind
- StringportToBind
- intbacklog
- protocolContext
- IOException
IOException
public ListeningInterface addListeningInterface(InetAddress addressToBind, int portToBind, ProtocolContext context) throws IOException
addressToBind
- portToBind
- context
- IOException
public ListeningInterface addListeningInterface(InetAddress addressToBind, int portToBind, int backlog, ProtocolContext context) throws IOException
addressToBind
- portToBind
- backlog
- context
- IOException
public void removeListeningInterface(InetAddress addressBound, int portBound)
addressBound
- portBound
- public void removeListeningInterface(String addressBound, int portBound) throws UnknownHostException
addressBound
- portBound
- UnknownHostException
public ListeningInterface[] getListeningInterfaces()
public int getPermanentAcceptThreads()
public void setPermanentAcceptThreads(int permanentAcceptThreads)
An accept thread services the asynchronous server socket by processing requests for connections. Once a connection has been accepted it is then registered with a transfer thread where all IO is handled.
The server maintains this number of permanent threads but will also dynamically create additional threads if the permanent threads are overloaded.
permanentAcceptThreads
- public int getPermanentConnectThreads()
public void setPermanentConnectThreads(int permanentConnectThreads)
permanentConnectThreads
- public int getPermanentTransferThreads()
public void setPermanentTransferThreads(int permanentTransferThreads)
permanentAcceptThreads
- public int getMaximumChannelsPerThread()
public void setMaximumChannelsPerThread(int maximumChannelsPerThread)
maximumChannelsPerThread
- public int getIdleServiceRunPeriod()
public void setIdleServiceRunPeriod(int idleServicePeriod)
idleServicePeriod
- intpublic int getInactiveServiceRunsPerIdleEvent()
public void setInactiveServiceRunsPerIdleEvent(int inactivePeriodsPerIdleEvent)
inactivePeriodsPerIdleEvent
- intpublic static void addEventListener(EventListener listener)
public static void addEventListener(String threadPrefix, EventListener listener)
public static void removeEventListener(EventListener listener)
public static void removeEventListener(String threadPrefix)
public int getIpv6WorkaroundPort()
public void setIpv6WorkaroundPort(int ipv6WorkaroundPort)
public String getIpv6WorkaroundBindAddress()
public void setIpv6WorkaroundBindAddress(String ipv6WorkaroundBindAddress)
public <K> K getAttribute(String name, K defaultValue)
public int getAcceptThreadPriorty()
public void setAcceptThreadPriorty(int acceptThreadPriorty)
public int getConnectThreadPriority()
public void setConnectThreadPriority(int connectThreadPriority)
public int getTransferThreadPriority()
public void setTransferThreadPriority(int transferThreadPriority)
Copyright © 2023. All rights reserved.