org.apache.zookeeper.server.quorum
Modifier and Type | Class and Description |
---|---|
static class |
LeaderElection.ElectionResult |
Modifier and Type | Field and Description |
---|---|
protected static Random |
epochGen |
protected QuorumPeer |
self |
Constructor and Description |
---|
LeaderElection(QuorumPeer self) |
Modifier and Type | Method and Description |
---|---|
protected LeaderElection.ElectionResult |
countVotes(HashMap<InetSocketAddress,Vote> votes,
HashSet<Long> heardFrom) |
Vote |
lookForLeader()
Invoked in QuorumPeer to find or elect a new leader.
|
void |
shutdown()
There is nothing to shutdown in this implementation of
leader election, so we simply have an empty method.
|
protected static Random epochGen
protected QuorumPeer self
public LeaderElection(QuorumPeer self)
protected LeaderElection.ElectionResult countVotes(HashMap<InetSocketAddress,Vote> votes, HashSet<Long> heardFrom)
public void shutdown()
public Vote lookForLeader() throws InterruptedException
lookForLeader
in interface Election
InterruptedException
Copyright © 2014 The Apache Software Foundation