Package org.elasticsearch.indices.recovery

Class RecoverySourceHandler

java.lang.Object

org.elasticsearch.indices.recovery.RecoverySourceHandler

public class RecoverySourceHandler
extends 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 Summary

Fields

Modifier and Type	Field	Description
protected org.apache.logging.log4j.Logger	logger

Constructor Summary

Constructors

Constructor	Description
RecoverySourceHandler(IndexShard shard, RecoveryTargetHandler recoveryTarget, ThreadPool threadPool, StartRecoveryRequest request, int fileChunkSizeInBytes, int maxConcurrentFileChunks, int maxConcurrentOperations)

Method Summary

Modifier and Type	Method	Description
void	addListener(ActionListener<RecoveryResponse> listener)
void	cancel(String reason)	Cancels the recovery and interrupts all eligible threads.
protected void	failEngine(IOException cause)
StartRecoveryRequest	getRequest()
void	recoverToTarget(ActionListener<RecoveryResponse> listener)	performs the recovery from the local engine to the target
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

logger

protected final org.apache.logging.log4j.Logger logger

Constructor Details

RecoverySourceHandler

public RecoverySourceHandler(IndexShard shard,
 RecoveryTargetHandler recoveryTarget,
 ThreadPool threadPool,
 StartRecoveryRequest request,
 int fileChunkSizeInBytes,
 int maxConcurrentFileChunks,
 int maxConcurrentOperations)

Method Details

getRequest

public StartRecoveryRequest getRequest()

addListener

public void addListener(ActionListener<RecoveryResponse> listener)

recoverToTarget

public void recoverToTarget(ActionListener<RecoveryResponse> listener)

performs the recovery from the local engine to the target

cancel

public void cancel(String reason)

Cancels the recovery and interrupts all eligible threads.

toString

public String toString()

Overrides:

toString in class Object

failEngine

protected void failEngine(IOException cause)