public class LearnerHandler
extends java.lang.Thread
Modifier and Type | Field and Description |
---|---|
protected long |
sid
ZooKeeper server identifier of this learner
|
protected java.net.Socket |
sock |
protected int |
version |
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 |
tickOfLastAck() |
java.lang.String |
toString() |
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
protected final java.net.Socket sock
protected long sid
protected int version
public java.net.Socket getSocket()
public java.lang.String toString()
toString
in class java.lang.Thread
public QuorumPeer.LearnerType getLearnerType()
public static java.lang.String packetToString(QuorumPacket p)
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public void shutdown()
public long tickOfLastAck()
public void ping()
public boolean synced()
Copyright © 2019 The Apache Software Foundation