org.ow2.proactive.resourcemanager.selection

Class SelectionManager

java.lang.Object

org.ow2.proactive.resourcemanager.selection.SelectionManager

Direct Known Subclasses:

ProbablisticSelectionManager

public abstract class SelectionManager
extends Object

An interface of selection manager which is responsible for nodes selection from a pool of free nodes for further scripts execution.

Field Summary

Fields

Modifier and Type	Field and Description
protected HashSet<String>	authorizedSelectionScripts

Constructor Summary

Constructors

Constructor and Description
SelectionManager()
SelectionManager(RMCore rmcore)

Method Summary

Modifier and Type	Method and Description
abstract List<RMNode>	arrangeNodesForScriptExecution(List<RMNode> nodes, List<SelectionScript> scripts, Map<String,Serializable> bindings) Arranges nodes for script execution based on some criteria for example previous execution statistics.
<T> List<ScriptResult<T>>	executeScript(Script<T> script, Collection<RMNode> nodes, Map<String,Serializable> bindings)
abstract boolean	isPassed(SelectionScript script, Map<String,Serializable> bindings, RMNode rmnode) Predicts script execution result.
abstract boolean	processScriptResult(SelectionScript script, Map<String,Serializable> bindings, ScriptResult<Boolean> scriptResult, RMNode rmnode) Processes script result and updates knowledge base of selection manager at the same time.
void	scriptExecutionFinished(String nodeUrl) Indicates that script execution is finished for the node with specified url.
NodeSet	selectNodes(Criteria criteria, Client client)
void	shutdown() Handles shut down of the selection manager
void	updateAuthorizedScriptsSignatures() Loads authorized selection scripts.

Methods inherited from class java.lang.Object

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

Field Detail

authorizedSelectionScripts

protected HashSet<String> authorizedSelectionScripts

Constructor Detail

SelectionManager

public SelectionManager()

SelectionManager

public SelectionManager(RMCore rmcore)

Method Detail

updateAuthorizedScriptsSignatures

public void updateAuthorizedScriptsSignatures()

Loads authorized selection scripts.

arrangeNodesForScriptExecution

public abstract List<RMNode> arrangeNodesForScriptExecution(List<RMNode> nodes,
                                                            List<SelectionScript> scripts,
                                                            Map<String,Serializable> bindings)

Arranges nodes for script execution based on some criteria for example previous execution statistics.

Parameters:

nodes - - nodes list for script execution

scripts - - set of selection scripts

Returns:

collection of arranged nodes

isPassed

public abstract boolean isPassed(SelectionScript script,
                                 Map<String,Serializable> bindings,
                                 RMNode rmnode)

Predicts script execution result. Allows to avoid duplicate script execution on the same node.

Parameters:

script - - script to execute

rmnode - - target node

Returns:

true if script will pass on the node

processScriptResult

public abstract boolean processScriptResult(SelectionScript script,
                                            Map<String,Serializable> bindings,
                                            ScriptResult<Boolean> scriptResult,
                                            RMNode rmnode)

Processes script result and updates knowledge base of selection manager at the same time.

Parameters:

script - - executed script

scriptResult - - obtained script result

rmnode - - node on which script has been executed

Returns:

whether node is selected

selectNodes

public NodeSet selectNodes(Criteria criteria,
                           Client client)

executeScript

public <T> List<ScriptResult<T>> executeScript(Script<T> script,
                                               Collection<RMNode> nodes,
                                               Map<String,Serializable> bindings)

scriptExecutionFinished

public void scriptExecutionFinished(String nodeUrl)

Indicates that script execution is finished for the node with specified url.

shutdown

public void shutdown()

Handles shut down of the selection manager