Class QuorumMaj
- java.lang.Object
-
- org.apache.zookeeper.server.quorum.flexible.QuorumMaj
-
- All Implemented Interfaces:
QuorumVerifier
- Direct Known Subclasses:
QuorumOracleMaj
public class QuorumMaj extends java.lang.Object implements QuorumVerifier
This class implements a validator for majority quorums. The implementation is straightforward.
-
-
Field Summary
Fields Modifier and Type Field Description protected inthalf
-
Constructor Summary
Constructors Constructor Description QuorumMaj(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> allMembers)Defines a majority to avoid computing it every time.QuorumMaj(java.util.Properties props)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleancontainsQuorum(java.util.Set<java.lang.Long> ackSet)Verifies if a set is a majority.booleanequals(java.lang.Object o)java.util.Map<java.lang.Long,QuorumPeer.QuorumServer>getAllMembers()java.util.Map<java.lang.Long,QuorumPeer.QuorumServer>getObservingMembers()longgetVersion()java.util.Map<java.lang.Long,QuorumPeer.QuorumServer>getVotingMembers()longgetWeight(long id)Returns weight of 1 by default.inthashCode()voidsetVersion(long ver)java.lang.StringtoString()-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.zookeeper.server.quorum.flexible.QuorumVerifier
askOracle, getNeedOracle, getOraclePath, overrideQuorumDecision, revalidateOutstandingProp, revalidateVoteset, updateNeedOracle
-
-
-
-
Constructor Detail
-
QuorumMaj
public QuorumMaj(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> allMembers)
Defines a majority to avoid computing it every time.
-
QuorumMaj
public QuorumMaj(java.util.Properties props) throws QuorumPeerConfig.ConfigException- Throws:
QuorumPeerConfig.ConfigException
-
-
Method Detail
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
equals
public boolean equals(java.lang.Object o)
- Specified by:
equalsin interfaceQuorumVerifier- Overrides:
equalsin classjava.lang.Object
-
getWeight
public long getWeight(long id)
Returns weight of 1 by default.- Specified by:
getWeightin interfaceQuorumVerifier- Parameters:
id-
-
toString
public java.lang.String toString()
- Specified by:
toStringin interfaceQuorumVerifier- Overrides:
toStringin classjava.lang.Object
-
containsQuorum
public boolean containsQuorum(java.util.Set<java.lang.Long> ackSet)
Verifies if a set is a majority. Assumes that ackSet contains acks only from votingMembers- Specified by:
containsQuorumin interfaceQuorumVerifier
-
getAllMembers
public java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> getAllMembers()
- Specified by:
getAllMembersin interfaceQuorumVerifier
-
getVotingMembers
public java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> getVotingMembers()
- Specified by:
getVotingMembersin interfaceQuorumVerifier
-
getObservingMembers
public java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> getObservingMembers()
- Specified by:
getObservingMembersin interfaceQuorumVerifier
-
getVersion
public long getVersion()
- Specified by:
getVersionin interfaceQuorumVerifier
-
setVersion
public void setVersion(long ver)
- Specified by:
setVersionin interfaceQuorumVerifier
-
-