public class Replay
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
Replay.TxnInfo
Simple helper class to package a Txn vlsn and its associated commit
time.
|
Constructor and Description |
---|
Replay(RepImpl repImpl,
NameIdPair nameIdPair) |
Modifier and Type | Method and Description |
---|---|
void |
abortOldTxns()
When mastership changes, all inflight replay transactions are aborted.
|
void |
close()
Release all transactions, database handles, etc held by the replay
unit.
|
java.lang.String |
dumpState() |
java.util.Map<java.lang.Long,ReplayTxn> |
getActiveTxns() |
Replay.TxnInfo |
getLastReplayedTxn() |
VLSN |
getLastReplayedVLSN() |
(package private) LongStat |
getMessageQueueOverflows() |
StatGroup |
getStats(StatsConfig config)
Returns a copy of the statistics associated with Replay
|
void |
preRecoveryCheckpointInit(RecoveryInfo recoveryInfo)
Actions that must be taken before the recovery checkpoint, whether
the environment is read/write or read/only.
|
void |
replayEntry(NamedChannel namedChannel,
Protocol protocol,
Protocol.Entry entry)
Apply the operation represented by this log entry on this replica node.
|
void |
resetStats() |
void |
rollback(VLSN matchpointVLSN,
long matchpointLsn)
Go through all active txns and rollback up to but not including the log
entry represented by the matchpoint VLSN.
|
public Replay(RepImpl repImpl, NameIdPair nameIdPair)
LongStat getMessageQueueOverflows()
public void preRecoveryCheckpointInit(RecoveryInfo recoveryInfo)
public Replay.TxnInfo getLastReplayedTxn()
public VLSN getLastReplayedVLSN()
public void abortOldTxns() throws DatabaseException
DatabaseException
public void replayEntry(NamedChannel namedChannel, Protocol protocol, Protocol.Entry entry) throws DatabaseException, java.io.IOException, java.lang.InterruptedException, MasterStatus.MasterSyncException
java.lang.InterruptedException
MasterStatus.MasterSyncException
DatabaseException
java.io.IOException
public void rollback(VLSN matchpointVLSN, long matchpointLsn)
public void close()
public StatGroup getStats(StatsConfig config)
public void resetStats()
public java.util.Map<java.lang.Long,ReplayTxn> getActiveTxns()
public java.lang.String dumpState()
Copyright (c) 2004-2012 Oracle. All rights reserved.