Home
last modified time | relevance | path

Searched refs:Snapshot (Results 1 – 25 of 68) sorted by relevance

123

/rocksdb-6.9/include/rocksdb/
Dsnapshot.h20 class Snapshot {
26 virtual ~Snapshot();
37 ManagedSnapshot(DB* db, const Snapshot* _snapshot);
41 const Snapshot* snapshot();
45 const Snapshot* snapshot_;
Doptions.h45 class Snapshot; variable
1207 const Snapshot* snapshot;
/rocksdb-6.9/db/
Ddb_range_del_test.cc68 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
104 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
149 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
189 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
261 const Snapshot* snapshot = nullptr; in TEST_F()
541 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
594 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
783 const Snapshot* snapshot = nullptr; in TEST_F()
1183 const Snapshot* snapshot = nullptr; in TEST_F()
1360 const Snapshot* snapshot = nullptr; in TEST_F()
[all …]
Dsnapshot_impl.cc15 ManagedSnapshot::ManagedSnapshot(DB* db, const Snapshot* _snapshot) in ManagedSnapshot()
24 const Snapshot* ManagedSnapshot::snapshot() { return snapshot_;} in snapshot()
Ddb_basic_test.cc308 const Snapshot* s1 = db_->GetSnapshot(); in TEST_F()
521 TEST_F(DBBasicTest, Snapshot) { in TEST_F() argument
529 const Snapshot* s1 = db_->GetSnapshot(); in TEST_F()
539 const Snapshot* s2 = db_->GetSnapshot(); in TEST_F()
604 const Snapshot* snapshot1 = db_->GetSnapshot(); in TEST_F()
608 const Snapshot* snapshot2 = db_->GetSnapshot(); in TEST_F()
756 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
770 const Snapshot* snapshot1 = db_->GetSnapshot(); in TEST_F()
1239 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_P()
1577 const Snapshot* snap1 = dbfull()->GetSnapshot(); in TEST_P()
[all …]
Ddb_merge_operator_test.cc42 const Snapshot* snapshot = nullptr) { in GetWithReadCallback()
532 const Snapshot* snapshot1 = db_->GetSnapshot(); in TEST_F()
549 const Snapshot* snapshot2 = db_->GetSnapshot(); in TEST_F()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DSnapshotTest.java30 try (final Snapshot snapshot = db.getSnapshot()) { in snapshots()
54 try (final Snapshot sameSnapshot = readOptions.snapshot()) { in snapshots()
92 try (final Snapshot snapshot = db.getSnapshot(); in iteratorWithSnapshot()
136 try (final Snapshot snapshot = db.getSnapshot(); in iteratorWithSnapshotOnColumnFamily()
DAbstractTransactionTest.java77 final Snapshot snapshot = txn.getSnapshot(); in getSnapshot()
86 final Snapshot snapshot = txn.getSnapshot(); in getSnapshot_null()
861 private final List<Snapshot> createdSnapshots = new ArrayList<>();
864 public void snapshotCreated(final Snapshot newSnapshot) { in snapshotCreated()
868 public List<Snapshot> getCreatedSnapshots() { in getCreatedSnapshots()
/rocksdb-6.9/utilities/transactions/
Dtransaction_base.h202 const Snapshot* GetSnapshot() const override { in GetSnapshot()
247 void ReleaseSnapshot(const Snapshot* snapshot, DB* db);
298 std::shared_ptr<const Snapshot> snapshot_;
306 std::shared_ptr<const Snapshot> snapshot_;
316 SavePoint(std::shared_ptr<const Snapshot> snapshot, bool snapshot_needed, in SavePoint()
369 void SetSnapshotInternal(const Snapshot* snapshot);
Dwrite_prepared_txn_db.h444 virtual const Snapshot* GetSnapshot() override;
454 inline SnapshotBackup AssignMinMaxSeqs(const Snapshot* snapshot,
466 Snapshot* GetMaxSnapshot() { return &dummy_max_snapshot_; } in GetMaxSnapshot()
1077 SnapshotBackup WritePreparedTxnDB::AssignMinMaxSeqs(const Snapshot* snapshot, in AssignMinMaxSeqs()
1081 *min = static_cast_with_check<const SnapshotImpl, const Snapshot>(snapshot) in AssignMinMaxSeqs()
1083 *max = static_cast_with_check<const SnapshotImpl, const Snapshot>(snapshot) in AssignMinMaxSeqs()
Dwrite_prepared_txn_db.cc331 static_cast_with_check<const SnapshotImpl, const Snapshot>( in NewIterator()
340 static_cast_with_check<const SnapshotImpl, const Snapshot>(snapshot) in NewIterator()
366 min_uncommitted = static_cast_with_check<const SnapshotImpl, const Snapshot>( in NewIterators()
376 static_cast_with_check<const SnapshotImpl, const Snapshot>(snapshot) in NewIterators()
661 const Snapshot* WritePreparedTxnDB::GetSnapshot() { in GetSnapshot()
Dwrite_prepared_transaction_test.cc950 const Snapshot* snapshot0 = wp_db->GetSnapshot(); in TEST_P()
1957 const Snapshot* snap = db->GetSnapshot(); in TEST_P()
1997 const Snapshot* snap1 = db->GetSnapshot(); in TEST_P()
2001 const Snapshot* snap2 = db->GetSnapshot(); in TEST_P()
2358 const Snapshot* snapshot = db->GetSnapshot(); in TEST_P()
2381 std::vector<const Snapshot*> snapshots; in TEST_P()
2482 const Snapshot* snapshot1 = db->GetSnapshot(); in TEST_P()
2490 const Snapshot* snapshot2 = db->GetSnapshot(); in TEST_P()
2495 const Snapshot* snapshot3 = db->GetSnapshot(); in TEST_P()
2793 std::vector<const Snapshot*> snapshots; in TEST_P()
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DSnapshot.java11 public class Snapshot extends RocksObject { class
12 Snapshot(final long nativeHandle) { in Snapshot() method in Snapshot
DAbstractTransactionNotifier.java25 public abstract void snapshotCreated(final Snapshot newSnapshot); in snapshotCreated()
32 snapshotCreated(new Snapshot(snapshotHandle)); in snapshotCreated()
DReadOptions.java105 public Snapshot snapshot() { in snapshot()
109 return new Snapshot(snapshotHandle); in snapshot()
124 public ReadOptions setSnapshot(final Snapshot snapshot) { in setSnapshot()
DTransaction.java147 public Snapshot getSnapshot() { in getSnapshot()
153 final Snapshot snapshot = new Snapshot(snapshotNativeHandle); in getSnapshot()
/rocksdb-6.9/db/blob/
Ddb_blob_index_test.cc63 const Snapshot* snapshot = nullptr) { in GetImpl()
85 const Snapshot* snapshot = nullptr) { in GetBlobIndex()
191 const Snapshot* snapshot = dbfull()->GetSnapshot(); in TEST_F()
328 std::vector<const Snapshot*> snapshots; in TEST_F()
/rocksdb-6.9/db_stress_tool/
Dcf_consistency_stress.cc133 const Snapshot* snapshot = db_->GetSnapshot(); in TestGet()
359 const auto ss_deleter = [this](const Snapshot* ss) { in VerifyDb()
362 std::unique_ptr<const Snapshot, decltype(ss_deleter)> snapshot_guard( in VerifyDb()
510 const auto ss_deleter = [&](const Snapshot* ss) { in ContinuouslyVerifyDb()
513 std::unique_ptr<const Snapshot, decltype(ss_deleter)> snapshot_guard( in ContinuouslyVerifyDb()
/rocksdb-6.9/java/samples/src/main/java/
DOptimisticTransactionSample.java106 final Snapshot snapshot = txn.getSnapshot(); in repeatableRead()
156 Snapshot snapshot = txnDb.getSnapshot(); in readCommitted_monotonicAtomicViews()
DTransactionSample.java107 final Snapshot snapshot = txn.getSnapshot(); in repeatableRead()
153 Snapshot snapshot = txnDb.getSnapshot(); in readCommitted_monotonicAtomicViews()
/rocksdb-6.9/java/rocksjni/
Dsnapshot.cc25 reinterpret_cast<ROCKSDB_NAMESPACE::Snapshot*>(jsnapshot_handle); in Java_org_rocksdb_Snapshot_getSequenceNumber()
Dtransaction_notifier_jnicallback.h35 virtual void SnapshotCreated(const Snapshot* newSnapshot);
Dtransaction_notifier_jnicallback.cc22 const Snapshot* newSnapshot) { in SnapshotCreated()
/rocksdb-6.9/include/rocksdb/utilities/
Dleveldb_options.h24 class Snapshot; variable
Dtransaction.h35 virtual void SnapshotCreated(const Snapshot* newSnapshot) = 0;
111 virtual const Snapshot* GetSnapshot() const = 0;

123