org.ow2.proactive.resourcemanager.nodesource.infrastructure

Class DefaultInfrastructureManager

java.lang.Object

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

org.ow2.proactive.resourcemanager.nodesource.infrastructure.DefaultInfrastructureManager

All Implemented Interfaces:

Serializable, NodeSourcePlugin

public class DefaultInfrastructureManager
extends InfrastructureManager

A default infrastructure manager. Cannot perform the deployment but is able to register incoming nodes (existing nodes added by url) and remove them.

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
protected static org.apache.log4j.Logger	logger logger

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

ELASTIC, nodeSource, persistedInfraVariables, readLock, RM_URL_KEY, writeLock

Constructor Summary

Constructors

Constructor and Description
DefaultInfrastructureManager() Proactive default constructor.

Method Summary

Modifier and Type	Method and Description
void	acquireAllNodes() Asynchronous request of all nodes acquisition.
void	acquireNode() Asynchronous node acquisition request.
void	configure(Object... parameters) Adds information required to deploy nodes in the future.
String	getDescription() Node source description
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.
boolean	isThereNodesInSameJVM(org.objectweb.proactive.core.node.Node node) Check if there are any other nodes handled by the NodeSource in the same JVM of the node passed in parameter.
void	notifyAcquiredNode(org.objectweb.proactive.core.node.Node node) Notifies the implementation of the infrastructure manager that a new node has been registered.
void	notifyDownNode(String nodeName, String nodeUrl, org.objectweb.proactive.core.node.Node proactiveProgrammingNode) 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	removeDownNodePriorToNotify(String nodeName) This method can be overriden by subclasses, especially if they do not want the node to be removed from the InfrastructureManager map when detected as down.
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() Node source string representation

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

acquireAllNodes, acquireNodes, acquireNodes, addDeployingNode, addDeployingNodeWithLockAndPersist, addLostNodeWithLockAndPersist, addMultipleDeployingNodes, buildDeployingNodeURL, checkAllNodesAreAcquiredAndDo, checkNodeIsAcquiredAndDo, declareDeployingNodeLost, getDefaultCommandLineBuilder, getDeployingAndLostNodes, getDeployingNodesWithLock, getDeployingOrLostNode, getEmptyCommandLineBuilder, getLostNodesWithLock, getMeta, getPersistedDeployingNodesUrl, getPersistedInfraVariable, getPersistedLostNodesUrl, getRmUrl, getSectionDescriptions, internalConfigure, internalNotifyDownNode, internalRegisterAcquiredNode, internalRemoveDeployingNode, internalRemoveNode, internalShutDown, isShutDown, isUsingDeployingNode, multipleDeclareDeployingNodeLost, notifyDeployingNodeLost, persistInfrastructureVariables, reconfigure, recoverPersistedInfraVariables, 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

logger

protected static org.apache.log4j.Logger logger

logger

Constructor Detail

DefaultInfrastructureManager

public DefaultInfrastructureManager()

Proactive default constructor.

Method Detail

configure

public void configure(Object... parameters)

Adds information required to deploy nodes in the future. Do not initiate a real nodes deployment/acquisition as it's up to the policy. The runtime variables of an infrastructure should not be explicitly persisted in this method as the link with the node source is not properly set at the time of calling this method. They will be persisted at the end of the initialization in RMCore#createNodeSource

Specified by:

configure in class InfrastructureManager

Parameters:

parameters - of the infrastructure manager

acquireNode

public void acquireNode()

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

Specified by:

acquireNode in class InfrastructureManager

acquireAllNodes

public void acquireAllNodes()

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

Specified by:

acquireAllNodes in class InfrastructureManager

removeNode

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

Removes the node from the resource manager.

Specified by:

removeNode in class InfrastructureManager

Parameters:

node - the node to release.

Throws:

RMException - if any problems occurred.

toString

public String toString()

Node source string representation

Overrides:

toString in class Object

getDescription

public String getDescription()

Node source description

Specified by:

getDescription in class InfrastructureManager

Returns:

The Description of the implemented Infrastructure

isThereNodesInSameJVM

public boolean isThereNodesInSameJVM(org.objectweb.proactive.core.node.Node node)

Check if there are any other nodes handled by the NodeSource in the same JVM of the node passed in parameter.

Parameters:

node - Node to check if there any other node of the NodeSource in the same JVM

Returns:

true there is another node in the node's JVM handled by the nodeSource, false otherwise.

notifyAcquiredNode

public void notifyAcquiredNode(org.objectweb.proactive.core.node.Node node)
                        throws RMException

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:

RMException - if the implementation does not approve the node acquisition request

notifyDownNode

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

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

Specified by:

notifyDownNode in class InfrastructureManager

proactiveProgrammingNode - the ProActive Programming Node that is down.

Throws:

RMException - if any problems occurred.

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.

removeDownNodePriorToNotify

public void removeDownNodePriorToNotify(String nodeName)

Description copied from class: InfrastructureManager

This method can be overriden by subclasses, especially if they do not want the node to be removed from the InfrastructureManager map when detected as down.

Overrides:

removeDownNodePriorToNotify in class InfrastructureManager

Parameters:

nodeName - the node to remove

shutDown

public void shutDown()

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

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