org.ow2.proactive.resourcemanager.nodesource.infrastructure

Class AutoUpdateInfrastructure

java.lang.Object

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

org.ow2.proactive.resourcemanager.nodesource.infrastructure.HostsFileBasedInfrastructureManager

org.ow2.proactive.resourcemanager.nodesource.infrastructure.AutoUpdateInfrastructure

All Implemented Interfaces:

Serializable, NodeSourcePlugin

public class AutoUpdateInfrastructure
extends HostsFileBasedInfrastructureManager

This infrastructure launching a node by download node.jar on a node machine. Command to start a node can be tuned by client.

See Also:

Serialized Form

Nested Class Summary

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

HostsFileBasedInfrastructureManager.NodeNameBuilder

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 String	CLI_FILE_PROPERTY
protected String	command
static String	HOST_NAME
static String	NB_NODES
static String	NODE_NAME
static String	NODESOURCE_CREDENTIALS
static String	NODESOURCE_NAME

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

DEFAULT_NODE_DEPLOYMENT_FAILURE_THRESHOLD, DEFAULT_NODE_TIMEOUT, DEFAULT_WAIT_TIME_BETWEEN_NODE_DEPLOYMENT_FAILURES, hostsList, logger, maxDeploymentFailure, nodeNameBuilder, nodeTimeOut, waitBetweenDeploymentFailures

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
AutoUpdateInfrastructure()

Method Summary

Modifier and Type	Method and Description
void	configure(Object... parameters) Configures the infrastructure.
String	getDescription()
protected void	killNodeImpl(org.objectweb.proactive.core.node.Node node, InetAddress host) Kills the node passed as parameter
protected void	startNodeImpl(HostTracker hostTracker, int nbNodes, List<String> depNodeURLs) Internal node acquisition method

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

acquireAllNodes, acquireNode, addTimeouts, anyTimedOut, getSectionDescriptions, initializePersistedInfraVariables, notifyAcquiredNode, notifyDeployingNodeLost, notifyDownNode, onDownNodeReconnection, readHosts, removeNode, removeTimeouts, startNodeImplWithRetries, toString

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, internalConfigure, internalNotifyDownNode, internalRegisterAcquiredNode, internalRemoveDeployingNode, internalRemoveNode, internalShutDown, isShutDown, isUsingDeployingNode, multipleDeclareDeployingNodeLost, persistInfrastructureVariables, reconfigure, recoverPersistedInfraVariables, removeDownNodePriorToNotify, searchForNotAcquiredRmNode, setNodeSource, setPersistedInfraVariable, setPersistedNodeSourceData, setRmDbManager, setRmUrl, shutDown, update, updateDeployingNodeDescription

Methods inherited from class java.lang.Object

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

Field Detail

CLI_FILE_PROPERTY

public static final String CLI_FILE_PROPERTY

See Also:

Constant Field Values

NODE_NAME

public static final String NODE_NAME

See Also:

Constant Field Values

HOST_NAME

public static final String HOST_NAME

See Also:

Constant Field Values

NODESOURCE_NAME

public static final String NODESOURCE_NAME

See Also:

Constant Field Values

NODESOURCE_CREDENTIALS

public static final String NODESOURCE_CREDENTIALS

See Also:

Constant Field Values

NB_NODES

public static final String NB_NODES

See Also:

Constant Field Values

command

protected String command

Constructor Detail

AutoUpdateInfrastructure

public AutoUpdateInfrastructure()

Method Detail

configure

public void configure(Object... parameters)

Description copied from class: HostsFileBasedInfrastructureManager

Configures the infrastructure. parameters[0] = hosts list file content parameters[1] = timeout of the node deployment parameters[2] = max deployment failure parameters[3] = wait time between failures

Overrides:

configure in class HostsFileBasedInfrastructureManager

Parameters:

parameters - of the infrastructure manager

startNodeImpl

protected void startNodeImpl(HostTracker hostTracker,
                             int nbNodes,
                             List<String> depNodeURLs)
                      throws RMException

Internal node acquisition method

Starts a PA runtime on remote host using a custom script, register it manually in the nodesource.

Specified by:

startNodeImpl in class HostsFileBasedInfrastructureManager

Parameters:

hostTracker - The host on which one the node will be started

nbNodes - number of nodes to deploy

depNodeURLs - list of deploying or lost nodes urls created

Throws:

RMException - acquisition failed

killNodeImpl

protected void killNodeImpl(org.objectweb.proactive.core.node.Node node,
                            InetAddress host)
                     throws RMException

Description copied from class: HostsFileBasedInfrastructureManager

Kills the node passed as parameter

Specified by:

killNodeImpl in class HostsFileBasedInfrastructureManager

Parameters:

node - The node to kill

host - The host of the node

Throws:

RMException - if a problem occurred while removing

getDescription

public String getDescription()

Specified by:

getDescription in class InfrastructureManager

Returns:

short description of the IM