org.ow2.proactive.resourcemanager.selection.statistics

Class ProbablisticSelectionManager

java.lang.Object

org.ow2.proactive.resourcemanager.selection.SelectionManager

org.ow2.proactive.resourcemanager.selection.statistics.ProbablisticSelectionManager

public class ProbablisticSelectionManager
extends SelectionManager

An implementation of SelectionManager interface, based on probabilistic approach. The purpose of selection manager is to choose the nodes for further selection scripts execution. The goal is to find optimal strategy of nodes selection from the nodes pool to minimize scripts execution. In order to do that we assume that script will pass on the node with some probability. This probability will be increased or decreased accordingly depending on execution results. The selection of nodes sorted by its probability for each particular script gives an optimal strategy for scripts execution. For several scripts join probabilities are calculated for each nodes.

Field Summary

Fields inherited from class org.ow2.proactive.resourcemanager.selection.SelectionManager

authorizedSelectionScripts

Constructor Summary

Constructors

Constructor and Description
ProbablisticSelectionManager()
ProbablisticSelectionManager(RMCore rmcore)

Method Summary

Modifier and Type	Method and Description
List<RMNode>	arrangeNodesForScriptExecution(List<RMNode> nodes, List<SelectionScript> scripts, Map<String,Serializable> bindings) Find appropriate candidates nodes for script execution, taking into account "free" and "exclusion" nodes lists.
org.apache.log4j.Logger	getLogger()
boolean	isPassed(SelectionScript script, Map<String,Serializable> bindings, RMNode rmnode) Predicts script execution result.
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.

Methods inherited from class org.ow2.proactive.resourcemanager.selection.SelectionManager

executeScript, scriptExecutionFinished, selectNodes, shutdown, updateAuthorizedScriptsSignatures

Methods inherited from class java.lang.Object

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

Constructor Detail

ProbablisticSelectionManager

public ProbablisticSelectionManager()

ProbablisticSelectionManager

public ProbablisticSelectionManager(RMCore rmcore)

Method Detail

arrangeNodesForScriptExecution

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

Find appropriate candidates nodes for script execution, taking into account "free" and "exclusion" nodes lists.

Specified by:

arrangeNodesForScriptExecution in class SelectionManager

Parameters:

scripts - set of scripts to execute

nodes - free nodes list provided by resource manager

Returns:

candidates node list for script execution

isPassed

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

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

Specified by:

isPassed in class SelectionManager

Parameters:

script - - script to execute

rmnode - - target node

Returns:

true if script will pass on the node

processScriptResult

public 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.

Specified by:

processScriptResult in class SelectionManager

Parameters:

script - - executed script

scriptResult - - obtained script result

rmnode - - node on which script has been executed

Returns:

whether node is selected

getLogger

public org.apache.log4j.Logger getLogger()

See Also:

Loggable.getLogger()