| /rocksdb-6.9/table/ |
| D | merging_iterator.cc | 44 current_(nullptr), in MergingIterator()
56 current_ = CurrentForward(); in MergingIterator()
177 current_->Next(); in Next()
178 if (current_->Valid()) { in Next()
218 current_->Prev(); in Prev()
219 if (current_->Valid()) { in Prev()
235 return current_->key(); in key()
240 return current_->value(); in value()
290 IteratorWrapper* current_; member in ROCKSDB_NAMESPACE::MergingIterator
357 if (&child != current_) { in SwitchToForward()
[all …]
|
| /rocksdb-6.9/db/ |
| D | forward_iterator.cc | 213 current_(nullptr), in ForwardIterator()
475 } else if (current_ && current_ != mutable_iter_) { in SeekInternal()
522 current_->Next(); in Next()
526 } else if ((current_->Valid()) && (!IsOverUpperBound(current_->key()))) { in Next()
529 if ((current_->Valid()) && (IsOverUpperBound(current_->key()))) { in Next()
532 current_ = nullptr; in Next()
545 return current_->key(); in key()
661 current_ = nullptr; in RebuildIterators()
749 current_ = nullptr; in RenewIterators()
809 current_ = nullptr; in ResetIncompleteIterators()
[all …]
|
| D | memtable_list.cc | 423 auto& memlist = current_->memlist_; in TryInstallMemtableFlushResults()
509 current_->Remove(m, to_delete); in TryInstallMemtableFlushResults()
545 current_->Add(m, to_delete); in Add()
557 current_->TrimHistory(to_delete, usage); in TrimHistory()
595 if (!current_->memlist_.empty()) { in ApproximateOldestKeyTime()
602 if (current_->refs_ == 1) { in InstallNewVersion()
607 current_ = new MemTableListVersion(¤t_memory_usage_, current_); in InstallNewVersion()
608 current_->Ref(); in InstallNewVersion()
617 for (auto& m : current_->memlist_) { in PrecomputeMinLogContainingPrepSection()
752 auto& memlist = current_->memlist_; in RemoveOldMemTables()
[all …]
|
| D | column_family.h | 362 Version* current() { return current_; } in current()
526 Version* current_; // == dummy_versions->prev_ variable
627 : current_(cfd) {} in iterator()
634 current_ = current_->next_;
635 } while (current_->refs_.load(std::memory_order_relaxed) == 0);
639 return this->current_ != other.current_;
641 ColumnFamilyData* operator*() { return current_; }
644 ColumnFamilyData* current_;
723 : column_family_set_(column_family_set), current_(nullptr) {} in ColumnFamilyMemTablesImpl()
753 virtual ColumnFamilyData* current() override { return current_; } in current()
[all …]
|
| D | column_family.cc | 494 current_(nullptr), in ColumnFamilyData()
605 if (current_ != nullptr) { in ~ColumnFamilyData()
606 current_->Unref(); in ~ColumnFamilyData()
851 if (current_ != nullptr) { in RecalculateWriteStallConditions()
1014 current_ = current_version; in SetCurrent()
1527 handle_.SetCFD(current_); in Seek()
1528 return current_ != nullptr; in Seek()
1532 assert(current_ != nullptr); in GetLogNumber()
1537 assert(current_ != nullptr); in GetMemTable()
1538 return current_->mem(); in GetMemTable()
[all …]
|
| D | memtable_list.h | 215 current_(new MemTableListVersion(¤t_memory_usage_, in MemTableList()
224 current_->Ref(); in MemTableList()
231 MemTableListVersion* current() const { return current_; } in current()
338 auto& memlist = current_->memlist_; in GetEarliestMemTableID()
346 auto& memlist = current_->memlist_; in GetLatestMemTableID()
354 const auto& memlist = current_->memlist_; in AssignAtomicFlushSeq()
391 MemTableListVersion* current_; variable
|
| D | forward_iterator.h | 130 InternalIterator* current_; variable
|
| /rocksdb-6.9/util/ |
| D | vector_iterator.h | 23 current_(0) { in VectorIterator()
34 return !indices_.empty() && current_ < indices_.size(); in Valid()
37 virtual void SeekToFirst() override { current_ = 0; } in SeekToFirst()
38 virtual void SeekToLast() override { current_ = indices_.size() - 1; } in SeekToLast()
41 current_ = std::lower_bound(indices_.begin(), indices_.end(), target, in Seek()
47 current_ = std::lower_bound(indices_.begin(), indices_.end(), target, in SeekForPrev()
57 virtual void Next() override { current_++; } in Next()
58 virtual void Prev() override { current_--; } in Prev()
61 return Slice(keys_[indices_[current_]]); in key()
64 return Slice(values_[indices_[current_]]); in value()
[all …]
|
| D | filelock_test.cc | 19 static LockTest* current_; member in ROCKSDB_NAMESPACE::LockTest
26 current_ = this; in LockTest()
111 LockTest* LockTest::current_; member in ROCKSDB_NAMESPACE::LockTest
|
| /rocksdb-6.9/table/block_based/ |
| D | block.cc | 152 current_ = restarts_; in Prev()
207 current_ = restarts_; in Prev()
339 if (current_ == restarts_) { in SeekForGetImpl()
397 current_ = restarts_; in Seek()
493 current_ = restarts_; in CorruptionError()
502 current_ = NextEntryOffset(); in ParseNextDataKey()
510 current_ = restarts_; in ParseNextDataKey()
577 current_ = restarts_; in ParseNextIndexKey()
761 current_ = restarts_; in BinaryBlockIndexSeek()
798 current_ = restarts_; in BinaryBlockIndexSeek()
[all …]
|
| D | block.h | 244 current_ = restarts_; in InitializeBase()
259 current_ = restarts_; in InvalidateBase()
266 bool Valid() const override { return current_ < restarts_; } in Valid()
291 size_t TEST_CurrentEntrySize() { return NextEntryOffset() - current_; } in TEST_CurrentEntrySize()
312 uint32_t current_; variable
386 last_bitmap_offset_ = current_ + 1; in Initialize()
392 if (read_amp_bitmap_ && current_ < restarts_ && in value()
393 current_ != last_bitmap_offset_) { in value()
394 read_amp_bitmap_->Mark(current_ /* current entry offset */, in value()
396 last_bitmap_offset_ = current_; in value()
[all …]
|
| /rocksdb-6.9/test_util/ |
| D | testutil.h | 141 : keys_(keys), current_(keys.size()) { in VectorIterator()
148 : keys_(keys), values_(values), current_(keys.size()) { in VectorIterator()
152 virtual bool Valid() const override { return current_ < keys_.size(); } in Valid()
154 virtual void SeekToFirst() override { current_ = 0; } in SeekToFirst()
155 virtual void SeekToLast() override { current_ = keys_.size() - 1; } in SeekToLast()
158 current_ = std::lower_bound(keys_.begin(), keys_.end(), target.ToString()) - in Seek()
172 virtual void Next() override { current_++; } in Next()
173 virtual void Prev() override { current_--; } in Prev()
175 virtual Slice key() const override { return Slice(keys_[current_]); } in key()
176 virtual Slice value() const override { return Slice(values_[current_]); } in value()
[all …]
|
| /rocksdb-6.9/memtable/ |
| D | inlineskiplist_test.cc | 392 State current_; member in ROCKSDB_NAMESPACE::ConcurrentTest
406 const int g = current_.Get(k) + 1; in WriteStep()
411 current_.Set(k, g); in WriteStep()
416 const int g = current_.Get(k) + 1; in ConcurrentWriteStep()
427 ASSERT_EQ(g, current_.Get(k) + 1); in ConcurrentWriteStep()
428 current_.Set(k, g); in ConcurrentWriteStep()
435 initial_state.Set(k, current_.Get(k)); in ReadStep()
|
| D | skiplist_test.cc | 217 State current_; member in ROCKSDB_NAMESPACE::ConcurrentTest
231 const int g = current_.Get(k) + 1; in WriteStep()
234 current_.Set(k, g); in WriteStep()
241 initial_state.Set(k, current_.Get(k)); in ReadStep()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_iterator_test.cc | 111 : keys_(keys), values_(values), current_(keys.size()) { in LoggingForwardVectorIterator()
115 bool Valid() const override { return current_ < keys_.size(); } in Valid()
119 current_ = 0; in SeekToFirst()
125 current_ = std::lower_bound(keys_.begin(), keys_.end(), target.ToString()) - in Seek()
134 current_++; in Next()
140 return Slice(keys_[current_]); in key()
144 return Slice(values_[current_]); in value()
154 size_t current_; member in ROCKSDB_NAMESPACE::LoggingForwardVectorIterator
|
| /rocksdb-6.9/cache/ |
| D | cache_test.cc | 46 static CacheTest* current_; member in ROCKSDB_NAMESPACE::CacheTest
51 current_->deleted_keys_.push_back(DecodeKey(key)); in operator ()()
52 current_->deleted_values_.push_back(DecodeValue(v)); in operator ()()
71 current_ = this; in CacheTest()
149 CacheTest* CacheTest::current_; member in ROCKSDB_NAMESPACE::CacheTest
|