org.apache.ignite.internal.processors.cache

Class CacheAffinitySharedManager<K,V>

java.lang.Object

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

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

All Implemented Interfaces:

GridCacheSharedManager<K,V>

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

Field Summary

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

cctx, diagnosticLog, log

Constructor Summary

Constructors

Constructor and Description
CacheAffinitySharedManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	addDhtAssignmentFetchFuture(GridDhtAssignmentFetchFuture fut)
void	dumpDebugInfo()
IgniteInternalFuture<Map<Integer,Map<Integer,List<UUID>>>>	initAffinityOnNodeLeft(GridDhtPartitionsExchangeFuture fut)
void	initStartedCaches(boolean crd, GridDhtPartitionsExchangeFuture fut, Collection<DynamicCacheDescriptor> descs) Initialized affinity for cache received from node joining on this exchange.
void	onCacheChangeRequest(GridDhtPartitionsExchangeFuture fut, boolean crd, ExchangeActions exchActions) Called on exchange initiated for cache start/stop request.
void	onChangeAffinityMessage(GridDhtPartitionsExchangeFuture exchFut, boolean crd, CacheAffinityChangeMessage msg) Called on exchange initiated by CacheAffinityChangeMessage which sent after rebalance finished.
void	onClientEvent(GridDhtPartitionsExchangeFuture fut, boolean crd) Called on exchange initiated by client node join/fail.
void	onExchangeChangeAffinityMessage(GridDhtPartitionsExchangeFuture exchFut, boolean crd, CacheAffinityChangeMessage msg) Called when received CacheAffinityChangeMessage which should complete exchange.
void	onServerJoin(GridDhtPartitionsExchangeFuture fut, boolean crd) Called on exchange initiated by server node join.
boolean	onServerLeft(GridDhtPartitionsExchangeFuture fut) Called on exchange initiated by server node leave.
void	removeAllCacheInfo()
void	removeDhtAssignmentFetchFuture(GridDhtAssignmentFetchFuture fut)
protected void	start0()

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

context, isStopping, kernalStartInfo, kernalStopInfo, log, onDisconnected, onKernalStop, onKernalStop0, printMemoryStats, start, startInfo, stop, stop0, stopInfo, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheAffinitySharedManager

public CacheAffinitySharedManager()

Method Detail

start0

protected void start0()
               throws IgniteCheckedException

Overrides:

start0 in class GridCacheSharedManagerAdapter<K,V>

Throws:

IgniteCheckedException - If failed.

onCacheChangeRequest

public void onCacheChangeRequest(GridDhtPartitionsExchangeFuture fut,
                        boolean crd,
                        ExchangeActions exchActions)
                          throws IgniteCheckedException

Called on exchange initiated for cache start/stop request.

Parameters:

fut - Exchange future.

crd - Coordinator flag.

exchActions - Cache change requests.

Throws:

IgniteCheckedException - If failed.

removeAllCacheInfo

public void removeAllCacheInfo()

onExchangeChangeAffinityMessage

public void onExchangeChangeAffinityMessage(GridDhtPartitionsExchangeFuture exchFut,
                                   boolean crd,
                                   CacheAffinityChangeMessage msg)

Called when received CacheAffinityChangeMessage which should complete exchange.

Parameters:

exchFut - Exchange future.

crd - Coordinator flag.

msg - Affinity change message.

onChangeAffinityMessage

public void onChangeAffinityMessage(GridDhtPartitionsExchangeFuture exchFut,
                           boolean crd,
                           CacheAffinityChangeMessage msg)
                             throws IgniteCheckedException

Called on exchange initiated by CacheAffinityChangeMessage which sent after rebalance finished.

Parameters:

exchFut - Exchange future.

crd - Coordinator flag.

msg - Message.

Throws:

IgniteCheckedException - If failed.

onClientEvent

public void onClientEvent(GridDhtPartitionsExchangeFuture fut,
                 boolean crd)
                   throws IgniteCheckedException

Called on exchange initiated by client node join/fail.

Parameters:

fut - Exchange future.

crd - Coordinator flag.

Throws:

IgniteCheckedException - If failed.

addDhtAssignmentFetchFuture

public void addDhtAssignmentFetchFuture(GridDhtAssignmentFetchFuture fut)

Parameters:

fut - Future to add.

removeDhtAssignmentFetchFuture

public void removeDhtAssignmentFetchFuture(GridDhtAssignmentFetchFuture fut)

Parameters:

fut - Future to remove.

initStartedCaches

public void initStartedCaches(boolean crd,
                     GridDhtPartitionsExchangeFuture fut,
                     Collection<DynamicCacheDescriptor> descs)
                       throws IgniteCheckedException

Initialized affinity for cache received from node joining on this exchange.

Parameters:

crd - Coordinator flag.

fut - Exchange future.

descs - Cache descriptors.

Throws:

IgniteCheckedException - If failed.

onServerJoin

public void onServerJoin(GridDhtPartitionsExchangeFuture fut,
                boolean crd)
                  throws IgniteCheckedException

Called on exchange initiated by server node join.

Parameters:

fut - Exchange future.

crd - Coordinator flag.

Throws:

IgniteCheckedException - If failed.

onServerLeft

public boolean onServerLeft(GridDhtPartitionsExchangeFuture fut)
                     throws IgniteCheckedException

Called on exchange initiated by server node leave.

Parameters:

fut - Exchange future.

Returns:

True if affinity should be assigned by coordinator.

Throws:

IgniteCheckedException - If failed.

initAffinityOnNodeLeft

public IgniteInternalFuture<Map<Integer,Map<Integer,List<UUID>>>> initAffinityOnNodeLeft(GridDhtPartitionsExchangeFuture fut)
                                                                                  throws IgniteCheckedException

Parameters:

fut - Exchange future.

Returns:

Affinity assignment.

Throws:

IgniteCheckedException - If failed.

dumpDebugInfo

public void dumpDebugInfo()