| /dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/txn/ |
| H A D | RollbackTest.java | 258 VLSN lastVLSN = VLSN.NULL_VLSN; in masterDiesAndRejoins() local
309 lastVLSN); in masterDiesAndRejoins()
330 RepTestUtils.syncGroupToVLSN(repEnvInfo, 2, lastVLSN); in masterDiesAndRejoins()
332 RepTestUtils.syncGroupToVLSN(repEnvInfo, 3, lastVLSN); in masterDiesAndRejoins()
354 RepTestUtils.syncGroupToVLSN(repEnvInfo, 3, lastVLSN); in masterDiesAndRejoins()
426 lastVLSN); in replicasDieAndRejoin()
483 return lastVLSN; in checkIfWholeGroupInSync()
493 RepTestUtils.syncGroupToVLSN(repEnvInfo, 2, lastVLSN); in waitForReplicaToSync()
531 VLSN lastVLSN = range.getLast(); in ensureDistinctLastAndSyncVLSN() local
533 if (lastVLSN.equals(syncVLSN)) { in ensureDistinctLastAndSyncVLSN()
[all …]
|
| H A D | ReplayRecoveryTest.java | 147 VLSN lastVLSN = RepInternal.getRepImpl(master). in doRollbackRecovery() local
149 RepTestUtils.syncGroupToVLSN(repEnvInfo, 2, lastVLSN); in doRollbackRecovery()
233 VLSN lastVLSN = RepInternal.getRepImpl(master). in doResurrection() local
235 RepTestUtils.syncGroupToVLSN(repEnvInfo, 2, lastVLSN); in doResurrection()
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/rep/vlsn/ |
| H A D | VLSNBucket.java | 105 protected VLSN lastVLSN = VLSN.NULL_VLSN; field in VLSNBucket
150 this.lastVLSN = firstVLSN; in VLSNBucket()
237 lastVLSN = vlsn; in put()
281 if (lastVLSN.compareTo(vlsn) > 0) { in belongs()
296 lastVLSN.compareTo(vlsn) < 0) { in belongs()
329 return lastVLSN; in getLast()
387 if (lastVLSN.equals(vlsn)) { in getGTELsn()
515 if (lastVLSN.equals(vlsn)) { in getLsn()
589 lastVLSN = VLSN.NULL_VLSN; in removeFromHead()
623 firstVLSN = lastVLSN; in removeFromHead()
[all …]
|
| H A D | VLSNTracker.java | 701 if (lastOnDiskVLSN.compareTo(lastVLSN) < 0) { in ensureRangeEndIsMapped()
731 addEndMapping(lastVLSN, lastLsn); in ensureRangeEndIsMapped()
738 private void addEndMapping(VLSN lastVLSN, long lastLsn) { in addEndMapping() argument
740 assert (lastVLSN.compareTo(range.getLast()) == 0) : in addEndMapping()
747 addBucket.put(lastVLSN, lastLsn); in addEndMapping()
751 firstTrackedVLSN = lastVLSN; in addEndMapping()
882 ArrayList<VLSN> lastVLSN = new ArrayList<VLSN>(); in verify() local
886 lastVLSN.add(b.getLast()); in verify()
889 if (!verifyBucketBoundaries(firstVLSN, lastVLSN)) { in verify()
903 VLSN lastBucketVLSN = lastVLSN.get(lastVLSN.size() -1); in verify()
[all …]
|
| H A D | VLSNIndex.java | 1896 ArrayList<VLSN> lastVLSN = new ArrayList<VLSN>(); in verify() local
1937 lastVLSN.add(bucket.getLast()); in verify()
1964 lastOnDisk = lastVLSN.get(lastVLSN.size()-1); in verify()
1967 if (!VLSNTracker.verifyBucketBoundaries(firstVLSN, lastVLSN)) { in verify()
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/rep/utilint/ |
| H A D | DbStreamVerify.java | 194 private VLSN lastVLSN = VLSN.NULL_VLSN; field in DbStreamVerify.VerifyReader
232 if ((lastVLSN != null) && lastVLSN.isNull()) { in processEntry()
238 !currentVLSN.follows(lastVLSN)) { in processEntry()
243 lastVLSN.getSequence()) + in processEntry()
244 " Last=" + lastVLSN + " at lsn " + in processEntry()
259 lastVLSN = currentVLSN; in processEntry()
268 out1.println("LastVLSN = " + lastVLSN + " at " + in displayLast()
|
| /dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/stream/ |
| H A D | FeederReaderTest.java | 82 VLSN lastVLSN = expected.get(expected.size() - 1).getVLSN(); in testForwardScans() local
90 for (int i = 1; i <= lastVLSN.getSequence(); i++) { in testForwardScans()
145 VLSN lastVLSN = expected.get(expected.size() - 1).getVLSN(); in testBackwardScans() local
147 for (long i = lastVLSN.getSequence(); i >= 1; i--) { in testBackwardScans()
175 VLSN lastVLSN = expected.get(expected.size() - 1).getVLSN(); in testFindSyncableentries() local
177 for (long i = lastVLSN.getSequence(); i >= 1; i--) { in testFindSyncableentries()
307 VLSN lastVLSN = expected.get(expected.size() - 1).getVLSN(); in checkForwardScan() local
309 (int)(lastVLSN.getSequence() - startVLSN.getSequence()) / STRIDE; in checkForwardScan()
322 WireRecord notThere = feederReader.scanForwards(lastVLSN.getNext(), in checkForwardScan()
485 VLSN lastVLSN = expected.get(expected.size() - 1).getVLSN(); in testNonFlushedFetch() local
[all …]
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/log/ |
| H A D | CleanerFileReader.java | 52 private VLSN lastVLSN = VLSN.NULL_VLSN; field in CleanerFileReader
168 assert (vlsn.compareTo(lastVLSN) > 0) : in processEntry()
169 "vlsns out of order, last=" + lastVLSN + in processEntry()
171 lastVLSN = vlsn; in processEntry()
320 return lastVLSN; in getLastVLSN()
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/rep/stream/ |
| H A D | FeederReplicaSyncup.java | 319 private final VLSN lastVLSN; field in FeederReplicaSyncup.NetworkRestoreException
326 VLSN lastVLSN, in NetworkRestoreException() argument
330 this.lastVLSN = lastVLSN; in NetworkRestoreException()
338 "[" + firstVLSN + "-" + lastVLSN + "]"; in getMessage()
|
| /dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/util/ |
| H A D | RepEnvWrapper.java | 128 VLSN lastVLSN = RepInternal.getRepImpl(master).getRepNode(). in closeInternal() local
130 RepTestUtils.syncGroupToVLSN(repEnvInfo, repNodes, lastVLSN); in closeInternal()
133 RepTestUtils.checkNodeEquality(lastVLSN, false, repEnvInfo); in closeInternal()
|
| /dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/vlsn/ |
| H A D | VLSNIndexTruncateTest.java | 345 VLSN lastVLSN = expected.get(expected.size()-1).vlsn; in doTruncate() local
347 if (deletePoint.vlsn.equals(lastVLSN)) { in doTruncate()
353 postTruncateLast = lastVLSN; in doTruncate()
|
| H A D | MergeTest.java | 253 VLSN lastVLSN = expected.get(expected.size() - 1).vlsn; in checkMerge() local
254 assertEquals(lastVLSN, range.getLast()); in checkMerge()
278 if (info.vlsn.equals(lastVLSN)) { in checkMerge()
|
| H A D | VLSNConsistencyTest.java | 112 VLSN lastVLSN = repNode.getVLSNIndex().getRange().getLast(); in testVLSNConsistency() local
113 while (lastVLSN.compareTo(commitVLSN) <= 0) { in testVLSNConsistency()
|
| /dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/impl/node/ |
| H A D | CleanerThrottleTest.java | 407 VLSN lastVLSN = vlsnIndex.getRange().getLast(); in runAndClean() local
412 lastVLSN); in runAndClean()
414 lastVLSN = vlsnIndex.getRange().getLast(); in runAndClean()
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/rep/impl/node/ |
| H A D | RepNode.java | 2343 final VLSN lastVLSN = getVLSNIndex().getRange().getLast(); in getUnprotectedFileSet() local
2344 final long lastVLSNFile = getVLSNIndex().getGTEFileNumber(lastVLSN); in getUnprotectedFileSet()
2446 " holds last VLSN " + lastVLSN); in getUnprotectedFileSet()
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/rep/impl/ |
| H A D | RepImpl.java | 1289 public void vlsnHeadTruncate(VLSN lastVLSN, long deleteFileNum) { in vlsnHeadTruncate() argument
1291 vlsnIndex.truncateFromHead(lastVLSN, deleteFileNum); in vlsnHeadTruncate()
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/dbi/ |
| H A D | EnvironmentImpl.java | 2894 public void vlsnHeadTruncate(VLSN lastVLSN, long deleteFileNum) { in vlsnHeadTruncate() argument
|