Class Follower
- java.lang.Object
- 
- org.apache.zookeeper.server.quorum.Learner
- 
- org.apache.zookeeper.server.quorum.Follower
 
 
- 
 public class Follower extends Learner This class has the control logic for the Follower.
- 
- 
Field Summary- 
Fields inherited from class org.apache.zookeeper.server.quorum.LearnerbufferedOutput, closeSocketAsync, leaderAddr, leaderIs, leaderOs, leaderProtocolVersion, LEARNER_ASYNC_SENDING, LEARNER_CLOSE_SOCKET_ASYNC, LOG, messageTracker, sock, sockBeingClosed
 
- 
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description protected longgetLastQueued()The zxid of the last operation queuedIterable<Map<String,Object>>getSyncedObserversInfo()IntegergetSyncedObserverSize()longgetZxid()The zxid of the last operation seenprotected voidprocessPacket(QuorumPacket qp)Examine the packet received in qp and dispatch based on its contents.voidresetObserverConnectionStats()voidshutdown()Shutdown the PeerStringtoString()- 
Methods inherited from class org.apache.zookeeper.server.quorum.LearnerconnectToLeader, createSocket, findLeader, getAsyncSending, getPendingRevalidationsCount, getSocket, nanoTime, ping, registerWithLeader, revalidate, setAsyncSending, sockConnect, startSendingThread, syncWithLeader
 
- 
 
- 
- 
- 
Method Detail- 
processPacketprotected void processPacket(QuorumPacket qp) throws Exception Examine the packet received in qp and dispatch based on its contents.- Parameters:
- qp-
- Throws:
- IOException
- Exception
 
 - 
getZxidpublic long getZxid() The zxid of the last operation seen- Returns:
- zxid
 
 - 
getLastQueuedprotected long getLastQueued() The zxid of the last operation queued- Returns:
- zxid
 
 - 
getSyncedObserverSizepublic Integer getSyncedObserverSize() 
 - 
resetObserverConnectionStatspublic void resetObserverConnectionStats() 
 
- 
 
-