public class Replica.ConsistencyTracker
extends java.lang.Object
Constructor and Description |
---|
Replica.ConsistencyTracker() |
Modifier and Type | Method and Description |
---|---|
void |
awaitVLSN(long vlsn,
ReplicaConsistencyPolicy consistencyPolicy)
Wait until the log record identified by VLSN has gone by.
|
(package private) void |
close() |
(package private) void |
forceTripLatches(DatabaseException exception)
Frees all the threads that are waiting on latches.
|
long |
getMasterTxnEndVLSN() |
void |
lagAwait(TimeConsistencyPolicy consistencyPolicy) |
(package private) void |
logStats() |
(package private) void |
reinit(long matchedTxnVLSN,
long matchedTxnEndTime)
Invoked each time after a replica syncup so that the Replica
can re-establish it's consistency vis a vis the master and what
part of the replication stream it considers as having been replayed.
|
void |
shutdown()
Shutdown the consistency tracker.
|
(package private) void |
trackHeartbeat(Protocol.Heartbeat heartbeat) |
(package private) void |
trackTxnEnd() |
(package private) void |
trackVLSN() |
void reinit(long matchedTxnVLSN, long matchedTxnEndTime)
matchedTxnVLSN
- the replica state corresponds to this txnmatchedTxnEndTime
- the time at which this txn was committed or
aborted on the masterpublic long getMasterTxnEndVLSN()
void close()
void logStats()
void forceTripLatches(DatabaseException exception)
exception
- the exception to be thrown to explain the reason
behind the latches being forced.void trackTxnEnd()
void trackVLSN()
void trackHeartbeat(Protocol.Heartbeat heartbeat)
public void lagAwait(TimeConsistencyPolicy consistencyPolicy) throws java.lang.InterruptedException, ReplicaConsistencyException, DatabaseException
java.lang.InterruptedException
ReplicaConsistencyException
DatabaseException
public void awaitVLSN(long vlsn, ReplicaConsistencyPolicy consistencyPolicy) throws java.lang.InterruptedException, ReplicaConsistencyException, DatabaseException
java.lang.InterruptedException
ReplicaConsistencyException
DatabaseException
public void shutdown()
Copyright (c) 2004-2012 Oracle. All rights reserved.