org.gridgain.grid.kernal.managers.deployment

Class GridDeploymentManager

java.lang.Object

org.gridgain.grid.kernal.managers.GridManagerAdapter<GridDeploymentSpi>

org.gridgain.grid.kernal.managers.deployment.GridDeploymentManager

All Implemented Interfaces:

GridComponent, GridManager

public class GridDeploymentManager
extends GridManagerAdapter<GridDeploymentSpi>

Deployment manager.

Field Summary

Fields inherited from class org.gridgain.grid.kernal.managers.GridManagerAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridDeploymentManager(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	addCacheParticipants(Map<UUID,GridUuid> allParticipants, Map<UUID,GridUuid> addedParticipants) Adds participants to all SHARED deployments.
GridDeployment	deploy(Class<?> cls, ClassLoader clsLdr)
boolean	enabled()
Map<String,Class<? extends GridComputeTask<?,?>>>	findAllTasks(GridPredicate<? super Class<? extends GridComputeTask<?,?>>>... p)
GridUuid	getClassLoaderId(ClassLoader ldr)
GridDeployment	getDeployment(GridUuid ldrId) Gets any deployment by loader ID.
GridDeployment	getDeployment(String rsrcName)
GridDeployment	getGlobalDeployment(GridDeploymentMode depMode, String rsrcName, String clsName, String userVer, UUID sndNodeId, GridUuid clsLdrId, Map<UUID,GridUuid> participants, GridPredicate<GridNode> nodeFilter)
GridDeployment	getLocalDeployment(String rsrcName)
boolean	isGlobalLoader(ClassLoader ldr)
void	onKernalStart0()
void	onKernalStop0(boolean cancel)
void	start() Starts grid component.
void	stop(boolean cancel) Stops grid component.
void	undeployTask(String taskName, boolean locUndeploy, Collection<GridNode> rmtNodes)

Methods inherited from class org.gridgain.grid.kernal.managers.GridManagerAdapter

addSpiAttributes, assertParameter, collectDiscoveryData, getSpi, getSpi, getSpis, onDiscoveryDataReceived, onKernalStart, onKernalStop, printMemoryStats, startInfo, startSpi, stopInfo, stopSpi, toString, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

GridDeploymentManager

public GridDeploymentManager(GridKernalContext ctx)

Parameters:

ctx - Grid kernal context.

Method Detail

start

public void start()
           throws GridException

Starts grid component.

Throws:

GridException - Throws in case of any errors.

stop

public void stop(boolean cancel)
          throws GridException

Stops grid component.

Parameters:

cancel - If true, then all ongoing tasks or jobs for relevant components need to be cancelled.

Throws:

GridException - Thrown in case of any errors.

onKernalStart0

public void onKernalStart0()
                    throws GridException

Overrides:

onKernalStart0 in class GridManagerAdapter<GridDeploymentSpi>

Throws:

GridException - If failed.

onKernalStop0

public void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridManagerAdapter<GridDeploymentSpi>

Parameters:

cancel - Cancel flag.

enabled

public boolean enabled()

Specified by:

enabled in interface GridManager

Overrides:

enabled in class GridManagerAdapter<GridDeploymentSpi>

Returns:

Returns true if at least one SPI does not have a NO-OP implementation, false otherwise.

findAllTasks

public Map<String,Class<? extends GridComputeTask<?,?>>> findAllTasks(@Nullable
                                                             GridPredicate<? super Class<? extends GridComputeTask<?,?>>>... p)

Parameters:

p - Filtering predicate.

Returns:

All deployed tasks for given predicate.

undeployTask

public void undeployTask(String taskName,
                boolean locUndeploy,
                Collection<GridNode> rmtNodes)

Parameters:

taskName - Task name.

locUndeploy - Local undeploy flag.

rmtNodes - Nodes to send request to.

deploy

@Nullable
public GridDeployment deploy(Class<?> cls,
                             ClassLoader clsLdr)
                      throws GridException

Parameters:

cls - Class to deploy.

clsLdr - Class loader.

Returns:

Grid deployment.

Throws:

GridException - If deployment failed.

getDeployment

@Nullable
public GridDeployment getDeployment(GridUuid ldrId)

Gets any deployment by loader ID.

Parameters:

ldrId - Loader ID.

Returns:

Deployment for given ID.

getDeployment

@Nullable
public GridDeployment getDeployment(String rsrcName)

Parameters:

rsrcName - Resource to find deployment for.

Returns:

Found deployment or null if one was not found.

getLocalDeployment

@Nullable
public GridDeployment getLocalDeployment(String rsrcName)

Parameters:

rsrcName - Class name.

Returns:

Grid cached task.

getGlobalDeployment

@Nullable
public GridDeployment getGlobalDeployment(GridDeploymentMode depMode,
                                          String rsrcName,
                                          String clsName,
                                          String userVer,
                                          UUID sndNodeId,
                                          GridUuid clsLdrId,
                                          Map<UUID,GridUuid> participants,
                                          @Nullable
                                          GridPredicate<GridNode> nodeFilter)

Parameters:

depMode - Deployment mode.

rsrcName - Resource name (could be task name).

clsName - Class name.

userVer - User version.

sndNodeId - Sender node ID.

clsLdrId - Class loader ID.

participants - Node class loader participant map.

nodeFilter - Node filter for class loader.

Returns:

Deployment class if found.

addCacheParticipants

public void addCacheParticipants(Map<UUID,GridUuid> allParticipants,
                        Map<UUID,GridUuid> addedParticipants)

Adds participants to all SHARED deployments.

Parameters:

allParticipants - All participants.

addedParticipants - Added participants.

getClassLoaderId

@Nullable
public GridUuid getClassLoaderId(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.

isGlobalLoader

public boolean isGlobalLoader(ClassLoader ldr)

Parameters:

ldr - Loader to check.

Returns:

True if P2P class loader.