org.gridgain.grid.kernal.processors.job

Class GridJobProcessor

java.lang.Object

org.gridgain.grid.kernal.processors.GridProcessorAdapter

org.gridgain.grid.kernal.processors.job.GridJobProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class GridJobProcessor
extends GridProcessorAdapter

Responsible for all grid job execution and communication.

Field Summary

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

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridJobProcessor(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
GridJobWorker	activeJob(GridUuid jobId) Gets active job.
void	cancelJob(GridUuid sesId, GridUuid jobId, boolean sys)
boolean	internal()
void	masterLeaveLocal(GridUuid sesId) Notify processor that master leave aware handler must be invoked on all jobs with the given session ID.
void	onKernalStop(boolean cancel) Callback to notify that kernal is about to stop.
void	printMemoryStats() Prints memory statistics (sizes of internal structures, etc.).
void	processJobExecuteRequest(GridNode node, GridJobExecuteRequest req)
Collection<GridComputeJobSibling>	requestJobSiblings(GridComputeTaskSession ses)
void	setAttributes(GridJobSessionImpl ses, Map<?,?> attrs)
void	start() Starts grid component.
void	stop(boolean cancel) Stops grid component.

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

GridJobProcessor

public GridJobProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

start

public void start()
           throws GridException

Starts grid component.

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)

Stops grid component.

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.

onKernalStop

public void onKernalStop(boolean cancel)

Callback to notify that kernal is about to stop.

Specified by:

onKernalStop in interface GridComponent

Overrides:

onKernalStop in class GridProcessorAdapter

Parameters:

cancel - Flag indicating whether jobs should be canceled.

activeJob

@Nullable
public GridJobWorker activeJob(GridUuid jobId)

Gets active job.

Parameters:

jobId - Job ID.

Returns:

Active job.

internal

public boolean internal()

Returns:

True if running internal task.

setAttributes

public void setAttributes(GridJobSessionImpl ses,
                 Map<?,?> attrs)
                   throws GridException

Parameters:

ses - Session.

attrs - Attributes.

Throws:

GridException - If failed.

requestJobSiblings

public Collection<GridComputeJobSibling> requestJobSiblings(GridComputeTaskSession ses)
                                                     throws GridException

Parameters:

ses - Session.

Returns:

Siblings.

Throws:

GridException - If failed.

masterLeaveLocal

public void masterLeaveLocal(GridUuid sesId)

Notify processor that master leave aware handler must be invoked on all jobs with the given session ID.

Parameters:

sesId - Session ID.

cancelJob

public void cancelJob(@Nullable
             GridUuid sesId,
             @Nullable
             GridUuid jobId,
             boolean sys)

Parameters:

sesId - Session ID.

jobId - Job ID.

sys - System flag.

processJobExecuteRequest

public void processJobExecuteRequest(GridNode node,
                            GridJobExecuteRequest req)

Parameters:

node - Node.

req - Request.

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