Class RecoverySourceHandler

  • public class RecoverySourceHandler
    extends java.lang.Object
    RecoverySourceHandler handles the three phases of shard recovery, which is everything relating to copying the segment files as well as sending translog operations across the wire once the segments have been copied. Note: There is always one source handler per recovery that handles all the file and translog transfer. This handler is completely isolated from other recoveries while the RateLimiter passed via RecoverySettings is shared across recoveries originating from this nodes to throttle the number bytes send during file transfer. The transaction log phase bypasses the rate limiter entirely.
    • Field Detail

      • logger

        protected final org.apache.logging.log4j.Logger logger
    • Method Detail

      • recoverToTarget

        public void recoverToTarget​(ActionListener<RecoveryResponse> listener)
        performs the recovery from the local engine to the target
      • cancel

        public void cancel​(java.lang.String reason)
        Cancels the recovery and interrupts all eligible threads.
      • toString

        public java.lang.String toString()
        toString in class java.lang.Object
      • failEngine

        protected void failEngine​( cause)