org.gridgain.grid.segmentation.tcp

Class TcpSegmentationResolver

java.lang.Object

org.gridgain.grid.segmentation.tcp.TcpSegmentationResolver

All Implemented Interfaces:

Serializable, SegmentationResolver

public class TcpSegmentationResolver
extends Object
implements SegmentationResolver

Segmentation resolver implementation that checks whether node is in the correct segment or not by establishing TCP connection to configured host and port and immediately closing it.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	DFLT_CONN_TIMEOUT Default value for local port.
static int	DFLT_LOC_PORT Default value for local port.

Constructor Summary

Constructors

Constructor and Description
TcpSegmentationResolver()

Method Summary

Modifier and Type	Method and Description
int	getConnectTimeout() Gets connect timeout.
boolean	isValidSegment() Checks whether segment is valid.
TcpSegmentationResolver	setAddress(InetSocketAddress addr) Sets target address to check reachability of.
TcpSegmentationResolver	setAddressAsString(String addr) Convenient way to set address.
TcpSegmentationResolver	setConnectTimeout(int connTimeout) Sets connect timeout.
TcpSegmentationResolver	setHost(String host) Convenient way to set address.
TcpSegmentationResolver	setLocalAddress(InetAddress locAddr) Sets local address.
TcpSegmentationResolver	setLocalAddressAsString(String locAddr) Convenient way to set local address.
TcpSegmentationResolver	setLocalPort(int locPort) Sets local port.
TcpSegmentationResolver	setPort(int port) Convenient way to set address.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

DFLT_LOC_PORT

public static final int DFLT_LOC_PORT

Default value for local port.

See Also:

Constant Field Values

DFLT_CONN_TIMEOUT

public static final int DFLT_CONN_TIMEOUT

Default value for local port.

See Also:

Constant Field Values

Constructor Detail

TcpSegmentationResolver

public TcpSegmentationResolver()

Method Detail

isValidSegment

public boolean isValidSegment()
                       throws IgniteCheckedException

Checks whether segment is valid.

When segmentation happens every node ends up in either one of two segments:

• Correct segment
• Invalid segment

Nodes in correct segment will continue operate as if nodes in the invalid segment simply left the topology (i.e. the topology just got "smaller"). Nodes in the invalid segment will realized that were "left out or disconnected" from the correct segment and will try to reconnect via segmentation policy set in configuration.

Specified by:

isValidSegment in interface SegmentationResolver

Returns:

True if segment is correct, false otherwise.

Throws:

IgniteCheckedException - If an error occurred.

setAddress

public TcpSegmentationResolver setAddress(InetSocketAddress addr)

Sets target address to check reachability of.

This is required property. Address has to be set using one of the available methods.

Parameters:

addr - Address to check reachability of.

Returns:

this for chaining.

See Also:

setAddressAsString(String), setHost(String), setPort(int)

setAddressAsString

public TcpSegmentationResolver setAddressAsString(String addr)
                                           throws IgniteCheckedException

Convenient way to set address.

This is required property. Address has to be set using one of the available methods.

Parameters:

addr - Address to check reachability of.

Returns:

this for chaining.

Throws:

IgniteCheckedException - If host is unknown or failed to parse address.

See Also:

setAddress(InetSocketAddress), setHost(String), setPort(int)

setHost

public TcpSegmentationResolver setHost(String host)

Convenient way to set address.

This is required property. Address has to be set using one of the available methods.

Parameters:

host - Host name to check reachability of.

Returns:

this for chaining.

See Also:

setAddress(InetSocketAddress), setAddressAsString(String), setPort(int)

setPort

public TcpSegmentationResolver setPort(int port)

Convenient way to set address.

This is required property. Address has to be set using one of the available methods.

Parameters:

port - Port number on the host to check reachability of.

Returns:

this for chaining.

See Also:

setAddress(InetSocketAddress), setAddressAsString(String), setHost(String)

setLocalAddress

public TcpSegmentationResolver setLocalAddress(InetAddress locAddr)
                                        throws IgniteCheckedException

Sets local address.

If not specified, check will be performed through any local address available.

Parameters:

locAddr - Local address.

Returns:

this for chaining.

Throws:

IgniteCheckedException - If host is unknown.

See Also:

setLocalAddressAsString(String)

setLocalAddressAsString

public TcpSegmentationResolver setLocalAddressAsString(String locAddr)
                                                throws IgniteCheckedException

Convenient way to set local address.

If not specified, check will be performed through any local address available.

Parameters:

locAddr - Local address.

Returns:

this for chaining.

Throws:

IgniteCheckedException - If host is unknown.

See Also:

setLocalAddress(InetAddress)

setLocalPort

public TcpSegmentationResolver setLocalPort(int locPort)

Sets local port.

If not specified, DFLT_LOC_PORT is used.

Parameters:

locPort - Local port.

Returns:

this for chaining.

getConnectTimeout

public int getConnectTimeout()

Gets connect timeout.

Returns:

Connect timeout.

setConnectTimeout

public TcpSegmentationResolver setConnectTimeout(int connTimeout)

Sets connect timeout.

If not specified, DFLT_CONN_TIMEOUT is used.

Parameters:

connTimeout - Connect timeout.

Returns:

this for chaining.

toString

public String toString()

Overrides:

toString in class Object