|
|||||||||
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 |
anyVLSNAwait(long vlsn,
ReplicaConsistencyPolicy consistencyPolicy)
Wait until the log record identified by VLSN has gone by. |
(package private) void |
close()
|
void |
commitVLSNAwait(long vlsn,
ReplicaConsistencyPolicy consistencyPolicy)
Wait until the commit log record identified by VLSN has gone by. |
(package private) void |
forceTripLatches(DatabaseException exception)
Frees all the threads that are waiting on latches. |
long |
getMasterCommitVLSN()
|
void |
lagAwait(TimeConsistencyPolicy consistencyPolicy)
|
(package private) void |
logStats()
|
(package private) void |
reinit(long matchedTxnVLSN,
long matchedCommitTime)
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 |
trackCommit()
|
(package private) void |
trackHeartbeat(Protocol.Heartbeat heartbeat)
|
(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 matchedCommitTime)
matchedTxnVLSN
- the replica state corresponds to this txnmatchedCommitTime
- the time at which this txn was committed
on the masterpublic long getMasterCommitVLSN()
void close()
void logStats()
void forceTripLatches(DatabaseException exception)
exception
- the exception to be thrown to explain the reason
behind the latches being forced.void trackCommit()
void trackVLSN()
void trackHeartbeat(Protocol.Heartbeat heartbeat)
public void lagAwait(TimeConsistencyPolicy consistencyPolicy) throws InterruptedException, ReplicaConsistencyException, DatabaseException
InterruptedException
ReplicaConsistencyException
DatabaseException
public void commitVLSNAwait(long vlsn, ReplicaConsistencyPolicy consistencyPolicy) throws InterruptedException, ReplicaConsistencyException, DatabaseException
InterruptedException
ReplicaConsistencyException
DatabaseException
public void anyVLSNAwait(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 |