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
IgniteInternalFuture<?>	affinityReadyFuture(AffinityTopologyVersion ver)
GridClientPartitionTopology	clearClientTopology(int cacheId)
Collection<GridClientPartitionTopology>	clientTopologies()
GridDhtPartitionTopology	clientTopology(int cacheId, GridDhtPartitionsExchangeFuture exchFut)
GridDhtPartitionsFullMessage	createPartitionsFullMessage(Collection<ClusterNode> nodes, GridDhtPartitionExchangeId exchId, GridCacheVersion lastVer, boolean compress)
GridDhtPartitionsSingleMessage	createPartitionsSingleMessage(ClusterNode targetNode, GridDhtPartitionExchangeId exchangeId, boolean clientOnlyExchange, boolean sndCounters)
void	dumpDebugInfo()
void	dumpDebugInfo(AffinityTopologyVersion exchTopVer)
void	dumpLongRunningOperations(long timeout)
List<GridDhtPartitionsExchangeFuture>	exchangeFutures()
void	forceDummyExchange(boolean reassign, GridDhtPartitionsExchangeFuture exchFut)
IgniteInternalFuture<Boolean>	forceRebalance(GridDhtPartitionsExchangeFuture exchFut) Forces preload exchange.
boolean	hasPendingExchange()
Object	interruptLock()
GridDhtTopologyFuture	lastFinishedFuture()
void	lastFinishedFuture(GridDhtTopologyFuture fut)
GridDhtTopologyFuture	lastTopologyFuture()
IgniteProductVersion	minimumNodeVersion(AffinityTopologyVersion topVer) Gets minimum node version for the given topology version.
void	onExchangeDone(GridDhtPartitionsExchangeFuture exchFut, Throwable err)
protected void	onKernalStart0(boolean reconnect)
protected void	onKernalStop0(boolean cancel)
AffinityTopologyVersion	readyAffinityVersion()
static Object	rebalanceTopic(int idx)
IgniteInternalFuture<?>	reconnectExchangeFuture()
void	scheduleResendPartitions() Schedules next full partitions update.
protected void	start0()
protected void	stop0(boolean cancel)
AffinityTopologyVersion	topologyVersion() Gets topology version of last partition exchange, it is possible that last partition exchange is not completed yet.

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

context, isStopping, kernalStartInfo, kernalStopInfo, log, onDisconnected, 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.

reconnectExchangeFuture

public IgniteInternalFuture<?> reconnectExchangeFuture()

Returns:

Reconnect partition exchange future.

onKernalStart0

protected void onKernalStart0(boolean reconnect)
                       throws IgniteCheckedException

Overrides:

onKernalStart0 in class GridCacheSharedManagerAdapter<K,V>

Parameters:

reconnect - True if manager restarted after client reconnect.

Throws:

IgniteCheckedException - If failed.

rebalanceTopic

public static Object rebalanceTopic(int idx)

Parameters:

idx - Index.

Returns:

Topic for index.

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.

interruptLock

public Object interruptLock()

Returns:

Interrupt lock.

clientTopology

public GridDhtPartitionTopology clientTopology(int cacheId,
                                      GridDhtPartitionsExchangeFuture exchFut)

Parameters:

cacheId - Cache ID.

exchFut - Exchange future.

Returns:

Topology.

clientTopologies

public Collection<GridClientPartitionTopology> clientTopologies()

Returns:

Collection of client topologies.

clearClientTopology

public GridClientPartitionTopology clearClientTopology(int cacheId)

Parameters:

cacheId - Cache ID.

Returns:

Client partition topology.

topologyVersion

public AffinityTopologyVersion topologyVersion()

Gets topology version of last partition exchange, it is possible that last partition exchange is not completed yet.

Returns:

Topology version.

readyAffinityVersion

public AffinityTopologyVersion readyAffinityVersion()

Returns:

Topology version of latest completed partition exchange.

lastTopologyFuture

public GridDhtTopologyFuture lastTopologyFuture()

Returns:

Last initialized topology future.

lastFinishedFuture

@Nullable
public GridDhtTopologyFuture lastFinishedFuture()

Returns:

Last finished topology future.

lastFinishedFuture

public void lastFinishedFuture(GridDhtTopologyFuture fut)

Parameters:

fut - Finished future.

affinityReadyFuture

@Nullable
public IgniteInternalFuture<?> affinityReadyFuture(AffinityTopologyVersion ver)

Parameters:

ver - Topology version.

Returns:

Future or null is future is already completed.

minimumNodeVersion

public IgniteProductVersion minimumNodeVersion(AffinityTopologyVersion topVer)

Gets minimum node version for the given topology version.

Parameters:

topVer - Topology version to get minimum node version for.

Returns:

Minimum node version.

exchangeFutures

public List<GridDhtPartitionsExchangeFuture> exchangeFutures()

Returns:

Exchange futures.

hasPendingExchange

public boolean hasPendingExchange()

Returns:

True if pending future queue is empty.

forceDummyExchange

public void forceDummyExchange(boolean reassign,
                      GridDhtPartitionsExchangeFuture exchFut)

Parameters:

exchFut - Exchange future.

reassign - Dummy reassign flag.

forceRebalance

public IgniteInternalFuture<Boolean> forceRebalance(GridDhtPartitionsExchangeFuture exchFut)

Forces preload exchange.

Parameters:

exchFut - Exchange future.

scheduleResendPartitions

public void scheduleResendPartitions()

Schedules next full partitions update.

createPartitionsFullMessage

public GridDhtPartitionsFullMessage createPartitionsFullMessage(Collection<ClusterNode> nodes,
                                                       @Nullable
                                                       GridDhtPartitionExchangeId exchId,
                                                       @Nullable
                                                       GridCacheVersion lastVer,
                                                       boolean compress)

Parameters:

nodes - Target nodes.

exchId - Non-null exchange ID if message is created for exchange.

lastVer - Last version.

compress - True if it is possible to use compression for message.

Returns:

Message.

createPartitionsSingleMessage

public GridDhtPartitionsSingleMessage createPartitionsSingleMessage(ClusterNode targetNode,
                                                           @Nullable
                                                           GridDhtPartitionExchangeId exchangeId,
                                                           boolean clientOnlyExchange,
                                                           boolean sndCounters)

Parameters:

targetNode - Target node.

exchangeId - ID.

clientOnlyExchange - Client exchange flag.

sndCounters - True if need send partition update counters.

Returns:

Message.

onExchangeDone

public void onExchangeDone(GridDhtPartitionsExchangeFuture exchFut,
                  @Nullable
                  Throwable err)

Parameters:

exchFut - Exchange.

err - Error.

dumpDebugInfo

public void dumpDebugInfo()
                   throws Exception

Throws:

Exception - If failed.

dumpDebugInfo

public void dumpDebugInfo(@Nullable
                 AffinityTopologyVersion exchTopVer)
                   throws Exception

Parameters:

exchTopVer - Optional current exchange topology version.

Throws:

Exception - If failed.

dumpLongRunningOperations

public void dumpLongRunningOperations(long timeout)

Parameters:

timeout - Operation timeout.