org.apache.zookeeper.server.quorum

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, leaderAddr, leaderIs, leaderOs, leaderProtocolVersion, LOG, messageTracker, sock

Method Summary

Modifier and Type	Method and Description
protected long	getLastQueued() The zxid of the last operation queued
Iterable<Map<String,Object>>	getSyncedObserversInfo()
Integer	getSyncedObserverSize()
long	getZxid() The zxid of the last operation seen
protected void	processPacket(QuorumPacket qp) Examine the packet received in qp and dispatch based on its contents.
void	resetObserverConnectionStats()
void	shutdown() Shutdown the Peer
String	toString()

Methods inherited from class org.apache.zookeeper.server.quorum.Learner

connectToLeader, createSocket, findLeader, getPendingRevalidationsCount, getSocket, nanoTime, ping, registerWithLeader, revalidate, sockConnect, syncWithLeader

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

toString

public String toString()

Overrides:

toString in class Object

processPacket

protected void processPacket(QuorumPacket qp)
                      throws Exception

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

public Integer getSyncedObserverSize()

getSyncedObserversInfo

public Iterable<Map<String,Object>> getSyncedObserversInfo()

resetObserverConnectionStats

public void resetObserverConnectionStats()

shutdown

public void shutdown()

Description copied from class: Learner

Shutdown the Peer

Overrides:

shutdown in class Learner