Package org.apache.zookeeper.server.quorum

Class 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 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

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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 java.lang.Thread

        activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, 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

      • 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()