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, diagnosticLog, log

Constructor Summary

Constructors

Constructor and Description
GridCachePartitionExchangeManager()

Method Summary

Methods

Modifier and Type	Method and Description
IgniteInternalFuture<?>	affinityReadyFuture(AffinityTopologyVersion ver)
GridClientPartitionTopology	clearClientTopology(int grpId)
Collection<GridClientPartitionTopology>	clientTopologies()
GridDhtPartitionTopology	clientTopology(int grpId, GridDhtPartitionsExchangeFuture exchFut)
GridDhtPartitionsFullMessage	createPartitionsFullMessage(boolean compress, GridDhtPartitionExchangeId exchId, GridCacheVersion lastVer, IgniteDhtPartitionHistorySuppliersMap partHistSuppliers, IgniteDhtPartitionsToReloadMap partsToReload)
GridDhtPartitionsSingleMessage	createPartitionsSingleMessage(ClusterNode targetNode, GridDhtPartitionExchangeId exchangeId, boolean clientOnlyExchange, boolean sndCounters)
void	dumpDebugInfo(GridDhtPartitionsExchangeFuture exchFut)
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()
void	onExchangeDone(GridDhtPartitionsExchangeFuture exchFut, Throwable err)
void	onKernalStart(boolean active, boolean reconnect)
protected void	onKernalStop0(boolean cancel)
void	onLocalJoin(DiscoveryEvent evt, DiscoCache cache) Callback for local join event (needed since regular event for local join is not generated).
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, 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.

onLocalJoin

public void onLocalJoin(DiscoveryEvent evt,
               DiscoCache cache)

Callback for local join event (needed since regular event for local join is not generated).

Parameters:

evt - Event.

cache - Cache.

reconnectExchangeFuture

public IgniteInternalFuture<?> reconnectExchangeFuture()

Returns:

Reconnect partition exchange future.

onKernalStart

public void onKernalStart(boolean active,
                 boolean reconnect)
                   throws IgniteCheckedException

Parameters:

active - Cluster state.

reconnect - Reconnect flag.

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 grpId,
                                      GridDhtPartitionsExchangeFuture exchFut)

Parameters:

grpId - Cache group ID.

exchFut - Exchange future.

Returns:

Topology.

clientTopologies

public Collection<GridClientPartitionTopology> clientTopologies()

Returns:

Collection of client topologies.

clearClientTopology

public GridClientPartitionTopology clearClientTopology(int grpId)

Parameters:

grpId - Cache group 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.

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(boolean compress,
                                                       @Nullable
                                                       GridDhtPartitionExchangeId exchId,
                                                       @Nullable
                                                       GridCacheVersion lastVer,
                                                       @Nullable
                                                       IgniteDhtPartitionHistorySuppliersMap partHistSuppliers,
                                                       @Nullable
                                                       IgniteDhtPartitionsToReloadMap partsToReload)

Parameters:

compress - True if possible to compress message (properly work only if prepareMarshall/ finishUnmarshall methods are called).

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

lastVer - Last version.

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(@Nullable
                 GridDhtPartitionsExchangeFuture exchFut)
                   throws Exception

Parameters:

exchFut - Optional current exchange future.

Throws:

Exception - If failed.

dumpLongRunningOperations

public void dumpLongRunningOperations(long timeout)

Parameters:

timeout - Operation timeout.