com.gigaspaces.config.lrmi.nio

Class NIOConfiguration

java.lang.Object

com.gigaspaces.config.lrmi.nio.NIOConfiguration

All Implemented Interfaces:

com.gigaspaces.config.lrmi.ITransportConfig, Externalizable, Serializable, Cloneable

public class NIOConfiguration
extends Object
implements com.gigaspaces.config.lrmi.ITransportConfig, Cloneable, Externalizable

This class provides configuration object of NIO communication transport protocol.

Since:

5.2

Author:

Igor Goldenberg

See Also:

GenericExporter, Serialized Form

Constructor Summary

Constructors

Constructor and Description
NIOConfiguration() Should not be used, only for externalizable.
NIOConfiguration(int minThreads, int maxThreads, int maxConnPool, boolean isMultiplex, String bindHostName, String bindPort) Deprecated.
NIOConfiguration(int minThreads, int maxThreads, int maxConnPool, boolean isMultiplex, String bindHostName, String bindPort, int threadsQueueSize, int slowConsumerThroughput, int slowConsumerLatency, int slowConsumerRetries) Deprecated.
NIOConfiguration(int minThreads, int maxThreads, int maxConnPool, boolean isMultiplex, String bindHostName, String bindPort, int threadsQueueSize, int slowConsumerThroughput, int slowConsumerLatency, int slowConsumerRetries, int readSelectorThreads, String watchdogRequestTimeout, String watchdogListeningTimeout, String watchdogIdleConnectionTimeout, long threadPoolIdleTimeout, String socketConnectTimeout) Deprecated.
NIOConfiguration(int minThreads, int maxThreads, int maxConnPool, boolean isMultiplex, String bindHostName, String bindPort, int readSelectorThreads, String watchdogRequestTimeout, String watchdogListeningTimeout, String watchdogIdleConnectionTimeout, long threadPoolIdleTimeout, String socketConnectTimeout) Deprecated.
NIOConfiguration(int minThreads, int maxThreads, int maxConnPool, String bindHostName, String bindPort)
NIOConfiguration(int minThreads, int maxThreads, int maxConnPool, String bindHostName, String bindPort, int threadsQueueSize, int slowConsumerThroughput, int slowConsumerLatency, int slowConsumerRetries) Deprecated.
NIOConfiguration(int minThreads, int maxThreads, int maxConnPool, String bindHostName, String bindPort, int threadsQueueSize, int slowConsumerThroughput, int slowConsumerLatency, int slowConsumerRetries, int slowConsumerReadtimeout, int readSelectorThreads, String watchdogRequestTimeout, String watchdogListeningTimeout, String watchdogIdleConnectionTimeout, long threadPoolIdleTimeout, String socketConnectTimeout, int systemPriorityQueueCapacity, long systemPriorityThreadIdleTimeout, int systemPriorityMinThreads, int systemPriorityMaxThreads, int customQueueCapacity, long customThreadIdleTimeout, int customMinThreads, int customMaxThreads, boolean protocolValidationEnabled) Constructor.
NIOConfiguration(int minThreads, int maxThreads, int maxConnPool, String bindHostName, String bindPort, int threadsQueueSize, int slowConsumerThroughput, int slowConsumerLatency, int slowConsumerRetries, int readSelectorThreads, String watchdogRequestTimeout, String watchdogListeningTimeout, String watchdogIdleConnectionTimeout, long threadPoolIdleTimeout, String socketConnectTimeout) Deprecated.
NIOConfiguration(int minThreads, int maxThreads, int maxConnPool, String bindHostName, String bindPort, int readSelectorThreads, String watchdogRequestTimeout, String watchdogListeningTimeout, String watchdogIdleConnectionTimeout, long threadPoolIdleTimeout, String socketConnectTimeout) The most commonly used constructor through the services.config configuration file.

Method Summary

