org.apache.ignite.internal.processors.cache

Class GridCachePartitionExchangeManager<K,V>

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter<K,V>

org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager<K,V>

All Implemented Interfaces:

GridCacheSharedManager<K,V>

public class GridCachePartitionExchangeManager<K,V>
extends GridCacheSharedManagerAdapter<K,V>

Partition exchange manager.

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter

cctx, log

Constructor Summary

Constructors

Constructor and Description
GridCachePartitionExchangeManager()

Method Summary

Methods

Modifier and Type	Method and Description
Collection<GridClientPartitionTopology<K,V>>	clientTopologies()
GridDhtPartitionTopology<K,V>	clientTopology(int cacheId, GridDhtPartitionExchangeId exchId)
List<IgniteInternalFuture<?>>	exchangeFutures()
void	forceDummyExchange(boolean reassign, GridDhtPartitionsExchangeFuture<K,V> exchFut)
void	forcePreloadExchange(GridDhtPartitionsExchangeFuture<K,V> exchFut) Forces preload exchange.
boolean	hasPendingExchange()
GridDhtTopologyFuture	lastTopologyFuture()
void	onExchangeDone(GridDhtPartitionsExchangeFuture<K,V> exchFut)
protected void	onKernalStart0()
protected void	onKernalStop0(boolean cancel)
void	scheduleResendPartitions() Schedules next full partitions update.
protected void	start0()
protected void	stop0(boolean cancel)
boolean	topologyChanged()
long	topologyVersion() Gets topology version of last completed partition exchange.

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter

context, kernalStartInfo, kernalStopInfo, log, onKernalStart, onKernalStop, printMemoryStats, start, startInfo, stop, stopInfo, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCachePartitionExchangeManager

public GridCachePartitionExchangeManager()

Method Detail

start0

protected void start0()
               throws IgniteCheckedException

Overrides:

start0 in class GridCacheSharedManagerAdapter<K,V>

Throws:

IgniteCheckedException - If failed.

onKernalStart0

protected void onKernalStart0()
                       throws IgniteCheckedException

Overrides:

onKernalStart0 in class GridCacheSharedManagerAdapter<K,V>

Throws:

IgniteCheckedException - If failed.

onKernalStop0

protected void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridCacheSharedManagerAdapter<K,V>

Parameters:

cancel - Cancel flag.

stop0

protected void stop0(boolean cancel)

Overrides:

stop0 in class GridCacheSharedManagerAdapter<K,V>

Parameters:

cancel - Cancel flag.

clientTopology

public GridDhtPartitionTopology<K,V> clientTopology(int cacheId,
                                           GridDhtPartitionExchangeId exchId)

Parameters:

cacheId - Cache ID.

exchId - Exchange ID.

Returns:

Topology.

clientTopologies

public Collection<GridClientPartitionTopology<K,V>> clientTopologies()

Returns:

Collection of client topologies.

topologyVersion

public long topologyVersion()

Gets topology version of last completed partition exchange.

Returns:

Topology version.

lastTopologyFuture

public GridDhtTopologyFuture lastTopologyFuture()

Returns:

Last completed topology future.

exchangeFutures

public List<IgniteInternalFuture<?>> exchangeFutures()

Returns:

Exchange futures.

hasPendingExchange

public boolean hasPendingExchange()

Returns:

True if pending future queue is empty.

topologyChanged

public boolean topologyChanged()

Returns:

True if topology has changed.

forceDummyExchange

public void forceDummyExchange(boolean reassign,
                      GridDhtPartitionsExchangeFuture<K,V> exchFut)

Parameters:

exchFut - Exchange future.

reassign - Dummy reassign flag.

forcePreloadExchange

public void forcePreloadExchange(GridDhtPartitionsExchangeFuture<K,V> exchFut)

Forces preload exchange.

Parameters:

exchFut - Exchange future.

scheduleResendPartitions

public void scheduleResendPartitions()

Schedules next full partitions update.

onExchangeDone

public void onExchangeDone(GridDhtPartitionsExchangeFuture<K,V> exchFut)

Parameters:

exchFut - Exchange.