Package org.apache.ignite.internal.processors.cache

Class GridCacheSharedManagerAdapter<K,V>

java.lang.Object

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

All Implemented Interfaces:

GridCacheSharedManager<K,V>

Direct Known Subclasses:

CacheAffinitySharedManager, CacheDiagnosticManager, CacheJtaManagerAdapter, CdcUtilityActiveCdcManager, FilePageStoreManager, FileWriteAheadLogManager, GridCacheDeploymentManager, GridCacheIoManager, GridCacheMvccManager, GridCachePartitionExchangeManager, GridCacheSharedTtlCleanupManager, GridCacheVersionManager, IgniteCacheDatabaseSharedManager, IgniteSnapshotManager, IgniteTxManager, PartitionsEvictManager, WalStateManager

public class GridCacheSharedManagerAdapter<K,V>
extends Object
implements GridCacheSharedManager<K,V>

Convenience adapter for cache managers.

Field Summary

Fields

Modifier and Type	Field	Description
protected GridCacheSharedContext<K,V>	cctx	Context.
protected IgniteLogger	diagnosticLog	Diagnostic logger.
protected IgniteLogger	log	Logger.

Constructor Summary

Constructors

Constructor	Description
GridCacheSharedManagerAdapter()

Method Summary

Modifier and Type	Method	Description
protected GridCacheSharedContext<K,V>	context()
protected boolean	isStopping()
protected String	kernalStartInfo()
protected String	kernalStopInfo()
void	onDisconnected(IgniteFuture<?> reconnectFut)
void	onKernalStart(boolean active)	Callback that notifies that kernal has successfully started, including all managers and processors.
protected void	onKernalStart0(boolean active)
void	onKernalStop(boolean cancel)
protected void	onKernalStop0(boolean cancel)
void	onReconnected(boolean active)
void	printMemoryStats()	Prints memory statistics (sizes of internal data structures, etc.).
void	start(GridCacheSharedContext<K,V> cctx)	Starts manager.
protected void	start0()
protected String	startInfo()
void	stop(boolean cancel)	Stops manager.
protected void	stop0(boolean cancel)
protected String	stopInfo()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

cctx

protected GridCacheSharedContext<K,V> cctx

Context.

log

protected IgniteLogger log

Logger.

diagnosticLog

protected IgniteLogger diagnosticLog

Diagnostic logger.

Constructor Detail

GridCacheSharedManagerAdapter

public GridCacheSharedManagerAdapter()

Method Detail

start

public final void start(GridCacheSharedContext<K,V> cctx)
                 throws IgniteCheckedException

Starts manager.

Specified by:

start in interface GridCacheSharedManager<K,V>

Parameters:

cctx - Context.

Throws:

IgniteCheckedException - If failed.

context

protected GridCacheSharedContext<K,V> context()

Returns:

Context.

start0

protected void start0()
               throws IgniteCheckedException

Throws:

IgniteCheckedException - If failed.

onKernalStart

public final void onKernalStart(boolean active)

Callback that notifies that kernal has successfully started, including all managers and processors.

Specified by:

onKernalStart in interface GridCacheSharedManager<K,V>

Parameters:

active - Cluster active flag.

onKernalStart0

protected void onKernalStart0(boolean active)

Parameters:

active - Cluster active flag.

stop

public final void stop(boolean cancel)

Stops manager.

Specified by:

stop in interface GridCacheSharedManager<K,V>

Parameters:

cancel - Cancel flag.

isStopping

protected final boolean isStopping()

Returns:

true If this component is stopping.

stop0

protected void stop0(boolean cancel)

Parameters:

cancel - Cancel flag.

onKernalStop

public final void onKernalStop(boolean cancel)

Specified by:

onKernalStop in interface GridCacheSharedManager<K,V>

Parameters:

cancel - Cancel flag.

onKernalStop0

protected void onKernalStop0(boolean cancel)

Parameters:

cancel - Cancel flag.

onDisconnected

public void onDisconnected(IgniteFuture<?> reconnectFut)

Specified by:

onDisconnected in interface GridCacheSharedManager<K,V>

Parameters:

reconnectFut - Reconnect future.

onReconnected

public void onReconnected(boolean active)

Specified by:

onReconnected in interface GridCacheSharedManager<K,V>

Parameters:

active - Active flag.

printMemoryStats

public void printMemoryStats()

Prints memory statistics (sizes of internal data structures, etc.). NOTE: this method is for testing and profiling purposes only.

Specified by:

printMemoryStats in interface GridCacheSharedManager<K,V>

startInfo

protected String startInfo()

Returns:

Start info.

stopInfo

protected String stopInfo()

Returns:

Stop info.

kernalStartInfo

protected String kernalStartInfo()

Returns:

Start info.

kernalStopInfo

protected String kernalStopInfo()

Returns:

Stop info.

toString

public String toString()

Overrides:

toString in class Object