Class QuorumOracleMaj
- java.lang.Object
-
- org.apache.zookeeper.server.quorum.flexible.QuorumMaj
-
- org.apache.zookeeper.server.quorum.flexible.QuorumOracleMaj
-
- All Implemented Interfaces:
QuorumVerifier
public class QuorumOracleMaj extends QuorumMaj
-
-
Constructor Summary
Constructors Constructor Description QuorumOracleMaj(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> allMembers, java.lang.String oraclePath)
QuorumOracleMaj(java.util.Properties props, java.lang.String oraclePath)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
askOracle()
boolean
containsQuorum(java.util.Set<java.lang.Long> ackSet)
Verifies if a set is a majority.boolean
equals(java.lang.Object o)
boolean
getNeedOracle()
java.lang.String
getOraclePath()
int
hashCode()
boolean
overrideQuorumDecision(java.util.List<LearnerHandler> forwardingFollowers)
boolean
revalidateOutstandingProp(Leader self, java.util.ArrayList<Leader.Proposal> outstandingProposal, long lastCommitted)
boolean
revalidateVoteset(SyncedLearnerTracker voteSet, boolean timeout)
boolean
updateNeedOracle(java.util.List<LearnerHandler> forwardingFollowers)
-
Methods inherited from class org.apache.zookeeper.server.quorum.flexible.QuorumMaj
getAllMembers, getObservingMembers, getVersion, getVotingMembers, getWeight, setVersion, toString
-
-
-
-
Constructor Detail
-
QuorumOracleMaj
public QuorumOracleMaj(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> allMembers, java.lang.String oraclePath)
-
QuorumOracleMaj
public QuorumOracleMaj(java.util.Properties props, java.lang.String oraclePath) throws QuorumPeerConfig.ConfigException
- Throws:
QuorumPeerConfig.ConfigException
-
-
Method Detail
-
updateNeedOracle
public boolean updateNeedOracle(java.util.List<LearnerHandler> forwardingFollowers)
-
askOracle
public boolean askOracle()
-
getNeedOracle
public boolean getNeedOracle()
-
getOraclePath
public java.lang.String getOraclePath()
-
overrideQuorumDecision
public boolean overrideQuorumDecision(java.util.List<LearnerHandler> forwardingFollowers)
-
revalidateOutstandingProp
public boolean revalidateOutstandingProp(Leader self, java.util.ArrayList<Leader.Proposal> outstandingProposal, long lastCommitted)
-
revalidateVoteset
public boolean revalidateVoteset(SyncedLearnerTracker voteSet, boolean timeout)
-
containsQuorum
public boolean containsQuorum(java.util.Set<java.lang.Long> ackSet)
Description copied from class:QuorumMaj
Verifies if a set is a majority. Assumes that ackSet contains acks only from votingMembers- Specified by:
containsQuorum
in interfaceQuorumVerifier
- Overrides:
containsQuorum
in classQuorumMaj
-
equals
public boolean equals(java.lang.Object o)
- Specified by:
equals
in interfaceQuorumVerifier
- Overrides:
equals
in classQuorumMaj
-
-