Modifier and Type	Method and Description
com.gigaspaces.config.lrmi.ITransportConfig	clone()
static NIOConfiguration	create() Creates a new instance of NIO configuration based on system properties.
String	getBindHostName()
String	getBindPort()
int	getConnectionPoolSize()
int	getCustomMaxThreads()
int	getCustomMinThreads()
int	getCustomQueueCapacity()
long	getCustomThreadIdleTimeout()
int	getMaxConnPool()
int	getMaxThreads()
int	getMinThreads()
String	getProtocolAdaptorClass()
String	getProtocolName()
int	getReadSelectorThreads()
int	getSlowConsumerLatency()
int	getSlowConsumerReadTimeout()
int	getSlowConsumerRetries()
int	getSlowConsumerThroughput()
long	getSocketConnectTimeout()
int	getSystemPriorityMaxThreads()
int	getSystemPriorityMinThreads()
int	getSystemPriorityQueueCapacity()
long	getSystemPriorityThreadIdleTimeout()
long	getThreadPoolIdleTimeout()
int	getThreadsQueueSize()
long	getWatchdogIdleConnectionTimeout()
long	getWatchdogListeningTimeout()
long	getWatchdogRequestTimeout()
boolean	isBlockingConnection()
boolean	isProtocolValidationEnabled()
void	readExternal(ObjectInput in)
void	setBindHost(String bindHostName)
void	setBindPort(String bindPort)
void	setBlockingConnection(boolean blockingConnection)
void	setMaxConnPool(int maxConnPool)
void	setMaxThreads(int maxThreads)
void	setMinThreads(int minThreads)
void	setSlowConsumerLatency(int slowConsumerLatency)
void	setSlowConsumerReadTimeout(int slowConsumerReadTimeout)
void	setSlowConsumerRetries(int slowConsumerRetries)
void	setSlowConsumerThroughput(int slowConsumerThroughput)
void	setThreadsQueueSize(int threadsQueueSize)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

NIOConfiguration

@Deprecated
public NIOConfiguration(int minThreads,
                                    int maxThreads,
                                    int maxConnPool,
                                    boolean isMultiplex,
                                    String bindHostName,
                                    String bindPort)

Deprecated.

NIOConfiguration

public NIOConfiguration(int minThreads,
                        int maxThreads,
                        int maxConnPool,
                        String bindHostName,
                        String bindPort)

NIOConfiguration

@Deprecated
public NIOConfiguration(int minThreads,
                                    int maxThreads,
                                    int maxConnPool,
                                    boolean isMultiplex,
                                    String bindHostName,
                                    String bindPort,
                                    int readSelectorThreads,
                                    String watchdogRequestTimeout,
                                    String watchdogListeningTimeout,
                                    String watchdogIdleConnectionTimeout,
                                    long threadPoolIdleTimeout,
                                    String socketConnectTimeout)

Deprecated.

The most commonly used constructor through the services.config configuration file.

NIOConfiguration

public NIOConfiguration(int minThreads,
                        int maxThreads,
                        int maxConnPool,
                        String bindHostName,
                        String bindPort,
                        int readSelectorThreads,
                        String watchdogRequestTimeout,
                        String watchdogListeningTimeout,
                        String watchdogIdleConnectionTimeout,
                        long threadPoolIdleTimeout,
                        String socketConnectTimeout)

The most commonly used constructor through the services.config configuration file.

NIOConfiguration

@Deprecated
public NIOConfiguration(int minThreads,
                                    int maxThreads,
                                    int maxConnPool,
                                    boolean isMultiplex,
                                    String bindHostName,
                                    String bindPort,
                                    int threadsQueueSize,
                                    int slowConsumerThroughput,
                                    int slowConsumerLatency,
                                    int slowConsumerRetries,
                                    int readSelectorThreads,
                                    String watchdogRequestTimeout,
                                    String watchdogListeningTimeout,
                                    String watchdogIdleConnectionTimeout,
                                    long threadPoolIdleTimeout,
                                    String socketConnectTimeout)

Deprecated.

NIOConfiguration

@Deprecated
public NIOConfiguration(int minThreads,
                                    int maxThreads,
                                    int maxConnPool,
                                    String bindHostName,
                                    String bindPort,
                                    int threadsQueueSize,
                                    int slowConsumerThroughput,
                                    int slowConsumerLatency,
                                    int slowConsumerRetries,
                                    int readSelectorThreads,
                                    String watchdogRequestTimeout,
                                    String watchdogListeningTimeout,
                                    String watchdogIdleConnectionTimeout,
                                    long threadPoolIdleTimeout,
                                    String socketConnectTimeout)

Deprecated.

NIOConfiguration

public NIOConfiguration(int minThreads,
                        int maxThreads,
                        int maxConnPool,
                        String bindHostName,
                        String bindPort,
                        int threadsQueueSize,
                        int slowConsumerThroughput,
                        int slowConsumerLatency,
                        int slowConsumerRetries,
                        int slowConsumerReadtimeout,
                        int readSelectorThreads,
                        String watchdogRequestTimeout,
                        String watchdogListeningTimeout,
                        String watchdogIdleConnectionTimeout,
                        long threadPoolIdleTimeout,
                        String socketConnectTimeout,
                        int systemPriorityQueueCapacity,
                        long systemPriorityThreadIdleTimeout,
                        int systemPriorityMinThreads,
                        int systemPriorityMaxThreads,
                        int customQueueCapacity,
                        long customThreadIdleTimeout,
                        int customMinThreads,
                        int customMaxThreads,
                        boolean protocolValidationEnabled)

