|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.sleepycat.je.rep.impl.node.Replay
public class Replay
Replays log records from the replication stream, and manages the transactions for those records. The Replay module has a lifetime equivalent to the environment owned by this replicator. Its lifetime is longer than the feeder/replica stream. For example, suppose this is nodeX: t1 - Node X is a replica, node A is master. Replay X is alive t2 - Node X is a replica, node B takes over as master. X's Replay module is still alive and has the same set of active txns. It doesn't matter to X that the master has changed. t3 - Node X becomes the master. Now its Replay unit is cleared, because anything managed by the Replay is defunct.
Nested Class Summary | |
---|---|
static class |
Replay.TxnInfo
Simple helper class to package a Txn vlsn and its associated commit time. |
Constructor Summary | |
---|---|
Replay(RepImpl repImpl,
NameIdPair nameIdPair)
|
Method Summary | |
---|---|
void |
abortOldTxns()
When mastership changes, all inflight replay transactions are aborted. |
void |
close()
Release all transactions, database handles, etc held by the replay unit. |
String |
dumpState()
|
Map<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. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public Replay(RepImpl repImpl, NameIdPair nameIdPair)
Method Detail |
---|
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, IOException, InterruptedException, MasterStatus.MasterSyncException
InterruptedException
MasterStatus.MasterSyncException
DatabaseException
IOException
public void rollback(VLSN matchpointVLSN, long matchpointLsn)
public void close()
public StatGroup getStats(StatsConfig config)
public void resetStats()
public Map<Long,ReplayTxn> getActiveTxns()
public String dumpState()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |