Home
last modified time | relevance | path

Searched refs:TxnInfo (Results 1 – 4 of 4) sorted by relevance

/dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/rep/stream/
H A DFeederTxns.java41 private final Map<Long, TxnInfo> txnMap;
52 txnMap = new ConcurrentHashMap<Long, TxnInfo>(); in FeederTxns()
73 TxnInfo txnInfo = new TxnInfo(txn); in setupForAcks()
74 TxnInfo prevInfo = txnMap.put(txn.getId(), txnInfo); in setupForAcks()
83 TxnInfo txnInfo = txnMap.get(txnId); in getAckTxn()
109 final TxnInfo txnInfo = txnMap.get(txnId); in noteReplicaAck()
130 TxnInfo txnInfo = txnMap.get(txn.getId()); in awaitReplicaAcks()
147 public class TxnInfo { class in FeederTxns
152 private TxnInfo(MasterTxn txn) { in TxnInfo() method in FeederTxns.TxnInfo
/dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/rep/impl/node/
H A DReplay.java209 private volatile TxnInfo lastReplayedTxn = null;
372 public TxnInfo getLastReplayedTxn() { in getLastReplayedTxn()
519 lastReplayedTxn = new TxnInfo(lastReplayedVLSN, in replayEntry()
562 lastReplayedTxn = new TxnInfo(lastReplayedVLSN, in replayEntry()
1436 public static class TxnInfo { class in Replay
1440 private TxnInfo(VLSN txnVLSN, long masterTxnEndTime) { in TxnInfo() method in Replay.TxnInfo
H A DDurabilityQuorum.java127 public void ensureSufficientAcks(FeederTxns.TxnInfo txnInfo, in ensureSufficientAcks()
H A DReplica.java1398 Replay.TxnInfo lastReplayedTxn = replay.getLastReplayedTxn(); in trackTxnEnd()