org.ow2.proactive.resourcemanager.nodesource.infrastructure

Class CLIInfrastructure

java.lang.Object

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

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

org.ow2.proactive.resourcemanager.nodesource.infrastructure.CLIInfrastructure

All Implemented Interfaces:

Serializable, NodeSourcePlugin

public class CLIInfrastructure
extends HostsFileBasedInfrastructureManager

An infrastructure manager that operates custom scripts in order to deploy/remove nodes.

Deployment phase:

• launch the script by providing host name, node name, node source name, rm url
• if no node within timeout => terminates the script.

Removal phase:

• remove node from the resource manager
• launch removal script giving host name and node url.

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
protected File	deploymentScript
protected String	interpreter
protected File	removalScript

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

Method Summary

Modifier and Type	Method and Description
protected void	configure(Object... parameters) Configures the Infrastructure
String	getDescription()
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	killNodeImpl(org.objectweb.proactive.core.node.Node node, InetAddress h) Kills the node passed as parameter
void	shutDown() Notify this infrastructure it is going to be shut down along with its nodesource.
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, 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, update, updateDeployingNodeDescription

Methods inherited from class java.lang.Object

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

Field Detail

interpreter

protected String interpreter

deploymentScript

protected File deploymentScript

removalScript

protected File removalScript

Constructor Detail

CLIInfrastructure

public CLIInfrastructure()

Method Detail

configure

protected void configure(Object... parameters)

Configures the Infrastructure

Overrides:

configure in class HostsFileBasedInfrastructureManager

Parameters:

parameters - parameters[4] : An interpreter that launch the script parameters[5] : A script that deploys nodes on a single host parameters[6] : A script that removes a node

Throws:

IllegalArgumentException - configuration failed

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 h)

Kills the node passed as parameter

Specified by:

killNodeImpl in class HostsFileBasedInfrastructureManager

Parameters:

node - The node to kill

h - The host of the node

getDescription

public String getDescription()

Specified by:

getDescription in class InfrastructureManager

Returns:

short description of the IM

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.

Overrides:

initializePersistedInfraVariables in class HostsFileBasedInfrastructureManager