public static class IOReactorConfig.Builder extends Object
Modifier and Type | Method and Description |
---|---|
IOReactorConfig |
build() |
static int |
getDefaultMaxIOThreadCount()
Gets the default value for
ioThreadCount . |
IOReactorConfig.Builder |
setBacklogSize(int backlogSize)
Sets the default backlog size value for server sockets binds.
|
static void |
setDefaultMaxIOThreadCount(int defaultMaxIOThreadCount)
Sets the default value for
ioThreadCount . |
IOReactorConfig.Builder |
setIoThreadCount(int ioThreadCount)
Sets the number of I/O dispatch threads to be used by the I/O reactor.
|
IOReactorConfig.Builder |
setRcvBufSize(int rcvBufSize)
Sets the default value of the
SocketOptions.SO_RCVBUF parameter
for newly created sockets. |
IOReactorConfig.Builder |
setSelectInterval(TimeValue selectInterval)
Sets time interval at which the I/O reactor wakes up to check for timed out sessions
and session requests.
|
IOReactorConfig.Builder |
setSndBufSize(int sndBufSize)
Sets the default value of the
SocketOptions.SO_SNDBUF parameter
for newly created sockets. |
IOReactorConfig.Builder |
setSocksProxyAddress(SocketAddress socksProxyAddress)
Sets the address of the SOCKS proxy to use.
|
IOReactorConfig.Builder |
setSocksProxyPassword(String socksProxyPassword)
Sets the password to provide to the SOCKS proxy for username/password authentication.
|
IOReactorConfig.Builder |
setSocksProxyUsername(String socksProxyUsername)
Sets the username to provide to the SOCKS proxy for username/password authentication.
|
IOReactorConfig.Builder |
setSoKeepAlive(boolean soKeepAlive)
Sets the default value of the
SocketOptions.SO_KEEPALIVE parameter
for newly created sockets. |
IOReactorConfig.Builder |
setSoLinger(int soLinger,
TimeUnit timeUnit)
Sets the default value of the
SocketOptions.SO_LINGER parameter
for newly created sockets. |
IOReactorConfig.Builder |
setSoLinger(TimeValue soLinger)
Sets the default value of the
SocketOptions.SO_LINGER parameter
for newly created sockets. |
IOReactorConfig.Builder |
setSoReuseAddress(boolean soReuseAddress)
Sets the default value of the
SocketOptions.SO_REUSEADDR parameter
for newly created sockets. |
IOReactorConfig.Builder |
setSoTimeout(int soTimeout,
TimeUnit timeUnit)
Sets the default socket timeout value for non-blocking I/O operations.
|
IOReactorConfig.Builder |
setSoTimeout(Timeout soTimeout)
Sets the default socket timeout value for non-blocking I/O operations.
|
IOReactorConfig.Builder |
setTcpKeepCount(int tcpKeepCount)
Sets the maximum number of keepalive probes TCP should send before dropping the connection.
|
IOReactorConfig.Builder |
setTcpKeepIdle(int tcpKeepIdle)
Sets the time (in seconds) the connection needs to remain idle before TCP starts
sending keepalive probes.
|
IOReactorConfig.Builder |
setTcpKeepInterval(int tcpKeepInterval)
Sets the time (in seconds) between individual keepalive probes.
|
IOReactorConfig.Builder |
setTcpNoDelay(boolean tcpNoDelay)
Sets the default value of the
SocketOptions.TCP_NODELAY parameter
for newly created sockets. |
IOReactorConfig.Builder |
setTrafficClass(int trafficClass)
Sets the default value of the
SocketOptions.IP_TOS parameter
for newly created sockets. |
public static int getDefaultMaxIOThreadCount()
ioThreadCount
. Returns
Runtime.availableProcessors()
if
setDefaultMaxIOThreadCount(int)
was called with a value less <= 0.public static void setDefaultMaxIOThreadCount(int defaultMaxIOThreadCount)
ioThreadCount
. Use a value <= 0 to
cause getDefaultMaxIOThreadCount()
to return
Runtime.availableProcessors()
.defaultMaxIOThreadCount
- the default value for ioThreadCount.public IOReactorConfig.Builder setSelectInterval(TimeValue selectInterval)
Default: 1000
milliseconds.
public IOReactorConfig.Builder setIoThreadCount(int ioThreadCount)
Default: 2
public IOReactorConfig.Builder setSoTimeout(int soTimeout, TimeUnit timeUnit)
Default: 0
(no timeout)
SocketOptions.SO_TIMEOUT
public IOReactorConfig.Builder setSoTimeout(Timeout soTimeout)
Default: 0
(no timeout)
SocketOptions.SO_TIMEOUT
public IOReactorConfig.Builder setSoReuseAddress(boolean soReuseAddress)
SocketOptions.SO_REUSEADDR
parameter
for newly created sockets.
Default: false
SocketOptions.SO_REUSEADDR
public IOReactorConfig.Builder setSoLinger(int soLinger, TimeUnit timeUnit)
SocketOptions.SO_LINGER
parameter
for newly created sockets.
Default: -1
SocketOptions.SO_LINGER
public IOReactorConfig.Builder setSoLinger(TimeValue soLinger)
SocketOptions.SO_LINGER
parameter
for newly created sockets.
Default: -1
SocketOptions.SO_LINGER
public IOReactorConfig.Builder setSoKeepAlive(boolean soKeepAlive)
SocketOptions.SO_KEEPALIVE
parameter
for newly created sockets.
Default: -1
SocketOptions.SO_KEEPALIVE
public IOReactorConfig.Builder setTcpNoDelay(boolean tcpNoDelay)
SocketOptions.TCP_NODELAY
parameter
for newly created sockets.
Default: false
SocketOptions.TCP_NODELAY
public IOReactorConfig.Builder setTrafficClass(int trafficClass)
SocketOptions.IP_TOS
parameter
for newly created sockets.
Default: 0
SocketOptions.IP_TOS
public IOReactorConfig.Builder setSndBufSize(int sndBufSize)
SocketOptions.SO_SNDBUF
parameter
for newly created sockets.
Default: 0
(system default)
SocketOptions.SO_SNDBUF
public IOReactorConfig.Builder setRcvBufSize(int rcvBufSize)
SocketOptions.SO_RCVBUF
parameter
for newly created sockets.
Default: 0
(system default)
SocketOptions.SO_RCVBUF
public IOReactorConfig.Builder setBacklogSize(int backlogSize)
Default: 0
(system default)
public IOReactorConfig.Builder setTcpKeepIdle(int tcpKeepIdle)
public IOReactorConfig.Builder setTcpKeepInterval(int tcpKeepInterval)
public IOReactorConfig.Builder setTcpKeepCount(int tcpKeepCount)
public IOReactorConfig.Builder setSocksProxyAddress(SocketAddress socksProxyAddress)
public IOReactorConfig.Builder setSocksProxyUsername(String socksProxyUsername)
public IOReactorConfig.Builder setSocksProxyPassword(String socksProxyPassword)
public IOReactorConfig build()
Copyright © 2005–2021 The Apache Software Foundation. All rights reserved.