Constructor.

Parameters:

minThreads - Maintains thread pool in Client and Server that manage incoming remote requests. The thread pool size is increased each time with one additional thread and shrinks when existing threads are not used for 5 minutes. This parameter specifies the minimum size of this thread pool.

maxThreads - This parameter specifies the maximum size of this thread pool. You should make sure the pool max size will accommodate the maximum number of concurrent requests to the serverEndPoint. When the pool is exhausted and all threads are consumed to process incoming requests, additional requests will be blocked until existing requested processing will be completed.

maxConnPool - Client connection pool maximum size to server. Starts with 1 connection.

bindHostName - The host address the server socket is bound to. Relevant for the multi-NIC environment. If null resolves to the localhost IP address.

bindPort - the bind port used for incoming client requests. The server port is set by default to 0, which means next free port. This means that whenever the serverEndPoint is launched it allocates one of the available ports. Define a specific port value to enforce a specific port for the serverEndPoint.

threadsQueueSize - Maintains thread pool queue size in Client and Server that manage incoming remote requests. Once the queue sized is reached the incoming messages are blocked.

slowConsumerThroughput - a client that its network throughput doesn't reach this limit will be suspected as slow.

slowConsumerLatency - a client that is suspected as slow that will not be recover after this time will be disconnected.

slowConsumerRetries - the number of retries to recover a client that is suspected as slow.

slowConsumerReadtimeout - the allowed time to read a reply until it is considered slow consuming

readSelectorThreads - LRMI number of read selector threads default = 1.

watchdogRequestTimeout - LRMI Watchdog request timeout.

watchdogListeningTimeout - LRMI Watchdog Listening timeout.

watchdogIdleConnectionTimeout -

threadPoolIdleTimeout - LRMI ThreadPool idle timeout

socketConnectTimeout - The timeout on lrmi socket connect.

systemPriorityQueueCapacity - TODO

protocolValidationEnabled - TODO

See Also:

SystemProperties.LRMI_READ_SELECTOR_THREADS, SystemProperties.WATCHDOG_REQUEST_TIMEOUT_DEFAULT, SystemProperties.WATCHDOG_LISTENING_TIMEOUT_DEFAULT

NIOConfiguration

@Deprecated
public NIOConfiguration(int minThreads,
                                    int maxThreads,
                                    int maxConnPool,
                                    boolean isMultiplex,
                                    String bindHostName,
                                    String bindPort,
                                    int threadsQueueSize,
                                    int slowConsumerThroughput,
                                    int slowConsumerLatency,
                                    int slowConsumerRetries)

Deprecated.

NIOConfiguration

@Deprecated
public NIOConfiguration(int minThreads,
                                    int maxThreads,
                                    int maxConnPool,
                                    String bindHostName,
                                    String bindPort,
                                    int threadsQueueSize,
                                    int slowConsumerThroughput,
                                    int slowConsumerLatency,
                                    int slowConsumerRetries)

Deprecated.

NIOConfiguration

public NIOConfiguration()

Should not be used, only for externalizable.

Method Detail

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

create

public static NIOConfiguration create()

Creates a new instance of NIO configuration based on system properties.

clone

public com.gigaspaces.config.lrmi.ITransportConfig clone()

Specified by:

clone in interface com.gigaspaces.config.lrmi.ITransportConfig

Overrides:

clone in class Object

getProtocolAdaptorClass

public String getProtocolAdaptorClass()

Specified by:

getProtocolAdaptorClass in interface com.gigaspaces.config.lrmi.ITransportConfig

getMinThreads

public int getMinThreads()

Specified by:

getMinThreads in interface com.gigaspaces.config.lrmi.ITransportConfig

setMinThreads

public void setMinThreads(int minThreads)

getMaxThreads

public int getMaxThreads()

Specified by:

getMaxThreads in interface com.gigaspaces.config.lrmi.ITransportConfig

setMaxThreads

public void setMaxThreads(int maxThreads)

getThreadsQueueSize

public int getThreadsQueueSize()

Specified by:

getThreadsQueueSize in interface com.gigaspaces.config.lrmi.ITransportConfig

setThreadsQueueSize

public void setThreadsQueueSize(int threadsQueueSize)

getConnectionPoolSize

public int getConnectionPoolSize()

Specified by:

getConnectionPoolSize in interface com.gigaspaces.config.lrmi.ITransportConfig

setMaxConnPool

public void setMaxConnPool(int maxConnPool)

setBindHost

public void setBindHost(String bindHostName)

setBindPort

public void setBindPort(String bindPort)

setBlockingConnection

public void setBlockingConnection(boolean blockingConnection)

getMaxConnPool

public int getMaxConnPool()

getBindPort

public String getBindPort()

getBindHostName

public String getBindHostName()

getProtocolName

public final String getProtocolName()

Specified by:

getProtocolName in interface com.gigaspaces.config.lrmi.ITransportConfig

isBlockingConnection

public boolean isBlockingConnection()

Specified by:

isBlockingConnection in interface com.gigaspaces.config.lrmi.ITransportConfig

getSlowConsumerLatency

public int getSlowConsumerLatency()

Specified by:

getSlowConsumerLatency in interface com.gigaspaces.config.lrmi.ITransportConfig

setSlowConsumerLatency

public void setSlowConsumerLatency(int slowConsumerLatency)

getSlowConsumerRetries

public int getSlowConsumerRetries()

Specified by:

getSlowConsumerRetries in interface com.gigaspaces.config.lrmi.ITransportConfig

setSlowConsumerRetries

public void setSlowConsumerRetries(int slowConsumerRetries)

getSlowConsumerReadTimeout

public int getSlowConsumerReadTimeout()

setSlowConsumerReadTimeout

public void setSlowConsumerReadTimeout(int slowConsumerReadTimeout)

getSlowConsumerThroughput

public int getSlowConsumerThroughput()

Specified by:

getSlowConsumerThroughput in interface com.gigaspaces.config.lrmi.ITransportConfig

setSlowConsumerThroughput

public void setSlowConsumerThroughput(int slowConsumerThroughput)

getReadSelectorThreads

public int getReadSelectorThreads()

Specified by:

getReadSelectorThreads in interface com.gigaspaces.config.lrmi.ITransportConfig

Returns:

Returns the _readSelectorThreads.

getSystemPriorityQueueCapacity

public int getSystemPriorityQueueCapacity()

Specified by:

getSystemPriorityQueueCapacity in interface com.gigaspaces.config.lrmi.ITransportConfig

getSystemPriorityThreadIdleTimeout

public long getSystemPriorityThreadIdleTimeout()

Specified by:

getSystemPriorityThreadIdleTimeout in interface com.gigaspaces.config.lrmi.ITransportConfig

getSystemPriorityMinThreads

public int getSystemPriorityMinThreads()

getSystemPriorityMaxThreads

public int getSystemPriorityMaxThreads()

getCustomQueueCapacity

public int getCustomQueueCapacity()

getCustomThreadIdleTimeout

public long getCustomThreadIdleTimeout()

getCustomMinThreads

public int getCustomMinThreads()

getCustomMaxThreads

public int getCustomMaxThreads()

getWatchdogRequestTimeout

public long getWatchdogRequestTimeout()

Specified by:

getWatchdogRequestTimeout in interface com.gigaspaces.config.lrmi.ITransportConfig

Returns:

Returns the _watchdogRequestTimeout.

getWatchdogListeningTimeout

public long getWatchdogListeningTimeout()

Specified by:

getWatchdogListeningTimeout in interface com.gigaspaces.config.lrmi.ITransportConfig

Returns:

Returns the _watchdogListeningTimeout.

getWatchdogIdleConnectionTimeout

public long getWatchdogIdleConnectionTimeout()

Specified by:

getWatchdogIdleConnectionTimeout in interface com.gigaspaces.config.lrmi.ITransportConfig

Returns:

Returns the _watchdogIdleConnectionTimeout.

getThreadPoolIdleTimeout

public long getThreadPoolIdleTimeout()

Specified by:

getThreadPoolIdleTimeout in interface com.gigaspaces.config.lrmi.ITransportConfig

getSocketConnectTimeout

public long getSocketConnectTimeout()

Specified by:

getSocketConnectTimeout in interface com.gigaspaces.config.lrmi.ITransportConfig

isProtocolValidationEnabled

public boolean isProtocolValidationEnabled()

toString

public String toString()

Overrides:

toString in class Object