org.ow2.proactive.resourcemanager.nodesource.infrastructure

Class LocalInfrastructure

java.lang.Object

org.ow2.proactive.resourcemanager.nodesource.infrastructure.InfrastructureManager

org.ow2.proactive.resourcemanager.nodesource.infrastructure.LocalInfrastructure

All Implemented Interfaces:

Serializable, NodeSourcePlugin

public class LocalInfrastructure
extends InfrastructureManager

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.ow2.proactive.resourcemanager.nodesource.infrastructure.InfrastructureManager

InfrastructureManager.PersistedInfraVariablesHandler<T>, InfrastructureManager.RMDeployingNodeAccessor

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_NODE_NUMBER
static long	DEFAULT_TIMEOUT

Fields inherited from class org.ow2.proactive.resourcemanager.nodesource.infrastructure.InfrastructureManager

ELASTIC, logger, nodeSource, persistedInfraVariables, readLock, RM_URL_KEY, writeLock

Constructor Summary

Constructors

Constructor and Description
LocalInfrastructure()

Method Summary

Modifier and Type	Method and Description
void	acquireAllNodes() Asynchronous request of all nodes acquisition.
void	acquireNode() Asynchronous node acquisition request.
void	acquireNodes(int numberOfNodes, Map<String,?> nodeConfiguration) Asynchronous node acquisition request.
protected void	configure(Object... args) args[0] = credentials args[1] = max nodes args[2] = timeout args[3] = pa props
String	getDescription()
Map<String,String>	getMeta()
Map<Integer,String>	getSectionDescriptions()
protected void	initializePersistedInfraVariables() This method should initialize a value in the runtime variables map for all the runtime variables that will be used in the class.
protected void	notifyAcquiredNode(org.objectweb.proactive.core.node.Node node) Notifies the implementation of the infrastructure manager that a new node has been registered.
protected void	notifyDeployingNodeLost(String pnURL) Notifies the user that the deploying node was lost or removed (because of a timeout, user interaction...) Default empty implementation is provided because implementors don't necessary use this feature.
void	notifyDownNode(String nodeName, String nodeUrl, org.objectweb.proactive.core.node.Node node) Define what needs to be done in an infrastructure implementation when a node is detected as down.
void	onDownNodeReconnection(org.objectweb.proactive.core.node.Node node) Called by the system every time a node that is DOWN reconnects and changes its status to FREE or BUSY.
void	removeNode(org.objectweb.proactive.core.node.Node node) Removes the node from the resource manager.
void	shutDown() Notify this infrastructure it is going to be shut down along with its nodesource.
String	toString()

Methods inherited from class org.ow2.proactive.resourcemanager.nodesource.infrastructure.InfrastructureManager

acquireAllNodes, acquireNodes, addDeployingNode, addDeployingNodeWithLockAndPersist, addLostNodeWithLockAndPersist, addMultipleDeployingNodes, buildDeployingNodeURL, checkAllNodesAreAcquiredAndDo, checkNodeIsAcquiredAndDo, declareDeployingNodeLost, getDefaultCommandLineBuilder, getDeployingAndLostNodes, getDeployingNodesWithLock, getDeployingOrLostNode, getEmptyCommandLineBuilder, getLostNodesWithLock, getPersistedDeployingNodesUrl, getPersistedInfraVariable, getPersistedLostNodesUrl, getRmUrl, internalConfigure, internalNotifyDownNode, internalRegisterAcquiredNode, internalRemoveDeployingNode, internalRemoveNode, internalShutDown, isShutDown, isUsingDeployingNode, multipleDeclareDeployingNodeLost, persistInfrastructureVariables, reconfigure, recoverPersistedInfraVariables, removeDownNodePriorToNotify, searchForNotAcquiredRmNode, setNodeSource, setPersistedInfraVariable, setPersistedNodeSourceData, setRmDbManager, setRmUrl, update, updateDeployingNodeDescription

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_NODE_NUMBER

public static final int DEFAULT_NODE_NUMBER

DEFAULT_TIMEOUT

public static final long DEFAULT_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

LocalInfrastructure

public LocalInfrastructure()

Method Detail

getDescription

public String getDescription()

Specified by:

getDescription in class InfrastructureManager

Returns:

The Description of the implemented Infrastructure

acquireAllNodes

public void acquireAllNodes()

Description copied from class: InfrastructureManager

Asynchronous request of all nodes acquisition. Proactive nodes should be registered by calling InfrastructureManager.internalRegisterAcquiredNode(Node)

