| /rocksdb-6.9/utilities/transactions/ |
| D | write_prepared_txn_db.cc | 329 snapshot_seq = options.snapshot->GetSequenceNumber(); in NewIterator()
338 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator()
365 snapshot_seq = options.snapshot->GetSequenceNumber(); in NewIterators()
373 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterators()
681 SequenceNumber snap_seq = snap_impl->GetSequenceNumber(); in GetSnapshotInternal()
692 snap_impl->GetSequenceNumber() <= max && retry < 100) { in GetSnapshotInternal()
696 snap_impl->GetSequenceNumber(), max, retry); in GetSnapshotInternal()
705 assert(snap_impl->GetSequenceNumber() > max); in GetSnapshotInternal()
706 if (snap_impl->GetSequenceNumber() <= max) { in GetSnapshotInternal()
708 "Snapshot seq " + ToString(snap_impl->GetSequenceNumber()) + in GetSnapshotInternal()
[all …]
|
| D | write_prepared_transaction_test.cc | 1394 if (snap->GetSequenceNumber() != 0) { in TEST_P()
1467 ASSERT_GT(snap->GetSequenceNumber(), writes - 1); in TEST_P()
1483 auto snap_seq = snap->GetSequenceNumber(); in TEST_P()
1505 auto seq1 = snap->GetSequenceNumber(); in TEST_P()
1512 auto seq2 = snap->GetSequenceNumber(); in TEST_P()
1958 auto snap_seq = snap->GetSequenceNumber(); in TEST_P()
1976 snap_seq = snap->GetSequenceNumber(); in TEST_P()
2011 snap_seq = snap1->GetSequenceNumber(); in TEST_P()
2019 snap_seq = snap1->GetSequenceNumber(); in TEST_P()
2055 snap_seq = snap2->GetSequenceNumber(); in TEST_P()
[all …]
|
| D | write_unprepared_txn_db.cc | 432 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator()
446 if (txn->largest_validated_seq_ > snapshot->GetSequenceNumber() && in NewIterator()
|
| D | optimistic_transaction.cc | 149 seq = snapshot_->GetSequenceNumber(); in TryLock()
|
| D | write_unprepared_txn.cc | 113 std::max(largest_validated_seq_, snapshot_->GetSequenceNumber()); in HandleWrite()
853 SequenceNumber snap_seq = roptions.snapshot->GetSequenceNumber(); in RollbackToSavePointInternal()
982 SequenceNumber snap_seq = snapshot_->GetSequenceNumber(); in ValidateSnapshot()
|
| D | write_prepared_txn.cc | 436 SequenceNumber snap_seq = snapshot_->GetSequenceNumber(); in ValidateSnapshot()
|
| D | pessimistic_transaction.cc | 667 SequenceNumber snap_seq = snapshot_->GetSequenceNumber(); in ValidateSnapshot()
|
| D | transaction_base.cc | 726 snapshot->GetSequenceNumber()); in ReleaseSnapshot()
|
| /rocksdb-6.9/test_util/ |
| D | transaction_test_util.cc | 189 txn->GetSnapshot()->GetSequenceNumber(), full_key.c_str(), in DoInsert()
345 roptions.snapshot ? roptions.snapshot->GetSequenceNumber() : 0ul, in Verify()
363 roptions.snapshot ? roptions.snapshot->GetSequenceNumber() : 0ul); in Verify()
372 roptions.snapshot ? roptions.snapshot->GetSequenceNumber() : 0ul); in Verify()
|
| /rocksdb-6.9/db/ |
| D | snapshot_impl.h | 29 virtual SequenceNumber GetSequenceNumber() const override { return number_; } in GetSequenceNumber() function
155 return oldest()->GetSequenceNumber(); in GetOldestSnapshotSequence()
|
| D | db_merge_operator_test.cc | 44 : snapshot->GetSequenceNumber(); in GetWithReadCallback()
533 ASSERT_EQ(2, snapshot1->GetSequenceNumber()); in TEST_F()
550 ASSERT_EQ(4, snapshot2->GetSequenceNumber()); in TEST_F()
|
| D | db_basic_test.cc | 533 ASSERT_EQ(GetSequenceOldestSnapshots(), s1->GetSequenceNumber()); in TEST_F()
542 ASSERT_EQ(GetSequenceOldestSnapshots(), s1->GetSequenceNumber()); in TEST_F()
550 ASSERT_EQ(GetSequenceOldestSnapshots(), s1->GetSequenceNumber()); in TEST_F()
566 ASSERT_EQ(GetSequenceOldestSnapshots(), s1->GetSequenceNumber()); in TEST_F()
581 ASSERT_EQ(GetSequenceOldestSnapshots(), s2->GetSequenceNumber()); in TEST_F()
|
| D | table_cache.cc | 303 ->GetSequenceNumber() <= fd.largest_seqno)) { in CreateRowCacheKeyPrefix()
|
| D | memtable_list.cc | 193 ? read_opts.snapshot->GetSequenceNumber() in AddRangeTombstoneIterators()
|
| D | db_test.cc | 1705 ASSERT_EQ(GetSequenceOldestSnapshots(), s1->GetSequenceNumber()); in TEST_F()
1714 ASSERT_EQ(GetSequenceOldestSnapshots(), s1->GetSequenceNumber()); in TEST_F()
1722 ASSERT_EQ(GetSequenceOldestSnapshots(), s1->GetSequenceNumber()); in TEST_F()
1738 ASSERT_EQ(GetSequenceOldestSnapshots(), s1->GetSequenceNumber()); in TEST_F()
1753 ASSERT_EQ(GetSequenceOldestSnapshots(), s2->GetSequenceNumber()); in TEST_F()
2648 SequenceNumber GetSequenceNumber() const override { in GetSequenceNumber() function in ROCKSDB_NAMESPACE::ModelDB::ModelSnapshot
|
| D | db_iterator_test.cc | 45 ? read_options.snapshot->GetSequenceNumber() in NewIterator()
|
| /rocksdb-6.9/java/rocksjni/ |
| D | snapshot.cc | 26 return snapshot->GetSequenceNumber(); in Java_org_rocksdb_Snapshot_getSequenceNumber()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | snapshot.h | 23 virtual SequenceNumber GetSequenceNumber() const = 0;
|
| /rocksdb-6.9/table/ |
| D | sst_file_reader.cc | 68 ? options.snapshot->GetSequenceNumber() in NewIterator()
|
| /rocksdb-6.9/trace_replay/ |
| D | block_cache_tracer.cc | 79 uint64_t BlockCacheTraceHelper::GetSequenceNumber( in GetSequenceNumber() function in ROCKSDB_NAMESPACE::BlockCacheTraceHelper
342 BlockCacheTraceHelper::GetSequenceNumber(access), in WriteHumanReadableTraceRecord()
|
| D | block_cache_tracer.h | 40 static uint64_t GetSequenceNumber(const BlockCacheTraceRecord& access);
|
| D | block_cache_tracer_test.cc | 366 ASSERT_EQ(3, BlockCacheTraceHelper::GetSequenceNumber(read_record)); in TEST_F()
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_impl.cc | 1778 oldest_snapshot = snapshots.oldest()->GetSequenceNumber(); in VisibleToActiveSnapshot()
1999 read_options, cfd, snapshot->GetSequenceNumber(), in NewIterator()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.cc | 2563 ? read_options.snapshot->GetSequenceNumber() in NewIterator()
2669 ? read_options.snapshot->GetSequenceNumber() in NewIterators()
|
| /rocksdb-6.9/utilities/backupable/ |
| D | backupable_db.cc | 187 uint64_t GetSequenceNumber() { in GetSequenceNumber() function in ROCKSDB_NAMESPACE::BackupEngineImpl::BackupMeta
|