org.gridgain.grid.dr.hub.receiver

Class GridDrReceiverHubConfiguration

java.lang.Object

org.gridgain.grid.dr.hub.receiver.GridDrReceiverHubConfiguration

public class GridDrReceiverHubConfiguration
extends Object

Data center replication receiver hub configuration.

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	DFLT_DIRECT_BUF Default value of direct buffer allocation.
static long	DFLT_FLUSH_FREQ Default flush frequency DR data loader.
static long	DFLT_IDLE_TIMEOUT Default server socket idle timeout.
static int	DFLT_LOCAL_PORT Default server port.
static int	DFLT_MSG_QUEUE_LIMIT Default message queue limit per connection (for incoming and outgoing .
static int	DFLT_PARALLEL_LOAD_OPS Default per node parallel operations for DR data loader.
static int	DFLT_PER_NODE_BUF_SIZE Default per node buffer buffer size for DR data loader.
static int	DFLT_SELECTOR_CNT Default quantity of NIO threads responsible for sender hub connections processing.
static boolean	DFLT_TCP_NODELAY Default TCP_NODELAY flag value for server sockets.
static int	DFLT_WORKER_THREAD_CNT Default number of threads responsible for sender hub requests processing.
static long	DFLT_WRITE_TIMEOUT Default server socket write timeout.

Constructor Summary

Constructors

Constructor and Description
GridDrReceiverHubConfiguration() Default constructor.
GridDrReceiverHubConfiguration(GridDrReceiverHubConfiguration cfg) Copying constructor.

Method Summary

Methods

Modifier and Type	Method and Description
long	getFlushFrequency() Gets data flush frequency.
long	getIdleTimeout() Gets idle timeout for receiver hub's TCP server connection.
String	getLocalInboundHost() Gets local host name receiver hub TCP server is bound to.
int	getLocalInboundPort() Gets local port receiver hub TCP server is bound to.
int	getMessageQueueLimit() Gets message queue limit for incoming and outgoing messages in receiver hub's TCP server.
int	getPerNodeBufferSize() Gets per-node data buffer size.
int	getPerNodeParallelLoadOperations() Gets per-node parallel load operations.
int	getSelectorCount() Gets amount of selector threads in receiver hub's TCP server.
int	getWorkerThreads() Gets amount of threads responsible for sender hub batches processing.
long	getWriteTimeout() Gets write timeout for receiver hub's TCP server connection.
boolean	isDirectBuffer() Gets direct buffer flag in receiver hub's TCP server.
boolean	isTcpNodelay() Gets TCP_NODELAY flag in receiver hub's TCP server.
void	setDirectBuffer(boolean directBuf) Sets direct buffer flag in receiver hub's TCP server.
void	setFlushFrequency(long flushFreq) Sets data flush frequency.
void	setIdleTimeout(long idleTimeout) Sets idle timeout for receiver hub's TCP server connection.
void	setLocalInboundHost(String locInboundHost) Sets local host name receiver hub TCP server is bound to.
void	setLocalInboundPort(int locInboundPort) Sets local port receiver hub TCP server is bound to.
void	setMessageQueueLimit(int msgQueueLimit) Sets message queue limit for incoming and outgoing messages in receiver hub's TCP server.
void	setPerNodeBufferSize(int perNodeBufSize) Sets per-node data buffer size.
void	setPerNodeParallelLoadOperations(int perNodeParallelLoadOps) Sets per-node parallel load operations.
void	setSelectorCount(int selectorCnt) Sets amount of selector threads in receiver hub's TCP server.
void	setTcpNodelay(boolean tcpNodelay) Sets TCP_NODELAY flag in receiver hub's TCP server.
void	setWorkerThreads(int workerCnt) Sets amount of threads responsible for sender hub batches processing.
void	setWriteTimeout(long writeTimeout) Sets write timeout for receiver hub's TCP server connection.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

DFLT_LOCAL_PORT

public static final int DFLT_LOCAL_PORT

Default server port.

See Also:

Constant Field Values

DFLT_SELECTOR_CNT

public static final int DFLT_SELECTOR_CNT

Default quantity of NIO threads responsible for sender hub connections processing.

DFLT_WORKER_THREAD_CNT

public static final int DFLT_WORKER_THREAD_CNT

Default number of threads responsible for sender hub requests processing.

DFLT_MSG_QUEUE_LIMIT

public static final int DFLT_MSG_QUEUE_LIMIT

Default message queue limit per connection (for incoming and outgoing .

See Also:

Constant Field Values

DFLT_TCP_NODELAY

public static final boolean DFLT_TCP_NODELAY

Default TCP_NODELAY flag value for server sockets.

See Also:

Constant Field Values

DFLT_DIRECT_BUF

public static final boolean DFLT_DIRECT_BUF

Default value of direct buffer allocation.

See Also:

Constant Field Values

DFLT_IDLE_TIMEOUT

public static final long DFLT_IDLE_TIMEOUT

Default server socket idle timeout.

See Also:

Constant Field Values

DFLT_WRITE_TIMEOUT

public static final long DFLT_WRITE_TIMEOUT

Default server socket write timeout.

See Also:

Constant Field Values

DFLT_FLUSH_FREQ

public static final long DFLT_FLUSH_FREQ

Default flush frequency DR data loader.

See Also:

Constant Field Values

DFLT_PER_NODE_BUF_SIZE

public static final int DFLT_PER_NODE_BUF_SIZE

Default per node buffer buffer size for DR data loader.

See Also:

Constant Field Values

DFLT_PARALLEL_LOAD_OPS

public static final int DFLT_PARALLEL_LOAD_OPS

Default per node parallel operations for DR data loader.

See Also:

Constant Field Values

Constructor Detail

GridDrReceiverHubConfiguration

public GridDrReceiverHubConfiguration()

Default constructor.

GridDrReceiverHubConfiguration

public GridDrReceiverHubConfiguration(GridDrReceiverHubConfiguration cfg)

Copying constructor.

Parameters:

cfg - Configuration to copy.

Method Detail

getLocalInboundHost

public String getLocalInboundHost()

Gets local host name receiver hub TCP server is bound to.

If not set, GridConfiguration.getLocalHost() will be used.

Defaults to null.

Returns:

Local host name receiver hub TCP server is bound to.

setLocalInboundHost

public void setLocalInboundHost(String locInboundHost)

Sets local host name receiver hub TCP server is bound to. See getLocalInboundHost() for more information.

Parameters:

locInboundHost - Local host name receiver hub TCP server is bound to.

getLocalInboundPort

public int getLocalInboundPort()

Gets local port receiver hub TCP server is bound to.

Defaults to DFLT_LOCAL_PORT.

Returns:

Local port receiver hub TCP server is bound to.

setLocalInboundPort

public void setLocalInboundPort(int locInboundPort)

Sets local port receiver hub TCP server is bound to. See getLocalInboundPort() for more information.

Parameters:

locInboundPort - Local port receiver hub TCP server is bound to.

getSelectorCount

public int getSelectorCount()

Gets amount of selector threads in receiver hub's TCP server.

Defaults to DFLT_SELECTOR_CNT.

Returns:

Amount of selector threads in receiver hub's TCP server.

setSelectorCount

public void setSelectorCount(int selectorCnt)

Sets amount of selector threads in receiver hub's TCP server. See getSelectorCount() for more information.

Parameters:

selectorCnt - Amount of selector threads in receiver hub's TCP server.

getWorkerThreads

public int getWorkerThreads()

Gets amount of threads responsible for sender hub batches processing.

Defaults to DFLT_WORKER_THREAD_CNT.

Returns:

Amount of threads responsible for sender hub batches processing.

setWorkerThreads

public void setWorkerThreads(int workerCnt)

Sets amount of threads responsible for sender hub batches processing. See getWorkerThreads() for more information.

Parameters:

workerCnt - Amount of threads responsible for sender hub batches processing.

getMessageQueueLimit

public int getMessageQueueLimit()

Gets message queue limit for incoming and outgoing messages in receiver hub's TCP server.

Defaults to DFLT_MSG_QUEUE_LIMIT.

Returns:

Message queue limit for incoming and outgoing messages in receiver hub's TCP server.

setMessageQueueLimit

public void setMessageQueueLimit(int msgQueueLimit)

Sets message queue limit for incoming and outgoing messages in receiver hub's TCP server. See getMessageQueueLimit() for more information.

Parameters:

msgQueueLimit - Message queue limit for incoming and outgoing messages in receiver hub's TCP server.

isTcpNodelay

public boolean isTcpNodelay()

Gets TCP_NODELAY flag in receiver hub's TCP server.

Defaults to DFLT_TCP_NODELAY.

Returns:

TCP_NODELAY flag in receiver hub's TCP server.

setTcpNodelay

public void setTcpNodelay(boolean tcpNodelay)

Sets TCP_NODELAY flag in receiver hub's TCP server. See isTcpNodelay() for more information.

Parameters:

tcpNodelay - TCP_NODELAY flag in receiver hub's TCP server.

isDirectBuffer

public boolean isDirectBuffer()

Gets direct buffer flag in receiver hub's TCP server.

Defaults to DFLT_DIRECT_BUF.

Returns:

Direct buffer flag in receiver hub's TCP server.

setDirectBuffer

public void setDirectBuffer(boolean directBuf)

Sets direct buffer flag in receiver hub's TCP server. See isDirectBuffer() for more information.

Parameters:

directBuf - Direct buffer flag in receiver hub's TCP server.

getIdleTimeout

public long getIdleTimeout()

Gets idle timeout for receiver hub's TCP server connection.

Defaults to DFLT_IDLE_TIMEOUT.

Returns:

Idle timeout for receiver hub's TCP server connection.

setIdleTimeout

public void setIdleTimeout(long idleTimeout)

Sets idle timeout for receiver hub's TCP server connection. See getWriteTimeout() for more information.

Parameters:

idleTimeout - Idle timeout for receiver hub's TCP server connection.

getWriteTimeout

public long getWriteTimeout()

Gets write timeout for receiver hub's TCP server connection.

Defaults to DFLT_WRITE_TIMEOUT.

Returns:

Write timeout for receiver hub's TCP server connection.

setWriteTimeout

public void setWriteTimeout(long writeTimeout)

Sets write timeout for receiver hub's TCP server connection. See getWriteTimeout() for more information.

Parameters:

writeTimeout - Write timeout for receiver hub's TCP server connection.

getFlushFrequency

public long getFlushFrequency()

Gets data flush frequency. Defines how often receiver hub flushes batches received from sender hubs to receiver caches.

Defaults to DFLT_FLUSH_FREQ.

Returns:

Data flush frequency.

setFlushFrequency

public void setFlushFrequency(long flushFreq)

Sets data flush frequency. See getFlushFrequency() for more information.

Parameters:

flushFreq - Data flush frequency.

getPerNodeBufferSize

public int getPerNodeBufferSize()

Gets per-node data buffer size. When amount of cache entries enqueued for particular receiver cache data node exceeds this limit, pending data will be flushed to that data node.

Defaults to DFLT_PER_NODE_BUF_SIZE.

Returns:

Per-node data buffer size.

setPerNodeBufferSize

public void setPerNodeBufferSize(int perNodeBufSize)

Sets per-node data buffer size. See getPerNodeBufferSize() for more information.

Parameters:

perNodeBufSize - Per-node data buffer size.

getPerNodeParallelLoadOperations

public int getPerNodeParallelLoadOperations()

Gets per-node parallel load operations. Defines how many data flush operations can be performed on a single receiver cache data node simultaneously.

Defaults DFLT_PARALLEL_LOAD_OPS.

Returns:

Per-node parallel load operations

setPerNodeParallelLoadOperations

public void setPerNodeParallelLoadOperations(int perNodeParallelLoadOps)

Sets per-node parallel load operations. See getPerNodeParallelLoadOperations() for more information.

Parameters:

perNodeParallelLoadOps - Per-node parallel load operations

toString

public String toString()

Overrides:

toString in class Object