org.gridgain.grid.kernal.processors.session

Class GridTaskSessionProcessor

java.lang.Object

org.gridgain.grid.kernal.processors.GridProcessorAdapter

org.gridgain.grid.kernal.processors.session.GridTaskSessionProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class GridTaskSessionProcessor
extends GridProcessorAdapter

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.GridProcessorAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridTaskSessionProcessor(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
GridTaskSessionImpl	createTaskSession(GridUuid sesId, UUID taskNodeId, String taskName, GridDeployment dep, String taskClsName, Collection<UUID> top, long startTime, long endTime, Collection<GridComputeJobSibling> siblings, Map<Object,Object> attrs, boolean fullSup)
GridTaskSessionImpl	getSession(GridUuid sesId)
void	printMemoryStats() Prints memory statistics (sizes of internal structures, etc.).
boolean	removeSession(GridUuid sesId) Removes session for a given session ID.
void	start() Starts session processor.
void	stop(boolean cancel) Stops session processor.

Methods inherited from class org.gridgain.grid.kernal.processors.GridProcessorAdapter

addAttributes, assertParameter, collectDiscoveryData, onDiscoveryDataReceived, onKernalStart, onKernalStop, toString, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

GridTaskSessionProcessor

public GridTaskSessionProcessor(GridKernalContext ctx)

Parameters:

ctx - Grid kernal context.

Method Detail

start

public void start()
           throws GridException

Starts session processor.

Specified by:

start in interface GridComponent

Overrides:

start in class GridProcessorAdapter

Throws:

GridException - Throws in case of any errors.

stop

public void stop(boolean cancel)
          throws GridException

Stops session processor.

Specified by:

stop in interface GridComponent

Overrides:

stop in class GridProcessorAdapter

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.

createTaskSession

public GridTaskSessionImpl createTaskSession(GridUuid sesId,
                                    UUID taskNodeId,
                                    String taskName,
                                    @Nullable
                                    GridDeployment dep,
                                    String taskClsName,
                                    @Nullable
                                    Collection<UUID> top,
                                    long startTime,
                                    long endTime,
                                    Collection<GridComputeJobSibling> siblings,
                                    Map<Object,Object> attrs,
                                    boolean fullSup)

Parameters:

sesId - Session ID.

taskNodeId - Task node ID.

taskName - Task name.

dep - Deployment.

taskClsName - Task class name.

top - Topology.

startTime - Execution start time.

endTime - Execution end time.

siblings - Collection of siblings.

attrs - Map of attributes.

fullSup - True to enable distributed session attributes and checkpoints.

Returns:

New session if one did not exist, or existing one.

getSession

@Nullable
public GridTaskSessionImpl getSession(GridUuid sesId)

Parameters:

sesId - Session ID.

Returns:

Session for a given session ID.

removeSession

public boolean removeSession(GridUuid sesId)

Removes session for a given session ID.

Parameters:

sesId - ID of session to remove.

Returns:

True if session was removed.

printMemoryStats

public void printMemoryStats()

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

Specified by:

printMemoryStats in interface GridComponent

Overrides:

printMemoryStats in class GridProcessorAdapter