org.ow2.proactive.resourcemanager.selection.topology

Class TopologyManager

java.lang.Object

org.ow2.proactive.resourcemanager.selection.topology.TopologyManager

public class TopologyManager
extends Object

Class is responsible for collecting the topology information, keeping it up to date and taking it into account for nodes selection.

Constructor Summary

Constructors

Constructor and Description
TopologyManager() Constructs new instance of the topology descriptor.
TopologyManager(Class<? extends Pinger> pingerClass)

Method Summary

Modifier and Type	Method and Description
void	addNode(org.objectweb.proactive.core.node.Node node) Updates the topology for new node.
TopologyHandler	getHandler(TopologyDescriptor topologyDescriptor) Returns the handler of corresponding descriptor.
Set<org.objectweb.proactive.core.node.Node>	getNodesOnHost(String hostName)
Topology	getTopology() Returns the topology representation.
void	removeNode(org.objectweb.proactive.core.node.Node node) Node is removed or down.

Methods inherited from class java.lang.Object

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

Constructor Detail

TopologyManager

public TopologyManager()
                throws ClassNotFoundException

Constructs new instance of the topology descriptor.

Throws:

ClassNotFoundException - when the pinger class specified in the RM configuration file is not found

TopologyManager

public TopologyManager(Class<? extends Pinger> pingerClass)

Method Detail

getHandler

public TopologyHandler getHandler(TopologyDescriptor topologyDescriptor)

Returns the handler of corresponding descriptor. HAndles contains the logic of nodes selection in respect of the topology information.

addNode

public void addNode(org.objectweb.proactive.core.node.Node node)

Updates the topology for new node. Executes the pinger on new node when this node belongs to unknow host.

removeNode

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

Node is removed or down. Method removes corresponding topology information.

getNodesOnHost

public Set<org.objectweb.proactive.core.node.Node> getNodesOnHost(String hostName)

getTopology

public Topology getTopology()

Returns the topology representation. As the Topology is not a thread-safe class and all synchronization happens on TopologyManager level, the topology is cloned.