| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | SnapshotTest.java | 30 try (final Snapshot snapshot = db.getSnapshot()) { in snapshots() argument
31 assertThat(snapshot.getSequenceNumber()).isGreaterThan(0); in snapshots()
32 assertThat(snapshot.getSequenceNumber()).isEqualTo(1); in snapshots()
35 readOptions.setSnapshot(snapshot); in snapshots()
76 db.releaseSnapshot(snapshot); in snapshots()
92 try (final Snapshot snapshot = db.getSnapshot(); in iteratorWithSnapshot() argument
94 new ReadOptions().setSnapshot(snapshot)) { in iteratorWithSnapshot()
120 db.releaseSnapshot(snapshot); in iteratorWithSnapshot()
136 try (final Snapshot snapshot = db.getSnapshot(); in iteratorWithSnapshotOnColumnFamily() argument
138 .setSnapshot(snapshot)) { in iteratorWithSnapshotOnColumnFamily()
[all …]
|
| /rocksdb-6.9/db/ |
| D | db_range_del_test.cc | 79 db_->ReleaseSnapshot(snapshot); in TEST_F()
129 db_->ReleaseSnapshot(snapshot); in TEST_F()
182 db_->ReleaseSnapshot(snapshot); in TEST_F()
204 db_->ReleaseSnapshot(snapshot); in TEST_F()
283 db_->ReleaseSnapshot(snapshot); in TEST_F()
554 db_->ReleaseSnapshot(snapshot); in TEST_F()
628 db_->ReleaseSnapshot(snapshot); in TEST_F()
740 db_->ReleaseSnapshot(snapshot); in TEST_F()
795 read_opts.snapshot = snapshot; in TEST_F()
1425 read_opts.snapshot = snapshot; in TEST_F()
[all …]
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2015-11-10-use-checkpoints-for-efficient-snapshots.markdown | 10 …snapshot of a running RocksDB database in a separate directory. Checkpoints can be used as a point…
15 …snapshot of a given RocksDB database in the specified directory. If the snapshot is on the same fi…
30 …ect and a directory, the CreateCheckpoint function creates a consistent snapshot of the database i…
40 … obsoleted. When the user is done with the snapshot, the user can delete the directory to remove t…
|
| /rocksdb-6.9/examples/ |
| D | transaction_example.cc | 91 const Snapshot* snapshot = txn->GetSnapshot(); in main() local
103 read_options.snapshot = snapshot; in main()
118 read_options.snapshot = nullptr; in main()
119 snapshot = nullptr; in main()
137 read_options.snapshot = txn_db->GetSnapshot(); in main()
150 read_options.snapshot = txn_db->GetSnapshot(); in main()
169 read_options.snapshot = nullptr; in main()
|
| D | optimistic_transaction_example.cc | 88 const Snapshot* snapshot = txn->GetSnapshot(); in main() local
95 read_options.snapshot = snapshot; in main()
109 read_options.snapshot = nullptr; in main()
110 snapshot = nullptr; in main()
132 read_options.snapshot = db->GetSnapshot(); in main()
149 read_options.snapshot = db->GetSnapshot(); in main()
163 read_options.snapshot = nullptr; in main()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_unprepared_txn_db.cc | 44 InvalidSnapshotReadCallback(SequenceNumber snapshot) in RollbackRecoveredTransaction() argument
45 : ReadCallback(snapshot) {} in RollbackRecoveredTransaction()
371 snapshot(s) {} in IteratorState()
375 std::shared_ptr<ManagedSnapshot> snapshot; member
424 const Snapshot* snapshot = nullptr; in NewIterator() local
425 if (options.snapshot == nullptr) { in NewIterator()
426 snapshot = GetSnapshot(); in NewIterator()
427 own_snapshot = std::make_shared<ManagedSnapshot>(db_impl_, snapshot); in NewIterator()
429 snapshot = options.snapshot; in NewIterator()
432 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator()
[all …]
|
| D | write_prepared_txn_db.cc | 309 snapshot(s) {} in IteratorState()
312 std::shared_ptr<ManagedSnapshot> snapshot; member
328 if (options.snapshot != nullptr) { in NewIterator()
329 snapshot_seq = options.snapshot->GetSequenceNumber(); in NewIterator()
332 options.snapshot) in NewIterator()
335 auto* snapshot = GetSnapshot(); in NewIterator() local
338 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator()
364 if (options.snapshot != nullptr) { in NewIterators()
367 options.snapshot) in NewIterators()
370 auto* snapshot = GetSnapshot(); in NewIterators() local
[all …]
|
| D | optimistic_transaction_test.cc | 783 read_options1.snapshot = txn1->GetSnapshot(); in TEST_P()
787 read_options2.snapshot = txn2->GetSnapshot(); in TEST_P()
814 read_options1.snapshot = txn1->GetSnapshot(); in TEST_P()
817 read_options2.snapshot = txn2->GetSnapshot(); in TEST_P()
865 read_options1.snapshot = txn1->GetSnapshot(); in TEST_P()
868 read_options2.snapshot = txn2->GetSnapshot(); in TEST_P()
883 read_options1.snapshot = txn1->GetSnapshot(); in TEST_P()
886 read_options2.snapshot = txn2->GetSnapshot(); in TEST_P()
900 read_options1.snapshot = txn1->GetSnapshot(); in TEST_P()
903 read_options2.snapshot = txn2->GetSnapshot(); in TEST_P()
[all …]
|
| D | write_prepared_txn_db.h | 454 inline SnapshotBackup AssignMinMaxSeqs(const Snapshot* snapshot,
668 inline void EnhanceSnapshot(SnapshotImpl* snapshot, in EnhanceSnapshot() argument
670 assert(snapshot); in EnhanceSnapshot()
671 assert(min_uncommitted <= snapshot->number_ + 1); in EnhanceSnapshot()
672 snapshot->min_uncommitted_ = min_uncommitted; in EnhanceSnapshot()
804 : ReadCallback(snapshot), in WritePreparedTxnReadCallback()
810 : ReadCallback(snapshot, min_uncommitted), in WritePreparedTxnReadCallback()
824 auto snapshot = max_visible_seq_; in IsVisibleFullCheck() local
827 db_->IsInSnapshot(seq, snapshot, min_uncommitted_, &snap_released); in IsVisibleFullCheck()
1077 SnapshotBackup WritePreparedTxnDB::AssignMinMaxSeqs(const Snapshot* snapshot, in AssignMinMaxSeqs() argument
[all …]
|
| D | write_unprepared_txn.h | 57 WritePreparedTxnDB* db, SequenceNumber snapshot, in WriteUnpreparedTxnReadCallback() argument
65 : ReadCallback(CalcMaxVisibleSeq(unprep_seqs, snapshot), min_uncommitted), in WriteUnpreparedTxnReadCallback()
68 wup_snapshot_(snapshot), in WriteUnpreparedTxnReadCallback()
280 ManagedSnapshot* snapshot) in SavePoint()
281 : unprep_seqs_(seqs), snapshot_(snapshot){}; in SavePoint()
|
| D | write_prepared_transaction_test.cc | 485 read_options.snapshot = snapshot; in VerifyKeys()
967 ropt.snapshot = snapshot2; in TEST_P()
1226 auto snapshot = *it; in TEST_P() local
2096 uint64_t snapshot = 0; in TEST_P() local
2112 while (!snapshot || wp_db->max_evicted_seq_ < snapshot + 100) { in TEST_P()
2128 if (!snapshot) { in TEST_P()
2143 snapshot = seq; in TEST_P()
2151 if (snapshot) { in TEST_P()
3162 roptions.snapshot = snap; in TEST_P()
3239 roptions.snapshot = snap; in TEST_P()
[all …]
|
| D | transaction_base.cc | 72 const Snapshot* snapshot = dbimpl_->GetSnapshotForWriteConflictBoundary(); in SetSnapshot() local
73 SetSnapshotInternal(snapshot); in SetSnapshot()
76 void TransactionBaseImpl::SetSnapshotInternal(const Snapshot* snapshot) { in SetSnapshotInternal() argument
79 snapshot_.reset(snapshot, std::bind(&TransactionBaseImpl::ReleaseSnapshot, in SetSnapshotInternal()
266 if (!do_validate && read_options.snapshot != nullptr) { in GetForUpdate()
292 if (!do_validate && read_options.snapshot != nullptr) { in GetForUpdate()
722 void TransactionBaseImpl::ReleaseSnapshot(const Snapshot* snapshot, DB* db) { in ReleaseSnapshot() argument
723 if (snapshot != nullptr) { in ReleaseSnapshot()
726 snapshot->GetSequenceNumber()); in ReleaseSnapshot()
727 db->ReleaseSnapshot(snapshot); in ReleaseSnapshot()
|
| D | transaction_test.cc | 3381 ASSERT_FALSE(snapshot); in TEST_P()
3385 snapshot = txn1->GetSnapshot(); in TEST_P()
3386 ASSERT_TRUE(snapshot); in TEST_P()
3398 snapshot = txn1->GetSnapshot(); in TEST_P()
3399 ASSERT_FALSE(snapshot); in TEST_P()
3629 read_options.snapshot = snapshot; in TEST_P()
4841 auto snapshot = txn1->GetSnapshot(); in TEST_P() local
4842 ASSERT_FALSE(snapshot); in TEST_P()
5072 ASSERT_FALSE(read_options.snapshot); in TEST_P()
5080 ASSERT_FALSE(read_options.snapshot); in TEST_P()
[all …]
|
| /rocksdb-6.9/test_util/ |
| D | transaction_test_util.cc | 65 read_options_.snapshot = txn_->GetSnapshot(); in TransactionDBInsert()
69 read_options_.snapshot = nullptr; in TransactionDBInsert()
292 roptions.snapshot = db->GetSnapshot(); in Verify()
345 roptions.snapshot ? roptions.snapshot->GetSequenceNumber() : 0ul, in Verify()
346 roptions.snapshot in Verify()
347 ? ((SnapshotImpl*)roptions.snapshot)->min_uncommitted_ in Verify()
363 roptions.snapshot ? roptions.snapshot->GetSequenceNumber() : 0ul); in Verify()
372 roptions.snapshot ? roptions.snapshot->GetSequenceNumber() : 0ul); in Verify()
379 db->ReleaseSnapshot(roptions.snapshot); in Verify()
|
| /rocksdb-6.9/java/samples/src/main/java/ |
| D | OptimisticTransactionSample.java | 106 final Snapshot snapshot = txn.getSnapshot(); in repeatableRead() local
112 readOptions.setSnapshot(snapshot); in repeatableRead()
156 Snapshot snapshot = txnDb.getSnapshot(); in readCommitted_monotonicAtomicViews() local
157 readOptions.setSnapshot(snapshot); in readCommitted_monotonicAtomicViews()
166 snapshot = txnDb.getSnapshot(); in readCommitted_monotonicAtomicViews()
167 readOptions.setSnapshot(snapshot); in readCommitted_monotonicAtomicViews()
|
| D | TransactionSample.java | 107 final Snapshot snapshot = txn.getSnapshot(); in repeatableRead() local
114 readOptions.setSnapshot(snapshot); in repeatableRead()
153 Snapshot snapshot = txnDb.getSnapshot(); in readCommitted_monotonicAtomicViews() local
154 readOptions.setSnapshot(snapshot); in readCommitted_monotonicAtomicViews()
164 snapshot = txnDb.getSnapshot(); in readCommitted_monotonicAtomicViews()
165 readOptions.setSnapshot(snapshot); in readCommitted_monotonicAtomicViews()
|
| /rocksdb-6.9/db/blob/ |
| D | db_blob_index_test.cc | 63 const Snapshot* snapshot = nullptr) { in GetImpl() argument
65 read_options.snapshot = snapshot; in GetImpl()
85 const Snapshot* snapshot = nullptr) { in GetBlobIndex() argument
87 std::string value = GetImpl(key, &is_blob_index, snapshot); in GetBlobIndex()
191 const Snapshot* snapshot = dbfull()->GetSnapshot(); in TEST_F() local
205 ASSERT_EQ("blob_index", GetBlobIndex("key" + ToString(i), snapshot)); in TEST_F()
216 dbfull()->ReleaseSnapshot(snapshot); in TEST_F()
424 for (auto* snapshot : snapshots) { in TEST_F() local
425 dbfull()->ReleaseSnapshot(snapshot); in TEST_F()
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | ReadOptions.java | 105 public Snapshot snapshot() { in snapshot() method in ReadOptions
107 long snapshotHandle = snapshot(nativeHandle_); in snapshot()
124 public ReadOptions setSnapshot(final Snapshot snapshot) { in setSnapshot() argument
126 if (snapshot != null) { in setSnapshot()
127 setSnapshot(nativeHandle_, snapshot.nativeHandle_); in setSnapshot()
586 private native long snapshot(long handle); in snapshot() method in ReadOptions
|
| /rocksdb-6.9/db_stress_tool/ |
| D | batched_ops_stress.cc | 124 readoptionscopy.snapshot = db_->GetSnapshot(); in TestGet()
156 db_->ReleaseSnapshot(readoptionscopy.snapshot); in TestGet()
186 readoptionscopy.snapshot = db_->GetSnapshot(); in TestMultiGet()
225 db_->ReleaseSnapshot(readoptionscopy.snapshot); in TestMultiGet()
260 const Snapshot* snapshot = db_->GetSnapshot(); in TestPrefixScan() local
270 readoptionscopy[i].snapshot = snapshot; in TestPrefixScan()
323 db_->ReleaseSnapshot(snapshot); in TestPrefixScan()
|
| D | db_stress_test_base.cc | 269 ropt.snapshot = snap_state.snapshot; in AssertSame()
819 const Snapshot* snapshot = db_->GetSnapshot(); in TestIterate() local
821 readoptionscopy.snapshot = snapshot; in TestIterate()
922 cmp_ro.snapshot = snapshot; in TestIterate()
990 db_->ReleaseSnapshot(snapshot); in TestIterate()
1469 const Snapshot* snapshot = in TestAcquireSnapshot() local
1473 const Snapshot* snapshot = db_->GetSnapshot(); in TestAcquireSnapshot() local
1476 ropt.snapshot = snapshot; in TestAcquireSnapshot()
1523 assert(snap_state.snapshot); in MaybeReleaseSnapshots()
1528 db_->ReleaseSnapshot(snap_state.snapshot); in MaybeReleaseSnapshots()
[all …]
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_readonly.cc | 37 SequenceNumber snapshot = versions_->LastSequence(); in Get() local
49 LookupKey lkey(key, snapshot); in Get()
78 read_options.snapshot != nullptr in NewIterator()
79 ? reinterpret_cast<const SnapshotImpl*>(read_options.snapshot) in NewIterator()
107 read_options.snapshot != nullptr in NewIterators()
108 ? reinterpret_cast<const SnapshotImpl*>(read_options.snapshot) in NewIterators()
|
| D | db_impl_secondary.cc | 335 SequenceNumber snapshot = versions_->LastSequence(); in GetImpl() local
339 LookupKey lkey(key, snapshot); in GetImpl()
397 } else if (read_options.snapshot != nullptr) { in NewIterator()
402 auto snapshot = versions_->LastSequence(); in NewIterator() local
403 result = NewIteratorImpl(read_options, cfd, snapshot, read_callback); in NewIterator()
410 SequenceNumber snapshot, ReadCallback* read_callback) { in NewIteratorImpl() argument
415 snapshot, in NewIteratorImpl()
420 db_iter->GetRangeDelAggregator(), snapshot); in NewIteratorImpl()
445 } else if (read_options.snapshot != nullptr) { in NewIterators()
|
| D | db_impl.cc | 1553 SequenceNumber snapshot; in GetImpl() local
1554 if (read_options.snapshot != nullptr) { in GetImpl()
1559 snapshot = in GetImpl()
1853 *snapshot = in MultiCFSnapshot()
1856 *snapshot = std::max(*snapshot, callback->max_visible_seq()); in MultiCFSnapshot()
1906 *snapshot = reinterpret_cast<const SnapshotImpl*>(read_options.snapshot) in MultiCFSnapshot()
1932 if (seq > *snapshot) { in MultiCFSnapshot()
2562 auto snapshot = read_options.snapshot != nullptr in NewIterator() local
2668 auto snapshot = read_options.snapshot != nullptr in NewIterators() local
2710 SnapshotImpl* snapshot = in GetSnapshotImpl() local
[all …]
|
| /rocksdb-6.9/java/rocksjni/ |
| D | snapshot.cc | 24 auto* snapshot = in Java_org_rocksdb_Snapshot_getSequenceNumber() local
26 return snapshot->GetSequenceNumber(); in Java_org_rocksdb_Snapshot_getSequenceNumber()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_iterator.cc | 15 #define DEFINITELY_IN_SNAPSHOT(seq, snapshot) \ argument
16 ((seq) <= (snapshot) && \
18 LIKELY(snapshot_checker_->CheckInSnapshot((seq), (snapshot)) == \
21 #define DEFINITELY_NOT_IN_SNAPSHOT(seq, snapshot) \ argument
22 ((seq) > (snapshot) || \
24 UNLIKELY(snapshot_checker_->CheckInSnapshot((seq), (snapshot)) == \
|