Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
protected long |
sid
ZooKeeper server identifier of this learner
|
protected Socket |
sock |
protected int |
version |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Modifier and Type | Method and Description |
---|---|
QuorumPeer.LearnerType |
getLearnerType() |
Socket |
getSocket() |
static 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() |
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 Socket sock
protected long sid
protected int version
public Socket getSocket()
public QuorumPeer.LearnerType getLearnerType()
public static String packetToString(QuorumPacket p)
public void run()
public void shutdown()
public long tickOfLastAck()
public void ping()
public boolean synced()
Copyright © 2016 The Apache Software Foundation