Home
last modified time | relevance | path

Searched refs:current (Results 1 – 25 of 52) sorted by relevance

123

/rocksdb-6.9/table/block_based/
Dblock_prefix_index.cc93 for (PrefixRecord* current : prefixes_) { in Finish()
99 assert(current->start_block >= prev->end_block); in Finish()
100 auto distance = current->start_block - prev->end_block; in Finish()
102 prev->end_block = current->end_block; in Finish()
108 current->next = prev; in Finish()
109 prefixes_per_bucket[bucket] = current; in Finish()
110 num_blocks_per_bucket[bucket] += current->num_blocks; in Finish()
141 auto current = prefixes_per_bucket[i]; in Finish() local
143 while (current != nullptr) { in Finish()
145 *last_block = current->end_block - iter; in Finish()
[all …]
/rocksdb-6.9/db/
Dmemtable_list_test.cc201 list.current()->Unref(&to_delete); in TEST_F()
223 bool found = list.current()->Get( in TEST_F()
289 found = list.current()->Get( in TEST_F()
295 found = list.current()->Get( in TEST_F()
302 found = list.current()->Get( in TEST_F()
309 found = list.current()->Get( in TEST_F()
316 list.current()->Unref(&to_delete); in TEST_F()
340 bool found = list.current()->Get( in TEST_F()
511 list.current()->Unref(&to_delete); in TEST_F()
754 list.current()->Unref(&to_delete); in TEST_F()
[all …]
Dinternal_stats.cc536 const auto* vstorage = cfd_->current()->storage_info(); in HandleNumFilesAtLevel()
552 const auto* vstorage = cfd_->current()->storage_info(); in HandleCompressionRatioAtLevelPrefix()
564 const auto* vstorage = cfd_->current()->storage_info(); in HandleLevelStats()
618 auto* current = cfd_->current(); in HandleSsTables() local
619 *value = current->DebugString(true, true); in HandleSsTables()
642 auto s = cfd_->current()->GetAggregatedTableProperties( in HandleAggregatedTablePropertiesAtLevel()
680 const auto* vstorage = cfd_->current()->storage_info(); in HandleCompactionPending()
732 *value = cfd_->imm()->current()->GetTotalNumEntries(); in HandleNumEntriesImmMemTables()
748 *value = cfd_->imm()->current()->GetTotalNumDeletes(); in HandleNumDeletesImmMemTables()
756 const auto* vstorage = cfd_->current()->storage_info(); in HandleEstimateNumKeys()
[all …]
Dforward_iterator.cc396 const VersionStorageInfo* vstorage = sv_->current->storage_info(); in SeekInternal()
630 read_options_, sv_->current->version_set()->LastSequence())); in RebuildIterators()
637 const auto* vstorage = sv_->current->storage_info(); in RebuildIterators()
692 read_options_, sv_->current->version_set()->LastSequence())); in RenewIterators()
698 const auto* vstorage = sv_->current->storage_info(); in RenewIterators()
700 const auto* vstorage_new = svnew->current->storage_info(); in RenewIterators()
784 const auto& l0_files = sv_->current->storage_info()->LevelFiles(0); in ResetIncompleteIterators()
881 const VersionStorageInfo* vstorage = sv_->current->storage_info(); in DeleteCurrentIter()
913 const VersionStorageInfo* vstorage = sv_->current->storage_info(); in TEST_CheckDeletedIters()
Dwrite_thread.cc297 Writer* current = from; in FindNextLeader() local
298 while (current->link_older != boundary) { in FindNextLeader()
299 current = current->link_older; in FindNextLeader()
300 assert(current != nullptr); in FindNextLeader()
302 return current; in FindNextLeader()
Ddb_flush_test.cc98 auto current_before = cfd->current(); in TEST_F()
99 int refs_before = cfd->current()->TEST_refs(); in TEST_F()
102 int refs_after_picking_memtables = cfd->current()->TEST_refs(); in TEST_F()
114 ASSERT_EQ(current_before, cfd->current()); in TEST_F()
115 ASSERT_EQ(refs_before, cfd->current()->TEST_refs()); in TEST_F()
385 ASSERT_LT(seq, cfd->imm()->current()->GetEarliestSequenceNumber()); in TEST_F()
Dcolumn_family.cc433 auto* memory_usage = current->cfd()->imm()->current_memory_usage(); in Cleanup()
438 current->Unref(); in Cleanup()
449 current = new_current; in Init()
453 current->Ref(); in Init()
627 imm_.current()->Unref(&to_delete); in ~ColumnFamilyData()
1052 imm_.current()->GetEarliestSequenceNumber(false)); in PickCompaction()
1084 auto read_seq = super_version->current->version_set()->LastSequence(); in RangesOverlapWithMemtables()
1095 auto* vstorage = super_version->current->storage_info(); in RangesOverlapWithMemtables()
1232 new_superversion->Init(this, mem_, imm_.current(), current_); in InstallSuperVersion()
Dexternal_sst_file_ingestion_job.cc312 auto vstorage = cfd_->current()->storage_info(); in UpdateStats()
545 auto* vstorage = cfd_->current()->storage_info(); in AssignLevelAndSeqnoForIngestedFile()
554 status = sv->current->OverlapWithLevelIterator( in AssignLevelAndSeqnoForIngestedFile()
615 auto* vstorage = cfd_->current()->storage_info(); in CheckLevelForIngestedBehindFile()
697 auto* vstorage = cfd_->current()->storage_info(); in IngestedFileFitInLevel()
Dversion_builder.cc776 cfd->current()->version_set()->file_options(), cfd->table_cache(), in BaseReferencedVersionBuilder()
777 cfd->current()->storage_info(), cfd->ioptions()->info_log)), in BaseReferencedVersionBuilder()
778 version_(cfd->current()) { in BaseReferencedVersionBuilder()
785 cfd->current()->version_set()->file_options(), cfd->table_cache(), in BaseReferencedVersionBuilder()
788 assert(version_ != cfd->current()); in BaseReferencedVersionBuilder()
Dcolumn_family.h204 Version* current; member
362 Version* current() { return current_; } in current() function
753 virtual ColumnFamilyData* current() override { return current_; } in current() function
Dversion_set.cc1725 : cfd_->current()->storage_info(), in Version()
3619 Version* current = column_family_data->current(); in AppendVersion() local
3620 assert(v != current); in AppendVersion()
3621 if (current != nullptr) { in AppendVersion()
3622 assert(current->refs_ > 0); in AppendVersion()
3623 current->Unref(); in AppendVersion()
5498 auto* current = cfd->current(); in AddLiveFiles() local
5504 if (v == current) { in AddLiveFiles()
5508 if (!found_current && current != nullptr) { in AddLiveFiles()
5511 current->AddLiveFiles(live_list); in AddLiveFiles()
[all …]
/rocksdb-6.9/db/compaction/
Dcompaction_job_test.cc322 compaction.SetInputVersion(cfd->current());
393 auto files = cfd->current()->storage_info()->LevelFiles(0); in TEST_F()
403 auto files = cfd->current()->storage_info()->LevelFiles(0); in TEST_F()
423 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
441 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
463 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
516 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
540 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
567 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
603 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
[all …]
/rocksdb-6.9/memtable/
Dskiplist_test.cc248 Key current; in ReadStep() local
250 current = MakeKey(K, 0); in ReadStep()
252 current = iter.key(); in ReadStep()
253 ASSERT_TRUE(IsValidKey(current)) << current; in ReadStep()
255 ASSERT_LE(pos, current) << "should not go backwards"; in ReadStep()
259 while (pos < current) { in ReadStep()
271 if (key(pos) < key(current)) { in ReadStep()
Dinlineskiplist_test.cc442 Key current; in ReadStep() local
444 current = MakeKey(K, 0); in ReadStep()
446 current = Decode(iter.key()); in ReadStep()
447 ASSERT_TRUE(IsValidKey(current)) << current; in ReadStep()
449 ASSERT_LE(pos, current) << "should not go backwards"; in ReadStep()
453 while (pos < current) { in ReadStep()
465 if (key(pos) < key(current)) { in ReadStep()
/rocksdb-6.9/docs/_posts/
D2015-10-27-getthreadlist.markdown118 …t's target db / column family, and the job it is currently doing and the current status of the job…
153 the current status of a thread. The `ThreadStatus` structure, defined in
174 // The operation (high-level action) that the current thread is involved.
177 // The elapsed time in micros of the current thread operation.
180 // An integer showing the current stage where the thread is involved
181 // in the current operation.
184 // A list of properties that describe some details about the current
189 // The state (lower-level action) that the current thread is involved.
D2014-03-27-how-to-backup-rocksdb.markdown73 …ven though they do not need to be copied. A checksum mismatch aborts the current backup (see "Unde…
92 …og files corresponding to live memtables. Backup will be consistent with current state of the data…
111 2. Get live files (this includes table files, current and manifest file).
115 …ile in backup directory or the corresponding live file in current DB. Both manifest and current fi…
D2014-03-27-how-to-persist-in-memory-rocksdb-database.markdown16 …By default, when we flush the memtable to table file, we also delete the current log, since we don…
18 …f you configure this directory to be on flash or disk, you will not lose current log file on machi…
21 …s is set to one day. To fully recover the DB, we also need to backup the current snapshot of the d…
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc890 auto* current = cfd->current(); in CompactFiles()
891 current->Ref(); in CompactFiles()
897 current->Unref(); in CompactFiles()
1160 Version* current = cfd->current(); in NotifyOnCompactionBegin() local
1161 current->Ref(); in NotifyOnCompactionBegin()
1209 current->Unref(); in NotifyOnCompactionBegin()
1234 Version* current = cfd->current(); in NotifyOnCompactionCompleted() local
1235 current->Ref(); in NotifyOnCompactionCompleted()
1248 current->Unref(); in NotifyOnCompactionCompleted()
2631 ->current() in BackgroundCompaction()
[all …]
Ddb_impl_debug.cc21 return default_cf_handle_->cfd()->current()->storage_info()->NumLevelBytes(0); in TEST_GetLevel0TotalSize()
54 return cfd->current()->storage_info()->MaxNextLevelOverlappingBytes(); in TEST_MaxNextLevelOverlappingBytes()
66 cfd->current()->storage_info()->LevelFiles(level); in TEST_GetFilesMetaData()
Ddb_impl_experimental.cc36 auto vstorage = cfd->current()->storage_info(); in SuggestCompactRange()
71 const auto* vstorage = cfd->current()->storage_info(); in PromoteL0()
Ddb_impl.cc879 Version* version = super_version->current; in TablesRangeTombstoneSummary()
1654 sv->current->Get( in GetImpl()
2749 if (!cfd->current() in ReleaseSnapshot()
2785 auto version = cfd->current(); in GetPropertiesOfAllTables()
2807 auto version = cfd->current(); in GetPropertiesOfTablesInRange()
2930 property_info, sv->current, value); in GetIntPropertyInternal()
3106 v = sv->current; in GetApproximateSizes()
3268 Version* input_version = cfd->current(); in DeleteFilesInRanges()
3367 sv->current->GetColumnFamilyMetaData(cf_meta); in GetColumnFamilyMetaData()
4415 ColumnFamilyData* cfd = sv->current->cfd(); in VerifyChecksum()
[all …]
/rocksdb-6.9/third-party/folly/folly/synchronization/test/
DDistributedMutexTest.cpp157 EXPECT_EQ(current, expected - 1); in combineNThreads()
198 auto current = mutex.lock_combine([&]() { in combineWithLockNThreads() local
210 EXPECT_EQ(expected, current + 1); in combineWithLockNThreads()
253 auto current = mutex.lock_combine([&]() { in combineWithTryLockNThreads() local
265 EXPECT_EQ(expected, current + 1); in combineWithTryLockNThreads()
346 EXPECT_EQ(expected, current[0] + 1); in combineWithLockTryAndTimedNThreads()
347 EXPECT_EQ(expected, current[1]); in combineWithLockTryAndTimedNThreads()
348 EXPECT_EQ(expected, current[2] - 1); in combineWithLockTryAndTimedNThreads()
349 EXPECT_EQ(expected, current[3] - 2); in combineWithLockTryAndTimedNThreads()
350 EXPECT_EQ(expected, current[4] - 3); in combineWithLockTryAndTimedNThreads()
[all …]
/rocksdb-6.9/third-party/folly/folly/synchronization/
DDistributedMutex-inl.h870 auto current = time();
871 if ((current - previous) >= kScheduledAwaySpinThreshold) {
874 previous = current;
1288 CombineFunction loadTask(Waiter* current, std::uintptr_t value) {
1293 return current->function_;
1464 auto current = &waiter;
1465 while (current) {
1478 auto value = current->futex_.load(std::memory_order_acquire);
1479 auto next = current->next_.load(std::memory_order_relaxed);
1480 auto task = loadTask(current, value);
[all …]
/rocksdb-6.9/
DRocksDBConfigVersion.cmake5 # The created file sets PACKAGE_VERSION_EXACT if the current version string and
7 # PACKAGE_VERSION_COMPATIBLE if the current version is >= requested version,
8 # but only if the requested major version is the same as the current one.
/rocksdb-6.9/env/
Denv_hdfs.cc143 tOffset current = hdfsTell(fileSys_, hfile_); in Skip() local
144 if (current < 0) { in Skip()
148 tOffset newoffset = current + n; in Skip()

123