Class QuorumPeer
- java.lang.Object
-
- java.lang.Thread
-
- org.apache.zookeeper.server.ZooKeeperThread
-
- org.apache.zookeeper.server.quorum.QuorumPeer
-
- All Implemented Interfaces:
java.lang.Runnable
,QuorumStats.Provider
public class QuorumPeer extends ZooKeeperThread implements QuorumStats.Provider
This class manages the quorum protocol. There are three states this server can be in:- Leader election - each server will elect a leader (proposing itself as a leader initially).
- Follower - the server will synchronize with the leader and replicate any transactions.
- Leader - the server will process requests and forward them to followers. A majority of followers must log the request before it can be accepted.
int xid; long myid; long leader_id; long leader_zxid;
The request for the current leader will consist solely of an xid: int xid;
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
QuorumPeer.AddressTuple
static class
QuorumPeer.LearnerType
static class
QuorumPeer.QuorumServer
static class
QuorumPeer.ServerState
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
ACCEPTED_EPOCH_FILENAME
static java.lang.String
CURRENT_EPOCH_FILENAME
long
end_fle
static java.lang.String
FLE_TIME_UNIT
Follower
follower
protected int
initLimit
The number of ticks that the initial synchronization phase can takeLeader
leader
protected boolean
localSessionsEnabled
Whether learners in this quorum should create new sessions as local.protected boolean
localSessionsUpgradingEnabled
Whether learners in this quorum should upgrade local sessions to global.protected int
maxSessionTimeout
Maximum number of milliseconds to allow for session timeout.protected int
minSessionTimeout
Minimum number of milliseconds to allow for session timeout.Observer
observer
protected int
quorumCnxnThreadsSize
The maximum number of threads to allow in the connectionExecutors thread pool which will be used to initiate quorum server connections.protected java.lang.String
quorumLearnerLoginContext
Quorum learner login context name in jaas-conf file to read the kerberos security details.protected boolean
quorumLearnerSaslAuthRequired
If this is false, quorum peer learner will talk to quorum peer server without authentication.protected boolean
quorumListenOnAllIPs
Whether or not to listen on all IPs for the two quorum ports (broadcast and fast leader election).protected boolean
quorumSaslEnableAuth
Enable/Disables quorum authentication using sasl.protected java.lang.String
quorumServerLoginContext
Quorum server login context name in jaas-conf file to read the kerberos security details.protected boolean
quorumServerSaslAuthRequired
If this is false, quorum peer server will accept another quorum peer client connection even if the authentication did not succeed.protected java.lang.String
quorumServicePrincipal
Kerberos quorum service principal.long
start_fle
static java.lang.String
SYNC_ENABLED
The syncEnabled can also be set via a system property.protected boolean
syncEnabled
Enables/Disables sync request processor.protected int
syncLimit
The number of ticks that can pass between sending a request and getting an acknowledgmentprotected java.util.concurrent.atomic.AtomicInteger
tick
The current tickprotected int
tickTime
The number of milliseconds of each tick-
Fields inherited from interface org.apache.zookeeper.server.quorum.QuorumStats.Provider
FOLLOWING_STATE, LEADING_STATE, LOOKING_STATE, OBSERVING_STATE, UNKNOWN_STATE
-
-
Constructor Summary
Constructors Constructor Description QuorumPeer()
QuorumPeer(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> quorumPeers, java.io.File snapDir, java.io.File logDir, int clientPort, int electionAlg, long myid, int tickTime, int initLimit, int syncLimit)
This constructor is only used by the existing unit test code.QuorumPeer(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> quorumPeers, java.io.File snapDir, java.io.File logDir, int clientPort, int electionAlg, long myid, int tickTime, int initLimit, int syncLimit, QuorumVerifier quorumConfig)
This constructor is only used by the existing unit test code.QuorumPeer(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> quorumPeers, java.io.File dataDir, java.io.File dataLogDir, int electionType, long myid, int tickTime, int initLimit, int syncLimit, boolean quorumListenOnAllIPs, ServerCnxnFactory cnxnFactory, QuorumVerifier quorumConfig)
QuorumPeer(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> quorumPeers, java.io.File dataDir, java.io.File dataLogDir, int electionType, long myid, int tickTime, int initLimit, int syncLimit, ServerCnxnFactory cnxnFactory)
For backward compatibility purposes, we instantiate QuorumMaj by default.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
areLocalSessionsEnabled()
Whether local sessions are enabledvoid
closeAllConnections()
QuorumVerifier
configFromString(java.lang.String s)
protected static int
countParticipants(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> peers)
Count the number of nodes in the map that could be followers.QuorumCnxManager
createCnxnManager()
protected Election
createElectionAlgorithm(int electionAlgorithm)
void
enableLocalSessions(boolean flag)
Whether to enable local sessionsvoid
enableLocalSessionsUpgrading(boolean flag)
Whether to allow local sessions to upgrade to global sessionslong
getAcceptedEpoch()
ZooKeeperServer
getActiveServer()
java.net.InetSocketAddress
getClientAddress()
int
getClientPort()
java.util.Set<java.lang.Long>
getCurrentAndNextConfigVoters()
long
getCurrentEpoch()
Vote
getCurrentVote()
java.net.InetSocketAddress
getElectionAddress()
Election
getElectionAlg()
Get an instance of LeaderElectionint
getElectionType()
Gets the election typelong
getId()
get the id of this quorum peer.int
getInitLimit()
Get the number of ticks that the initial synchronization phase can takelong
getLastLoggedZxid()
returns the highest zxid that this host has seenQuorumVerifier
getLastSeenQuorumVerifier()
Return QuorumVerifier object for the last proposed configuration.QuorumPeer.LearnerType
getLearnerType()
int
getMaxClientCnxnsPerHost()
Maximum number of connections allowed from particular host (ip)int
getMaxSessionTimeout()
maximum session timeout in millisecondsint
getMinSessionTimeout()
minimum session timeout in millisecondsjava.lang.String
getNextDynamicConfigFilename()
java.util.Map<java.lang.Long,QuorumPeer.QuorumServer>
getObservingView()
Returns only observers, no followers.QuorumPeer.ServerState
getPeerState()
java.net.InetSocketAddress
getQuorumAddress()
QuorumCnxManager
getQuorumCnxManager()
get reference to QuorumCnxManagerboolean
getQuorumListenOnAllIPs()
java.lang.String[]
getQuorumPeers()
Only used by QuorumStats at the momentint
getQuorumSize()
QuorumVerifier
getQuorumVerifier()
Return QuorumVerifier object for the last committed configuration.java.lang.String
getServerState()
boolean
getSyncEnabled()
Return syncEnabled.int
getSyncLimit()
Get the synclimitint
getTick()
Get the current tickint
getTickTime()
Get the number of milliseconds of each tickFileTxnSnapLog
getTxnFactory()
java.util.Map<java.lang.Long,QuorumPeer.QuorumServer>
getView()
A 'view' is a node's current opinion of the membership of the entire ensemble.java.util.Map<java.lang.Long,QuorumPeer.QuorumServer>
getVotingView()
Observers are not contained in this view, only nodes with PeerType=PARTICIPANT.protected ZKDatabase
getZkDb()
void
initConfigInZKDatabase()
void
initialize()
boolean
isLocalSessionsUpgradingEnabled()
Whether local sessions are allowed to upgrade to global sessionsboolean
isReconfigStateChange()
boolean
isRunning()
boolean
isSslQuorum()
protected Follower
makeFollower(FileTxnSnapLog logFactory)
protected Leader
makeLeader(FileTxnSnapLog logFactory)
protected Election
makeLEStrategy()
protected Observer
makeObserver(FileTxnSnapLog logFactory)
boolean
processReconfig(QuorumVerifier qv, java.lang.Long suggestedLeaderId, java.lang.Long zxid, boolean restartLE)
void
reconfigFlagClear()
void
reconfigFlagSet()
void
recreateSocketAddresses(long id)
Resolves hostname for a given server ID.void
restartLeaderElection(QuorumVerifier qvOLD, QuorumVerifier qvNEW)
void
run()
void
setAcceptedEpoch(long e)
void
setCnxnFactory(ServerCnxnFactory cnxnFactory)
protected void
setConfigFileName(java.lang.String s)
void
setCurrentEpoch(long e)
void
setCurrentVote(Vote v)
void
setElectionType(int electionType)
Sets the election typeprotected void
setFollower(Follower newFollower)
void
setInitLimit(int initLimit)
Set the number of ticks that the initial synchronization phase can takevoid
setLastSeenQuorumVerifier(QuorumVerifier qv, boolean writeToDisk)
protected void
setLeader(Leader newLeader)
void
setLearnerType(QuorumPeer.LearnerType p)
Sets the LearnerTypevoid
setMaxSessionTimeout(int max)
maximum session timeout in millisecondsvoid
setMinSessionTimeout(int min)
minimum session timeout in millisecondsvoid
setMyid(long myid)
set the id of this quorum peer.protected void
setObserver(Observer newObserver)
void
setPeerState(QuorumPeer.ServerState newState)
void
setQuorumListenOnAllIPs(boolean quorumListenOnAllIPs)
QuorumVerifier
setQuorumVerifier(QuorumVerifier qv, boolean writeToDisk)
void
setSecureCnxnFactory(ServerCnxnFactory secureCnxnFactory)
void
setSslQuorum(boolean sslQuorum)
void
setSyncEnabled(boolean syncEnabled)
Set syncEnabled.void
setSyncLimit(int syncLimit)
Set the synclimitvoid
setTickTime(int tickTime)
Set the number of milliseconds of each tickvoid
setTxnFactory(FileTxnSnapLog factory)
void
setUsePortUnification(boolean shouldUsePortUnification)
void
setZKDatabase(ZKDatabase database)
set zk database for this nodevoid
setZooKeeperServer(ZooKeeperServer zks)
boolean
shouldUsePortUnification()
void
shutdown()
void
start()
void
startLeaderElection()
void
stopLeaderElection()
static QuorumPeer
testingQuorumPeer()
protected void
updateElectionVote(long newEpoch)
Updates leader election info to avoid inconsistencies when a new server tries to join the ensemble.boolean
viewContains(java.lang.Long sid)
Check if a node is in the current view.-
Methods inherited from class org.apache.zookeeper.server.ZooKeeperThread
handleException
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, suspend, toString, yield
-
-
-
-
Field Detail
-
start_fle
public long start_fle
-
end_fle
public long end_fle
-
FLE_TIME_UNIT
public static final java.lang.String FLE_TIME_UNIT
- See Also:
- Constant Field Values
-
tickTime
protected int tickTime
The number of milliseconds of each tick
-
localSessionsEnabled
protected boolean localSessionsEnabled
Whether learners in this quorum should create new sessions as local. False by default to preserve existing behavior.
-
localSessionsUpgradingEnabled
protected boolean localSessionsUpgradingEnabled
Whether learners in this quorum should upgrade local sessions to global. Only matters if local sessions are enabled.
-
minSessionTimeout
protected int minSessionTimeout
Minimum number of milliseconds to allow for session timeout. A value of -1 indicates unset, use default.
-
maxSessionTimeout
protected int maxSessionTimeout
Maximum number of milliseconds to allow for session timeout. A value of -1 indicates unset, use default.
-
initLimit
protected int initLimit
The number of ticks that the initial synchronization phase can take
-
syncLimit
protected int syncLimit
The number of ticks that can pass between sending a request and getting an acknowledgment
-
syncEnabled
protected boolean syncEnabled
Enables/Disables sync request processor. This option is enabled by default and is to be used with observers.
-
tick
protected java.util.concurrent.atomic.AtomicInteger tick
The current tick
-
quorumListenOnAllIPs
protected boolean quorumListenOnAllIPs
Whether or not to listen on all IPs for the two quorum ports (broadcast and fast leader election).
-
quorumSaslEnableAuth
protected boolean quorumSaslEnableAuth
Enable/Disables quorum authentication using sasl. Defaulting to false.
-
quorumServerSaslAuthRequired
protected boolean quorumServerSaslAuthRequired
If this is false, quorum peer server will accept another quorum peer client connection even if the authentication did not succeed. This can be used while upgrading ZooKeeper server. Defaulting to false (required).
-
quorumLearnerSaslAuthRequired
protected boolean quorumLearnerSaslAuthRequired
If this is false, quorum peer learner will talk to quorum peer server without authentication. This can be used while upgrading ZooKeeper server. Defaulting to false (required).
-
quorumServicePrincipal
protected java.lang.String quorumServicePrincipal
Kerberos quorum service principal. Defaulting to 'zkquorum/localhost'.
-
quorumLearnerLoginContext
protected java.lang.String quorumLearnerLoginContext
Quorum learner login context name in jaas-conf file to read the kerberos security details. Defaulting to 'QuorumLearner'.
-
quorumServerLoginContext
protected java.lang.String quorumServerLoginContext
Quorum server login context name in jaas-conf file to read the kerberos security details. Defaulting to 'QuorumServer'.
-
quorumCnxnThreadsSize
protected int quorumCnxnThreadsSize
The maximum number of threads to allow in the connectionExecutors thread pool which will be used to initiate quorum server connections.
-
follower
public Follower follower
-
leader
public Leader leader
-
observer
public Observer observer
-
SYNC_ENABLED
public static final java.lang.String SYNC_ENABLED
The syncEnabled can also be set via a system property.- See Also:
- Constant Field Values
-
CURRENT_EPOCH_FILENAME
public static final java.lang.String CURRENT_EPOCH_FILENAME
- See Also:
- Constant Field Values
-
ACCEPTED_EPOCH_FILENAME
public static final java.lang.String ACCEPTED_EPOCH_FILENAME
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
QuorumPeer
public QuorumPeer() throws javax.security.sasl.SaslException
- Throws:
javax.security.sasl.SaslException
-
QuorumPeer
public QuorumPeer(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> quorumPeers, java.io.File dataDir, java.io.File dataLogDir, int electionType, long myid, int tickTime, int initLimit, int syncLimit, ServerCnxnFactory cnxnFactory) throws java.io.IOException
For backward compatibility purposes, we instantiate QuorumMaj by default.- Throws:
java.io.IOException
-
QuorumPeer
public QuorumPeer(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> quorumPeers, java.io.File dataDir, java.io.File dataLogDir, int electionType, long myid, int tickTime, int initLimit, int syncLimit, boolean quorumListenOnAllIPs, ServerCnxnFactory cnxnFactory, QuorumVerifier quorumConfig) throws java.io.IOException
- Throws:
java.io.IOException
-
QuorumPeer
public QuorumPeer(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> quorumPeers, java.io.File snapDir, java.io.File logDir, int clientPort, int electionAlg, long myid, int tickTime, int initLimit, int syncLimit) throws java.io.IOException
This constructor is only used by the existing unit test code. It defaults to FileLogProvider persistence provider.- Throws:
java.io.IOException
-
QuorumPeer
public QuorumPeer(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> quorumPeers, java.io.File snapDir, java.io.File logDir, int clientPort, int electionAlg, long myid, int tickTime, int initLimit, int syncLimit, QuorumVerifier quorumConfig) throws java.io.IOException
This constructor is only used by the existing unit test code. It defaults to FileLogProvider persistence provider.- Throws:
java.io.IOException
-
-
Method Detail
-
getLearnerType
public QuorumPeer.LearnerType getLearnerType()
-
setLearnerType
public void setLearnerType(QuorumPeer.LearnerType p)
Sets the LearnerType
-
setConfigFileName
protected void setConfigFileName(java.lang.String s)
-
getQuorumSize
public int getQuorumSize()
-
getId
public long getId()
get the id of this quorum peer.- Overrides:
getId
in classjava.lang.Thread
-
isSslQuorum
public boolean isSslQuorum()
-
shouldUsePortUnification
public boolean shouldUsePortUnification()
-
getCurrentVote
public Vote getCurrentVote()
-
setCurrentVote
public void setCurrentVote(Vote v)
-
setPeerState
public void setPeerState(QuorumPeer.ServerState newState)
-
reconfigFlagSet
public void reconfigFlagSet()
-
reconfigFlagClear
public void reconfigFlagClear()
-
isReconfigStateChange
public boolean isReconfigStateChange()
-
getPeerState
public QuorumPeer.ServerState getPeerState()
-
recreateSocketAddresses
public void recreateSocketAddresses(long id)
Resolves hostname for a given server ID. This method resolves hostname for a given server ID in both quorumVerifer and lastSeenQuorumVerifier. If the server ID matches the local server ID, it also updates myAddrs.
-
getQuorumAddress
public java.net.InetSocketAddress getQuorumAddress()
-
getElectionAddress
public java.net.InetSocketAddress getElectionAddress()
-
getClientAddress
public java.net.InetSocketAddress getClientAddress()
-
testingQuorumPeer
public static QuorumPeer testingQuorumPeer() throws javax.security.sasl.SaslException
- Throws:
javax.security.sasl.SaslException
-
initialize
public void initialize() throws javax.security.sasl.SaslException
- Throws:
javax.security.sasl.SaslException
-
start
public void start()
- Overrides:
start
in classjava.lang.Thread
-
stopLeaderElection
public void stopLeaderElection()
-
startLeaderElection
public void startLeaderElection()
-
countParticipants
protected static int countParticipants(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> peers)
Count the number of nodes in the map that could be followers.- Parameters:
peers
-- Returns:
- The number of followers in the map
-
getLastLoggedZxid
public long getLastLoggedZxid()
returns the highest zxid that this host has seen- Returns:
- the highest zxid for this host
-
makeFollower
protected Follower makeFollower(FileTxnSnapLog logFactory) throws java.io.IOException
- Throws:
java.io.IOException
-
makeLeader
protected Leader makeLeader(FileTxnSnapLog logFactory) throws java.io.IOException, X509Exception
- Throws:
java.io.IOException
X509Exception
-
makeObserver
protected Observer makeObserver(FileTxnSnapLog logFactory) throws java.io.IOException
- Throws:
java.io.IOException
-
createElectionAlgorithm
protected Election createElectionAlgorithm(int electionAlgorithm)
-
makeLEStrategy
protected Election makeLEStrategy()
-
setLeader
protected void setLeader(Leader newLeader)
-
setFollower
protected void setFollower(Follower newFollower)
-
setObserver
protected void setObserver(Observer newObserver)
-
getActiveServer
public ZooKeeperServer getActiveServer()
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
shutdown
public void shutdown()
-
getView
public java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> getView()
A 'view' is a node's current opinion of the membership of the entire ensemble.
-
getVotingView
public java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> getVotingView()
Observers are not contained in this view, only nodes with PeerType=PARTICIPANT.
-
getObservingView
public java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> getObservingView()
Returns only observers, no followers.
-
getCurrentAndNextConfigVoters
public java.util.Set<java.lang.Long> getCurrentAndNextConfigVoters()
-
viewContains
public boolean viewContains(java.lang.Long sid)
Check if a node is in the current view. With static membership, the result of this check will never change; only when dynamic membership is introduced will this be more useful.
-
getQuorumPeers
public java.lang.String[] getQuorumPeers()
Only used by QuorumStats at the moment- Specified by:
getQuorumPeers
in interfaceQuorumStats.Provider
-
getServerState
public java.lang.String getServerState()
- Specified by:
getServerState
in interfaceQuorumStats.Provider
-
setMyid
public void setMyid(long myid)
set the id of this quorum peer.
-
getTickTime
public int getTickTime()
Get the number of milliseconds of each tick
-
setTickTime
public void setTickTime(int tickTime)
Set the number of milliseconds of each tick
-
getMaxClientCnxnsPerHost
public int getMaxClientCnxnsPerHost()
Maximum number of connections allowed from particular host (ip)
-
areLocalSessionsEnabled
public boolean areLocalSessionsEnabled()
Whether local sessions are enabled
-
enableLocalSessions
public void enableLocalSessions(boolean flag)
Whether to enable local sessions
-
isLocalSessionsUpgradingEnabled
public boolean isLocalSessionsUpgradingEnabled()
Whether local sessions are allowed to upgrade to global sessions
-
enableLocalSessionsUpgrading
public void enableLocalSessionsUpgrading(boolean flag)
Whether to allow local sessions to upgrade to global sessions
-
getMinSessionTimeout
public int getMinSessionTimeout()
minimum session timeout in milliseconds
-
setMinSessionTimeout
public void setMinSessionTimeout(int min)
minimum session timeout in milliseconds
-
getMaxSessionTimeout
public int getMaxSessionTimeout()
maximum session timeout in milliseconds
-
setMaxSessionTimeout
public void setMaxSessionTimeout(int max)
maximum session timeout in milliseconds
-
getInitLimit
public int getInitLimit()
Get the number of ticks that the initial synchronization phase can take
-
setInitLimit
public void setInitLimit(int initLimit)
Set the number of ticks that the initial synchronization phase can take
-
getTick
public int getTick()
Get the current tick
-
configFromString
public QuorumVerifier configFromString(java.lang.String s) throws java.io.IOException, QuorumPeerConfig.ConfigException
- Throws:
java.io.IOException
QuorumPeerConfig.ConfigException
-
getQuorumVerifier
public QuorumVerifier getQuorumVerifier()
Return QuorumVerifier object for the last committed configuration.
-
getLastSeenQuorumVerifier
public QuorumVerifier getLastSeenQuorumVerifier()
Return QuorumVerifier object for the last proposed configuration.
-
restartLeaderElection
public void restartLeaderElection(QuorumVerifier qvOLD, QuorumVerifier qvNEW)
-
getNextDynamicConfigFilename
public java.lang.String getNextDynamicConfigFilename()
-
setLastSeenQuorumVerifier
public void setLastSeenQuorumVerifier(QuorumVerifier qv, boolean writeToDisk)
-
setQuorumVerifier
public QuorumVerifier setQuorumVerifier(QuorumVerifier qv, boolean writeToDisk)
-
getElectionAlg
public Election getElectionAlg()
Get an instance of LeaderElection
-
getSyncLimit
public int getSyncLimit()
Get the synclimit
-
setSyncLimit
public void setSyncLimit(int syncLimit)
Set the synclimit
-
getSyncEnabled
public boolean getSyncEnabled()
Return syncEnabled.- Returns:
-
setSyncEnabled
public void setSyncEnabled(boolean syncEnabled)
Set syncEnabled.- Parameters:
syncEnabled
-
-
getElectionType
public int getElectionType()
Gets the election type
-
setElectionType
public void setElectionType(int electionType)
Sets the election type
-
getQuorumListenOnAllIPs
public boolean getQuorumListenOnAllIPs()
-
setQuorumListenOnAllIPs
public void setQuorumListenOnAllIPs(boolean quorumListenOnAllIPs)
-
setCnxnFactory
public void setCnxnFactory(ServerCnxnFactory cnxnFactory)
-
setSecureCnxnFactory
public void setSecureCnxnFactory(ServerCnxnFactory secureCnxnFactory)
-
setSslQuorum
public void setSslQuorum(boolean sslQuorum)
-
setUsePortUnification
public void setUsePortUnification(boolean shouldUsePortUnification)
-
setZooKeeperServer
public void setZooKeeperServer(ZooKeeperServer zks)
-
closeAllConnections
public void closeAllConnections()
-
getClientPort
public int getClientPort()
-
setTxnFactory
public void setTxnFactory(FileTxnSnapLog factory)
-
getTxnFactory
public FileTxnSnapLog getTxnFactory()
-
setZKDatabase
public void setZKDatabase(ZKDatabase database)
set zk database for this node- Parameters:
database
-
-
getZkDb
protected ZKDatabase getZkDb()
-
initConfigInZKDatabase
public void initConfigInZKDatabase()
-
isRunning
public boolean isRunning()
-
getQuorumCnxManager
public QuorumCnxManager getQuorumCnxManager()
get reference to QuorumCnxManager
-
getCurrentEpoch
public long getCurrentEpoch() throws java.io.IOException
- Throws:
java.io.IOException
-
getAcceptedEpoch
public long getAcceptedEpoch() throws java.io.IOException
- Throws:
java.io.IOException
-
setCurrentEpoch
public void setCurrentEpoch(long e) throws java.io.IOException
- Throws:
java.io.IOException
-
setAcceptedEpoch
public void setAcceptedEpoch(long e) throws java.io.IOException
- Throws:
java.io.IOException
-
processReconfig
public boolean processReconfig(QuorumVerifier qv, java.lang.Long suggestedLeaderId, java.lang.Long zxid, boolean restartLE)
-
updateElectionVote
protected void updateElectionVote(long newEpoch)
Updates leader election info to avoid inconsistencies when a new server tries to join the ensemble. Here is the inconsistency scenario we try to solve by updating the peer epoch after following leader: Let's say we have an ensemble with 3 servers z1, z2 and z3. 1. z1, z2 were following z3 with peerEpoch to be 0xb8, the new epoch is 0xb9, aka current accepted epoch on disk. 2. z2 get restarted, which will use 0xb9 as it's peer epoch when loading the current accept epoch from disk. 3. z2 received notification from z1 and z3, which is following z3 with epoch 0xb8, so it started following z3 again with peer epoch 0xb8. 4. before z2 successfully connected to z3, z3 get restarted with new epoch 0xb9. 5. z2 will retry around a few round (default 5s) before giving up, meanwhile it will report z3 as leader. 6. z1 restarted, and looking with peer epoch 0xb9. 7. z1 voted z3, and z3 was elected as leader again with peer epoch 0xb9. 8. z2 successfully connected to z3 before giving up, but with peer epoch 0xb8. 9. z1 get restarted, looking for leader with peer epoch 0xba, but cannot join, because z2 is reporting peer epoch 0xb8, while z3 is reporting 0xb9. By updating the election vote after actually following leader, we can avoid this kind of stuck happened. Btw, the zxid and electionEpoch could be inconsistent because of the same reason, it's better to update these as well after syncing with leader, but that required protocol change which is non trivial. This problem is worked around by skipping comparing the zxid and electionEpoch when counting for votes for out of election servers during looking for leader. {@see https://issues.apache.org/jira/browse/ZOOKEEPER-1732}
-
createCnxnManager
public QuorumCnxManager createCnxnManager()
-
-