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 booleanaskOracle()booleancontainsQuorum(java.util.Set<java.lang.Long> ackSet)Verifies if a set is a majority.booleanequals(java.lang.Object o)booleangetNeedOracle()java.lang.StringgetOraclePath()inthashCode()booleanoverrideQuorumDecision(java.util.List<LearnerHandler> forwardingFollowers)booleanrevalidateOutstandingProp(Leader self, java.util.ArrayList<Leader.Proposal> outstandingProposal, long lastCommitted)booleanrevalidateVoteset(SyncedLearnerTracker voteSet, boolean timeout)booleanupdateNeedOracle(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:QuorumMajVerifies if a set is a majority. Assumes that ackSet contains acks only from votingMembers- Specified by:
containsQuorumin interfaceQuorumVerifier- Overrides:
containsQuorumin classQuorumMaj
-
equals
public boolean equals(java.lang.Object o)
- Specified by:
equalsin interfaceQuorumVerifier- Overrides:
equalsin classQuorumMaj
-
-