Class Follower
java.lang.Object
org.apache.zookeeper.server.quorum.Learner
org.apache.zookeeper.server.quorum.Follower
This class has the control logic for the Follower.
-
Field Summary
Fields inherited from class org.apache.zookeeper.server.quorum.Learner
bufferedOutput, closeSocketAsync, leaderAddr, leaderIs, leaderOs, leaderProtocolVersion, LEARNER_ASYNC_SENDING, LEARNER_CLOSE_SOCKET_ASYNC, LOG, messageTracker, sock, sockBeingClosed
-
Method Summary
Methods inherited from class org.apache.zookeeper.server.quorum.Learner
connectToLeader, createSocket, findLeader, getAsyncSending, getPendingRevalidationsCount, getSocket, nanoTime, ping, registerWithLeader, revalidate, setAsyncSending, sockConnect, startSendingThread, syncWithLeader
-
Method Details
-
toString
-
processPacket
Examine the packet received in qp and dispatch based on its contents.- Parameters:
qp
-- Throws:
IOException
Exception
-
getZxid
public long getZxid()The zxid of the last operation seen- Returns:
- zxid
-
getLastQueued
protected long getLastQueued()The zxid of the last operation queued- Returns:
- zxid
-
getSyncedObserverSize
-
getSyncedObserversInfo
-
resetObserverConnectionStats
public void resetObserverConnectionStats() -
shutdown
public void shutdown()Description copied from class:Learner
Shutdown the Peer
-