| /rocksdb-6.9/table/ |
| D | sst_file_writer.cc | 34 ioptions(options), in Rep()
46 ImmutableCFOptions ioptions; member
194 compression_type = r->ioptions.bottommost_compression; in Open()
195 if (r->ioptions.bottommost_compression_opts.enabled) { in Open()
198 compression_opts = r->ioptions.compression_opts; in Open()
200 } else if (!r->ioptions.compression_per_level.empty()) { in Open()
203 compression_opts = r->ioptions.compression_opts; in Open()
206 compression_opts = r->ioptions.compression_opts; in Open()
221 r->ioptions.table_properties_collector_factories; in Open()
296 s = r->file_writer->Sync(r->ioptions.use_fsync); in Finish()
[all …]
|
| D | table_test.cc | 470 ImmutableCFOptions ioptions(options_); in MemTableConstructor() local
1359 ImmutableCFOptions ioptions(options); in TEST_P() local
1408 ImmutableCFOptions ioptions(options); in IndexUncompressedHelper() local
1657 const ImmutableCFOptions ioptions(opt); in TEST_P() local
2522 ImmutableCFOptions ioptions(options); in TEST_P() local
2596 ImmutableCFOptions ioptions(options); in TEST_P() local
2640 ImmutableCFOptions ioptions(options); in TEST_P() local
3242 ImmutableCFOptions ioptions(options); in TEST_P() local
3284 ImmutableCFOptions ioptions(options); in TEST_P() local
3673 ImmutableCFOptions ioptions(options); in TEST_F() local
[all …]
|
| D | sst_file_reader.cc | 24 ImmutableCFOptions ioptions; member
32 ioptions(options), in Rep()
55 TableReaderOptions t_opt(r->ioptions, r->moptions.prefix_extractor.get(), in Open()
56 r->soptions, r->ioptions.internal_comparator); in Open()
73 return NewDBIterator(r->options.env, options, r->ioptions, r->moptions, in NewIterator()
74 r->ioptions.user_comparator, internal_iter, sequence, in NewIterator()
|
| D | format.cc | 343 const ImmutableCFOptions& ioptions, MemoryAllocator* allocator) { in UncompressBlockContentsForCompressionType() argument
349 StopWatchNano timer(ioptions.env, ShouldReportDetailedTime( in UncompressBlockContentsForCompressionType()
350 ioptions.env, ioptions.statistics)); in UncompressBlockContentsForCompressionType()
442 if (ShouldReportDetailedTime(ioptions.env, ioptions.statistics)) { in UncompressBlockContentsForCompressionType()
443 RecordTimeToHistogram(ioptions.statistics, DECOMPRESSION_TIMES_NANOS, in UncompressBlockContentsForCompressionType()
446 RecordTimeToHistogram(ioptions.statistics, BYTES_DECOMPRESSED, in UncompressBlockContentsForCompressionType()
448 RecordTick(ioptions.statistics, NUMBER_BLOCK_DECOMPRESSED); in UncompressBlockContentsForCompressionType()
463 const ImmutableCFOptions& ioptions, in UncompressBlockContents() argument
469 ioptions, allocator); in UncompressBlockContents()
|
| D | meta_blocks.cc | 196 const ImmutableCFOptions& ioptions, in ReadProperties() argument
218 ioptions, false /* decompress */, false /*maybe_compressed*/, in ReadProperties()
310 ROCKS_LOG_ERROR(ioptions.info_log, "%s", error_msg.c_str()); in ReadProperties()
358 const ImmutableCFOptions& ioptions, in ReadTableProperties() argument
378 metaindex_handle, &metaindex_contents, ioptions, false /* decompress */, in ReadTableProperties()
403 ioptions, properties, false /* verify_checksum */, in ReadTableProperties()
428 const ImmutableCFOptions& ioptions, in FindMetaBlock() argument
447 metaindex_handle, &metaindex_contents, ioptions, in FindMetaBlock()
470 const ImmutableCFOptions& ioptions, in ReadMetaBlock() argument
491 &metaindex_contents, ioptions, false /* decompress */, in ReadMetaBlock()
[all …]
|
| D | table_reader_bench.cc | 87 const ImmutableCFOptions ioptions(opts); in TableReaderBenchmark() local
103 ioptions, moptions, ikc, &int_tbl_prop_collector_factories, in TableReaderBenchmark()
145 TableReaderOptions(ioptions, moptions.prefix_extractor.get(), in TableReaderBenchmark()
176 GetContext get_context(ioptions.user_comparator, in TableReaderBenchmark()
177 ioptions.merge_operator, ioptions.info_log, in TableReaderBenchmark()
178 ioptions.statistics, GetContext::kNotFound, in TableReaderBenchmark()
|
| D | table_builder.h | 51 : ioptions(_ioptions), in TableReaderOptions()
61 const ImmutableCFOptions& ioptions; member
88 : ioptions(_ioptions), in ioptions() function
102 const ImmutableCFOptions& ioptions; member
|
| D | meta_blocks.h | 104 const ImmutableCFOptions& ioptions,
121 const ImmutableCFOptions& ioptions,
134 const ImmutableCFOptions& ioptions,
146 const ImmutableCFOptions& ioptions,
|
| /rocksdb-6.9/db/ |
| D | builder.cc | 45 const ImmutableCFOptions& ioptions, const MutableCFOptions& moptions, in NewTableBuilder() argument
58 return ioptions.table_factory->NewTableBuilder( in NewTableBuilder()
59 TableBuilderOptions(ioptions, moptions, internal_comparator, in NewTableBuilder()
70 const ImmutableCFOptions& ioptions, in BuildTable() argument
136 std::move(file), fname, file_options, env, ioptions.statistics, in BuildTable()
137 ioptions.listeners, ioptions.file_checksum_gen_factory)); in BuildTable()
140 ioptions, mutable_cf_options, internal_comparator, in BuildTable()
149 ioptions.merge_operator, nullptr, ioptions.info_log, in BuildTable()
157 ShouldReportDetailedTime(env, ioptions.statistics), in BuildTable()
211 StopWatch sw(env, ioptions.statistics, TABLE_SYNC_MICROS); in BuildTable()
[all …]
|
| D | table_properties_collector_test.cc | 43 void MakeBuilder(const Options& options, const ImmutableCFOptions& ioptions, in MakeBuilder() argument
56 ioptions, moptions, internal_comparator, int_tbl_prop_collector_factories, in MakeBuilder()
265 const ImmutableCFOptions ioptions(options); in TestCustomizedTablePropertiesCollector() local
273 GetIntTblPropCollectorFactory(ioptions, &int_tbl_prop_collector_factories); in TestCustomizedTablePropertiesCollector()
275 MakeBuilder(options, ioptions, moptions, internal_comparator, in TestCustomizedTablePropertiesCollector()
295 magic_number, ioptions, &props, in TestCustomizedTablePropertiesCollector()
411 ImmutableCFOptions ioptions(options); in TestInternalKeyPropertiesCollector() local
412 GetIntTblPropCollectorFactory(ioptions, &int_tbl_prop_collector_factories); in TestInternalKeyPropertiesCollector()
415 const ImmutableCFOptions ioptions(options); in TestInternalKeyPropertiesCollector() local
419 MakeBuilder(options, ioptions, moptions, pikc, in TestInternalKeyPropertiesCollector()
[all …]
|
| D | convenience.cc | 47 ImmutableCFOptions ioptions(options); in VerifySstFileChecksum() local
49 Status s = ioptions.fs->NewRandomAccessFile(file_path, in VerifySstFileChecksum()
53 s = ioptions.fs->GetFileSize(file_path, IOOptions(), &file_size, nullptr); in VerifySstFileChecksum()
61 s = ioptions.table_factory->NewTableReader( in VerifySstFileChecksum()
62 TableReaderOptions(ioptions, options.prefix_extractor.get(), env_options, in VerifySstFileChecksum()
|
| D | db_memtable_test.cc | 143 ImmutableCFOptions ioptions(options); in TEST_F() local
145 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
184 ioptions = ImmutableCFOptions(options); in TEST_F()
185 mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
196 ioptions = ImmutableCFOptions(options); in TEST_F()
197 mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
223 ImmutableCFOptions ioptions(options); in TEST_F() local
225 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
|
| D | memtable.cc | 44 const ImmutableCFOptions& ioptions, in ImmutableMemTableOptions() argument
55 inplace_update_support(ioptions.inplace_update_support), in ImmutableMemTableOptions()
57 inplace_callback(ioptions.inplace_callback), in ImmutableMemTableOptions()
59 statistics(ioptions.statistics), in ImmutableMemTableOptions()
60 merge_operator(ioptions.merge_operator), in ImmutableMemTableOptions()
61 info_log(ioptions.info_log) {} in ImmutableMemTableOptions()
64 const ImmutableCFOptions& ioptions, in MemTable() argument
69 moptions_(ioptions, mutable_cf_options), in MemTable()
80 table_(ioptions.memtable_factory->CreateMemTableRep( in MemTable()
82 ioptions.info_log, column_family_id)), in MemTable()
[all …]
|
| D | version_set.cc | 1210 auto ioptions = cfd_->ioptions(); in GetTableProperties() local
1422 auto* ioptions = cfd_->ioptions(); in GetColumnFamilyMetaData() local
1432 if (path_id < ioptions->cf_paths.size()) { in GetColumnFamilyMetaData()
1435 assert(!ioptions->cf_paths.empty()); in GetColumnFamilyMetaData()
1436 file_path = ioptions->cf_paths.back().path; in GetColumnFamilyMetaData()
2503 const ImmutableCFOptions& ioptions, in ComputeFilesMarkedForPeriodicCompaction() argument
2544 ROCKS_LOG_WARN(ioptions.info_log, in ComputeFilesMarkedForPeriodicCompaction()
3208 level_max_bytes_.resize(ioptions.num_levels); in CalculateBaseBytes()
3213 for (int i = 0; i < ioptions.num_levels; ++i) { in CalculateBaseBytes()
3281 ROCKS_LOG_INFO(ioptions.info_log, in CalculateBaseBytes()
[all …]
|
| D | memtable_list_test.cc | 232 ImmutableCFOptions ioptions(options); in TEST_F() local
235 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
277 MemTable* mem2 = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb2, in TEST_F()
349 ImmutableCFOptions ioptions(options); in TEST_F() local
352 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
437 MemTable* mem2 = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb2, in TEST_F()
462 MemTable* mem3 = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb3, in TEST_F()
525 ImmutableCFOptions ioptions(options); in TEST_F() local
544 MemTable* mem = new MemTable(cmp, ioptions, mutable_cf_options, &wb, in TEST_F()
789 ImmutableCFOptions ioptions(options); in TEST_F() local
[all …]
|
| D | job_context.h | 62 const std::string& name, const ImmutableCFOptions* ioptions) { in PushWriteStallNotification()
68 notif.immutable_cf_options = ioptions; in PushWriteStallNotification()
74 (void)ioptions; in PushWriteStallNotification()
|
| /rocksdb-6.9/table/block_based/ |
| D | block_based_table_builder.cc | 280 const ImmutableCFOptions ioptions; member
372 : ioptions(_ioptions), in Rep()
430 context.info_log = ioptions.info_log; in Rep()
473 ioptions.info_log, in BlockBasedTableBuilder()
616 r->ioptions.env, in WriteBlock()
617 ShouldReportDetailedTime(r->ioptions.env, r->ioptions.statistics)); in WriteBlock()
675 ROCKS_LOG_ERROR(r->ioptions.info_log, in WriteBlock()
698 if (ShouldReportDetailedTime(r->ioptions.env, r->ioptions.statistics)) { in WriteBlock()
725 StopWatch sw(r->ioptions.env, r->ioptions.statistics, WRITE_RAW_BLOCK_MICROS); in WriteRawBlock()
937 rep_->ioptions.merge_operator != nullptr in WritePropertiesBlock()
[all …]
|
| D | block_based_table_reader.cc | 583 if (!ioptions.allow_mmap_reads) { in Open()
773 ROCKS_LOG_WARN(rep_->ioptions.info_log, in ReadPropertiesBlock()
797 ROCKS_LOG_WARN(rep_->ioptions.info_log, in ReadPropertiesBlock()
814 ROCKS_LOG_ERROR(rep_->ioptions.info_log, in ReadPropertiesBlock()
872 rep_->ioptions.info_log, in ReadRangeDelBlock()
885 rep_->ioptions.info_log, in ReadRangeDelBlock()
1075 ROCKS_LOG_ERROR(rep_->ioptions.info_log, in ReadMetaIndexBlock()
1199 const ImmutableCFOptions& ioptions = rep_->ioptions; in PutDataBlockToCache() local
1503 rep_->ioptions.env->NowMicros(), in MaybeReadBlockAndLoadToCache()
1546 const ImmutableCFOptions& ioptions = rep_->ioptions; in RetrieveMultipleBlocks() local
[all …]
|
| D | hash_index_reader.cc | 68 const ImmutableCFOptions& ioptions = rep->ioptions; in Create() local
77 &prefixes_contents, ioptions, true /*decompress*/, in Create()
87 &prefixes_meta_contents, ioptions, true /*decompress*/, in Create()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_picker_level.cc | 52 const ImmutableCFOptions& ioptions) in LevelCompactionBuilder() argument
59 ioptions_(ioptions) {} in LevelCompactionBuilder()
120 static uint32_t GetPathId(const ImmutableCFOptions& ioptions,
409 const ImmutableCFOptions& ioptions, in GetPathId() argument
412 assert(!ioptions.cf_paths.empty()); in GetPathId()
415 uint64_t current_path_size = ioptions.cf_paths[0].target_size; in GetPathId()
425 while (p < ioptions.cf_paths.size() - 1) { in GetPathId()
433 if (ioptions.level_compaction_dynamic_level_bytes) { in GetPathId()
452 current_path_size = ioptions.cf_paths[p].target_size; in GetPathId()
|
| D | compaction_picker.h | 49 CompactionPicker(const ImmutableCFOptions& ioptions,
244 NullCompactionPicker(const ImmutableCFOptions& ioptions, in NullCompactionPicker() argument
246 : CompactionPicker(ioptions, icmp) {} in NullCompactionPicker()
302 CompressionType GetCompressionType(const ImmutableCFOptions& ioptions,
308 CompressionOptions GetCompressionOptions(const ImmutableCFOptions& ioptions,
|
| D | compaction_picker.cc | 101 CompressionType GetCompressionType(const ImmutableCFOptions& ioptions, in GetCompressionType() argument
113 if (ioptions.bottommost_compression != kDisableCompressionOption && in GetCompressionType()
115 return ioptions.bottommost_compression; in GetCompressionType()
119 if (!ioptions.compression_per_level.empty()) { in GetCompressionType()
140 return ioptions.compression_opts; in GetCompressionOptions()
145 if (ioptions.bottommost_compression != kDisableCompressionOption && in GetCompressionOptions()
147 ioptions.bottommost_compression_opts.enabled) { in GetCompressionOptions()
148 return ioptions.bottommost_compression_opts; in GetCompressionOptions()
150 return ioptions.compression_opts; in GetCompressionOptions()
153 CompactionPicker::CompactionPicker(const ImmutableCFOptions& ioptions, in CompactionPicker() argument
[all …]
|
| D | compaction_picker_level.h | 20 LevelCompactionPicker(const ImmutableCFOptions& ioptions, in LevelCompactionPicker() argument
22 : CompactionPicker(ioptions, icmp) {} in LevelCompactionPicker()
|
| /rocksdb-6.9/table/cuckoo/ |
| D | cuckoo_table_reader_test.cc | 118 const ImmutableCFOptions ioptions(options); in CreateCuckooFileAndCheckReader() local
119 CuckooTableReader reader(ioptions, std::move(file_reader), file_size, ucomp, in CreateCuckooFileAndCheckReader()
148 const ImmutableCFOptions ioptions(options); in CheckIterator() local
220 ImmutableCFOptions ioptions(options); in TEST_F() local
221 CuckooTableReader reader(ioptions, nullptr, 0, nullptr, nullptr); in TEST_F()
339 const ImmutableCFOptions ioptions(options); in TEST_F() local
340 CuckooTableReader reader(ioptions, std::move(file_reader), file_size, ucmp, in TEST_F()
451 const ImmutableCFOptions ioptions(options); in WriteFile() local
452 CuckooTableReader reader(ioptions, std::move(file_reader), file_size, in WriteFile()
484 const ImmutableCFOptions ioptions(options); in ReadKeys() local
[all …]
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_compaction_flush.cc | 66 cfd->ioptions()->compaction_thread_limiter.get()); in RequestCompactionToken()
229 cfd->ioptions()->cf_paths[0].path, file_meta.fd.GetNumber()); in FlushMemTableToOutputFile()
320 const std::string& curr_path = cfd->ioptions()->cf_paths[0].path; in AtomicFlushMemTablesToOutputFiles()
684 if (options.target_path_id >= cfd->ioptions()->cf_paths.size()) { in CompactRange()
957 if (cfd->ioptions()->cf_paths.size() == 1U) { in CompactFilesImpl()
1040 version->storage_info()->ComputeCompactionScore(*cfd->ioptions(), in CompactFilesImpl()
1449 cfd->ioptions()->compaction_style == kCompactionStyleFIFO) { in RunManualCompaction()
1457 cfd->ioptions()->compaction_style == kCompactionStyleFIFO) { in RunManualCompaction()
1847 cfd->ioptions()->min_write_buffer_number_to_merge && in WaitUntilFlushWouldNotStallWrites()
2932 assert(m->cfd->ioptions()->compaction_style != in BackgroundCompaction()
[all …]
|