org.apache.zookeeper.server.quorum

Class LearnerHandler

java.lang.Object

java.lang.Thread

org.apache.zookeeper.server.ZooKeeperThread

org.apache.zookeeper.server.quorum.LearnerHandler

All Implemented Interfaces:

java.lang.Runnable

public class LearnerHandler
extends ZooKeeperThread

There will be an instance of this class created by the Leader for each learner. All communication with a learner is handled by this class.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected long	sid ZooKeeper server identifier of this learner
protected java.net.Socket	sock
protected int	version

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

Modifier and Type	Method and Description
QuorumPeer.LearnerType	getLearnerType()
java.net.Socket	getSocket()
static java.lang.String	packetToString(QuorumPacket p)
void	ping() ping calls from the leader to the peers
void	run() This thread will receive packets from the peer and process them and also listen to new connections from new peers.
void	shutdown()
boolean	synced()
long	tickOfNextAckDeadline()
java.lang.String	toString()

Methods inherited from class org.apache.zookeeper.server.ZooKeeperThread

handleException

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield

Methods inherited from class java.lang.Object

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

Field Detail

sock

protected final java.net.Socket sock

sid

protected long sid

ZooKeeper server identifier of this learner

version

protected int version

Method Detail

getSocket

public java.net.Socket getSocket()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Thread

getLearnerType

public QuorumPeer.LearnerType getLearnerType()

packetToString

public static java.lang.String packetToString(QuorumPacket p)

run

public void run()

This thread will receive packets from the peer and process them and also listen to new connections from new peers.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

shutdown

public void shutdown()

tickOfNextAckDeadline

public long tickOfNextAckDeadline()

ping

public void ping()

ping calls from the leader to the peers

synced

public boolean synced()