Home
last modified time | relevance | path

Searched refs:meta (Results 1 – 25 of 31) sorted by relevance

12

/rocksdb-6.9/db/
Drepair.cc226 FileMetaData meta; member
406 FileMetaData meta; in ConvertLogToTable() local
464 FormatFileNumber(t.meta.fd.GetNumber(), t.meta.fd.GetPathId(), in ExtractMetaData()
477 db_options_.db_paths, t->meta.fd.GetNumber(), t->meta.fd.GetPathId()); in ScanTable()
481 t->meta.fd = FileDescriptor(t->meta.fd.GetNumber(), t->meta.fd.GetPathId(), in ScanTable()
585 0, table->meta.fd.GetNumber(), table->meta.fd.GetPathId(), in AddTables()
586 table->meta.fd.GetFileSize(), table->meta.smallest, in AddTables()
587 table->meta.largest, table->meta.fd.smallest_seqno, in AddTables()
588 table->meta.fd.largest_seqno, table->meta.marked_for_compaction, in AddTables()
590 table->meta.oldest_ancester_time, table->meta.file_creation_time, in AddTables()
[all …]
Dbuilder.cc95 meta->fd.file_size = 0; in BuildTable()
104 meta->fd.GetPathId()); in BuildTable()
165 meta->UpdateBoundaries(key, value, ikey.sequence, ikey.type); in BuildTable()
199 meta->fd.file_size = file_size; in BuildTable()
200 meta->marked_for_compaction = builder->NeedCompact(); in BuildTable()
201 assert(meta->fd.GetFileSize() > 0); in BuildTable()
219 meta->file_checksum = file_writer->GetFileChecksum(); in BuildTable()
237 ReadOptions(), file_options, internal_comparator, *meta, in BuildTable()
259 if (!s.ok() || meta->fd.GetFileSize() == 0) { in BuildTable()
263 if (meta->fd.GetFileSize() == 0) { in BuildTable()
[all …]
Dversion_builder.cc154 assert(meta); in GetBlobFileMetaData()
156 return meta; in GetBlobFileMetaData()
166 assert(meta); in GetBlobFileMetaData()
168 return meta; in GetBlobFileMetaData()
189 if (!meta) { in CheckConsistencyOfOldestBlobFileReference()
384 if (meta) { in ApplyBlobFileAddition()
411 if (!meta) { in ApplyBlobFileGarbage()
421 meta->GetSharedMeta(), in ApplyBlobFileGarbage()
505 assert(meta); in AddBlobFileIfNeeded()
507 if (meta->GetGarbageBlobCount() < meta->GetTotalBlobCount()) { in AddBlobFileIfNeeded()
[all …]
Dcompact_files_test.cc98 ROCKSDB_NAMESPACE::ColumnFamilyMetaData meta; in TEST_F() local
99 db->GetColumnFamilyMetaData(&meta); in TEST_F()
101 for (auto& file : meta.levels[0].files) { in TEST_F()
102 ASSERT_EQ(0, meta.levels[0].level); in TEST_F()
299 ROCKSDB_NAMESPACE::ColumnFamilyMetaData meta; in TEST_F() local
300 db->GetColumnFamilyMetaData(&meta); in TEST_F()
301 for (auto& file : meta.levels[0].files) { in TEST_F()
Dversion_builder_test.cc88 auto meta = std::make_shared<BlobFileMetaData>( in AddBlob() local
91 vstorage_.AddBlobFile(std::move(meta)); in AddBlob()
103 const auto& meta = it->second; in GetBlobFileMetaData() local
104 assert(meta); in GetBlobFileMetaData()
106 return meta; in GetBlobFileMetaData()
460 const auto meta = in TEST_F() local
462 ASSERT_NE(meta, nullptr); in TEST_F()
491 ASSERT_EQ(new_meta->GetSharedMeta(), meta->GetSharedMeta()); in TEST_F()
Dflush_job_test.cc377 FileMetaData meta; in TEST_F() local
379 ASSERT_OK(job->Run(nullptr /**/, &meta)); in TEST_F()
380 file_metas.emplace_back(meta); in TEST_F()
383 for (auto& meta : file_metas) { in TEST_F() local
384 file_meta_ptrs.push_back(&meta); in TEST_F()
Dversion_edit_handler.cc537 const FileMetaData& meta = elem.second; in MaybeCreateVersion() local
538 const FileDescriptor& fd = meta.fd; in MaybeCreateVersion()
542 s = version_set_->VerifyFileMetadata(fpath, meta); in MaybeCreateVersion()
Dmemtable_list_test.cc171 FileMetaData meta; in Mock_InstallMemtableAtomicFlushResults() local
173 meta.fd = FileDescriptor(file_num, 0, 0); in Mock_InstallMemtableAtomicFlushResults()
174 file_metas.emplace_back(meta); in Mock_InstallMemtableAtomicFlushResults()
177 for (auto& meta : file_metas) { in Mock_InstallMemtableAtomicFlushResults() local
178 file_meta_ptrs.push_back(&meta); in Mock_InstallMemtableAtomicFlushResults()
Dversion_set_test.cc1837 FileMetaData meta; in CreateDummyTableFiles() local
1838 meta = FileMetaData(file_num, /*file_path_id=*/0, file_size, ikey, ikey, in CreateDummyTableFiles()
1841 file_metas->emplace_back(meta); in CreateDummyTableFiles()
1893 FileMetaData meta = in TEST_F() local
1897 added_files.emplace_back(0, meta); in TEST_F()
1948 FileMetaData meta = in TEST_F() local
1952 added_files.emplace_back(0, meta); in TEST_F()
1996 for (const auto& meta : file_metas) { in TEST_F() local
1997 added_files.emplace_back(0, meta); in TEST_F()
Dbuilder.h71 FileMetaData* meta, const InternalKeyComparator& internal_comparator,
Dlistener_test.cc126 files_by_level[ci.output_level].end(), [&](const FileMetaData& meta) { in OnCompactionCompleted() argument
127 return meta.fd.GetNumber() == ci.output_file_infos[i].file_number; in OnCompactionCompleted()
280 [&](const FileMetaData& meta) { in OnFlushCompleted() argument
281 return meta.fd.GetNumber() == info.file_number; in OnFlushCompleted()
Ddb_tailing_iter_test.cc465 ColumnFamilyMetaData meta; in TEST_F() local
466 db_->GetColumnFamilyMetaData(handles_[1], &meta); in TEST_F()
Ddb_test.cc1092 for (const auto& meta : live_file_meta) { in CheckLiveFilesMeta() local
1093 if (level != meta.level) { in CheckLiveFilesMeta()
1094 level = meta.level; in CheckLiveFilesMeta()
1102 ASSERT_EQ(meta.column_family_name, kDefaultColumnFamilyName); in CheckLiveFilesMeta()
1103 ASSERT_EQ(meta.file_number, expected_meta.fd.GetNumber()); in CheckLiveFilesMeta()
1104 ASSERT_EQ(meta.file_number, TableFileNameToNumber(meta.name)); in CheckLiveFilesMeta()
1105 ASSERT_EQ(meta.size, expected_meta.fd.file_size); in CheckLiveFilesMeta()
1107 ASSERT_EQ(meta.largest_seqno, expected_meta.fd.largest_seqno); in CheckLiveFilesMeta()
1110 ASSERT_EQ(meta.oldest_blob_file_number, in CheckLiveFilesMeta()
6535 FileMetaData* meta = static_cast<FileMetaData*>(arg); in TEST_F() local
[all …]
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc121 FileMetaData meta; member
695 output.meta.fd.GetNumber(), output.meta.fd.GetPathId()); in Run()
1136 auto meta = &sub_compact->current_output()->meta; in FinishCompactionOutputFile() local
1137 assert(meta != nullptr); in FinishCompactionOutputFile()
1329 meta->file_checksum_func_name = in FinishCompactionOutputFile()
1349 meta->fd.GetNumber(), meta->fd.GetPathId()); in FinishCompactionOutputFile()
1356 meta = nullptr; in FinishCompactionOutputFile()
1373 if (meta != nullptr) { in FinishCompactionOutputFile()
1376 meta->fd.GetNumber(), meta->fd.GetPathId()); in FinishCompactionOutputFile()
1377 output_fd = meta->fd; in FinishCompactionOutputFile()
[all …]
Dcompaction_job_test.cc97 FileMetaData meta; in GenerateFileName() local
100 meta.fd = FileDescriptor(file_number, 0, 0); in GenerateFileName()
101 return TableFileName(db_paths, meta.fd.GetNumber(), meta.fd.GetPathId()); in GenerateFileName()
/rocksdb-6.9/db/blob/
Dblob_file_meta.cc42 std::ostream& operator<<(std::ostream& os, const BlobFileMetaData& meta) { in operator <<() argument
43 const auto& shared_meta = meta.GetSharedMeta(); in operator <<()
46 os << (*shared_meta) << " garbage_blob_count: " << meta.GetGarbageBlobCount() in operator <<()
47 << " garbage_blob_bytes: " << meta.GetGarbageBlobBytes(); in operator <<()
Dblob_file_meta.h122 std::ostream& operator<<(std::ostream& os, const BlobFileMetaData& meta);
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc1196 FileMetaData meta; in WriteLevel0TableForRecovery() local
1222 meta.oldest_ancester_time = current_time; in WriteLevel0TableForRecovery()
1269 if (s.ok() && meta.fd.GetFileSize() > 0) { in WriteLevel0TableForRecovery()
1270 edit->AddFile(level, meta.fd.GetNumber(), meta.fd.GetPathId(), in WriteLevel0TableForRecovery()
1271 meta.fd.GetFileSize(), meta.smallest, meta.largest, in WriteLevel0TableForRecovery()
1272 meta.fd.smallest_seqno, meta.fd.largest_seqno, in WriteLevel0TableForRecovery()
1273 meta.marked_for_compaction, meta.oldest_blob_file_number, in WriteLevel0TableForRecovery()
1274 meta.oldest_ancester_time, meta.file_creation_time, in WriteLevel0TableForRecovery()
1275 meta.file_checksum, meta.file_checksum_func_name); in WriteLevel0TableForRecovery()
1280 stats.bytes_written = meta.fd.GetFileSize(); in WriteLevel0TableForRecovery()
[all …]
Ddb_impl_compaction_flush.cc1196 const FileMetaData& meta = newf.second; in NotifyOnCompactionBegin() local
1197 const FileDescriptor& desc = meta.fd; in NotifyOnCompactionBegin()
1202 newf.first, file_number, meta.oldest_blob_file_number}); in NotifyOnCompactionBegin()
3075 const FileMetaData& meta = newf.second; in BuildCompactionJobInfo() local
3076 const FileDescriptor& desc = meta.fd; in BuildCompactionJobInfo()
3081 newf.first, file_number, meta.oldest_blob_file_number}); in BuildCompactionJobInfo()
/rocksdb-6.9/monitoring/
Dfile_read_sample.h19 inline void sample_file_read_inc(FileMetaData* meta) { in sample_file_read_inc() argument
20 meta->stats.num_reads_sampled.fetch_add(kFileReadSampleRate, in sample_file_read_inc()
/rocksdb-6.9/util/
Dthreadpool_imp.cc279 BGThreadMetadata* meta = reinterpret_cast<BGThreadMetadata*>(arg); in BGThreadWrapper() local
280 size_t thread_id = meta->thread_id_; in BGThreadWrapper()
281 ThreadPoolImpl::Impl* tp = meta->thread_pool_; in BGThreadWrapper()
306 delete meta; in BGThreadWrapper()
/rocksdb-6.9/docs/_posts/
D2014-05-14-lock.markdown12 …ly one single major lock, the DB mutex (DBImpl.mutex_) protecting all the meta operations, includi…
19 …* Change and check meta data structures, before and after finishing compactions, flushes and new m…
29 To solve this problem, we created a meta-meta data structure called “[super version](https://review…
43 … up. This autovector is quite useful for manipulating those meta data structures. Those meta opera…
D2018-11-21-delete-range.markdown95 the first solution. So, we introduced a separate meta-block for range tombstones.
105 *When there are range tombstones in an SST, they are segregated in a separate meta-block*
119 are flushed together into a single SST with a range tombstone meta-block. SSTs
143 which further complicates the range tombstone meta-block encoding; and (2) even
178 range tombstone memtables/meta-blocks.
D2017-01-06-rocksdb-5-0-1-released.markdown26 …e latest backup can be determined by finding the highest numbered file in the "meta/" subdirectory.
/rocksdb-6.9/tools/
Ddb_bench_tool.cc4532 ColumnFamilyMetaData meta; in DoDeterministicCompact() local
4573 db->GetColumnFamilyMetaData(&meta); in DoDeterministicCompact()
4580 meta.levels[0].files.begin(), in DoDeterministicCompact()
4630 db->GetColumnFamilyMetaData(&meta); in DoDeterministicCompact()
4637 meta.levels[0].files.begin(), in DoDeterministicCompact()
4688 db->GetColumnFamilyMetaData(&meta); in DoDeterministicCompact()
4689 auto total_size = meta.levels[0].size; in DoDeterministicCompact()
4716 db->GetColumnFamilyMetaData(&meta); in DoDeterministicCompact()
4725 db->GetColumnFamilyMetaData(&meta); in DoDeterministicCompact()
4796 db->GetColumnFamilyMetaData(&meta); in DoDeterministicCompact()
[all …]

12