org.gridgain.grid.spi.discovery.tcp.ipfinder.sharedfs

Class GridTcpDiscoverySharedFsIpFinder

java.lang.Object

org.gridgain.grid.spi.discovery.tcp.ipfinder.GridTcpDiscoveryIpFinderAdapter

org.gridgain.grid.spi.discovery.tcp.ipfinder.sharedfs.GridTcpDiscoverySharedFsIpFinder

All Implemented Interfaces:

GridTcpDiscoveryIpFinder

public class GridTcpDiscoverySharedFsIpFinder
extends GridTcpDiscoveryIpFinderAdapter

Shared filesystem-based IP finder.

Configuration

Mandatory

There are no mandatory configuration parameters.

Optional

• Path (see setPath(String))
• Shared flag (see GridTcpDiscoveryIpFinderAdapter.setShared(boolean))

If getPath() is not provided, then DFLT_PATH will be used and only local nodes will discover each other. To enable discovery over network you must provide a path to a shared directory explicitly.

The directory will contain empty files named like the following 192.168.1.136#1001.

Note that this finder is shared by default (see GridTcpDiscoveryIpFinder.isShared().

Field Summary

Fields

Modifier and Type	Field and Description
static String	DELIM Delimiter to use between address and port tokens in file names.
static String	DFLT_PATH Default path for discovering of local nodes (testing only).

Constructor Summary

Constructors

Constructor and Description
GridTcpDiscoverySharedFsIpFinder() Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
String	getPath() Gets path.
Collection<InetSocketAddress>	getRegisteredAddresses() Gets all addresses registered in this finder.
void	registerAddresses(Collection<InetSocketAddress> addrs) Registers new addresses.
void	setPath(String path) Sets path.
String	toString()
void	unregisterAddresses(Collection<InetSocketAddress> addrs) Unregisters provided addresses.

Methods inherited from class org.gridgain.grid.spi.discovery.tcp.ipfinder.GridTcpDiscoveryIpFinderAdapter

close, initializeLocalAddresses, isShared, onSpiContextDestroyed, onSpiContextInitialized, setShared, spiContext

Methods inherited from class java.lang.Object

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

Field Detail

DFLT_PATH

public static final String DFLT_PATH

Default path for discovering of local nodes (testing only). Note that this path is relative to GRIDGAIN_HOME/work folder if GRIDGAIN_HOME system or environment variable specified, otherwise it is relative to work folder under system java.io.tmpdir folder.

See Also:

GridConfiguration.getWorkDirectory(), Constant Field Values

DELIM

public static final String DELIM

Delimiter to use between address and port tokens in file names.

See Also:

Constant Field Values

Constructor Detail

GridTcpDiscoverySharedFsIpFinder

public GridTcpDiscoverySharedFsIpFinder()

Constructor.

Method Detail

getPath

public String getPath()

Gets path.

Returns:

Shared path.

setPath

@GridSpiConfiguration(optional=true)
public void setPath(String path)

Sets path.

Parameters:

path - Shared path.

getRegisteredAddresses

public Collection<InetSocketAddress> getRegisteredAddresses()
                                                     throws GridSpiException

Gets all addresses registered in this finder.

Returns:

All known addresses, potentially empty, but never null.

Throws:

GridSpiException - In case of error.

registerAddresses

public void registerAddresses(Collection<InetSocketAddress> addrs)
                       throws GridSpiException

Registers new addresses.

Implementation should accept duplicates quietly, but should not register address if it is already registered.

Parameters:

addrs - Addresses to register. Not null and not empty.

Throws:

GridSpiException - In case of error.

unregisterAddresses

public void unregisterAddresses(Collection<InetSocketAddress> addrs)
                         throws GridSpiException

Unregisters provided addresses.

Implementation should accept addresses that are currently not registered quietly (just no-op).

Parameters:

addrs - Addresses to unregister. Not null and not empty.

Throws:

GridSpiException - In case of error.

toString

public String toString()

Overrides:

toString in class GridTcpDiscoveryIpFinderAdapter