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.Learner
bufferedOutput, closeSocketAsync, leaderAddr, leaderIs, leaderOs, leaderProtocolVersion, LEARNER_ASYNC_SENDING, LEARNER_CLOSE_SOCKET_ASYNC, LOG, messageTracker, sock, sockBeingClosed 
 - 
 
- 
Method Summary
All 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.Learner
connectToLeader, createSocket, findLeader, getAsyncSending, getPendingRevalidationsCount, getSocket, nanoTime, ping, registerWithLeader, revalidate, setAsyncSending, sockConnect, startSendingThread, syncWithLeader 
 - 
 
 - 
 
- 
- 
Method Detail
- 
processPacket
protected void processPacket(QuorumPacket qp) throws Exception
Examine the packet received in qp and dispatch based on its contents.- Parameters:
 qp-- Throws:
 IOExceptionException
 
- 
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
public Integer getSyncedObserverSize()
 
- 
resetObserverConnectionStats
public void resetObserverConnectionStats()
 
 - 
 
 -