Home
last modified time | relevance | path

Searched refs:context (Results 1 – 25 of 51) sorted by relevance

123

/rocksdb-6.9/cache/
Dclock_cache.cc550 CleanupContext context; in SetCapacity() local
556 Cleanup(context); in SetCapacity()
616 CleanupContext context; in Insert() local
631 Cleanup(context); in Insert()
654 Cleanup(context); in Lookup()
661 CleanupContext context; in Release() local
667 Cleanup(context); in Release()
672 CleanupContext context; in Erase() local
674 Cleanup(context); in Erase()
691 CleanupContext context; in EraseUnRefEntries() local
[all …]
/rocksdb-6.9/table/block_based/
Dmock_block_based_table.h46 FilterBuildingContext context(table_options_); in GetBuilder()
47 context.column_family_name = "mock_cf"; in GetBuilder()
48 context.compaction_style = ioptions_.compaction_style; in GetBuilder()
49 context.level_at_creation = kMockLevel; in GetBuilder()
50 context.info_log = ioptions_.info_log; in GetBuilder()
51 return BloomFilterPolicy::GetBuilderFromContext(context); in GetBuilder()
Dfilter_policy.cc550 const FilterBuildingContext& context) const { in GetBuilderWithContext()
557 if (context.table_options.format_version < 5) { in GetBuilderWithContext()
568 if (whole_bits_per_key_ >= 14 && context.info_log && in GetBuilderWithContext()
580 context.info_log, in GetBuilderWithContext()
587 context.info_log); in GetBuilderWithContext()
595 const FilterBuildingContext& context) { in GetBuilderFromContext() argument
596 if (context.table_options.filter_policy) { in GetBuilderFromContext()
597 return context.table_options.filter_policy->GetBuilderWithContext(context); in GetBuilderFromContext()
Dblock_based_table_builder.cc65 const FilterBuildingContext& context, in CreateFilterBlockBuilder() argument
72 BloomFilterPolicy::GetBuilderFromContext(context); in CreateFilterBlockBuilder()
174 CompressionContext context(c); in CompressBlock() local
176 CompressionInfo info_tmp(options, context, in CompressBlock()
186 CompressionContext context(c); in CompressBlock() local
188 CompressionInfo info_tmp(options, context, in CompressBlock()
426 FilterBuildingContext context(table_options); in Rep() local
427 context.column_family_name = column_family_name; in Rep()
428 context.compaction_style = ioptions.compaction_style; in Rep()
429 context.level_at_creation = level_at_creation; in Rep()
[all …]
/rocksdb-6.9/utilities/blob_db/
Dblob_compaction_filter.h36 BlobIndexCompactionFilterBase(BlobCompactionContext&& context, in BlobIndexCompactionFilterBase() argument
38 : context_(std::move(context)), in BlobIndexCompactionFilterBase()
73 BlobIndexCompactionFilter(BlobCompactionContext&& context, in BlobIndexCompactionFilter() argument
75 : BlobIndexCompactionFilterBase(std::move(context), current_time, stats) { in BlobIndexCompactionFilter()
83 BlobIndexCompactionFilterGC(BlobCompactionContext&& context, in BlobIndexCompactionFilterGC() argument
86 : BlobIndexCompactionFilterBase(std::move(context), current_time, stats), in BlobIndexCompactionFilterGC()
Dblob_compaction_filter.cc298 BlobCompactionContext context; in CreateCompactionFilter() local
299 blob_db_impl()->GetCompactionContext(&context); in CreateCompactionFilter()
302 std::move(context), current_time, statistics())); in CreateCompactionFilter()
319 BlobCompactionContext context; in CreateCompactionFilter() local
321 blob_db_impl()->GetCompactionContext(&context, &context_gc); in CreateCompactionFilter()
324 std::move(context), std::move(context_gc), current_time, statistics())); in CreateCompactionFilter()
Dblob_db_impl.cc1104 CompressionContext context(type); in GetCompressedSlice() local
1141 BlobCompactionContext* context) const { in GetCompactionContextCommon()
1142 assert(context); in GetCompactionContextCommon()
1145 context->current_blob_files.clear(); in GetCompactionContextCommon()
1147 context->current_blob_files.insert(p.first); in GetCompactionContextCommon()
1149 context->fifo_eviction_seq = fifo_eviction_seq_; in GetCompactionContextCommon()
1154 assert(context); in GetCompactionContext()
1157 GetCompactionContextCommon(context); in GetCompactionContext()
1162 assert(context); in GetCompactionContext()
1166 GetCompactionContextCommon(context); in GetCompactionContext()
[all …]
Dblob_db_impl.h171 void GetCompactionContextCommon(BlobCompactionContext* context) const;
173 void GetCompactionContext(BlobCompactionContext* context);
174 void GetCompactionContext(BlobCompactionContext* context,
/rocksdb-6.9/port/win/
Dio_win.h26 inline Status IOErrorFromWindowsError(const std::string& context, DWORD err) { in IOErrorFromWindowsError() argument
28 ? Status::NoSpace(context, GetWindowsErrSz(err)) in IOErrorFromWindowsError()
30 ? Status::PathNotFound(context, GetWindowsErrSz(err)) in IOErrorFromWindowsError()
31 : Status::IOError(context, GetWindowsErrSz(err)); in IOErrorFromWindowsError()
34 inline Status IOErrorFromLastWindowsError(const std::string& context) { in IOErrorFromLastWindowsError() argument
35 return IOErrorFromWindowsError(context, GetLastError()); in IOErrorFromLastWindowsError()
38 inline Status IOError(const std::string& context, int err_number) { in IOError() argument
40 ? Status::NoSpace(context, strerror(err_number)) in IOError()
42 ? Status::PathNotFound(context, strerror(err_number)) in IOError()
43 : Status::IOError(context, strerror(err_number)); in IOError()
/rocksdb-6.9/utilities/table_properties_collectors/
Dcompact_on_deletion_collector_test.cc28 ROCKSDB_NAMESPACE::TablePropertiesCollectorFactory::Context context; in main() local
29 context.column_family_id = ROCKSDB_NAMESPACE:: in main()
66 factory->CreateTablePropertiesCollector(context)); in main()
98 factory->CreateTablePropertiesCollector(context)); in main()
143 collector.reset(factory->CreateTablePropertiesCollector(context)); in main()
/rocksdb-6.9/java/rocksjni/
Dcompaction_filter_factory_jnicallback.cc52 const CompactionFilter::Context& context) { in CreateCompactionFilter() argument
59 static_cast<jboolean>(context.is_full_compaction), in CreateCompactionFilter()
60 static_cast<jboolean>(context.is_manual_compaction)); in CreateCompactionFilter()
/rocksdb-6.9/db/
Ddb_compaction_filter_test.cc185 const CompactionFilter::Context& context) override { in CreateCompactionFilter() argument
187 EXPECT_EQ(expect_full_compaction_.load(), context.is_full_compaction); in CreateCompactionFilter()
188 EXPECT_EQ(expect_manual_compaction_.load(), context.is_manual_compaction); in CreateCompactionFilter()
191 EXPECT_EQ(expect_cf_id_.load(), context.column_family_id); in CreateCompactionFilter()
211 const CompactionFilter::Context& context) override { in CreateCompactionFilter() argument
212 if (context.is_manual_compaction) { in CreateCompactionFilter()
226 const CompactionFilter::Context& context) override { in CreateCompactionFilter() argument
227 if (context.is_manual_compaction) { in CreateCompactionFilter()
240 const CompactionFilter::Context& context) override { in CreateCompactionFilter() argument
241 if (context.is_manual_compaction) { in CreateCompactionFilter()
Dtable_properties_collector.h93 TablePropertiesCollectorFactory::Context context; in CreateIntTblPropCollector() local
94 context.column_family_id = column_family_id; in CreateIntTblPropCollector()
96 user_collector_factory_->CreateTablePropertiesCollector(context)); in CreateIntTblPropCollector()
Ddb_bloom_filter_test.cc738 const FilterBuildingContext& context) const override { in GetBuilderWithContext()
739 if (context.compaction_style == kCompactionStyleFIFO) { in GetBuilderWithContext()
740 return policy_fifo_->GetBuilderWithContext(context); in GetBuilderWithContext()
741 } else if (context.level_at_creation == 0) { in GetBuilderWithContext()
742 return policy_l0_other_->GetBuilderWithContext(context); in GetBuilderWithContext()
744 return policy_otherwise_->GetBuilderWithContext(context); in GetBuilderWithContext()
777 const FilterBuildingContext& context) const override { in GetBuilderWithContext()
779 test_report_ += context.column_family_name; in GetBuilderWithContext()
782 OptionsHelper::compaction_style_to_string[context.compaction_style]; in GetBuilderWithContext()
784 test_report_ += std::to_string(context.level_at_creation); in GetBuilderWithContext()
[all …]
Dc.cc240 void*, rocksdb_compactionfiltercontext_t* context);
248 ccontext.rep = context; in CreateCompactionFilter()
2782 return context; in rocksdb_perfcontext_create()
2786 context->rep->Reset(); in rocksdb_perfcontext_reset()
2796 PerfContext* rep = context->rep; in rocksdb_perfcontext_metric()
2941 delete context; in rocksdb_perfcontext_destroy()
2989 rocksdb_compactionfiltercontext_t* context) { in rocksdb_compactionfiltercontext_is_full_compaction() argument
2990 return context->rep.is_full_compaction; in rocksdb_compactionfiltercontext_is_full_compaction()
2994 rocksdb_compactionfiltercontext_t* context) { in rocksdb_compactionfiltercontext_is_manual_compaction() argument
2995 return context->rep.is_manual_compaction; in rocksdb_compactionfiltercontext_is_manual_compaction()
[all …]
/rocksdb-6.9/util/
Dcompression.h411 const CompressionContext& context() const { return context_; } in context() function
458 const UncompressionContext& context() const { return context_; } in context() function
1267 ZSTD_CCtx* context = info.context().ZSTDPreallocCtx(); in ZSTD_Compress() local
1268 assert(context != nullptr); in ZSTD_Compress()
1271 outlen = ZSTD_compress_usingCDict(context, &(*output)[output_header_len], in ZSTD_Compress()
1277 outlen = ZSTD_compress_usingDict(context, &(*output)[output_header_len], in ZSTD_Compress()
1315 ZSTD_DCtx* context = info.context().GetZSTDContext();
1316 assert(context != nullptr);
1320 context, output.get(), output_len, input_data, input_length,
1326 context, output.get(), output_len, input_data, input_length,
Dfile_checksum_helper.h91 const FileChecksumGenContext& context) override { in CreateFileChecksumGenerator() argument
93 new FileChecksumGenCrc32c(context)); in CreateFileChecksumGenerator()
/rocksdb-6.9/tools/advisor/advisor/
Ddb_log_parser.py42 self.context = token_list[1]
64 return self.context
82 'time: ' + self.time + '; context: ' + self.context +
/rocksdb-6.9/db/compaction/
Dcompaction.cc520 CompactionFilter::Context context; in CreateCompactionFilter() local
521 context.is_full_compaction = is_full_compaction_; in CreateCompactionFilter()
522 context.is_manual_compaction = is_manual_compaction_; in CreateCompactionFilter()
523 context.column_family_id = cfd_->GetID(); in CreateCompactionFilter()
525 context); in CreateCompactionFilter()
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc1539 Status DBImpl::TrimMemtableHistory(WriteContext* context) { in TrimMemtableHistory() argument
1553 context->superversion_context.NewSuperVersion(); in TrimMemtableHistory()
1554 assert(context->superversion_context.new_superversion.get() != nullptr); in TrimMemtableHistory()
1555 cfd->InstallSuperVersion(&context->superversion_context, &mutex_); in TrimMemtableHistory()
1565 Status DBImpl::ScheduleFlushes(WriteContext* context) { in ScheduleFlushes() argument
1588 status = SwitchMemtable(cfd, context); in ScheduleFlushes()
1634 Status DBImpl::SwitchMemtable(ColumnFamilyData* cfd, WriteContext* context) { in SwitchMemtable() argument
1691 context->superversion_context.NewSuperVersion(); in SwitchMemtable()
1741 context->superversion_context.new_superversion.release(); in SwitchMemtable()
1768 cfd->imm()->Add(cfd->mem(), &context->memtables_to_free_); in SwitchMemtable()
[all …]
/rocksdb-6.9/tools/advisor/test/
Dtest_db_log_parser.py34 context = "7f82ba72e700"
39 test_log = hr_time + " " + context + " " + message
/rocksdb-6.9/env/
Denv_hdfs.cc39 static Status IOError(const std::string& context, int err_number) { in IOError() argument
41 ? Status::NoSpace(context, strerror(err_number)) in IOError()
43 ? Status::PathNotFound(context, strerror(err_number)) in IOError()
44 : Status::IOError(context, strerror(err_number)); in IOError()
Dio_posix.cc48 std::string IOErrorMsg(const std::string& context, in IOErrorMsg() argument
51 return context; in IOErrorMsg()
53 return context + ": " + file_name; in IOErrorMsg()
57 IOStatus IOError(const std::string& context, const std::string& file_name, in IOError() argument
61 IOStatus s = IOStatus::NoSpace(IOErrorMsg(context, file_name), in IOError()
69 return IOStatus::PathNotFound(IOErrorMsg(context, file_name), in IOError()
72 return IOStatus::IOError(IOErrorMsg(context, file_name), in IOError()
/rocksdb-6.9/table/
Dblock_fetcher.cc269 UncompressionContext context(compression_type_); in ReadBlockContents() local
270 UncompressionInfo info(context, uncompression_dict_, compression_type_); in ReadBlockContents()
/rocksdb-6.9/java/src/test/java/org/rocksdb/test/
DRemoveEmptyValueCompactionFilterFactory.java13 …EmptyValueCompactionFilter createCompactionFilter(final AbstractCompactionFilter.Context context) { in createCompactionFilter() argument

123