com.evolveum.midpoint.task.quartzimpl.cluster

Class ClusterManager

java.lang.Object

com.evolveum.midpoint.task.quartzimpl.cluster.ClusterManager

public class ClusterManager
extends Object

Responsible for keeping the cluster consistent. (Clusterwide task management operations are in ExecutionManager.)

Author:

Pavol Mederly

Constructor Summary

Constructors

Constructor and Description
ClusterManager(TaskManagerQuartzImpl taskManager)

Method Summary

Methods

Modifier and Type	Method and Description
void	checkClusterConfiguration(OperationResult result) Verifies cluster consistency (currently checks whether there is no other node with the same ID, and whether clustered/non-clustered nodes are OK).
void	checkStalledTasks(OperationResult result)
void	checkSystemConfigurationChanged(OperationResult parentResult) Check whether system configuration has not changed in repository (e.g.
void	checkWaitingTasks(OperationResult result)
void	createNodeObject(OperationResult result)
void	deleteNode(String nodeOid, OperationResult result)
String	dumpNodeInfo(com.evolveum.midpoint.xml.ns._public.common.common_3.NodeType node)
List<PrismObject<com.evolveum.midpoint.xml.ns._public.common.common_3.NodeType>>	getAllNodes(OperationResult result)
PrismObject<com.evolveum.midpoint.xml.ns._public.common.common_3.NodeType>	getNode(String nodeOid, OperationResult result)
PrismObject<com.evolveum.midpoint.xml.ns._public.common.common_3.NodeType>	getNodeById(String nodeIdentifier, OperationResult result)
String	getNodeId()
PrismObject<com.evolveum.midpoint.xml.ns._public.common.common_3.NodeType>	getNodePrism()
boolean	isClusterManagerThreadActive()
boolean	isCurrentNode(PrismObject<com.evolveum.midpoint.xml.ns._public.common.common_3.NodeType> node)
boolean	isCurrentNode(String node)
boolean	isUp(com.evolveum.midpoint.xml.ns._public.common.common_3.NodeType nodeType)
void	recordNodeShutdown(OperationResult result)
void	startClusterManagerThread()
void	stopClusterManagerThread(long waitTime, OperationResult parentResult)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterManager

public ClusterManager(TaskManagerQuartzImpl taskManager)

Method Detail

checkClusterConfiguration

public void checkClusterConfiguration(OperationResult result)

Verifies cluster consistency (currently checks whether there is no other node with the same ID, and whether clustered/non-clustered nodes are OK).

Parameters:

result -

isClusterManagerThreadActive

public boolean isClusterManagerThreadActive()

recordNodeShutdown

public void recordNodeShutdown(OperationResult result)

getNodeId

public String getNodeId()

isCurrentNode

public boolean isCurrentNode(PrismObject<com.evolveum.midpoint.xml.ns._public.common.common_3.NodeType> node)

isCurrentNode

public boolean isCurrentNode(String node)

deleteNode

public void deleteNode(String nodeOid,
              OperationResult result)
                throws SchemaException,
                       ObjectNotFoundException

Throws:

SchemaException

ObjectNotFoundException

createNodeObject

public void createNodeObject(OperationResult result)
                      throws TaskManagerInitializationException

Throws:

TaskManagerInitializationException

getNodePrism

public PrismObject<com.evolveum.midpoint.xml.ns._public.common.common_3.NodeType> getNodePrism()

isUp

public boolean isUp(com.evolveum.midpoint.xml.ns._public.common.common_3.NodeType nodeType)

stopClusterManagerThread

public void stopClusterManagerThread(long waitTime,
                            OperationResult parentResult)

startClusterManagerThread

public void startClusterManagerThread()

dumpNodeInfo

public String dumpNodeInfo(com.evolveum.midpoint.xml.ns._public.common.common_3.NodeType node)

getAllNodes

public List<PrismObject<com.evolveum.midpoint.xml.ns._public.common.common_3.NodeType>> getAllNodes(OperationResult result)

getNode

public PrismObject<com.evolveum.midpoint.xml.ns._public.common.common_3.NodeType> getNode(String nodeOid,
                                                                                 OperationResult result)
                                                                                   throws SchemaException,
                                                                                          ObjectNotFoundException

Throws:

SchemaException

ObjectNotFoundException

getNodeById

public PrismObject<com.evolveum.midpoint.xml.ns._public.common.common_3.NodeType> getNodeById(String nodeIdentifier,
                                                                                     OperationResult result)
                                                                                       throws ObjectNotFoundException

Throws:

ObjectNotFoundException

checkSystemConfigurationChanged

public void checkSystemConfigurationChanged(OperationResult parentResult)

Check whether system configuration has not changed in repository (e.g. by another node in cluster). Applies new configuration if so.

Parameters:

parentResult -

checkWaitingTasks

public void checkWaitingTasks(OperationResult result)
                       throws SchemaException

Throws:

SchemaException

checkStalledTasks

public void checkStalledTasks(OperationResult result)
                       throws SchemaException

Throws:

SchemaException