org.gridgain.grid.kernal.processors.cache

Class GridCacheDeploymentManager<K,V>

java.lang.Object

org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter<K,V>

org.gridgain.grid.kernal.processors.cache.GridCacheDeploymentManager<K,V>

All Implemented Interfaces:

GridCacheManager<K,V>

public class GridCacheDeploymentManager<K,V>
extends GridCacheManagerAdapter<K,V>

Deployment manager for cache.

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

cctx, log

Constructor Summary

Constructors

Constructor and Description
GridCacheDeploymentManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	addDeploymentContext(GridDeploymentInfo info) Adds deployment info to deployment contexts queue.
ClassLoader	getClassLoader(GridUuid ldrId)
GridUuid	getClassLoaderId(ClassLoader ldr)
GridDeploymentInfoBean	globalDeploymentInfo()
ClassLoader	globalLoader() Gets distributed class loader.
void	ignoreOwnership(boolean ignore)
boolean	isGlobalLoader()
ClassLoader	localLoader()
void	onEnter() Callback on method enter.
void	onUndeploy(UUID leftNodeId, ClassLoader ldr) Undeploys given class loader.
void	p2pContext(UUID sndId, GridUuid ldrId, String userVer, GridDeploymentMode mode, Map<UUID,GridUuid> participants, boolean locDepOwner)
void	prepare(GridCacheDeployable deployable) Prepares deployable object.
void	printMemoryStats() Prints memory statistics (sizes of internal data structures, etc.).
void	registerClass(Class<?> cls)
void	registerClass(Class<?> cls, ClassLoader ldr)
void	registerClass(Object obj)
void	registerClasses(Iterable<?> objs) Register local classes.
void	registerClasses(Object... objs) Register local classes.
void	start0()
protected void	stop0(boolean cancel)
void	unwind() Undeploy all queued up closures.

Methods inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

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

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheDeploymentManager

public GridCacheDeploymentManager()

Method Detail

start0

public void start0()
            throws GridException

Overrides:

start0 in class GridCacheManagerAdapter<K,V>

Throws:

GridException - If failed.

stop0

protected void stop0(boolean cancel)

Overrides:

stop0 in class GridCacheManagerAdapter<K,V>

Parameters:

cancel - Cancel flag.

localLoader

public ClassLoader localLoader()

Returns:

Local-only class loader.

globalLoader

public ClassLoader globalLoader()

Gets distributed class loader. Note that p2pContext(UUID, GridUuid, String, GridDeploymentMode, Map, boolean) must be called from the same thread prior to using this class loader, or the loading may happen for the wrong node or context.

Returns:

Cache class loader.

onEnter

public void onEnter()

Callback on method enter.

ignoreOwnership

public void ignoreOwnership(boolean ignore)

Parameters:

ignore - True to ignore.

unwind

public void unwind()

Undeploy all queued up closures.

onUndeploy

public void onUndeploy(@Nullable
              UUID leftNodeId,
              ClassLoader ldr)

Undeploys given class loader.

Parameters:

leftNodeId - Left node ID.

ldr - Class loader to undeploy.

p2pContext

public void p2pContext(UUID sndId,
              GridUuid ldrId,
              String userVer,
              GridDeploymentMode mode,
              Map<UUID,GridUuid> participants,
              boolean locDepOwner)

Parameters:

sndId - Sender node ID.

ldrId - Loader ID.

userVer - User version.

mode - Deployment mode.

participants - Node participants.

locDepOwner - True if local deployment owner.

addDeploymentContext

public void addDeploymentContext(GridDeploymentInfo info)

Adds deployment info to deployment contexts queue.

Parameters:

info - Info to add.

registerClasses

public void registerClasses(Object... objs)
                     throws GridException

Register local classes.

Parameters:

objs - Objects to register.

Throws:

GridException - If registration failed.

registerClasses

public void registerClasses(Iterable<?> objs)
                     throws GridException

Register local classes.

Parameters:

objs - Objects to register.

Throws:

GridException - If registration failed.

registerClass

public void registerClass(Object obj)
                   throws GridException

Parameters:

obj - Object whose class to register.

Throws:

GridException - If failed.

registerClass

public void registerClass(Class<?> cls)
                   throws GridException

Parameters:

cls - Class to register.

Throws:

GridException - If failed.

registerClass

public void registerClass(Class<?> cls,
                 ClassLoader ldr)
                   throws GridException

Parameters:

cls - Class to register.

ldr - Class loader.

Throws:

GridException - If registration failed.

prepare

public void prepare(GridCacheDeployable deployable)

Prepares deployable object.

Parameters:

deployable - Deployable object.

globalDeploymentInfo

@Nullable
public GridDeploymentInfoBean globalDeploymentInfo()

Returns:

First global deployment.

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 GridCacheManager<K,V>

Overrides:

printMemoryStats in class GridCacheManagerAdapter<K,V>

getClassLoaderId

@Nullable
public GridUuid getClassLoaderId(@Nullable
                                 ClassLoader ldr)

Parameters:

ldr - Class loader to get ID for.

Returns:

ID for given class loader or null if given loader is not grid deployment class loader.

getClassLoader

@Nullable
public ClassLoader getClassLoader(GridUuid ldrId)

Parameters:

ldrId - Class loader ID.

Returns:

Class loader ID or null if loader not found.

isGlobalLoader

public boolean isGlobalLoader()

Returns:

True if context class loader is global.