org.elasticsearch.indices.recovery

Class SharedFSRecoverySourceHandler

java.lang.Object

org.elasticsearch.indices.recovery.RecoverySourceHandler

org.elasticsearch.indices.recovery.SharedFSRecoverySourceHandler

All Implemented Interfaces:

Engine.RecoveryHandler

public class SharedFSRecoverySourceHandler
extends RecoverySourceHandler

A recovery handler that skips phase 1 as well as sending the snapshot. During phase 3 the shard is marked as relocated an closed to ensure that the engine is closed and the target can acquire the IW write lock.

Field Summary

Fields inherited from class org.elasticsearch.indices.recovery.RecoverySourceHandler

logger

Constructor Summary

Constructors

Constructor and Description
SharedFSRecoverySourceHandler(IndexShard shard, StartRecoveryRequest request, RecoverySettings recoverySettings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, MappingUpdatedAction mappingUpdatedAction, ESLogger logger)

Method Summary

Modifier and Type	Method and Description
void	onRecoveryFailure(Throwable t)
void	phase1(SnapshotIndexCommit snapshot) Perform phase1 of the recovery operations.
void	phase2(Translog.Snapshot snapshot) Perform phase2 of the recovery process Phase2 takes a snapshot of the current translog *without* acquiring the write lock (however, the translog snapshot is a point-in-time view of the translog).
void	phase3(Translog.Snapshot snapshot) Perform phase 3 of the recovery process Phase3 again takes a snapshot of the translog, however this time the snapshot is acquired under a write lock.
protected int	sendSnapshot(Translog.Snapshot snapshot) Send the given snapshot's operations to this handler's target node.

Methods inherited from class org.elasticsearch.indices.recovery.RecoverySourceHandler

cancel, getResponse, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SharedFSRecoverySourceHandler

public SharedFSRecoverySourceHandler(IndexShard shard,
                                     StartRecoveryRequest request,
                                     RecoverySettings recoverySettings,
                                     TransportService transportService,
                                     ClusterService clusterService,
                                     IndicesService indicesService,
                                     MappingUpdatedAction mappingUpdatedAction,
                                     ESLogger logger)

Method Detail

phase1

public void phase1(SnapshotIndexCommit snapshot)
            throws ElasticsearchException

Description copied from class: RecoverySourceHandler

Perform phase1 of the recovery operations. Once this SnapshotIndexCommit snapshot has been performed no commit operations (files being fsync'd) are effectively allowed on this index until all recovery phases are done Phase1 examines the segment files on the target node and copies over the segments that are missing. Only segments that have the same size and checksum can be reused InternalEngine#recover is responsible for snapshotting the index and releasing the snapshot once all 3 phases of recovery are complete

Specified by:

phase1 in interface Engine.RecoveryHandler

Overrides:

phase1 in class RecoverySourceHandler

Throws:

ElasticsearchException

phase2

public void phase2(Translog.Snapshot snapshot)
            throws ElasticsearchException

Description copied from class: RecoverySourceHandler

Perform phase2 of the recovery process Phase2 takes a snapshot of the current translog *without* acquiring the write lock (however, the translog snapshot is a point-in-time view of the translog). It then sends each translog operation to the target node so it can be replayed into the new shard. InternalEngine#recover is responsible for taking the snapshot of the translog and releasing it once all 3 phases of recovery are complete

Specified by:

phase2 in interface Engine.RecoveryHandler

Overrides:

phase2 in class RecoverySourceHandler

Throws:

ElasticsearchException

phase3

public void phase3(Translog.Snapshot snapshot)
            throws ElasticsearchException

Description copied from class: RecoverySourceHandler

Perform phase 3 of the recovery process Phase3 again takes a snapshot of the translog, however this time the snapshot is acquired under a write lock. The translog operations are sent to the target node where they are replayed. InternalEngine#recover is responsible for taking the snapshot of the translog, and after phase 3 completes the snapshots from all three phases are released.

Specified by:

phase3 in interface Engine.RecoveryHandler

Overrides:

phase3 in class RecoverySourceHandler

Throws:

ElasticsearchException

sendSnapshot

protected int sendSnapshot(Translog.Snapshot snapshot)
                    throws ElasticsearchException

Description copied from class: RecoverySourceHandler

Send the given snapshot's operations to this handler's target node. Operations are bulked into a single request depending on an operation count limit or size-in-bytes limit

Overrides:

sendSnapshot in class RecoverySourceHandler

Returns:

the total number of translog operations that were sent

Throws:

ElasticsearchException

onRecoveryFailure

public void onRecoveryFailure(Throwable t)