| /rocksdb-6.9/db/ |
| D | read_callback.h | 25 inline bool IsVisible(SequenceNumber seq) { in IsVisible()
43 virtual void Refresh(SequenceNumber seq) { max_visible_seq_ = seq; } in Refresh()
|
| D | memtable_list.h | 72 SequenceNumber seq; variable
104 SequenceNumber seq; variable
353 void AssignAtomicFlushSeq(const SequenceNumber& seq) { in AssignAtomicFlushSeq()
|
| D | dbformat_test.cc | 17 uint64_t seq, in IKey()
37 uint64_t seq, in TestKey()
56 const uint64_t seq[] = { in TEST_F() local
|
| D | db_memtable_test.cc | 130 SequenceNumber seq = 123; in TEST_F() local
238 for (int seq = 1; seq < num_ops / 2; seq++) { in TEST_F() local
249 for (int seq = num_ops / 2; seq < num_ops; seq++) { in TEST_F() local
269 for (int seq = 0; seq < num_ops; seq++) { in TEST_F() local
|
| D | memtable.cc | 602 SequenceNumber seq; member
655 SequenceNumber seq; in SaveValue() local
782 SequenceNumber* seq, const ReadOptions& read_opts, in Get()
845 MergeContext* merge_context, SequenceNumber* seq, in GetFromTable()
910 SequenceNumber seq = kMaxSequenceNumber; in MultiGet() local
939 void MemTable::Update(SequenceNumber seq, in Update()
998 bool MemTable::UpdateCallback(SequenceNumber seq, in UpdateCallback()
|
| D | dbformat.cc | 29 uint64_t PackSequenceAndType(uint64_t seq, ValueType t) { in PackSequenceAndType()
65 void UnPackSequenceAndType(uint64_t packed, uint64_t* seq, ValueType* t) { in UnPackSequenceAndType()
|
| D | db_merge_operator_test.cc | 25 bool IsVisibleFullCheck(SequenceNumber seq) override { in IsVisibleFullCheck()
43 SequenceNumber seq = snapshot == nullptr ? db_->GetLatestSequenceNumber() in GetWithReadCallback() local
494 SequenceNumber seq, SequenceNumber snapshot_seq) const override { in TEST_F()
500 bool IsInSnapshot(SequenceNumber seq, SequenceNumber snapshot_seq) const { in TEST_F()
|
| D | snapshot_impl.h | 66 SnapshotImpl* New(SnapshotImpl* s, SequenceNumber seq, uint64_t unix_time, in New()
|
| D | memtable_list_test.cc | 214 SequenceNumber seq = 1; in TEST_F() local
331 SequenceNumber seq = 1; in TEST_F() local
520 SequenceNumber seq = 1; in TEST_F() local
785 SequenceNumber seq = 1; in TEST_F() local
|
| D | wal_manager_test.cc | 68 uint64_t seq = versions_->LastSequence() + 1; in Put() local
99 const SequenceNumber seq) { in OpenTransactionLogIter()
|
| D | range_del_aggregator_test.cc | 52 SequenceNumber seq; member
59 SequenceNumber seq; member
78 ParsedInternalKey InternalValue(const Slice& key, SequenceNumber seq) { in InternalValue()
|
| D | memtable_list.cc | 110 SequenceNumber* seq, const ReadOptions& read_opts, in Get()
145 SequenceNumber* seq, const ReadOptions& read_opts, bool* is_blob_index) { in GetFromHistory()
154 SequenceNumber* max_covering_tombstone_seq, SequenceNumber* seq, in GetFromList()
|
| D | range_del_aggregator.h | 73 SequenceNumber seq() const { return iter_->seq(); } in seq() function
332 bool InStripe(SequenceNumber seq) const { in InStripe()
|
| D | merge_helper_test.cc | 36 void AddKeyVal(const std::string& user_key, const SequenceNumber& seq, in AddKeyVal()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_iterator.cc | 15 #define DEFINITELY_IN_SNAPSHOT(seq, snapshot) \ argument
21 #define DEFINITELY_NOT_IN_SNAPSHOT(seq, snapshot) \ argument
27 #define IN_EARLIEST_SNAPSHOT(seq) \ argument
|
| /rocksdb-6.9/util/ |
| D | duplicate_detector.h | 20 bool IsDuplicateKeySeq(uint32_t cf, const Slice& key, SequenceNumber seq) { in IsDuplicateKeySeq()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_util.h | 25 SequenceNumber seq; member
|
| D | write_unprepared_txn.cc | 15 bool WriteUnpreparedTxnReadCallback::IsVisibleFullCheck(SequenceNumber seq) { in IsVisibleFullCheck()
593 for (const auto& seq : unprep_seqs_) { in CommitInternal() local
632 for (const auto& seq : unprep_seqs_) { in CommitInternal() local
749 for (const auto& seq : unprep_seqs_) { in RollbackInternal() local
780 for (const auto& seq : unprep_seqs_) { in RollbackInternal() local
|
| D | transaction_util.cc | 106 SequenceNumber seq = kMaxSequenceNumber; in CheckKey() local
|
| D | write_prepared_transaction_test.cc | 169 for (size_t seq = 1; seq <= t_cnt; seq++) { in TEST() local
183 auto seq = i; in TEST() local
1014 SequenceNumber seq = 0; in TEST_P() local
1325 const SequenceNumber seq = txn0->GetId(); // is also prepare seq in TEST_P() local
1680 auto seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P() local
1961 for (SequenceNumber seq = 0; in TEST_P() local
1977 for (SequenceNumber seq = 0; in TEST_P() local
2002 const SequenceNumber seq = 1; in TEST_P() local
2087 uint64_t seq = 0; in TEST_P() local
2333 uint64_t seq = 0; in TEST_P() local
[all …]
|
| D | write_unprepared_txn.h | 85 void Refresh(SequenceNumber seq) override { in Refresh()
|
| D | optimistic_transaction.cc | 147 SequenceNumber seq; in TryLock() local
|
| D | write_unprepared_txn_db.cc | 284 const auto& seq = batch.first; in Initialize() local
310 auto seq = seq_cnt.first; in Initialize() local
|
| /rocksdb-6.9/table/ |
| D | get_context.cc | 46 SequenceNumber* _max_covering_tombstone_seq, Env* env, SequenceNumber* seq, in GetContext()
79 SequenceNumber* seq, PinnedIteratorsManager* _pinned_iters_mgr, in GetContext()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_write.cc | 128 uint64_t seq; in WriteImpl() local
602 SequenceNumber seq, in UnorderedWriteMemtable()
1151 SequenceNumber seq; in WriteRecoverableState() local
1210 auto seq = versions_->LastSequence(); in AssignAtomicFlushSeq() local
1343 uint64_t seq = cfd->mem()->GetCreationSeq(); in HandleWriteBufferFull() local
1689 SequenceNumber seq = versions_->LastSequence(); in SwitchMemtable() local
|