|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.sleepycat.je.rep.impl.node.Replica.ConsistencyTracker
public class Replica.ConsistencyTracker
Tracks the consistency of this replica wrt the Master. It provides the mechanisms that will cause a beginTransaction() or a joinGroup() to wait until the specified consistency policy is satisfied.
Constructor Summary | |
---|---|
Replica.ConsistencyTracker()
|
Method Summary | |
---|---|
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()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public Replica.ConsistencyTracker()
Method Detail |
---|
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 InterruptedException, ReplicaConsistencyException, DatabaseException
InterruptedException
ReplicaConsistencyException
DatabaseException
public void awaitVLSN(long vlsn, ReplicaConsistencyPolicy consistencyPolicy) throws InterruptedException, ReplicaConsistencyException, DatabaseException
InterruptedException
ReplicaConsistencyException
DatabaseException
public void shutdown()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |