org.apache.zookeeper.server.quorum
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
protected long |
sid
ZooKeeper server identifier of this learner
|
protected Socket |
sock |
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
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 © 2014 The Apache Software Foundation