public class LocalRecoveryManager
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private java.util.List<LocalTransactionStore> |
localTransactionStores |
private java.util.Set<TransactionID> |
previouslyRecoveredTransactionIDs |
private TransactionIDFactory |
transactionIdFactory |
Constructor and Description |
---|
LocalRecoveryManager(TransactionIDFactory transactionIdFactory)
Create a LocalRecoveryManager instance
|
Modifier and Type | Method and Description |
---|---|
java.util.Set<TransactionID> |
getPreviouslyRecoveredTransactionIDs()
Get the set of transaction IDs collected by the previous recover() call
|
java.util.Set<TransactionID> |
recover()
Run recovery on all registered local transaction stores.
|
(package private) void |
register(LocalTransactionStore localTransactionStore)
Register a LocalTransactionStore from the recovery manager
|
(package private) void |
unregister(LocalTransactionStore localTransactionStore)
Unregister a LocalTransactionStore from the recovery manager
|
private final TransactionIDFactory transactionIdFactory
private final java.util.List<LocalTransactionStore> localTransactionStores
private volatile java.util.Set<TransactionID> previouslyRecoveredTransactionIDs
public LocalRecoveryManager(TransactionIDFactory transactionIdFactory)
transactionIdFactory
- the TransactionIDFactoryvoid register(LocalTransactionStore localTransactionStore)
localTransactionStore
- the LocalTransactionStorevoid unregister(LocalTransactionStore localTransactionStore)
localTransactionStore
- the LocalTransactionStorepublic java.util.Set<TransactionID> recover()
public java.util.Set<TransactionID> getPreviouslyRecoveredTransactionIDs()