org.apache.jackrabbit.oak.plugins.document

Class LastRevRecoveryAgent

java.lang.Object

org.apache.jackrabbit.oak.plugins.document.LastRevRecoveryAgent

public class LastRevRecoveryAgent
extends Object

Utility class for recovering potential missing _lastRev updates of nodes due to crash of a node. The recovery agent is also responsible for document sweeping (reverting uncommitted changes).

The recovery agent will only sweep documents for a given clusterId if the root document contains a sweep revision for the clusterId. A missing sweep revision for a clusterId indicates an upgrade from an earlier Oak version and a crash before the initial sweep finished. This is not the responsibility of the recovery agent. An initial sweep for an upgrade must either happen with the oak-run 'revisions' sweep command or on startup of an upgraded Oak instance.

Constructor Summary

Constructors

Constructor and Description
LastRevRecoveryAgent(DocumentNodeStore nodeStore)
LastRevRecoveryAgent(DocumentNodeStore nodeStore, MissingLastRevSeeker seeker)

Method Summary

Modifier and Type	Method and Description
Iterable<Integer>	getRecoveryCandidateNodes() Gets the _lastRev recovery candidate cluster nodes.
boolean	isRecoveryNeeded() Determines if any of the cluster node failed to renew its lease and did not properly shutdown.
void	performRecoveryIfNeeded()
int	recover(int clusterId) Same as recover(int, long), but does not wait for ongoing recovery.
int	recover(int clusterId, long waitUntil) Recover the correct _lastRev updates for potentially missing candidate nodes.
int	recover(Iterable<NodeDocument> suspects, int clusterId) Recover the correct _lastRev updates for the given candidate nodes.
int	recover(Iterable<NodeDocument> suspects, int clusterId, boolean dryRun) Recover the correct _lastRev updates for the given candidate nodes.

Methods inherited from class java.lang.Object

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

Constructor Detail

LastRevRecoveryAgent

public LastRevRecoveryAgent(DocumentNodeStore nodeStore,
                            MissingLastRevSeeker seeker)

LastRevRecoveryAgent

public LastRevRecoveryAgent(DocumentNodeStore nodeStore)

Method Detail

recover

public int recover(int clusterId,
                   long waitUntil)
            throws DocumentStoreException

Recover the correct _lastRev updates for potentially missing candidate nodes. If another cluster node is already performing the recovery for the given clusterId, this method will waitUntil the given time in milliseconds for the recovery to finish. This method will return:

• -1 when another cluster node is busy performing recovery for the given clusterId and the waitUntil time is reached.
• 0 when no recovery was needed or this thread waited for another cluster node to finish the recovery within the given waitUntil time.
• A positive value for the number of recovered documents when recovery was performed by this thread / cluster node.

Parameters:

clusterId - the cluster id for which the _lastRev are to be recovered

waitUntil - wait until this time is milliseconds for recovery of the given clusterId if another cluster node is already performing the recovery.

Returns:

the number of restored nodes or -1 if a timeout occurred while waiting for an ongoing recovery by another cluster node.

Throws:

DocumentStoreException

recover

public int recover(int clusterId)

Same as recover(int, long), but does not wait for ongoing recovery.

Parameters:

clusterId - the cluster id for which the _lastRev are to be recovered

Returns:

the number of restored nodes or -1 if there is an ongoing recovery by another cluster node.

recover

public int recover(Iterable<NodeDocument> suspects,
                   int clusterId)

Recover the correct _lastRev updates for the given candidate nodes.

Parameters:

suspects - the potential suspects

clusterId - the cluster id for which _lastRev recovery needed

Returns:

the number of documents that required recovery.

recover

public int recover(Iterable<NodeDocument> suspects,
                   int clusterId,
                   boolean dryRun)
            throws DocumentStoreException

Recover the correct _lastRev updates for the given candidate nodes.

Parameters:

suspects - the potential suspects

clusterId - the cluster id for which _lastRev recovery needed

dryRun - if true, this method will only perform a check but not apply the changes to the _lastRev fields.

Returns:

the number of documents that required recovery. This method returns the number of the affected documents even if dryRun is set true and no document was changed.

Throws:

DocumentStoreException

isRecoveryNeeded

public boolean isRecoveryNeeded()

Determines if any of the cluster node failed to renew its lease and did not properly shutdown. If any such cluster node is found then are potential candidates for last rev recovery. This method also returns true when there is a cluster node with an ongoing recovery.

Returns:

true if last rev recovery needs to be performed for any of the cluster nodes

performRecoveryIfNeeded

public void performRecoveryIfNeeded()

getRecoveryCandidateNodes

public Iterable<Integer> getRecoveryCandidateNodes()

Gets the _lastRev recovery candidate cluster nodes. This also includes cluster nodes that are currently being recovered. The method would not return self as a candidate for recovery even if it has failed to update lease in time

Returns:

the recovery candidate nodes.