org.ow2.proactive.resourcemanager.core.recovery

Class NodesRecoveryManager

java.lang.Object

org.ow2.proactive.resourcemanager.core.recovery.NodesRecoveryManager

public class NodesRecoveryManager
extends Object

This class handles the recovery of node sources and of nodes when the RM is restarted.

Since:

26/06/17

Field Summary

Fields

Modifier and Type	Field and Description
static String	END_OF_NODES_RECOVERY
static String	START_TO_RECOVER_NODES

Constructor Summary

Constructors

Constructor and Description
NodesRecoveryManager(RMCore rmCore)

Method Summary

Modifier and Type	Method and Description
protected Function<RMCore,NodesLockRestorationManager>	getNodesLockRestorationManagerBuilder()
void	initialize()
protected void	initNodesRestorationManager()
void	logRecoveryAbortedReason(String nodeSourceName, String reason)
boolean	recoverFullyDeployedInfrastructureOrReset(String nodeSourceName, NodeSource nodeSourceToDeploy, NodeSourceDescriptor descriptor)
void	recoverNodes(NodeSource nodeSource)
void	recoverNodeSourcesAndNodes()
void	restoreLock(RMNode rmNode, Client provider)

Methods inherited from class java.lang.Object

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

Field Detail

START_TO_RECOVER_NODES

public static final String START_TO_RECOVER_NODES

See Also:

Constant Field Values

END_OF_NODES_RECOVERY

public static final String END_OF_NODES_RECOVERY

See Also:

Constant Field Values

Constructor Detail

NodesRecoveryManager

public NodesRecoveryManager(RMCore rmCore)

Method Detail

initialize

public void initialize()

initNodesRestorationManager

protected void initNodesRestorationManager()

restoreLock

public void restoreLock(RMNode rmNode,
                        Client provider)

getNodesLockRestorationManagerBuilder

protected Function<RMCore,NodesLockRestorationManager> getNodesLockRestorationManagerBuilder()

recoverNodeSourcesAndNodes

public void recoverNodeSourcesAndNodes()

recoverFullyDeployedInfrastructureOrReset

public boolean recoverFullyDeployedInfrastructureOrReset(String nodeSourceName,
                                                         NodeSource nodeSourceToDeploy,
                                                         NodeSourceDescriptor descriptor)

recoverNodes

public void recoverNodes(NodeSource nodeSource)

logRecoveryAbortedReason

public void logRecoveryAbortedReason(String nodeSourceName,
                                     String reason)