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 queuedjava.lang.Iterable<java.util.Map<java.lang.String,java.lang.Object>>getSyncedObserversInfo()java.lang.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 Peerjava.lang.StringtoString()-
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
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
processPacket
protected void processPacket(QuorumPacket qp) throws java.lang.Exception
Examine the packet received in qp and dispatch based on its contents.- Parameters:
qp-- Throws:
java.io.IOExceptionjava.lang.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
public java.lang.Integer getSyncedObserverSize()
-
getSyncedObserversInfo
public java.lang.Iterable<java.util.Map<java.lang.String,java.lang.Object>> getSyncedObserversInfo()
-
resetObserverConnectionStats
public void resetObserverConnectionStats()
-
-