org.apache.ignite.internal.processors.cache

Class WalStateManager

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter

org.apache.ignite.internal.processors.cache.WalStateManager

All Implemented Interfaces:

GridCacheSharedManager

public class WalStateManager
extends GridCacheSharedManagerAdapter

Write-ahead log state manager. Manages WAL enable and disable.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WalStateManager.WALDisableContext Temporary storage for disabled WALs of group.

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	DFLT_DISABLE_WAL_DURING_REBALANCING
static String	ENABLE_DURABILITY_AFTER_REBALANCING

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

cctx, diagnosticLog

Constructor Summary

Constructors

Constructor and Description
WalStateManager(GridKernalContext kernalCtx) Constructor.

Method Summary

Modifier and Type	Method and Description
IgniteInternalFuture<Boolean>	changeWalMode(Collection<String> cacheNames, boolean enabled) Change WAL mode.
void	disableGroupDurabilityForPreloading(GridDhtPartitionsExchangeFuture fut) Change local WAL state before exchange is done.
boolean	isDisabled(int grpId) Checks WAL disabled for cache group.
void	onAck(WalStateAckMessage msg) Handle ack message.
void	onCachesInfoCollected() Callback invoked when caches info is collected inside cache processor start routine.
void	onDisconnected(IgniteFuture reconnectFut)
void	onFinishDiscovery(WalStateFinishMessage msg) Handle finish message in discovery thread.
void	onKernalStart() Handle cache processor kernal start.
void	onNodeLeft(UUID nodeId) Handle node leave event.
void	onProposeDiscovery(WalStateProposeMessage msg) Handle propose message in discovery thread.
void	onProposeExchange(WalStateProposeMessage msg) Handle propose message which is synchronized with other cache state actions through exchange thread.
void	onReconnected(boolean active)
boolean	prohibitWALDisabling() Reports whether WAL disabling with subsequent init(Collection, boolean) is denied.
void	prohibitWALDisabling(boolean val) Denies or allows WAL disabling with subsequent init(Collection, boolean) call.
static String	reason(long grpId, AffinityTopologyVersion topVer) Checkpoint reason for enabling group durability.
void	runWithOutWAL(IgniteRunnable cls) None record will be logged in closure call.
protected void	start0()
protected void	stop0(boolean cancel)
WalStateManager.WALDisableContext	walDisableContext()

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

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

Methods inherited from class java.lang.Object

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

Field Detail

ENABLE_DURABILITY_AFTER_REBALANCING

public static final String ENABLE_DURABILITY_AFTER_REBALANCING

See Also:

Constant Field Values

DFLT_DISABLE_WAL_DURING_REBALANCING

public static final boolean DFLT_DISABLE_WAL_DURING_REBALANCING

See Also:

IgniteSystemProperties.IGNITE_DISABLE_WAL_DURING_REBALANCING, Constant Field Values

Constructor Detail

WalStateManager

public WalStateManager(GridKernalContext kernalCtx)

Constructor.

Parameters:

kernalCtx - Kernal context.

Method Detail

start0

protected void start0()
               throws IgniteCheckedException

Overrides:

start0 in class GridCacheSharedManagerAdapter

Throws:

IgniteCheckedException - If failed.

stop0

protected void stop0(boolean cancel)

Overrides:

stop0 in class GridCacheSharedManagerAdapter

Parameters:

cancel - Cancel flag.

onCachesInfoCollected

public void onCachesInfoCollected()

Callback invoked when caches info is collected inside cache processor start routine. Discovery is not active at this point.

onKernalStart

public void onKernalStart()

Handle cache processor kernal start. At this point we already collected discovery data from other nodes (discovery already active), but exchange worker is not active yet. We need to iterate over available group descriptors and perform top operations, taking in count that no cache operations are possible at this point, so checkpoint is not needed.

onDisconnected

public void onDisconnected(IgniteFuture reconnectFut)

Specified by:

onDisconnected in interface GridCacheSharedManager

Overrides:

onDisconnected in class GridCacheSharedManagerAdapter

Parameters:

reconnectFut - Reconnect future.

onReconnected

public void onReconnected(boolean active)

Specified by:

onReconnected in interface GridCacheSharedManager

Overrides:

onReconnected in class GridCacheSharedManagerAdapter

Parameters:

active - Active flag.

prohibitWALDisabling

public void prohibitWALDisabling(boolean val)

Denies or allows WAL disabling with subsequent init(Collection, boolean) call.

Parameters:

val - denial status.

prohibitWALDisabling

public boolean prohibitWALDisabling()

Reports whether WAL disabling with subsequent init(Collection, boolean) is denied.

Returns:

denial status.

changeWalMode

public IgniteInternalFuture<Boolean> changeWalMode(Collection<String> cacheNames,
                                                   boolean enabled)

Change WAL mode.

Parameters:

cacheNames - Cache names.

enabled - Enabled flag.

Returns:

Future completed when operation finished.

disableGroupDurabilityForPreloading

public void disableGroupDurabilityForPreloading(GridDhtPartitionsExchangeFuture fut)

Change local WAL state before exchange is done. This method will disable WAL for groups without partitions in OWNING state if such feature is enabled.

Parameters:

fut - Exchange future.

onProposeDiscovery

public void onProposeDiscovery(WalStateProposeMessage msg)

Handle propose message in discovery thread.

Parameters:

msg - Message.

onProposeExchange

public void onProposeExchange(WalStateProposeMessage msg)

Handle propose message which is synchronized with other cache state actions through exchange thread. If operation is no-op (i.e. state is not changed), then no additional processing is needed, and coordinator will trigger finish request right away. Otherwise all nodes start asynchronous checkpoint flush, and send responses to coordinator. Once all responses are received, coordinator node will trigger finish message.

Parameters:

msg - Message.

onAck

public void onAck(WalStateAckMessage msg)

Handle ack message.

Parameters:

msg - Ack message.

onFinishDiscovery

public void onFinishDiscovery(WalStateFinishMessage msg)

Handle finish message in discovery thread.

Parameters:

msg - Message.

onNodeLeft

public void onNodeLeft(UUID nodeId)

Handle node leave event.

Parameters:

nodeId - Node ID.

isDisabled

public boolean isDisabled(int grpId)

Checks WAL disabled for cache group.

Parameters:

grpId - Group id.

Returns:

True if WAL disable for group. False If not.

walDisableContext

public WalStateManager.WALDisableContext walDisableContext()

Returns:

WAL disable context.

runWithOutWAL

public void runWithOutWAL(IgniteRunnable cls)
                   throws IgniteCheckedException

None record will be logged in closure call.

Parameters:

cls - Closure to execute out of WAL scope.

Throws:

IgniteCheckedException - If operation failed.

reason

public static String reason(long grpId,
                            AffinityTopologyVersion topVer)

Checkpoint reason for enabling group durability.

Parameters:

grpId - Group id.

topVer - Topology version.