org.codehaus.wadi.dindex.impl
Class Coordinator
java.lang.Object
org.codehaus.wadi.dindex.impl.Coordinator
- All Implemented Interfaces:
- Runnable
- public class Coordinator
- extends Object
- implements Runnable
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_log
protected final Log _log
_flag
protected final Slot _flag
_config
protected final CoordinatorConfig _config
_cluster
protected final Cluster _cluster
_dispatcher
protected final Dispatcher _dispatcher
_localNode
protected final Node _localNode
_numItems
protected final int _numItems
_inactiveTime
protected final long _inactiveTime
_thread
protected Thread _thread
_remoteNodes
protected Node[] _remoteNodes
Coordinator
public Coordinator(CoordinatorConfig config)
start
public void start()
throws Exception
- Throws:
Exception
stop
public void stop()
throws Exception
- Throws:
Exception
queueRebalancing
public void queueRebalancing()
run
public void run()
- Specified by:
run
in interface Runnable
rebalanceClusterState
public void rebalanceClusterState()
execute
protected void execute(RedistributionPlan plan,
String correlationId,
Quipu quipu)
printNodes
protected int printNodes(Collection nodes)
printNodes
protected void printNodes(Node[] living,
Node[] leaving)
printNode
protected int printNode(Node node)
getNode
protected Node getNode(Destination destination)
Copyright © 2004-2006 Core Developers Network Ltd.. All Rights Reserved.