Specified by:

acquireAllNodes in class InfrastructureManager

acquireNode

public void acquireNode()

Description copied from class: InfrastructureManager

Asynchronous node acquisition request. Proactive node should be registered by calling InfrastructureManager.internalRegisterAcquiredNode(Node)

Specified by:

acquireNode in class InfrastructureManager

acquireNodes

public void acquireNodes(int numberOfNodes,
                         Map<String,?> nodeConfiguration)

Description copied from class: InfrastructureManager

Asynchronous node acquisition request. The request may be skipped if another concurrent request is on-going.

Overrides:

acquireNodes in class InfrastructureManager

Parameters:

numberOfNodes - the number of nodes to acquire

nodeConfiguration - the configuration for nodes to be acquired

configure

protected void configure(Object... args)

args[0] = credentials args[1] = max nodes args[2] = timeout args[3] = pa props

Specified by:

configure in class InfrastructureManager

Parameters:

args - of the infrastructure manager

notifyDeployingNodeLost

protected void notifyDeployingNodeLost(String pnURL)

Notifies the user that the deploying node was lost or removed (because of a timeout, user interaction...) Default empty implementation is provided because implementors don't necessary use this feature. Anyway, if they decide to do so, they can override this method, for instance, to change a flag that would get a control loop to exit...

Overrides:

notifyDeployingNodeLost in class InfrastructureManager

Parameters:

pnURL - the deploying node's URL for which one the timeout occurred.

notifyAcquiredNode

protected void notifyAcquiredNode(org.objectweb.proactive.core.node.Node node)
                           throws org.ow2.proactive.resourcemanager.exception.RMException

Description copied from class: InfrastructureManager

Notifies the implementation of the infrastructure manager that a new node has been registered. If this method throws an exception, the node registration will be discarded. This method is always called if implementor doesn't use deploying nodes (no call to InfrastructureManager.addDeployingNode(String, String, String, long) was made), and is called only for deploying nodes for which one no timeout occurred.

Specified by:

notifyAcquiredNode in class InfrastructureManager

Parameters:

node - the newly registered node

Throws:

org.ow2.proactive.resourcemanager.exception.RMException - if the implementation does not approve the node acquisition request

removeNode

public void removeNode(org.objectweb.proactive.core.node.Node node)
                throws org.ow2.proactive.resourcemanager.exception.RMException

Description copied from class: InfrastructureManager

Removes the node from the resource manager.

Specified by:

removeNode in class InfrastructureManager

Parameters:

node - the node to release.

Throws:

org.ow2.proactive.resourcemanager.exception.RMException - if any problems occurred.

notifyDownNode

public void notifyDownNode(String nodeName,
                           String nodeUrl,
                           org.objectweb.proactive.core.node.Node node)

Description copied from class: InfrastructureManager

Define what needs to be done in an infrastructure implementation when a node is detected as down.

Specified by:

notifyDownNode in class InfrastructureManager

node - the ProActive Programming Node that is down.

onDownNodeReconnection

public void onDownNodeReconnection(org.objectweb.proactive.core.node.Node node)

Description copied from class: InfrastructureManager

Called by the system every time a node that is DOWN reconnects and changes its status to FREE or BUSY.

Overrides:

onDownNodeReconnection in class InfrastructureManager

Parameters:

node - the node that has reconnected.

shutDown

public void shutDown()

Description copied from class: InfrastructureManager

Notify this infrastructure it is going to be shut down along with its nodesource. All necessary cleanup should be done here.

Overrides:

shutDown in class InfrastructureManager

toString

public String toString()

Overrides:

toString in class Object

initializePersistedInfraVariables

protected void initializePersistedInfraVariables()

Description copied from class: InfrastructureManager

This method should initialize a value in the runtime variables map for all the runtime variables that will be used in the class. It is called at initialization time of the infrastructure, just before the InfrastructureManager.configure(Object...) method. This method runs with the write lock acquired.

Specified by:

initializePersistedInfraVariables in class InfrastructureManager

getSectionDescriptions

public Map<Integer,String> getSectionDescriptions()

Specified by:

getSectionDescriptions in interface NodeSourcePlugin

Overrides:

getSectionDescriptions in class InfrastructureManager

getMeta

public Map<String,String> getMeta()

Specified by:

getMeta in interface NodeSourcePlugin

Overrides:

getMeta in class InfrastructureManager