org.gridgain.grid.kernal.managers.discovery

Class GridDiscoveryManager

java.lang.Object

org.gridgain.grid.kernal.managers.GridManagerAdapter<GridDiscoverySpi>

org.gridgain.grid.kernal.managers.discovery.GridDiscoveryManager

All Implemented Interfaces:

GridComponent, GridManager

public class GridDiscoveryManager
extends GridManagerAdapter<GridDiscoverySpi>

Discovery SPI manager.

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	DISCOVERY_HISTORY_SIZE Discovery cached history size.

Fields inherited from class org.gridgain.grid.kernal.managers.GridManagerAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridDiscoveryManager(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	ackTopology() Prints the latest topology info into log taking into account logging/verbosity settings.
boolean	alive(GridNode node)
boolean	alive(UUID nodeId)
boolean	aliveAll(Collection<UUID> nodeIds)
Collection<GridNode>	aliveCacheNodes(String cacheName, long topVer) Gets cache nodes for cache with given name.
Collection<GridNode>	aliveRemoteCacheNodes(String cacheName, long topVer) Gets cache remote nodes for cache with given name.
Collection<GridNode>	allNodes()
Collection<GridNode>	cacheAffinityNodes(String cacheName, long topVer) Gets cache nodes for cache with given name that participate in affinity calculation.
Collection<GridNode>	cacheNodes(String cacheName, long topVer) Gets cache nodes for cache with given name.
Collection<GridNode>	daemonNodes()
org.gridgain.grid.kernal.managers.discovery.GridDiscoveryManager.DiscoCache	discoCache() Gets discovery collection cache from SPI safely guarding against "floating" collections.
long	gridStartTime() Gets first grid node start time, see GridDiscoverySpi.getGridStartTime().
boolean	hasNearCache(String cacheName, long topVer) Checks if cache with given name has at least one node with near cache enabled.
GridDiscoveryEvent	localJoinEvent()
GridNode	localNode()
GridLocalMetrics	metrics()
GridNode	node(UUID nodeId)
Collection<GridNode>	nodes(Collection<UUID> ids, GridPredicate<UUID>... p) Gets collection of node for given node IDs and predicates.
Collection<GridNode>	nodes(long topVer) Gets all nodes for given topology version.
void	onKernalStop0(boolean cancel)
boolean	pingNode(UUID nodeId)
Collection<GridNode>	remoteCacheNodes(String cacheName, long topVer) Gets cache remote nodes for cache with given name.
Collection<GridNode>	remoteNodes()
void	setNodeAttributes(Map<String,Object> attrs, GridProductVersion ver) Sets local node attributes into discovery SPI.
GridNodeShadow	shadow(GridNode node) Gets node shadow.
int	size()
void	start() Starts grid component.
void	stop(boolean cancel) Stops grid component.
Collection<GridNode>	topology(long topVer) Gets topology by specified version from history storage.
GridFuture<Long>	topologyFuture(long awaitVer) Gets future that will be completed when current topology version becomes greater or equal to argument passed.
long	topologyHash(Iterable<? extends GridNode> nodes) Gets topology hash for given set of nodes.
long	topologyVersion()
NavigableMap<GridProductVersion,Collection<GridNode>>	topologyVersionMap() Gets topology grouped by node versions.

Methods inherited from class org.gridgain.grid.kernal.managers.GridManagerAdapter

addSpiAttributes, assertParameter, collectDiscoveryData, enabled, getSpi, getSpi, getSpis, onDiscoveryDataReceived, onKernalStart, onKernalStart0, onKernalStop, printMemoryStats, startInfo, startSpi, stopInfo, stopSpi, toString, validateNode

Methods inherited from class java.lang.Object

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

Field Detail

DISCOVERY_HISTORY_SIZE

protected static final int DISCOVERY_HISTORY_SIZE

Discovery cached history size.

See Also:

Constant Field Values

Constructor Detail

GridDiscoveryManager

public GridDiscoveryManager(GridKernalContext ctx)

Parameters:

ctx - Context.

Method Detail

setNodeAttributes

public void setNodeAttributes(Map<String,Object> attrs,
                     GridProductVersion ver)

Sets local node attributes into discovery SPI.

Parameters:

attrs - Attributes to set.

ver - Version.

start

public void start()
           throws GridException

Starts grid component.

Throws:

GridException - Throws in case of any errors.

metrics

public GridLocalMetrics metrics()

Returns:

Local metrics.

ackTopology

public void ackTopology()

Prints the latest topology info into log taking into account logging/verbosity settings.

onKernalStop0

public void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridManagerAdapter<GridDiscoverySpi>

Parameters:

cancel - Cancel flag.

stop

public void stop(boolean cancel)
          throws GridException

Stops grid component.

Parameters:

cancel - If true, then all ongoing tasks or jobs for relevant components need to be cancelled.

Throws:

GridException - Thrown in case of any errors.

shadow

public GridNodeShadow shadow(GridNode node)

Gets node shadow.

Parameters:

node - Node.

Returns:

Node's shadow.

aliveAll

public boolean aliveAll(@Nullable
               Collection<UUID> nodeIds)

Parameters:

nodeIds - Node IDs to check.

Returns:

True if at least one ID belongs to an alive node.

alive

public boolean alive(UUID nodeId)

Parameters:

nodeId - Node ID.

Returns:

True if node for given ID is alive.

alive

public boolean alive(GridNode node)

Parameters:

node - Node.

Returns:

True if node is alive.

pingNode

public boolean pingNode(UUID nodeId)

Parameters:

nodeId - ID of the node.

Returns:

True if ping succeeded.

node

@Nullable
public GridNode node(UUID nodeId)

Parameters:

nodeId - ID of the node.

Returns:

Node for ID.

nodes

public Collection<GridNode> nodes(@Nullable
                         Collection<UUID> ids,
                         GridPredicate<UUID>... p)

Gets collection of node for given node IDs and predicates.

Parameters:

ids - Ids to include.

p - Filter for IDs.

Returns:

Collection with all alive nodes for given IDs.

topologyHash

public long topologyHash(Iterable<? extends GridNode> nodes)

Gets topology hash for given set of nodes.

Parameters:

nodes - Subset of grid nodes for hashing.

Returns:

Hash for given topology.

topologyFuture

public GridFuture<Long> topologyFuture(long awaitVer)

Gets future that will be completed when current topology version becomes greater or equal to argument passed.

Parameters:

awaitVer - Topology version to await.

Returns:

Future.

discoCache

public org.gridgain.grid.kernal.managers.discovery.GridDiscoveryManager.DiscoCache discoCache()

Gets discovery collection cache from SPI safely guarding against "floating" collections.

Returns:

Discovery collection cache.

remoteNodes

public Collection<GridNode> remoteNodes()

Returns:

All non-daemon remote nodes in topology.

allNodes

public Collection<GridNode> allNodes()

Returns:

All non-daemon nodes in topology.

topologyVersionMap

public NavigableMap<GridProductVersion,Collection<GridNode>> topologyVersionMap()

Gets topology grouped by node versions.

Returns:

Version to collection of nodes map.

size

public int size()

Returns:

Full topology size.

nodes

public Collection<GridNode> nodes(long topVer)

Gets all nodes for given topology version.

Parameters:

topVer - Topology version.

Returns:

Collection of cache nodes.

cacheNodes

public Collection<GridNode> cacheNodes(@Nullable
                              String cacheName,
                              long topVer)

Gets cache nodes for cache with given name.

Parameters:

cacheName - Cache name.

topVer - Topology version.

Returns:

Collection of cache nodes.

remoteCacheNodes

public Collection<GridNode> remoteCacheNodes(@Nullable
                                    String cacheName,
                                    long topVer)

Gets cache remote nodes for cache with given name.

Parameters:

cacheName - Cache name.

topVer - Topology version.

Returns:

Collection of cache nodes.

aliveCacheNodes

public Collection<GridNode> aliveCacheNodes(@Nullable
                                   String cacheName,
                                   long topVer)

Gets cache nodes for cache with given name.

Parameters:

cacheName - Cache name.

topVer - Topology version.

Returns:

Collection of cache nodes.

aliveRemoteCacheNodes

public Collection<GridNode> aliveRemoteCacheNodes(@Nullable
                                         String cacheName,
                                         long topVer)

Gets cache remote nodes for cache with given name.

Parameters:

cacheName - Cache name.

topVer - Topology version.

Returns:

Collection of cache nodes.

cacheAffinityNodes

public Collection<GridNode> cacheAffinityNodes(@Nullable
                                      String cacheName,
                                      long topVer)

Gets cache nodes for cache with given name that participate in affinity calculation.

Parameters:

cacheName - Cache name.

topVer - Topology version.

Returns:

Collection of cache affinity nodes.

hasNearCache

public boolean hasNearCache(@Nullable
                   String cacheName,
                   long topVer)

Checks if cache with given name has at least one node with near cache enabled.

Parameters:

cacheName - Cache name.

topVer - Topology version.

Returns:

True if cache with given name has at least one node with near cache enabled.

topology

@Nullable
public Collection<GridNode> topology(long topVer)

Gets topology by specified version from history storage.

Parameters:

topVer - Topology version.

Returns:

Topology nodes or null if there are no nodes for passed in version.

daemonNodes

public Collection<GridNode> daemonNodes()

Returns:

All daemon nodes in topology.

localNode

public GridNode localNode()

Returns:

Local node.

topologyVersion

public long topologyVersion()

Returns:

Topology version.

localJoinEvent

public GridDiscoveryEvent localJoinEvent()

Returns:

Event that represents a local node joined to topology.

gridStartTime

public long gridStartTime()

Gets first grid node start time, see GridDiscoverySpi.getGridStartTime().

Returns:

Start time of the first grid node.