Searched refs:snapshot_ (Results 1 – 11 of 11) sorted by relevance
| /rocksdb-6.9/db/ |
| D | snapshot_impl.cc | 13 snapshot_(db->GetSnapshot()) {} in ManagedSnapshot()
16 : db_(db), snapshot_(_snapshot) {} in ManagedSnapshot()
19 if (snapshot_) { in ~ManagedSnapshot()
20 db_->ReleaseSnapshot(snapshot_); in ~ManagedSnapshot()
24 const Snapshot* ManagedSnapshot::snapshot() { return snapshot_;} in snapshot()
|
| D | db_test2.cc | 3001 : ReadCallback(snapshot), snapshot_(snapshot) {} in TEST_F()
3003 return seq <= snapshot_; in TEST_F()
3007 SequenceNumber snapshot_; in TEST_F() member in ROCKSDB_NAMESPACE::TEST_F::TestReadCallback
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_base.h | 203 return snapshot_ ? snapshot_.get() : nullptr; in GetSnapshot()
211 snapshot_.reset(); in ClearSnapshot()
298 std::shared_ptr<const Snapshot> snapshot_; variable
306 std::shared_ptr<const Snapshot> snapshot_; member
319 : snapshot_(snapshot), in SavePoint()
|
| D | optimistic_transaction.cc | 148 if (snapshot_) { in TryLock()
149 seq = snapshot_->GetSequenceNumber(); in TryLock()
|
| D | write_unprepared_txn.cc | 111 if (snapshot_) { in HandleWrite()
113 std::max(largest_validated_seq_, snapshot_->GetSequenceNumber()); in HandleWrite()
848 roptions.snapshot = top.snapshot_->snapshot(); in RollbackToSavePointInternal()
976 assert(snapshot_); in ValidateSnapshot()
980 snapshot_.get()) in ValidateSnapshot()
982 SequenceNumber snap_seq = snapshot_->GetSequenceNumber(); in ValidateSnapshot()
|
| D | write_unprepared_txn.h | 277 std::unique_ptr<ManagedSnapshot> snapshot_; member
281 : unprep_seqs_(seqs), snapshot_(snapshot){}; in SavePoint()
|
| D | write_prepared_txn.cc | 430 assert(snapshot_); in ValidateSnapshot()
434 snapshot_.get()) in ValidateSnapshot()
436 SequenceNumber snap_seq = snapshot_->GetSequenceNumber(); in ValidateSnapshot()
|
| D | pessimistic_transaction.cc | 587 if (!do_validate || snapshot_ == nullptr) { in TryLock()
665 assert(snapshot_); in ValidateSnapshot()
667 SequenceNumber snap_seq = snapshot_->GetSequenceNumber(); in ValidateSnapshot()
|
| D | transaction_base.cc | 79 snapshot_.reset(snapshot, std::bind(&TransactionBaseImpl::ReleaseSnapshot, in SetSnapshotInternal()
125 save_points_->emplace(snapshot_, snapshot_needed_, snapshot_notifier_, in SetSavePoint()
134 snapshot_ = save_point.snapshot_; in RollbackToSavePoint()
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_iterator.h | 24 : snapshot_(snapshot), in BlobDBIterator()
137 std::unique_ptr<ManagedSnapshot> snapshot_; variable
|
| /rocksdb-6.9/include/rocksdb/ |
| D | snapshot.h | 45 const Snapshot* snapshot_; variable
|